在控制器里需要发布消息的位置调用Rabbitmq工具类中的publish方法;
3.自定义几个consumer进程,编写消费的具体回调函数,并在onWorkerStart中调用Rabbitmq工具类中的消费方法;
### 代码:
```php
class Rabbitmq
{/**
* 发布消息到worker队列,支持一次性发布多个消息
*
* @author Aaron <chenqiang@h024.cn>
*
* @param=> AMQPMessage::DELIVERY_MODE_PERSISTENT)
);
// $log->debug("{$queueName}入队数据$message->content);
}
}
```
### 报错过程:
> Epoll数量与rabbitmq队列消费进程数量正相关
```shell
# php start.php start