باستخدام RabbitMQ مع MonsterMQ الجزء 4

الروابط بين الطابور والمبادل

$producer->queue('queue-1')->bind('logs');

$producer->queue('queue-2')->bind('logs', 'binding-key');

مبادل مباشر

ملزمة متعددة

إصدار الرسالة

$producer->newDirectExchange('my-logs');

$producer->newDirectExchange('my-logs');
$producer->publish($message, $severity, 'my-logs');

اشتراك

// Worker 1
foreach ($severities as $severity) {
   $consumer->queue('queue-1')->bind('my-logs', $severity);
}

ضع كل شيء معا

try {
   $producer = \MonsterMQ\Client\Producer();

   $producer->connect('127.0.0.1', 5672);
   $producer->logIn('guest', 'guest');

   $producer->newDirectExchange('my-logs');

   $severity = isset($argv[1]) && !empty($argv[1]) ? $argv[1] : 'info';

   $message = implode(' ', array_slice($argv, 2));
   $message = empty($message) ? "Hello World!" : $message;

   $producer->publish($message, $severity, 'my-logs');

   echo "\n Sent {$message} \n";
} catch(\Exception $e) {
   var_dump($e);
}

try {
   $consumer = \MonsterMQ\Client\Consumer();

   $consumer->connect('127.0.0.1', 5672);
   $consumer->logIn('guest', 'guest');

   $producer->queue('queue-1')->setExclusive()->declare();

   $severities = array_slice($argv, 1);
   if (empty($severities)) {
      file_put_contents('php://stderr', "Usage: $argv[0] [info] [warning] [error]\n");
      exit(1);
   }

   foreach ($severities as $severity) {
      $producer->queue('queue-1')->bind('my-logs', $severity);
   }

   $consumer->consume('queue-1');

  echo " \n Waiting for logs. To exit press CTRL+C\n";

   $consumer->wait(function ($message, $channelNumber) use ($consumer){
      echo "\n $message \n";
   });
} catch(\Exception $e) {
   var_dump($e);
}

php worker-1.php warning error > logs_from_rabbit.log

php worker-2.php info warning error
# => Waiting for logs. To exit press CTRL+C

php send.php error "Run. Run. Or it will explode."