Skip to content

Commit 0f085e4

Browse files
committed
Update RM
1 parent 082a12a commit 0f085e4

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

doc/XXL-MQ官方文档.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -644,20 +644,20 @@ transaction | 事务开关,开启消息事务性保证只会成功执行一次
644644
- AccessToken:能力
645645
- AppName:
646646
- 能力(注册、节点动态更新;用于Topic数据分片;);【AppName维度,在线实例信息:实例总数 = instanceNum;序号 = instanceIndex;partitionScope = 3~5;】
647-
- 模型:Instance注册:字段(appname + uuid + register_heartbeat);app维度20s汇总一次,同步至app表;时钟打平,从0开始每20s一次;
647+
- 模型:Instance注册:字段(appname + uuid + register_heartbeat);app维度20s汇总一次,同步至app表;时钟打平,从0开始每20s一次; 【TODO - 01:注册Helper(App+Topic)逻辑;】
648648
- Topic:
649-
- 能力(定义管理 + 查看注册节点 / 节点分片分配情况;);【Topic】【名称】【负责人】【告警邮箱】【状态】【存储策略】【partition数量】【优先级】【重试次数】【重试间隔策略】【归档策略】
649+
- 能力(定义管理 + 查看注册节点 / 节点分片分配情况;);【Topic】【名称】【负责人】【告警邮箱】【状态】【存储策略】【partition数量】【优先级】【重试次数】【重试间隔策略】【归档策略】 【TODO - 02:Topic管理】
650650
- 模型:topic + store + partitionCount + level + author + alarm_email + timeout
651651
- Message:
652-
- 能力:查看 + 管理(增 + 该状态 + 归档);消息队列,物理消息队列;【10min一次,自动数据归档;】
652+
- 能力:查看 + 管理(增 + 该状态 + 归档);消息队列,物理消息队列;【10min一次,自动数据归档;】 【TODO - 03:消息管理能力;更新 + 归档】
653653
- 模型:msgid + msgbody + topic + group + partitionId + status + retryCount + intervalTime + effectTime + consume_log;
654654
- 属性:
655655
- topic:关联 消息主题;
656656
- group:数据广播;【topic向上;广播;】
657657
- uuid序号:并行处理
658658
- partitionKey:分区Key进行hashcode取模,会转成分区ID,限制 [0-10000] 之内;结合Consumer在线列表,匹配消费分片范围,实现并行分片消费消息;【topic向下;并行;同sId保障顺序;根据消费者 partition 信息计算 范围;】
659659
- MessageArchive:
660-
- 能力:定期讲终止态消息,同步归档,清理原始表;
660+
- 能力:定期讲终止态消息,同步归档,清理原始表; 【TODO - 04:消息归档数据查看;】
661661
- 模型:同 message;
662662
- Registry:
663663
- 能力:提供 Consumer 注册、动态发现能力;消息分片消费时使用;

0 commit comments

Comments
 (0)