swoole-rabbitmq 多消费者异步队列服务

使用 Swoole 提供的进程管理模块，父进程当做变成守护进程，父进程创建再子进程（消费进程，监听信号进程，定时器...） 可作为独立队列回调服务，向rabbitmq队列发送消息，配置callback后，异步回调到callback地址，用于业务解耦。 或集成到自己系统模块下，callback配置对应的 模块/控制器/方法，命令行执行回调。

服务操作

启动: php index.php "command/SmcServer/manage" "command=start" 停止: php index.php "command/SmcServer/manage" "command=stop" 重启: php index.php "command/SmcServer/manage" "command=restart" 查看状态: php index.php "command/SmcServer/manage" "command=status"

队列操作

查看队列、动态增加队列、删除队列，系统自动加载新的队列配置(使用redis保存配置信息)，还可以http增删改查

查看队列列表: php index.php "command/SmcServer/queueList" 增加队列配置: php index.php "command/SmcServer/addQueue" "queueName=send_email&minConsumerNum=3&maxConsumerNum=10&callbackUrl=callback/Message/send" 启动队列消费进程 php index.php "command/SmcServer/start" "queueName=send_email" 停止队列消费进程 php index.php "command/SmcServer/stop" "queueName=send_email" 更新队列配置: php index.php "command/SmcServer/addQueue" "queueName=send_email&minConsumerNum=3&maxConsumerNum=10&callbackUrl=callback/Message/send" 删除队列: php index.php "command/SmcServer/deleteQueue" "queueName=send_email"

配置rabbitMQ连接及交换机

<?php //config/smc/queueConfig.php 手动创建交换机 multi_consumer_exchange return [ //消息服务连接配置：/etc/rabbitmq/rabbitmq.conf //listeners.tcp.local = 127.0.0.1:5672 'connection' => [ 'host' => '127.0.0.1', 'user' => 'test', 'pass' => 'test', 'port' => '5672', 'vhost' => '/', //default vhost 'exchange' => 'multi_consumer_exchange', 'timeout' => 3, ], 'queues' => [ //已改为redis存储，启动前需要保证在redis有相关配置存在 //一个队列对应一个回调地址callback //callback可改造成http请求地址 //需手动创建交换机 // 'default_multi_consumer' => [ // 'queueName' => 'default_multi_consumer', //队列名称 // 'routeKey' => 'default_multi_consumer', //路由key // 'vhost' => '/', //队列所在的vhost // 'prefetchCount' => 5, //默认为10，不需要的话去掉该选项或设置为null // 'minConsumerNum' => 1, //最小消费者数量 // 'maxConsumerNum' => 10, //最大消费者数量，系统限制最大20 // 'warningNum' => 1000, //达到预警的消息数量，请合理设置，建议不少于1000 // //本框架直接写模块路由，如果是外部的请求可以填写完整http地址，系统会以http-post-json方式回调 // 'callbackUrl' => 'testCallbackUrl', // ], ], ];