## RocketMQ簡介 RocketMQ是阿里巴巴開源的訊息中介軟體。目前已經貢獻給Apache軟體基金會，成為Apache的頂級專案。 ### rocketMQ基本概念  #### 1. Producer Group 生產者組：是一類生產者的集合，通常傳送同一類訊息並且傳送邏輯一致。 #### 2. Producer 生產者：負責傳送訊息，有三種訊息傳送模式。 - 同步傳送：收到確認後再發送下一條訊息 - 非同步傳送：傳送後，不等待確認繼續傳送下一條 - 單向傳送：只負責傳送訊息，無法確認並且沒有回撥，適合收集日誌 #### 3. Consumer Group 消費者組：是一類消費者的集合，通常消費同一類訊息並且消費邏輯一致。 #### 4. Consumer 訊息者：負責消費訊息，有兩種消費模式 - 拉取型消費：主動從訊息伺服器拉取資訊，只要批量拉取到訊息，使用者應用就會啟動消費過程 - 推送型消費：實際上也是拉取訊息，只不過是將拉取邏輯進行了封裝，將訊息到達時執行的回撥介面留給使用者來實現 #### 5. Broker 訊息伺服器：儲存訊息 #### 6. NameServer 作用和zookeeper類似，用來儲存broker相關元素，並給producer和consumer查詢broker訊息，Producer 在傳送訊息前會根據 Topic 到 NameServer 獲取到 Broker 的路由資訊，Consumer 也會定時獲取 Topic 的路由資訊。 #### 7. Topic 訊息主題 #### 8. Tag 標籤，Topic的二級分類，也可以理解為訊息佇列，主題被劃分為一個或多個子主題，即訊息佇列。一個 Topic 下可以設定多個訊息佇列，傳送訊息時執行該訊息的 Topic ，RocketMQ 會輪詢該 Topic 下的所有佇列將訊息發出去。 ## Spring Boot整合Rocketmq ### 1. 引入依賴 ```xml ``` ### 2. 配置rocketmq資訊 ```yml rocketmq: name-server: 127.0.0.1:9876 producer: group: my-producer-group ``` ### 3. 構建生產者 ```java @RestController public class Producer { @Autowired private RocketMQTemplate rocketMQTemplate; @GetMapping("send") public void send(){ rocketMQTemplate.convertAndSend("first-topic","你好,Java旅途"); } } ``` ### 4. 構建消費者 ```java @Component @RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group") @Slf4j public class Consumer implements RocketMQ