部署环境

开始前先进入RabbitMQ的web管理界面#xff0c;选择Queues菜单#xff0c;点…

Thinkphp6连接使用RabbitMQ不止tp6其他框架对应改下也一样如何使用Docker部署RabbitMQ在上一篇已经讲了-传送门-。

部署环境

开始前先进入RabbitMQ的web管理界面选择Queues菜单点击底部的Add

new

topthink/think-worker安装rabbitmq扩展

composer

在app并在其下创建Send.php文件$options数组中的host地址改成你的rabbitmq地址。

?phpnamespace

websocket://127.0.0.1:2345;/***

收到信息*

$data){//websocket发送过来的消息$connection-send(我收到你的信息了:.$data);//rabbitMQ配置$options

密码];(new

Client($options))-connect()-***n(function

(Client

$client-channel();})-***n(function

(Channel

如果设置true存在则返回OK否则就报错。

设置false存在返回OK不存在则自动创建*

durable:

是否持久化设置false是存放到内存中RabbitMQ重启后会丢失,*

设置true则代表是一个持久的队列服务重启之后也会存在因为服务会把持久化的Queue存放在硬盘上当服务重启的时候会重新加载之前被持久化的Queue*

exclusive:

是否排他指定该选项为true则队列只对当前连接有效连接断开后自动删除*

auto_delete:

是否自动删除当最后一个消费者断开连接之后队列是否自动被删除*/return

false,

text/plain]这样消费端是springboot注解接收直接是字符串类型*

exchange

bool|PromiseInterface|int*/return

[content_type

}在config/worker_server.php中设置worker_class值为app\workerman\Send

启动这个生产者

至此生产这一步就走完了那么如果我不想通过websocket方式想用tcp方式生产数据怎么办

将Send.php中websocket:127.0.0.1改成tcp:127.0.0.1重启服务把controller目录中Index.php修改为以下内容

?php

stream_socket_client(tcp://127.0.0.1:2345,

$errno,

$msg.\n);//断开服务fclose($client);return

消费者

同生产者一样新创建一个thinkphp6项目注意端口别和生产者冲突这里我设置的是2346端口

在app并在其下创建Receive.php文件$options数组中的host地址改成你的rabbitmq地址。

?phpnamespace

onWorkerStart($worker){//rabbitMQ配置$options

密码];(new

Client($options))-connect()-***n(function

(Client

$client-channel();})-***n(function

(Channel

如果设置true存在则返回OK否则就报错。

设置false存在返回OK不存在则自动创建*

durable:

是否持久化设置false是存放到内存中RabbitMQ重启后会丢失,*

设置true则代表是一个持久的队列服务重启之后也会存在因为服务会把持久化的Queue存放在硬盘上当服务重启的时候会重新加载之前被持久化的Queue*

exclusive:

是否排他指定该选项为true则队列只对当前连接有效连接断开后自动删除*

auto_delete:

是否自动删除当最后一个消费者断开连接之后队列是否自动被删除*/return

false,

}在config/worker_server.php中设置worker_class值为app\workerman\Receive并将端口改为2346

启动这个消费者

https://www.workerman.net/doc/workerman/components/workerman-rabbitmq.html

https://blog.csdn.net/weixin_47723549/article/details/124493059