石頭智能洗地機A10 Plus體驗：雙向自清潔治好了我的懶癌
一、前言和介紹專為家庭請假懶人而生的石頭科技在近日又帶來了自己的全新旗艦新品，石頭智能洗地機A10 Plus。從這個產品名上就不難看出，這次石頭推出的并不是常見的掃地機器
我們知道RocketMQ主要分為消息 生產、存儲（消息堆積）、消費 三大塊領域。
那接下來，我們白話一下，RocketMQ是如何發送消息的，揭秘消息生產全過程。
注意，如果白話中不小心提到相關代碼配置與類名，請參考RocketMQ 4.9.4版本
RocketMQ生產消息時，支持多種「消息類型」：
SendResult send(final Message msg);SendResult send(final Message msg, final MessageQueueSelector selector, final Object arg);SendResult send(final Message msg, final MessageQueue mq);上面列舉的三種send方法，都是以同步發送模式為例。定時/延遲消息從發送方式角度來說，不算一種獨立的消息類型。
一般我們要發送一條消息給RocketMQ，需要創建這樣一個消息體。
Message msg = new Message( "TestTopic", "Hello World".getBytes() );在這個消息體里面，我們只單純指定了要發送的Topic名字，以及要發送的消息內容。
那么，RocketMQ-client怎么知道這條消息要發送到RocketMQ集群中的哪一個broker上呢？
這里需要了解下RocketMQ中Topic的「路由注冊與發現機制」。
RocketMQ基本架構
Topic 路由注冊與發現：
Topic路由信息
Topic的路由信息，包括了Topic的 隊列queue和broker的映射關系 ，那么如何利用這個Topic的路由信息呢？
我們需要根據前面的不同「消息類型」進行分別討論：
根據消息類型獲取到目標隊列queue后，就可以根據Topic路由信息發送消息到指定broker上了。
從發送模式角度來說，RocketMQ有三種「消息發送模式」：
SendResult send(final Message msg);void send(final Message msg, final SendCallback sendCallback);void sendOneway(final Message msg);上面列舉的三種send方法，都是以「普通消息」為例。
「消息類型」 和 「消息發送模式」 是 N*M 的關系，所以聰明的你一定已經想到了，存在9種不同組合（不包括事物消息），RocketMQ也是在接口中定義了9種不同方法。
前面介紹了三種「消息發送模式」，其中「單向發送」屬于不可靠發送，我們無法知道是否發送成功。
而「同步發送」和「異步發送」都是可靠發送，我們能夠獲取發送狀態，知道是否成功。
在「同步發送」中，我們可以根據SendResult中的sendStatus屬性判斷是否發送成功。
SendResult類屬性
在「異步發送」中，我們可以自定義實現SendCallback的onSuccess()方法和onException()方法，來判斷消息是否發送成功。
SendCallback接口定義
如果消息發送失敗了，RocketMQ-client默認有重試機制，以確保消息的高可用性。
前面提到，生產者每30秒獲取一次主題的路由信息，所以即使某個 Broker 宕機，消息發送者可能無法立即察覺到它的宕機狀態。
但是，當消息發送者向某個 Broker 發送消息后，如果返回異常，生產者會在接下來的一段時間內（例如5分鐘）避免再次選擇該 Broker 上的隊列來發送消息。這樣做的目的是規避可能發生故障的 Broker。
當然了，用戶也能根據返回的異常，自己定義業務重試、補償機制。
需要注意的是，不同「消息類型」和「消息發送模式」的RocketMQ-client默認重試機制不同。
消息類型：
注意：有序消息異常時RocketMQ-client都是默認不重試
消息發送模式：
注意：單向發送模式異常時RocketMQ-client默認不重試
本文鏈接：http://m.rrqrq.com/showinfo-26-144-0.html三分鐘白話RocketMQ系列—— 如何發送消息
聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
上一篇： 使用Webdriver-manager解決瀏覽器與驅動不匹配所帶來自動化無法執行的問題
下一篇： 從零到英雄：高并發與性能優化的神奇之旅
Copyright ? 2016-2023 天津谷騏科技有限公司 版權所有 sitemap.xml
違法及侵權請聯系：2376512515@qq.com 津ICP備18001702號
津公網安備 12010102000574號