上一篇 <<<RocketMQ脓豪、RabbitMQ和Kafka的對比
下一篇 >>>RocketMQ保證順序消費demo
消息隊列rocketmq是Apache旗下的開源項目（原是Alibaba開源的項目）油狂，當springboot盛行后讳推，Apache團隊開源了rocketmq-spring來幫助我們在springboot中快速集成rocketmq汉柒，只需引入rocketmq-spring-boot-starter即可。
rocketmq-spring不僅實現(xiàn)了自動配置功能，最主要還是封裝了spring-message風格的rocketmq操作，使得我們在spring中昼蛀，能夠像使用rabbitmq一樣方便快捷的使用rocketmq宴猾。
1.加入依賴包
<dependencies>
<!-- springboot-web組件 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.0.3</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
2.配置修改
rocketmq:
#只要配置nameserver即可
name-server: 10.211.55.16:9876;
producer:
#生產(chǎn)者必須要有group，要不然啟動不了
group: tt1226
#超時時間設置長一點叼旋，要不然會報錯sendDefaultImpl call timeout
send-message-timeout: 50000
3.核心代碼
@RestController
public class ProducerController {
@Autowired
private RocketMQTemplate rocketMQTemplate;
@RequestMapping("/sendMsg")
public String sendMsg() {
OrderEntity orderEntity = new OrderEntity("123456","螞蟻課堂會員");
rocketMQTemplate.convertAndSend("myTest",JSON.toJSONString(orderEntity));
return "success";
}
}
@Service
@RocketMQMessageListener(topic = "myTest", consumerGroup = "myTest")
public class OrdeConsumer implements RocketMQListener<String> {
@Override
public void onMessage(String o) {
System.out.println("o:" + JSON.toJSONString(o));
}
}
推薦閱讀：
<<<消息中間件的核心思想
<<<消息中間件常見問題匯總
<<<基于Netty簡單手寫消息中間件思路
<<<消息隊列常用名詞與中間件對比
<<<Rabbitmq基礎知識
<<<Rabbitmq示例之點對點簡單隊列
<<<Rabbitmq示例之工作(公平)隊列
<<<Rabbitmq示例之發(fā)布訂閱模式
<<<Rabbitmq示例之路由模式Routing
<<<Rabbitmq示例之通配符模式Topics
<<<Rabbitmq示例之RPC模式
<<<Rabbitmq隊列模式總結
<<<Rabbitmq如何保證消息不丟失
<<<Springboot利用AmqpTemplate整合Rabbitmq
<<<Rabbitmq如何保證冪等性
<<<Rabbitmq的重試策略
<<<Rabbitmq通過死信隊列實現(xiàn)過期監(jiān)聽
<<<Rabbitmq解決分布式事務思路
<<<Rabbitmq解決分布式事務demo
<<<Rabbitmq環(huán)境安裝
<<<Kafka中的專業(yè)術語都有哪些
<<<Kafka的設計原理介紹
<<<Kafka集群如何實現(xiàn)相互感知
<<<Kafka如何實現(xiàn)分區(qū)及指定分區(qū)消費
<<<Kafka如何保證消息順序消費
<<<Kafka如何保證高吞吐量
<<<Kafka集群環(huán)境搭建
<<<RocketMQ架構原理
<<<RocketMQ仇哆、RabbitMQ和Kafka的對比
<<<RocketMQ保證順序消費demo
<<<RocketMQ如何動態(tài)擴容和縮容
<<<RocketMQ如何解決分布式事務
<<<RocketMQ單機版本安裝
<<<RocketMQ集群環(huán)境程序啟用相關知識點
<<<RocketMQ單機做主備實操
<<<RocketMQ所有配置說明
