File tree Expand file tree Collapse file tree 1 file changed +14
-7
lines changed Expand file tree Collapse file tree 1 file changed +14
-7
lines changed Original file line number Diff line number Diff line change @@ -634,9 +634,9 @@ transaction | 事务开关,开启消息事务性保证只会成功执行一次
634
634
### Tmp
635
635
636
636
1、模型说明:
637
- - AppName:服务应用,一个应用包含多个 Consumer ;
638
- - instance:uuid ;
639
- - Topic:消息主题,逻辑消息队列 ;
637
+ - Topic:消息主题 ;
638
+ - 查看注册节点 ;
639
+ - 操作:状态 ;
640
640
- Message:消息队列,物理消息队列;msgid + msgbody + topic + group + shardingId + status + retryCount + effectTime;
641
641
- topic:关联 消息主题;
642
642
- group:
@@ -651,16 +651,23 @@ transaction | 事务开关,开启消息事务性保证只会成功执行一次
651
651
- 功能:直连Broker;发起消息生产;
652
652
- 性能:内存queue,批量异步推送;异常,写本地磁盘;(xxl-tool)
653
653
- 要点:
654
- - 并行消息:指定 topic + group(固定) + shardingid(随机生成 ),生产单条消息;借助 shardingid 分片消费;
655
- - 串行消息:指定 topic + group(固定) + shardingid(固定),生产单条消息;固定 shardingid 绑定固定节点消费;
656
- - 广播消息:指定 topic + group(uuid) + shardingid(任意 );根据在线 group 列表生产多条消息;
654
+ - 并行消息:指定 topic + group(固定) + shardingid(随机 ),生产单条消息;借助 shardingid 分片消费;
655
+ - 串行消息:指定 topic + group(固定) + shardingid(固定>0 ),生产单条消息;固定 shardingid 绑定固定节点消费;
656
+ - 广播消息:指定 topic + group(uuid) + shardingid(随机 );根据在线 group 列表生产多条消息;
657
657
- Consumer:
658
658
- 功能:查询消息,消费消息,回调消息;
659
659
- 性能:批量查询、批量回调;
660
660
- 要点:
661
661
- 注册:
662
- - 写:instanceUUID : topic + group + shardingId
662
+ - 写:instanceUUID : topic + group
663
+ - instance01
664
+ - topic01 / group01
665
+ - topic02 / group02
663
666
- 读:instanceIndex / instanceNum;
667
+ - topic01
668
+ - group01: 3/5
669
+ - topic02
670
+ - group02: 4/6
664
671
- 查询:分片查询:topic + group + 注册分片计算->消息分片范围;
665
672
- 属性:
666
673
- topic:绑定 Topic,只消费该topic的消息;
You can’t perform that action at this time.
0 commit comments