php-amqplib

    2熱度

    1回答

    我有一個RabbitMQ容器和一個PHP 7容器,其中包含Symfony 3.1.x項目,該項目使用OldSoundRabbitMqBundle執行RabbitMQ使用者。 當運行這個命令執行test消費者: bin/console rabbitmq:consumer -w test 我收到以下錯誤: [PhpAmqpLib\Exception\AMQPIOException] Error r

    0熱度

    1回答

    我有兩個關於RabbitMQ的消費者問題(接收器): 我如何定義(靜態地從隊列中)什麼是註冊到某一個隊列的消費者,因此,如果一個消費者下消息在消費者再次上漲之後仍然會交付,還是有其他方法可以實現這一目標? 消費者如何連接到尚未創建的隊列,在rabbitmq教程中,我可以在生產者之前調用消費者,它仍然可以工作,有人可以請解釋這是如何工作的嗎? 感謝

    1熱度

    1回答

    工作。隊列顯示消費者不再存在,我假設發生的事情是RabbitMQ繼續向消費者傳遞消息。它們表現爲不斷增加的未消息信息數量。我使用php-amqplib在PHP中執行此操作。 我可以通過殺死消費者進程(命令行上的控制-C)產生的問題。 我試圖指定3秒的心跳,並試圖保持活躍真假兩。有了心跳,消費者最終將失敗: Exception fwrite(): send of 573 bytes failed w

    1熱度

    1回答

    如何使用RabbitMQ發送消息數組? 我不想單獨發送每封郵件。 對於examlple: ch.publish(ex, '', new Buffer('hello world')); 我怎麼能使用somethink像: ch.publish(ex, '', new Buffer([msg1, msg2, msg3...])); 謝謝!

    10熱度

    2回答

    我已經設置了RabbitMQ來解析來自外部API的一些20.000個請求,但它在幾分鐘後保持超時。它確實可以在總共20,000個請求中正確解析大約2000個。 日誌文件說: =INFO REPORT==== 16-Feb-2016::17:02:50 === accepting AMQP connection <0.1648.0> (127.0.0.1:33091 -> 127.0.0.1:56

    0熱度

    1回答

    我在這裏遇到了一個PHP amqp消費者的小問題,它在一段時間後停止工作。您可以在下面看到我的silex命令。我也嘗試過使用心跳和Keepalive配置來處理斷開的網絡連接,但不會改變。什麼可能是消費者不讀隊列消息的原因?腳本沒有退出,它似乎在睡覺。 <?php use Symfony\Component\Console\Input\InputInterface; use Symfony\C

    1熱度

    2回答

    我有一個關於third RabbitMQ tutorial的問題。我試圖實現類似的東西,除非不能保證消費者在生產者向交易所發送消息時運行。 所以,我有我的製片人,其消息發佈給扇出交換: $channel->exchange_declare('my_exchange', 'fanout', false, false, false); $channel->basic_publish('my_mess

    1熱度

    1回答

    我正在使用php-amqplib與PHP和RabbitMQ進行客戶端 - 服務器通信。 我有一個生產者腳本,看起來像工作正常,但我的消費者沒有收到任何東西。 我用sudo rabbitmqctl list_queues檢查了隊列中的條目,每次運行生產者後,計數器都會增加。 我的消費者沒有任何PHP錯誤,看起來像等待消息。 什麼看起來不錯,它會在啓動時運行回調腳本一次,並收到空的傳入消息 - 而不會

    4熱度

    1回答

    我使用vladimir-yuldashev/laravel-queue-rabbitmq庫流明項目中使用RabbitMQ的隊列「PhpAmqpLib \異常\ AMQPRuntimeException通道連接被關閉」錯誤與流明隊列。 隊列功能工作正常,但我看到下面噸的錯誤在我的日誌文件。 lumen.ERROR: PhpAmqpLib\Exception\AMQPRuntimeException:

    0熱度

    1回答

    我想將多值傳遞給由RabbitMQ通過PHP提供的隊列。這是一個手機號碼和內容的短信發送者。 是更好地這兩個參數發送一個JSON字符串排隊的有效載荷和對消費者的身邊收杆JSON或,發送手機號碼作爲頭參數和內容的有效載荷和使用get("application_headers")和getNativeData消費者的身邊,用手機數? 哪種方式有更好的性能?