写了一个rabbitmq的工具类,下面贴代码,需要生产消息时直接
```php
\util\Rabbitmq\publishWorkerQueue($queueName, $msg);
```
需要消费消息时$queueName, $callback);
```
我一直有个疑问,这个rabbit的connection对象,应该是在worker启动时就创建好,然后在需要的地方直接调用就行,否则像现在这样,每生产一次要建立一次连接再销毁但是我想不明白该在什么地方怎么写这个全局建立连接对象的方法,对于logger对象也是同样的疑问,希望可以得到指点。
具体代码如下:
```php
<?chenqiang@h024.cn>
*
* @param string $queueName 队列名称
* @param callable $callback 消费的回调函数,接收值$msg了队列中的一条消息
* @param bool $autoAck 自动确认消费,默认为false,需要在消费回调里手动执行$msg->ack()做消费成功确认