spring-rabbit

0熱度

1回答

我有一個使用Spring集成的Spring Boot應用程序。該應用程序從RabbitMQ隊列中提取消息，轉換該消息中的數據，聚合50個轉換後的消息，將這些消息放入數組中，並將它們作爲JSON發送到RESTful端點。我看到內存緩慢地爬起來，直到應用程序崩潰。我跑了我們的應用程序探查並有建立隨時間推移VariableLinkedBlockingQueue的實例。應用程序似乎在應用程序啓動後將其清

1熱度

2回答

rabbitmq中prefetch count和no ack有什麼區別

我需要知道rabbitmq中prefetch count和no ack之間有什麼區別嗎？而且是什麼下面的語句之間的區別： - 如果我設置預取數說10確實是在10消費者線程？或 - 如果我註冊10個cosumers它會創建10個線程？這上面是更有效的

0熱度

1回答

Spring RabbitMQ - Message Requeue limit

使用Spring-boot和Spring-starter-amqp作爲我的消息傳遞應用程序。我的問題場景是這樣的：第一個問題：我想重發我的消息只有5次，然後消息應該從隊列中發出，如果發生業務異常（這裏我只關注業務異常）。第二個問題：如果第一個用例是可能的，我們可以通過某種方式增加嘗試次數。假設在第一次嘗試時發生業務異常，它應該立即要求，但在第二次嘗試中，應該在2分鐘後然後4分鐘，然後6分鐘，然

1熱度

1回答

春季兔子重試提供被拒絕的消息..它可以嗎？

我有以下的配置 spring.rabbitmq.listener.prefetch=1 spring.rabbitmq.listener.concurrency=1 spring.rabbitmq.listener.retry.enabled=true spring.rabbitmq.listener.retry.max-attempts=3 spring.rabbitmq.listene

0熱度

1回答

如何在Spring RabbitMQ項目中使用多個虛擬主機？

我有以下兩個配置類： @Configuration @EnableRabbit @Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class }) public class RabbitConfigA { @Autowired @Qualifier("rabbitConnectionFactory_A")

1熱度

1回答

我們可以更改rabbitmq的屬性spring配置和流的兔子

在我的POC中，我使用Spring Cloud Config和Spring Stream Rabbit。我想動態地改變監聽器的數量（併發性）。有可能這樣做嗎？我想這樣做以下： 1）如果在隊列中的郵件太多，我想增加併發級別。 2）在方案中，其中我的下游系統不可用時，我想停止處理從隊列中的消息（在短併發級別0）。我怎麼能做到這一點？感謝您的幫助。

1熱度

1回答

覆蓋

我們一直在使用的框架使用Spring AMQP，其中框架設置SimpleMessageListenerContainer.setDefaultRequeueRejected（假）SimpleMessageListenerContainer.setDefaultRequeueRejected（假的）行爲，這意味着默認的消息不會，如果拋出來重新排隊消費者的例外。有沒有什麼辦法可以改變這種行爲不改變

0熱度

1回答

是否可以在傳出消息中設置AMQP消息屬性？

我正在使用Spring Cloud Stream和RabbitMQ活頁夾。我需要調用不使用Spring Cloud Stream的外部服務。此服務正在使用type和correlation_id消息屬性。我試圖在傳出消息中設置標題，但即使屬性在技術上是標題，它們也會以特殊方式處理。所以設置type標題不會設置屬性。我知道攔截器，如果只使用Spring RabbitMq，它不會是一個問題。但是由於

2熱度

1回答

如何使用java發送相關性id到消息中，從發送方發送並從接收方檢索到消息頭

我已經使用Rabbit MQ發送和接收JSON消息。我已經實現使用RabbitTemplate實例與convertAndSend方法的應用程序將消息發送到交換如下： rabbitTemplate.convertAndSend(exchangeNameOut, message.getString(PERSISTENCE_MESSAGE_ROUTING_KEY), message.

-2熱度

3回答

卡夫卡vs兔MQ的優缺點

卡夫卡和RabbitMQ是衆所周知的郵件經紀人。我想用Spring Boot構建一個微服務，看起來Spring Cloud爲他們提供了開箱即用的解決方案，作爲事實上的選擇。我知道有一些RabbitMQ的trayectory有很多支持。卡夫卡屬於阿帕奇，所以它應該是好的。那麼RabbitMQ和Kafka之間的主要區別是什麼？考慮到這將與Spring Cloud一起使用。請分享您的經驗和標準。提前致謝