发送方相关信息

message消息

• 事务消息 — XA二阶段提交

• 半事务消息 — 完成第一阶段提交，消费者不可见

• 消息回查 — 没有经过二阶段确认

• 延迟消息 — 延迟消息，18level

• 消息过滤 — 消费特定消息

topic主题

• topic — 一类消息集合，区分不同业务场景

• queue — 主题由一个或者多个队列组成，消息发往某个组题会进行队列选择，扩展发送和消费的性能，增加队列提升消费性能，消费者数量不能大于队列数量

• offset — 消息增加后分配的队列偏移量

消费方相关信息

• 消费者组 — 订阅组题消费，可以订阅多个主题。一个消费者组包含多个消费者，消费者可以是同一个进程中的多个线程，多个消费者组进程可以部署在多个节点

• 广播模式消费 — 一个主题的消息会被订阅的相关消费者组的所有消费者收到

• 集群模式消费 — 同一个消费者组内的所有消费者只能订阅一部分主题消息，一条消息只会被消费者组的一个消费者消费

• 消费位移 — 消费者组记录消费位置

• 并发消费 — 同一队列消息多线程消息，不能保证消息顺序

• 顺序消费

• 消息回溯 — 按时间顺序重新消费

消费模型

组件

• Name Server — 路由注册发现，无状态集群部署，最终一致性

• Broker — 消息存储 Master读写消息， Slave读取消息， 与Name Server 维持keepalive,30s一次心跳

• 生产者和消费者 — 组成集群，与Name Server维持keepalive，30s一次心跳，

• 与Broker维持keepalive，30s一次心跳