RabbitMQ包：一个队列和多个工作者

Question

我目前正在尝试使用RabbitMQ（具有出色的RabbitMQBundle）来处理大量的异步工作。

目标是让一个队列发布相同类型的消息，并让多个服务器上的X个工作者在同一时间内查看消息。

每个工人都要偷看一条消息，完成工作，然后偷看另一条消息，等等。

这里是我的conf：

old_sound_rabbit_mq:
connections:
    default:
        host:     'localhost'
        port:     5672
        user:     'myuser'
        password: 'mypassword'
        vhost:    '/'
        lazy:     false
producers:
    generate_report:
        connection:       default
        exchange_options: { name: 'gen_report', type: fanout }
consumers:
    generate_report:
        connection:       default
        exchange_options: { name: 'gen_report', type: fanout }
        queue_options:    { name: 'gen_report' }
        callback:         generator.report.consumer

在我的consumer中，我有一个日志文件中的条目和120秒的睡眠。

我启动了php app/console rabbitmq:consumer generate_report类似10次，但是当我查看日志文件时，我只有每条120的消息，目标是有10条！

我还尝试将我的队列设置为topic或direct,结果相同。

我不明白我做错了什么:'（

提前致谢

Answer 1

我也经历过同样的问题。您可以做的是将获取的消息数设置为1。

$channel->basic_qos(null，1,null)；

http://www.rabbitmq.com/tutorials/tutorial-two-php.html，参见公平调度部分。