加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 站长学院 > PHP教程 > 正文

php – 无法读取RabbitMQ的所有消息

发布时间:2020-12-13 15:55:25 所属栏目:PHP教程 来源:网络整理
导读:我创建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,nu
我创建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条消息.

我做错了什么,为什么我只收到第一条消息?

使用此:https://github.com/videlalvaro/php-amqplib

解决方法

Your QoS is set to 1.所以RabbitMQ一次只发送一条消息.

由于您只收到了您期望的消息,因此您收到的第一条与您的条件不符的消息仍然是不可用的.因此,RabbitMQ不会发送新消息.

所以不匹配的消息必须是unacked and requeued

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读