我创建RabbitMQ监听器:
$connection = new AMQPConnection( $AMQP_config['server'],$AMQP_config['port'],$AMQP_config['user'],$AMQP_config['password'],$AMQP_config['virtual_host'] ); $channel = $connection->channel(); $channel->basic_qos( null,1,null ); $channel->basic_consume( $AMQP_config['queue'],'',false,array($this,'CallbackResponse') ); while(count($channel->callbacks)) { $channel->wait(); } $channel->close(); $connection->close();
public function CallbackResponse(AMQPMessage $msg) { $response = json_decode($msg->body)->acopMessage; if ($response->reqMRef == $this->_request_reference) { $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']); } }
我的RabbitMQ服务器上有5条消息.但我只收到一个回调,只有一个进入CallbackResponse().
我想检查队列中的所有消息,找到我发送的消息,阅读它,这样就会留下4条消息.
我做错了什么,为什么我只收到第一条消息?
解决方法
Your QoS is set to 1.所以RabbitMQ一次只发送一条消息.
由于您只收到了您期望的消息,因此您收到的第一条与您的条件不符的消息仍然是不可用的.因此,RabbitMQ不会发送新消息.
所以不匹配的消息必须是unacked and requeued
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。