我創建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,

false,

false,

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條消息.

我做錯了什么,為什么我只收到第一條消息？

總結

以上是生活随笔為你收集整理的php怎么读取mq的数据,php – 无法读取RabbitMQ的所有消息的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。