В чем смысл $ channel-> wait() в RabbitMQ

Question

Я совершенно новый в RabbitMQ. Я работаю с библиотекой php-amqplib с codeigniter и все еще интересуюсь некоторыми знаниями, которых мне не хватает.

• Почему используется $channel->wait()?
• Почему он всегда находится внутри бесконечной петли?
• Как я могу обойти бесконечный цикл while.

Как в случае, когда один пользователь моего проекта хочет транслировать новую кампанию на 100 тыс. Потенциальных клиентов, второй пользователь получает действие, если у него есть 100 писем, которые нужно отправить, второй должен ждать 100 тыс. Писем, чтобы получить первый, затем последний пользователь получает свою очередь.

Мне нужно решение для Параллельных потребителей, который работает плавно, не затрагивая другие

Вот мой фрагмент кода:

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 process_message($msg) { 
      echo 'Mail Sent'; 
      $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']); 
     } 
     function shutdown($channel, $conn){ 
      echo '['.date('H:i:s').'] Campaign consumer - Shutdown!!'; 
     } 

     ${'channel_'.$i}->basic_consume($q, $consumer_tag, false, false, true, false,'process_message'); 
     while(1) { 
      ${'channel_'.$i}->wait(); 
     } 
     register_shutdown_function('shutdown', ${'channel_'.$i}, ${'conn_'.$i}); 
    } 

Если кто-то любезно наставит меня через этот процесс я буду благодарен.

Answer 1

Когда вы звоните $channel->wait() вы:

• Проверка очереди на этом канале, чтобы увидеть, если есть ожидающие сообщения.

• Для каждого сообщения вы вызываете зарегистрированный обратный вызов для обратного вызова соответствующего канала.

С "привет мир", например, шаг за шагом::

// First, you define `$callback` as a function receiving 
// one parameter (the _message_). 
$callback = function($msg) { 
    echo " [x] Received ", $msg->body, "\n"; 
}; 

// Then, you assign `$callback` the the "hello" queue. 
$channel->basic_consume('hello', '', false, true, false, false, $callback); 

// Finally: While I have any callbacks defined for the channel, 
while(count($channel->callbacks)) { 
    // inspect the queue and call the corresponding callbacks 
    //passing the message as a parameter 
    $channel->wait(); 
} 
// This is an infinite loop: if there are any callbacks, 
// it'll run forever unless you interrupt script's execution. 

Попросите второго отправить пользователю использовать другую очередь. У вас может быть столько очередей, сколько хотите.