rabbitmq

-1熱度

1回答

這次可以在RabbitMQ中爲呼叫處理程序存儲時間嗎？ RabbitMQ是否支持這個？

0熱度

1回答

我試圖測試Kubernetes上的氣流。調度程序，工作者，隊列和Web服務器都在不同的部署上，我使用Celery Executor來運行我的任務。除了調度程序無法排隊工作以外，一切正常。當我從Web UI或CLI手動執行它時，Airflow能夠正常運行我的任務，但我試圖測試調度程序以使其工作。我的配置幾乎一樣，因爲它是在單個服務器上： sql_alchemy_conn = postgresql

1熱度

1回答

防止RabbitMQ將消息寫入磁盤

我有一個要求，即永遠不應將消息寫入磁盤。 RabbitMQ文檔聲明如下：持久性和瞬態消息都可寫入磁盤。持久性消息一旦到達隊列就會被寫入磁盤，而瞬態消息只會寫入磁盤，以便在內存壓力下將其從內存中逐出。這對於「在內存壓力下」的含義有點模糊。有沒有辦法確保瞬態消息永遠不會寫入磁盤？如果涉及到它，如果在這種情況下無法傳遞信息，則可以丟失信息。

1熱度

1回答

如何在Masstransit/RabbitMQ中組織隊列？

我想知道消費消息的最佳實踐。我已經閱讀了MassTransit文檔，並且正在尋找這方面的內容，但是我沒有得出任何結論。我有一個api（託管公交車實例），正在發佈消息。這些消息是多種多樣的，因爲這個API不是微服務（購買，銷售等的消息）。如何組織我的消費者/隊列？一個隊列類型的過程？例如，一個用於購買，另一個用於銷售，這個解決方案可能涉及許多流程，我不確定它是否是一個好的解決方案。如果我想購買

0熱度

1回答

爲什麼我們應該在接收者中聲明隊列的名字？

我正在學習RabbitMQ。我不明白爲什麼在receive_logs.pyexample我們設定的交換類型： channel.exchange_declare(exchange='logs', exchange_type='fanout') 以及與此交流結合隊列的名稱： channel.queue_bind(exchange='logs', queue=q

0熱度

1回答

如何刪除rabbitmq中的消息（pika）

如何刪除發佈和接收的消息，在rabbitmq 我正在用python測試rabitmq，同樣的消息還在繼續發佈和接收，如何避免這種情況。我怎樣才能刪除公佈並收到

0熱度

1回答

如何對RabbitMQ Cluster進行性能測試以做進一步的微調？

我已經創建了一個RabbitMQ羣集，它正在對由應用程序生成的消息進行排隊。我需要對集羣進行性能測試，以便找出集羣的整體效率，並做出決定進行進一步的微調以提高性能。我們用PerfTest java工具嘗試過。但實現不了多少。

0熱度

1回答

如何註冊一個隊列，並且它是RabbitMQ和Spring的獨佔使用者/偵聽器？

我有以下問題需要解決：我想實現一個簡單的使用RabbitMQ消息傳遞的延遲重試機制。我有一個基礎設施，可以讓我延遲傳遞信息。我可以有任何想要在運行時利用這種延遲重試機制的感興趣的參與者。參與者只想給我提供2個細節和消息： 1.隊列名稱，他們希望在延遲T秒後傳遞消息。 2.隊列的消費者（比如消息的消費者。）我試圖做到以下幾點： private void startSeparateListene

0熱度

3回答

RabbitMQ連接錯誤「沒有指定的端點可達」

我在服務器和我的系統上安裝了rabbitmq服務。我想使用RPC模式： var factory = new ConnectionFactory() { HostName = "158.2.14.42", Port = Protocols.DefaultProtocol.DefaultPort, UserName = "Administrator", Pas

0熱度

1回答

Apache進程不會在與RabbitMQ斷開連接後死亡

我試圖在我的項目中使用Server Side Events機制。（這類似於類固醇上的長輪詢）來自「Sending events from the server」字幕的例子效果非常好。幾秒鐘後，斷開連接，apache進程終止。此方法工作正常。但是！如果我嘗試使用RabbitMQ，則在瀏覽器從服務器斷開連接後，Apache不會導致進程中斷（es.close()）。並且進程保持原樣並在docker