。

基于java语言实现#xff0c;十万级数据吞吐量#xff0c;ms级处理速度#xff0c;分布式架构#xff0c;功能强大#xff0c;扩展性强。

官方…RocketMq是阿里出品基于MetaQ的开源中间件已捐赠给Apache基金会并成为Apache的顶级项目。

基于java语言实现十万级数据吞吐量ms级处理速度分布式架构功能强大扩展性强。

官方文档

建议将不同业务类型的数据拆分到不同的主题中管理通过主题实现存储的隔离性和订阅隔离性。

1.2

的消息本身是匿名无身份的同一分类的消息使用相同的主题来做身份识别和权限关理。

2.模型关系

的顶层存储所有消息资源的定义都在主题内部完成但主题是一个逻辑概念并不是实际的消息容器。

主题内部由多个队列组成消息的存储和水平扩展能力最终是由队列实现的并且针对主题的所有约束和属性设置最终也是通过主题内部的队列来实现。

3.内部属性

定义队列作为主题的组成单元是消息存储的实际容器一个主题内包含一个或多个队列消息实际存储在主题的各队列内。

3.3

从5.0版本开始支持强制校验消息类型即每个主题只允许发送一种消息类型的消息这样可以更好的运维和管理生产系统避免混乱。

为保证向下兼容4.x版本行为强制校验功能默认关闭推荐通过服务端参数

重试主题这里的topic是消息发送失败时候系统为之创建的主题。

系统主题这里的topic是Brocker启动后就自动生成的主题。

5.生产中使用建议

主题属于顶层资源和容器拥有独立的权限管理、可观测性指标采集和监控等能力创建和管理主题会占用一定的系统资源。

因此生产环境需要严格管理主题资源请勿随意进行增、删、改、查操作。

5.2

如果想调整读写队列的数量首先减少写队列数量再减少读队列的数量确保已读完。

假设创建了4个写队列2个读队列则有两个队列的消息无法被消费反之则存在两个空闲的读队列。

RocketMq不直接将读写队列设置相同直接目的是为了安全的收缩队列数量间接的为了安全的扩容。

5.2.2

主题的设计原则为通过主题隔离业务不同业务逻辑的消息建议使用不同的主题。

同一业务逻辑消息的类型都相同因此对于指定主题应该只收发同一种类型的消息。