2017-08-20 48 views
0

我在我的rabbitmq設置中遇到了一種情況。我的情況是如下,即使有聽衆與這些隊列相關聯,RabbitMQ隊列也會在一段時間內累積消息

設置:

  1. 有2所涉及的虛擬機。
  2. 這兩個虛擬機在循環中每7秒發送25mb大小的消息。
  3. 有設置用於在機器之間傳輸消息的鏟子。
  4. 這兩臺機器都有偵聽器來使用其他機器發送的消息。
  5. 聽衆只是消費的信息,並出來。聽衆方面沒有涉及任何處理。
  6. 還有rabbitmQ經紀人是已啓用SSL。我使用Spring RabbitMq
  7. 我正在使用SimpleMessageListenerContainer進行收聽。

我的問題:

  1. 過了一段時間,說經過不斷的消息交換1.5天, 沒有在隊列中的消息積累。

  2. 收聽者已啓動,但消費速率在一段時間內消失 並且消息堆積在隊列中。

  3. 積聚在隊列中的一些消息處於未確認狀態。

事情,我也想嘗試:

  1. 增加沒有。的隊列聽衆。
  2. 增加偵聽器的預取計數。

我的問題

  1. 爲什麼消息得到了積累的時間段。
  2. 之間是否有任何網絡干擾。我是否需要爲聽衆添加額外的參數來解決網絡干擾問題。

請指導我這裏。我需要幫助來微調我的設置,使其更加強大。

+0

嗨,感謝您的輸入..我只使用rabbitmq 3.6.10版本。關於我的設置的一些更多的輸入:1.它是一個運行在vms上的java進程。 2.兩臺機器共有25個隊列。 3.發送者進程產生25個線程並每7秒發送25MB數據。每個線程之間的差距是7秒。 4.有25個鏟子用於將信息從發送者泵送到接收者機器。 5.在接收者方面,對於所有25個隊列**,只有一個監聽者。請告訴我你需要什麼額外信息。 –

回答

0

這裏的人很難調試你的應用程序。

消耗率減少在一段時間

這是最喜歡你的應用程序的症狀,而該消息系統或框架。我會從那裏開始。

中間是否有任何網絡干擾。

使用最新版本的RabbitMQ,默認情況下會啓用心跳,因此應該檢測到任何此類「干擾」。

+0

嗨,感謝您的輸入..我只使用rabbitmq 3.6.10版本。關於我的設置的一些更多的輸入:1.它是一個運行在vms上的java進程。 2.兩臺機器共有25個隊列。 3.發送者進程產生25個線程並每7秒發送25MB數據。每個線程之間的差距是7秒。 4.有25個鏟子用於將信息從發送者泵送到接收者機器。 5.在接收方,所有25個隊列中只有一個聽衆。請告訴我你需要什麼額外信息。 –

相關問題