一、RocketMQ 安裝
由于我們SpringCloud Alibaba 選擇的版本是 2.2.6.RELEASE ，所以對應 RocketMQ 版本就暫定 4.4.0
Docker 安裝 RocketMQ 步驟（記得指定版本）：傳送門
二、引入 RocketMQ
2.1、創建子模塊專案：傳送門
2.2、pom 檔案 添加參考
<!-- RocketMQ -->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
</dependency>2.3、application.yml 添加配置
rocketmq:
name-server: **.**.**.**:****
producer:
group: wangjingGroup2.4、新建 topic
2.5、發送訊息代碼
package com.wangjing.servicenacos.controller;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/test")
public class TestController {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@RequestMapping("/test")
public String test() {
rocketMQTemplate.convertAndSend("wangjing-topic","哈哈哈");
return "測驗service-nacos，埠：8801";
}
}
2.6、監聽訊息代碼
package com.wangjing.servicenacos.listener;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;
@Component
@RocketMQMessageListener(
topic = "wangjing-topic", //topic：和消費者發送的topic相同
consumerGroup = "wjConsumerGroup") //group：不用和生產者group相同
public class MqConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String message) {
System.out.println("消費者接受到的訊息內容是：" + message);
}
}
2.7、啟動專案，訪問 http://localhost:8801/test/test 測驗
注：以上內容僅提供參考和交流，請勿用于商業用途，如有侵權聯系本人洗掉！
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/433246.html
標籤：其他