搭建RocketMQ
安装步骤 https://www.imooc.com/article/290089
前往http://rocketmg.apache.org/release notes/release-notes-4.51/，下载 Binary 文件即可。

搭建RocketMQ控制台
https://www.imooc.com/article/290092

访问RocketMQ首页

RocketMQ的术语和概念

RocketMQ开发者指南
https://git.imooc.com/coding-358/rocketmq-dev-guide
服务引入RocketMQ生产者
加依赖

写配置

写代码
注入 private final RocketMQTemplate rocketMQTemplate;

启动后，访问。再看RocketMQ控制台


生产者模型

服务引入RocketMQ消费者
配置同上，上代码

消费者模型

消息实现分布式事务（发送半消息，就是需要二次确认）

半消息和消息回查

分布式事务消息的三种状态（半消息不属于消息事务状态）

Spring Cloud Stream
用于构建消息驱动的微服务的框架

Spring Cloud Stream编程模型

微服务集成了Stream，Stream的Destination Binder创建了两个Binding，左边的Binding连接Rabbit MQ右边的Binding连接Kafka,左边的Binding从Rabbit MQ消费消息，然后通过中间这段代码处理，把处理结果输送到Kafka里面。


Spring Cloud Stream可以进行消息的生产、消费、监控、异常处理、分布式事务。
Spring Cloud Stream知识点盘点和总结，包括:
Stream注解
Spring Integration(Spring Cloud Stream的底层)注解
Spring Messaging(Spring消息编程模型)注解
Spring Cloud Stream APl