rabbitMQ调试

  $connection \= new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');  
  $channel \= $connection\->channel();  
  
  $channel\->queue\_declare('hello4', false, false, false, false);  
  
  echo ' \[\*\] Waiting for messages. To exit press CTRL+C', "\\n";  
  
  $callback \= function($msg) {  
  echo " \[x\] Received ", $msg\->body, "\\n";  
 };  
  $channel\->basic\_consume('hello', '', false, true, false, false, $callback);  
  
  
//        while(count($channel->callbacks)) {  
//            $channel->wait();  
//        }  
  
  $channel\->close();  
  $connection\->close();

// while(count($channel->callbacks)) {
// $channel->wait();
// }
$channel->wait(); 是做什么的 ,总因为这里而卡死网页

阅读 1.2k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进