RocketMQ

6、Checke the state of LocalTransaction

同步

nameServer

Broker1主

Commit Send Msg

NameServer存放生产者、消费者、topic信息

1注册

5、Check backwhen the forth stepconfirmation is not received

4、Commit or Rollback

1、SendHlafMsg

span style=\"font-size: inherit;\

2、HlafMsgSend OK

5消费消息

RocketMQ与kafka的区别注册中心不同：kafka采用zookeeper；RocketMQ采用自己独立编写的NameServer为什么RocketMQ不采用zookeeper?1、因为zk选举必须满足过半机制才可以使用，而NameServer去中心化，只需要有一个NameServer在，整个注册中心环境就可以使用；2、自己编写注册中心可以快速实现扩展功能在kafka中Broker是物理概念，但是在RocketMQ中一个Broker等于多个master组合其次新增事务消息、顺序消息

事务消息

Broker1备

MQ Producer

控制台RocketMQ-console

https://my.oschina.net/buru1kan/blog/1814356git clone -b release-rocketmq-console-1.0.0 https://github.com/apache/rocketmq-externals.git导入项目到IDEAhttp://127.0.0.1:8080/rocketmq

3投递消息

Producer

MQ Subscriber

MQ Server

RocketMQ 背景是阿里巴巴 经历过双十一考验 、java语言编写 就是对kafka实现的升级版本1、支持事务消息（实现解决分布式事务问题）2、支持高并发顺序消息处理 采用内存队列+多线程处理3、消费者支持tag过滤 减少我们带宽传输RocketMQ关键核心名称：NameServer：类似eureka实现服务注册发现，生产者、消费者 topic信息都统一存放到我们的 NameServer上。去中心化，默认端口号为9876Broker：存储和转发消息 默认10911端口Producer 生产者Consumer 消费者主备 同步主节点的数据，当主宕机之后 可以从备变为主保证高可用；

Broker2备

3、ExecuteLocalTransaction

生产者1、发送同步消息 这种可靠性同步地发送方法使用的比较广泛，比如：重要的消息通知，短信通知2、发送异步消息 异步消息通常用在对响应时间敏感的业务场景，即发送端不能容忍长时间地等待broker的响应3、发送单向消息 这种方式主要用在不特别关心发送结果的场景，例如日志发送消费者1、默认负载均衡模式2、可以设置广播模式consumer.setMessageModel(MessageModel.BROADCASTING)顺序消息、延时消息、批量消息（每次发送不能超过4M）、过滤消息、事务消息

LocalTransaction

2获取Broker地址

Rollback Delete Msg

4获取Broker地址

7、Commit or Rollbackaccording to transaction status

Broker2主

Consumer