php接收rabbitmq訊息時,如果按照下面官方的寫法,可能會導致過幾分鐘後連線就丟失了,接收網頁就像假死一樣:
<?php
require_once __dir__ . '/vendor/autoload.php';
use phpamqplib\connection\amqpstreamconnection;
$connection = new amqpstreamconnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('hello', false, false, false, false);
echo " [*] waiting for messages. to exit press ctrl+c\n";
$callback = function ($msg) ;
$channel->basic_consume('hello', '', false, true, false, false, $callback);
while (count($channel->callbacks))
$channel->close();
$connection->close();
最後發現需要在建構函式裡設定連線amqpstreamconnection的心跳和讀寫超時時間, 超時時間需是心跳的2倍以上,這樣連線就不會消失了
可以在rabbitmq的管理**上檢視連線的心跳是否設定成功:
PHP 實現RabbitMQ訊息佇列 二
1 安裝拓展及工具包 2 實現 a 發布訊息 host 127.0.0.1 主機 port 5672 埠 login test 賬號 password 123123 密碼 vhost test host預設為 require once vendor autoload.php usephpamqpli...
基於PHP使用rabbitmq實現訊息佇列
1.從github上面獲取amqp基於php的實現擴充套件 2.建立生產者 send.php 1 require dir protected vendor autoload.php 23 usephpamqplib connection amqpstreamconnection 4use phpam...
RabbitMQ 訊息廣播
rabbitmq訊息模型的核心理念是 發布者 producer 不會直接傳送任何訊息給佇列。事實上,發布者 producer 甚至不知道訊息是否已經被投遞到佇列。發布者 producer 只需要把訊息傳送給乙個交換機 exchange 交換機非常簡單,它一邊從發布者方接收訊息,一邊把訊息推送到佇列。...