我有一個要求,我有1個直接交換,並且5個不同的隊列通過唯一的路由鍵綁定到它。基本上每個隊列都是針對不同的消費者端點。我正在使用彈簧託管端點註冊表,使用@RabbitListener
。所以有5個端點註冊。在我實現它的時候,我創建了一個RabbitListenerContainerFactory
,其值爲concurrentConsumer
。但是我有一個問題,如果有一個工廠創建的消費者規模爲2,那麼所有的終端都會有不同的消費者或消費者每個工廠都會創建,並且此containerFactory
將爲所有5個端點提供服務。因此,如果2個消費者爲所有5個隊列服務,那麼其他隊列消費者將處於空閒狀態直到一個隊列消息首先被服務時,負載將不會不平衡。 我應該爲不同的終端創建單獨的containerFactory
嗎?創建一個具有2個消費者和多個端點的單個RabbitListenerContainerFactory來監聽消息的行爲
2
A
回答
1
每個@RabbitListener
都有自己的容器,每個容器都有2個消費者。
這是一個容器工廠用於爲每個註釋的方法創建一個容器。把它看作是一個「模板」;很像XML中的<rabbit:listener-container/>
元素 - 它具有一組公共屬性,但每個子元素都有自己的容器。
相關問題
- 1. 生產者 - 消費者多個生產者多個隊列單個消費者
- 2. 多個生產者,單個消費者
- 3. 製片人 - 消費者Scenerio。我有一個生產者和多個消費者
- 4. 消費者的有效MQ消息一個消息
- 5. 消費阻止具有多個任務/消費者的集合
- 6. 多個WebpartProviders與單個Webpart消費者
- 7. 單個生產者到多個消費者(相同的消費者羣體)
- 8. Pentaho JMS消費者 - 對單個消費者的多個生產者
- 9. 約一個休息端點常規的想法和兩個消費者
- 10. 許多生產者和一個消費者一次輪詢所有消息
- 11. 多個消費者一個隊列
- 12. 同一執行器服務中的多個生產者和單個消費者
- 13. 不允許同一端點的多個消費者
- 14. 鎖定免費隊列 - 單個生產者,多個消費者
- 15. ActiveMQ一個生產者多消費者
- 16. 單隊列:多個消費者同時處理消息
- 17. 多個生產者和多個消費者的Redis pub子
- 18. 使用的RabbitMQ - 多個生產者和多個消費者
- 19. BlockingCollection多個消費者
- 20. MassTransit多個消費者
- 21. 從聽者傳遞一個消息
- 22. 爲一個類型的消費者
- 23. SAML單SP多個消費者/域
- 24. 在消費者正在收聽消息之前,消費者沒有收到來自MQ的消息
- 25. 單生產者單消費者現在我需要多個消費者
- 26. 駱駝不會爲一個消費者處理消息
- 27. 如何在多個消費者閱讀相同的kafka消息
- 28. 向ActiveMQ中的多個消費者發送消息
- 29. 消息與80000個生產者和少數消費者
- 30. 消費者選擇的JMS單個消息確認