spring-boot-route（十五）整合RocketMQ

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. 引入依賴

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-spring-boot-starter</artifactId>
    <version>2.1.0</version>
</dependency>

2. 配置rocketmq信息

rocketmq:
  name-server: 127.0.0.1:9876
  producer:
    group: my-producer-group

3. 構建生產者

@RestController
public class Producer {

    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    @GetMapping("send")
    public void send(){

        rocketMQTemplate.convertAndSend("first-topic","你好,Java旅途");
    }
}

4. 構建消費者

@Component
@RocketMQMessageListener(topic = "first-topic",consumerGroup = "my-consumer-group")
@Slf4j
public class Consumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String message) {
        log.info("我收到消息了！消息內容爲："+message);
    }
}

emmm，消息隊列的內容就暫時告一段落了，文章中只是演示了最簡單的收發消息，在實際應用中須要考慮的問題遠比這要多。

---

本文示例代碼已上傳至github，點個star支持一下！

Spring Boot系列教程目錄

spring-boot-route（一）Controller接收參數的幾種方式

spring-boot-route（二）讀取配置文件的幾種方式

spring-boot-route（三）實現多文件上傳

spring-boot-route（四）全局異常處理

spring-boot-route（五）整合swagger生成接口文檔

spring-boot-route（六）整合JApiDocs生成接口文檔

spring-boot-route（七）整合jdbcTemplate操做數據庫

spring-boot-route（八）整合mybatis操做數據庫

spring-boot-route（九）整合JPA操做數據庫

spring-boot-route（十）多數據源切換

spring-boot-route（十一）數據庫配置信息加密

spring-boot-route（十二）整合redis作爲緩存

spring-boot-route（十三）整合RabbitMQ

spring-boot-route（十四）整合Kafka

spring-boot-route（十五）整合RocketMQ

spring-boot-route（十六）使用logback生產日誌文件

spring-boot-route（十七）使用aop記錄操做日誌

spring-boot-route（十八）spring-boot-adtuator監控應用

spring-boot-route（十九）spring-boot-admin監控服務

spring-boot-route（二十）Spring Task實現簡單定時任務

spring-boot-route（二十一）quartz實現動態定時任務

spring-boot-route（二十二）實現郵件發送功能

spring-boot-route（二十三）開發微信公衆號

這個系列的文章都是工做中頻繁用到的知識，學完這個系列，應付平常開發綽綽有餘。若是還想了解其餘內容，掃面下方二維碼告訴我，我會進一步完善這個系列的文章！