ActiveMQ重試機制

2022-08-21 22:15:11 字數 831 閱讀 3215

1.activemq重試機制是什麼?

消費者收到訊息,之後出現異常了,沒有告訴broker確認收到該訊息,

broker

會嘗試再將該訊息傳送給消費者。嘗試

n次,如果消費者還是沒有確認收到該訊息,那麼該訊息將被放到死信佇列中,之後

broker

不會再將該訊息傳送給消費者。

2.

具體哪些情況會引發訊息重發?

① client用了

transactions

且在session中呼叫了

rollback

② client用了

transactions且在

呼叫commit之前關閉或者沒有

commit

③ client在client_acknowledge的傳遞模式下,

session

中呼叫了

recover(允許訊息重發模式下)

3.

訊息重發時間間隔和重發次數

間隔:1  次數:6

4.有毒訊息poison ack

乙個訊息被redelivedred(重發)給消費者端

超過預設的最大重發次數(

預設6次

)時,消費

者端會給mq發乙個

「poison ack」

表示這個訊息有毒,告訴

broker

不要再發了。這個時候

broker

會把這個訊息放到

dlq(

死信佇列)。

中斷重試機制

原文 中斷重試 中斷重試機制 public abstract class retrytemplate public retrytemplate setsleeptime int sleeptime this sleeptime sleeptime return this public intgetr...

Spring重試機制

org.springframework.retrygroupid spring retryartifactid dependency org.springframework.bootgroupid spring boot starter aopartifactid dependency 程式啟動類新...

Polly 重試機制

引用 install package microsoft.extensions.http.polly 在core中的使用 方式一 先配置再執行 注意 執行 executeasync 方法,異常會丟擲 方式二 邊配置邊執行 result await policy handle ex ex.code 4...