spring-amqp

1熱度

1回答

我使用Spring Cloud方法來構建一些應該相互交互的微服務。對於微服務之間的消息傳遞，我打算使用RabbitMQ和Spring AMQP，但是當我看着Spring Cloud Stream時，我感覺失落了。在我看來，Spring Cloud Stream是下一個抽象層次（可能太強大了，但應該得到整體印象）還有許多非常有用的功能。所以我想知道爲什麼有人會使用Spring AMQP進行新的開發？

0熱度

2回答

Spring AMQP監聽器超時

我有處理SpringAMQP監聽器超時能力的要求，即我們從生產者發送消息，Spring AMQP的消費者監聽器線程接收到消息但說需要很多時間來執行自己並掛起，最終導致Listener線程無法使用。那麼，有沒有辦法，我們必須由Spring AMQP提供任何消費超時設置讓聽者線程被釋放再次給定的超時時間

0熱度

1回答

如何從使用的RabbitMQ彈簧一體化

[編輯]上載完成CONFIGS手動ACK消息： rabbit.xml從兔 <rabbit:connection-factory id="amqpConnectionFactoryInbound" host="${rabbit.host}" port="${rabbit.port}" username="${rabbit.username}" password="${rabbit.passwor

1熱度

1回答

Spring Cloud DataFlow RabbitMQ最小啓動時間間隔

我希望在啓動應用程序後立即啓動50個Rabbit消費者，並在需要時每秒啓動更多消費者（最多500位消費者）。如何在部署人的application.yaml中爲RabbitMQ設置startConsumerMinInterval？我在Spring AMQP文檔中找到startConsumerMinInterval屬性，但在binder文檔中我找不到任何提及此屬性的內容。

0熱度

1回答

的情況下，代理連接彈簧AMQP的消息彈性下降

我有管理的春天AMQP客戶端消息彈性的使用案例中的RabbitMQ服務器連接下來的情況下，因爲我已經使用過Spring重試 RabbitTemplate template = // get template from some bean RetryTemplate retryTemplate = new RetryTemplate(); ExponentialBackOffPolicy ba

0熱度

1回答

Spring RabbitMQ連接和資源管理問題

我需要通過HAProxy使用來自Rabbit HA羣集的消息，因此我在spring-amqp-documentation中建議使用CacheMode.CONNECTION。此外我需要消耗許多隊列中的消息，所以我創建的每個隊列SimpleMessageListenerContainer有4個併發用戶，我有幾個問題：後幾次測試看起來，我的做法是沒有效率的，因爲每次當一個新的隊列也添加了新的Simpl

0熱度

1回答

SimpleRabbitListenerContainerFactory和defaultRequeueRejected

按照文檔，defaultRequeueRejected的默認值是true，但看代碼看起來是錯誤的。我不知道如果我錯過什麼或者我們必須改變，在SimpleRabbitListenerContainerFactory.java 編輯示例代碼，把消息隊列的測試後，我希望它留在隊列中，因爲它的失敗，但它正在拋出。我想要重試消息，因此我在容器工廠中配置了它，如果重試後失敗，我希望它重新排隊。我相信我在這裏

0熱度

1回答

Spring AMQP和兩個RabbitMQ服務器之間的變化

我有一個使用Spring AMQP的項目。我有兩個SimpleMessageListenerContainer，一個帶有服務器自我聲明的隊列（amq-gen），另一個帶有給定名稱的隊列。我使用一個SimpleRoutingConnectionFactory和兩個CachingConnectionFactory。對於錯誤檢測，我有一個ConnectionListener，ListenerConta

0熱度

1回答

Rabbitmq ready和unack消息

我有一個擁有50個消費者的隊列，預取計數爲100左右。所有消費者都來自單個JVM實例。所以，當應用程序關閉時，消息處於READY狀態。處於就緒狀態的消息數量等於（prefetch_count *消費者數量）。現在的問題是，在READY狀態下的消息會發生什麼？它會重新遞交還是會死信？

0熱度

1回答

AMQP協議的內部工作

我有一個疑問 - AMQP內部使用哪種數據結構來存儲消息。我知道它有運輸（TCP/IP）消息協議&類型系統消息屬性 Message Broker的便攜式再現 - MOM經紀人管理之間層API映射路由-in即將除了的AMQP網絡協議我相信它應該只是隊列。如果是這樣，那麼所有的操作，如阻塞隊列，使其持久（等）都在它上面執行？任何工作原理的示例（網址或博客將起作用） AWS SQS