最新回答 / 慕娘8336713
confirm是生產者將消息發送到交換機后的回調,ack是true,說明消息已經成功發送到交換機了; returnCallBack是交換機路由到隊列的回調,所以路由失敗跟ack沒關系; 解決方案: 路由失敗的時候,把當前消息保存下來(自己隨意,不丟就行),然后再針對這部分消息做補償;
最贊回答 / changfaaipiaorou
發送端有兩種配置,confirm模式和非confirm模式。如果處于非confirm模式下,消息由于Productor到broker的網絡波動導致失敗,無法感知和重試。如果發送端處于confirm模式下,發送的每一條消息,broker會回復一個confirm消息,來確認消息的到達保證HA。confirm模式下發送端的性能會有所下降
最新回答 / 己悅丶
@Input(StreamClient.input)和@Output(StreamClient.input)通道名不能一樣
已采納回答 / Gintoki3172619
看一下第二張圖的 #30 行,如果用 Map 接收的話應該用 @Headers 注解,而不是 @Header。另外有個小建議,你的類名里的 AreaRecieve 中的單詞是不是拼寫錯了。
2018-12-21
最新回答 / 0_空想神話_0
可通過注入實現。
@Bean Jackson2JsonMessageConverter?messageConverter()?{ ???return?new?Jackson2JsonMessageConverter(); }
2018-11-23