RocketMQ消息支持的模式-消息异步发送
生活随笔
收集整理的這篇文章主要介紹了
RocketMQ消息支持的模式-消息异步发送
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
異步發送是指發送方發出數據后,不等接收方發回響應,接著發送下個數據包的通訊方式。 MQ 的異步發送,需要用戶實現異步發送回調接口(SendCallback)。消息發送方在發送了一條消息后,不需要等待服務器響應即可返回,進行第二條消息發送。發送方通過回調接口接收服務器響應,并對響應結果進行處理?
異步代碼改造
producer.send(msg, new SendCallback() {?@Override?public void onSuccess(SendResult sendResult) {?System.out.printf("%s%n",sendResult);?}?@Override?public void onException(Throwable throwable) {?throwable.printStackTrace();?}? });?
總結
以上是生活随笔為你收集整理的RocketMQ消息支持的模式-消息异步发送的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: RocketMQ消息支持的模式-消息同步
- 下一篇: RocketMQ消息支持的模式-Orde