spring-rabbitmq

0熱度

1回答

我SpringBoot配置包含很強的重試政策rabbitTemplate試 spring: rabbitmq: template: retry: enabled: true initial-interval: 500 max-attempts: 10 multiplier: 5 max-interval:

0熱度

1回答

兔子監聽器vs兔子模板在重試本機

我們正在嘗試使用MessageRecoverer進行一些企圖異常和存儲消息的重試操作，所以我們在XML中進行了第一次配置，例如max attempt和interval等重試。審閱後重試公共屬性在這個環節https://docs.spring.io/spring-boot/docs/current/reference/html/common-application-properties.html#%

0熱度

1回答

Spring Boot - RabbitMQ - 處理經紀人故障的場景

我們在我們的項目中使用rabbitmq進行消息傳遞。這主要用於審計日誌記錄。我們試圖檢查我們的應用如何響應某些故障情況。例如，如果RabbitMQ關閉，消費者會不斷嘗試連接到rabbitmq並失敗。如果rabbitmq停機，消費者是否有辦法停止嘗試？以類似的方式，當代理停止時，發佈者如何停止嘗試將消息發送到隊列？斷路器是我們可以考慮的選項之一嗎？

1熱度

1回答

SpringBoot：手動確認多個AMQP消息

我需要在成功處理並存儲後，才能在兔子聽衆中手動確認多條消息。使用的彈簧啓動配置如下 listener: concurrency: 2 max-concurrency: 20 acknowledge-mode: manual prefetch: 30 消息應該一次存儲20個批次。只有當它們被成功存儲時，才應該發送多重確認。存儲機制也存在關聯超時，即使沒有2

1熱度

1回答

如何避免在發生意外錯誤時關閉SimpleMessageListenerContainer？

我正在使用Java boot 1.4.0和'spring-boot-starter-amqp'來連接到rabbitMq。消息製作者，消費者和rabbitMq服務器都在我的控制之下。在製作過程中，幾個月的事情都很好。但突然我的消費者停止了下面給出的例外。由於我只生產總是有效的信息，我不知道哪裏出了問題。但是這導致我的聽者容器關閉。因此我的消息處理已停止。我不得不手動重新啓動消息使用者程序。所以我

0熱度

1回答

當使用spring-websocket和rabbitmq-stomp時不會發送消息給所有活動用戶

我有一個基於spring websocket over stomp（由spring boot 1.5.1提供支持）的web應用程序。我使用Rabbitmq（3.6.6）和stomp插件作爲全功能代理。據the doc of stomp，從/主題目標的消息/將被傳遞到所有活躍用戶。主題目的地對於簡單的主題目的地其中遞送每個消息的副本到所有活動用戶，形式 /主題的目的地/都可以使用。主題目標支

3熱度

1回答

如何一起使用Rabbit連接緩存模式和Autodeclare功能？

的Spring AMQP Reference說：與1.3版本開始，CachingConnectionFactory可配置爲高速緩存的連接以及剛剛渠道。在這種情況下，每次調用createConnection()都會創建一個新連接（或從緩存中檢索一個空閒連接）。關閉連接會將其返回到緩存（如果尚未達到緩存大小）。在這種連接上創建的通道也被緩存。在某些環境中使用單獨的連接可能很有用，例如從HA羣集消耗，

0熱度

1回答

春天啓動的RabbitMQ DLE不接受我的春天啓動的RabbitMQ工作的任何消息

。我創建一個死信隊列，我可以能夠RabbitMQ的管理爲「d，DLE」，但沒有DLK看可能是我失蹤設置「X-死信路由鍵」，事情是我不希望我的路由消費者key.Few綁定到特定的交流，我創建每個交換DLE如果有那麼DLE連接到接收消息，並做了用戶依賴logic.But是交換爲交換消費者的任何問題不幸的是，這不起作用，DLE沒有收到任何消息。請找到下面的代碼， package com.sample.

0熱度

1回答

RabbitMq中每個消息使用者的單獨死信隊列

我有一個使用RabbitMQ構建的發佈 - 訂閱場景。有一個交換機，發佈者正在發送消息，任何訂閱該交換機的消費者都會在其各自的隊列中接收這些消息。這是一個只有一個生產者但有多個消費者的粉絲場景。現在我願意將死信隊列整合到系統中，以便稍後可以處理被拒絕的消息。我的問題是 1）我應該爲每個消費者配置一個單獨的死信隊列，還是應該有一個處理所有消費者的所有被拒絕消息？ 2）如果兩者都可能，哪一個更好？

0熱度

1回答

Spring RabbitMq - 隊列創建事件監聽器

我想知道是否有任何事件發佈時，queue實際上是通過Spring Api在Rabbitmq物理創建的。我問的原因是某種程度上我們有競爭條件。 queue的訂閱通常需要更長的時間，而訂閱已經發生，從BE發送消息到該隊列，並且因爲結果隊列不存在於Rabbitmq中，並且消息丟失並且永遠不會到達FE。對不起，我不能提供任何代碼，因爲它通過放一小段代碼不會有多大意義。但是我很肯定，問題是因爲種族的狀