php接收rabbitmq訊息時丟失連線的問題

2021-08-29 12:00:01 字數 880 閱讀 2055

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 交換機非常簡單，它一邊從發布者方接收訊息，一邊把訊息推送到佇列。...