PHP 實現RabbitMQ訊息佇列 二

2022-03-18 16:24:52 字數 1989 閱讀 4551

1、安裝拓展及工具包

2、**實現

a、發布訊息

<?php


$_host = '127.0.0.1';//


主機$_port = '5672';//


埠$_login = 'test';//


賬號$_password = '123123';//


密碼$_vhost = 'test';//


host預設為/


require_once '../../../../vendor/autoload.php';


usephpamqplib\connection\amqpstreamconnection;


usephpamqplib\message\amqpmessage;


$exchange = 'test';//


交換機$connection = new amqpstreamconnection($_host, $_port, $_login, $_password, $_vhost


);$channel = $connection->channel();


$channel->exchange_declare($exchange, 'direct', true, false, false


);$routerkey = 'lol_status';


//模擬批量發布訊息


for ($i = 0; $i


< 100; $i++) 


$channel->close();


$connection->close();


?>

b、消費訊息

<?php


$_host = '127.0.0.1';


$_port = '5672';


$_login = 'test';


$_password = '123123';


$_vhost = 'test';


require_once '../../../../vendor/autoload.php';


usephpamqplib\connection\amqpstreamconnection;


$exchange = 'test';//


交換機名稱


$queuename = 'lol';//


佇列名稱


$routerkey = 'lol_status'; //


路由key


$connection = new amqpstreamconnection($_host, $_port, $_login, $_password, $_vhost


);$channel = $connection->channel();


$channel->exchange_declare($exchange, 'direct', true, false, false


);$channel->queue_bind($queuename, $exchange, $routerkey


);//


獲取訊息數量資訊


$declare_info = $channel->queue_declare($queuename,true);//


$declare_info[1] 訊息數量


echo " 等待訊息中..." .php_eol


;$callback = function ($msg


);//


第4個引數 false:手動應答 true:自動應答


$channel->basic_consume($queuename, '', false, true, false, false, $callback


);//


阻塞模式


while ($channel->is_consuming()) 


$channel->close();


$connection->close();


?>

基於PHP使用rabbitmq實現訊息佇列

1.從github上面獲取amqp基於php的實現擴充套件 2.建立生產者 send.php 1 require dir protected vendor autoload.php 23 usephpamqplib connection amqpstreamconnection 4use phpam...

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

php接收rabbitmq訊息時,如果按照下面官方的寫法,可能會導致過幾分鐘後連線就丟失了,接收網頁就像假死一樣 require once dir vendor autoload.php use phpamqplib connection amqpstreamconnection connectio...

RabbitMQ 訊息廣播

rabbitmq訊息模型的核心理念是 發布者 producer 不會直接傳送任何訊息給佇列。事實上，發布者 producer 甚至不知道訊息是否已經被投遞到佇列。發布者 producer 只需要把訊息傳送給乙個交換機 exchange 交換機非常簡單，它一邊從發布者方接收訊息，一邊把訊息推送到佇列。...