上一篇 <<<RocketMQ、RabbitMQ和Kafka的对比
下一篇 >>>RocketMQ保证顺序消费demo
消息队列rocketmq是Apache旗下的开源项目（原是Alibaba开源的项目），当springboot盛行后，Apache团队开源了rocketmq-spring来帮助我们在springboot中快速集成rocketmq，只需引入rocketmq-spring-boot-starter即可。
rocketmq-spring不仅实现了自动配置功能，最主要还是封装了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:
#生产者必须要有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示例之发布订阅模式
<<<Rabbitmq示例之路由模式Routing
<<<Rabbitmq示例之通配符模式Topics
<<<Rabbitmq示例之RPC模式
<<<Rabbitmq队列模式总结
<<<Rabbitmq如何保证消息不丢失
<<<Springboot利用AmqpTemplate整合Rabbitmq
<<<Rabbitmq如何保证幂等性
<<<Rabbitmq的重试策略
<<<Rabbitmq通过死信队列实现过期监听
<<<Rabbitmq解决分布式事务思路
<<<Rabbitmq解决分布式事务demo
<<<Rabbitmq环境安装
<<<Kafka中的专业术语都有哪些
<<<Kafka的设计原理介绍
<<<Kafka集群如何实现相互感知
<<<Kafka如何实现分区及指定分区消费
<<<Kafka如何保证消息顺序消费
<<<Kafka如何保证高吞吐量
<<<Kafka集群环境搭建
<<<RocketMQ架构原理
<<<RocketMQ、RabbitMQ和Kafka的对比
<<<RocketMQ保证顺序消费demo
<<<RocketMQ如何动态扩容和缩容
<<<RocketMQ如何解决分布式事务
<<<RocketMQ单机版本安装
<<<RocketMQ集群环境程序启用相关知识点
<<<RocketMQ单机做主备实操
<<<RocketMQ所有配置说明
