如何用PHP编写示例代码实现RabbitMQ消息队列？

本文共计1681个文字，预计阅读时间需要7分钟。

目录+业务场景+1. 初步部署ThinkPHP6框架+2. 安装Workerman扩展+3. 生产者+4. 消费者+5. 整体测试+业务场景+项目公司是主PHP开发，框架为ThinkPHP。

目录

• 业务场景
• 1、首先部署好thinkphp6框架
• 2、安装workerman扩展
• 3、生产者
• 4、消费者
• 5、整体测试

业务场景

项目公司是主php做开发的，框架为thinkphp。众所周知，php本身的运行效率存在一定的缺陷，所以如果有一个很复杂很耗时的业务时，必须开发一个常驻内存的程序。首先我想到了php的workerman与swoole，但是这里应上面的标题哈，想将耗时任务交给另一个服务器，同时列队处理。所以这里我想独立部署一个rabbitMQ服务器用于处理列队任务。

当rabbitMQ服务器我们准备好了，建立了一个持久化命名为ceshi的列队，如下：

项目上生产者和消费者的开发我这里全部采用tinkphp6+workerman，为便于管理。