1、根據rabbitmq 官方文檔 搭建了一個測試 創建隊列 以及 發送消息 接受消息 但是都是 用 php server.php 和 php client.php 這樣的形式 來執行的 如果部署到服務器 如何實現 client.php 來自動消費這個隊列里面的消息 始終與服務器保持聯系 網上的一些資料是寫一個sell 腳本 以及while 循環來處理 不知道還有什么其他的方式。
2 回答
守著星空守著你
TA貢獻1799條經驗 獲得超8個贊
public function receive($callback, $routingKey = null)
{
if (self::$connection === null) {
$this->openConnection();
}
//channel
$channel = new \AMQPChannel(self::$connection);
$channel->setPrefetchCount($this->preFetchCount);
$queue = new \AMQPQueue($channel);
$queue->setName($this->queue);
$queue->bind($this->exchange, empty($routingKey) ? $this->routingKey : $routingKey);
while (true) {
$queue->consume($callback);
}
}參考一下。目前PHP只有while循環的形式（當然，你可以考慮一下php的多線程）
- 2 回答
- 0 關注
- 2762 瀏覽
添加回答
舉報
0/150
提交
取消