小编Neo*_*ead的帖子

我对 RabbitMQ 还很陌生。我正在使用 codeigniter 来使用 php-amqplib 库，并且仍然想知道我所缺乏的一些知识。

• 为什么$channel->wait()使用？
• 为什么它总是驻留在无限的 while 循环中？
• 如何/我可以绕过无限 while 循环。

就像在我的项目的一个用户想要向 100k 潜在客户广播新活动的情况下，如果第二个用户要发送大约 100 封邮件，那么第二个用户就会受到影响，第二个用户必须先等待 100k 邮件发送，然后是最后一个用户轮到他了。

我需要一个针对并发消费者的解决方案，使他们能够顺利工作而不影响其他人

这是我的代码片段：

public function campaign2(){
        $this->load->library('mylibrary');
        for( $i=1;$i<=5;$i++ ) {
            $url = "http://localhost/myproject/rabbit/waiting";
            $param = array('index' => $i);
            $this->waiting($i);
        }          
}

public function waiting($i)
    {
        ini_set('memory_limit','400M');
        ini_set('max_execution_time', 0);
        ini_set('display_errors', 1);

        ${'conn_'.$i} = connectRabbit();
        ${'channel_'.$i} = ${'conn_'.$i}->channel();
        ${'channel_'.$i}->exchange_declare('ha-local-campaign-'.$i.'-exchange', 'fanout', false, true, false);
        $q    = populateQueueName('campaign-'.$i);
        ${'channel_'.$i}->queue_declare($q, false, true, false, false); 
        ${'channel_'.$i}->queue_bind($q, 'ha-local-campaign-'.$i.'-exchange', 'priority.'.$i);
        $consumer_tag = 'campaign_consumer' ;
        function …