https://github.com/alibaba/spring-cloud-alibaba/wiki/版本说明#组件版本关系 1 组件介绍1.1 Message Queue RocketMQ支持多master的架构。思考一个问题：当有多个master的时候，发往Topic的多条消息会在多个master的Broker上存储。那么，发往某一个Topic的多条消息，是不是在所有的Broker上存储完

1 Producer保证消息高可靠（1）尽量采用同步或者异步的方式发送消息，最好不要使用oneway的方式发送，也就是说当把消息发到broker之后，一定要得到broker的响应 （2）建立数据库消息发送表，防止消息还没来得及发送当前系统就宕机了，这样等系统恢复的时候，可以根据消息发送表中的记录决定是否需要重新发送，发送成功之后要将对应表中的记录删除或者更新成发送成功状态，可以避免重复发送消息

1 NameServer1.1 NameServer启动流程 1.2 NameServer处理Broker注册信息 2 Broker2.1 Broker启动与注册信息 2.2 Broker消息的存储结构 2.2.1 CommitLog默认大小是1G，可以通过MessageStoreConfig中的mappedFileSizeCommitLog属性查看。 CommitLog是消息存储的真正物理文件，

https://github.com/alibaba/spring-cloud-alibaba/wiki/版本说明#组件版本关系 1 单机nameserver默认端口：9876 rocketmq默认端口：10911 路径：/usr/local/soft 1.1 基于Binary搭建1.1.1 下载官网：http://rocketmq.apache.org/ 12cd /usr/local/soft

1 订单延迟关闭1.1 业务场景假设有一个业务场景：超过30分钟未付款的订单自动关闭，这个功能怎么做？ 思路：发一条跟订单相关的消息，30分钟后被消费，在消费者的代码中查询订单数据，如果支付状态是未付款，就关闭订单。 RabbitMQ本身不支持延迟投递，总的来说有2种实现方案： ​ 1、先存储到数据库，用定时任务扫描 ​ 2、利用RabbitMQ的死信队列（Dead Letter Qu

1 集群配置-docker1）拉取RabbitMQ镜像（带managment） 1docker pull rabbitmq:3.7.17-management 2）创建docker网络（让容器可以和主机通信） 1docker network create rabbitmqnet 3）创建三个容器，端口分别是 5673 5674 5675 ，管理端口是 15673 15674 15675 123

1 生产者原理源码地址：https://github.com/apache/kafka/tree/trunk/clients 1.1 生产者发送消息消息发送的整体流程。生产端主要由两个线程协调运行。这两条线程分别为main线程和sender线程（发送线程）。 1Producer<String, String> producer = new KafkaProducer<>(

官网：http://www.rabbitmq.com/getstarted.html 1 安装与配置由于RabbitMQ是用Erlang语言编写的，必须要先安装Erlang环境。 Erlang和RabbitMQ版本有对应关系：https://www.rabbitmq.com/which-erlang.html 1.1 window 下载安装Erlang 23.1：https://www.erlan

1 Java API 引入依赖 1234<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId></dependency> topic要先提前创建，或者配置允许自动创建topic。 1auto.cre

官网：http://kafka.apache.org/documentation/ Kafka 是使用 Scala 编写具有高水平扩展和高吞吐量的分布式消息系统。 Kafka 对消息保存时根据 Topic 进行归类，发送消息者成为 Producer ，消息接受者成为 Consumer ，此外 kafka 集群有多个 kafka 实例组成，每个实例(server)称为 broker。 无论是 Kaf