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