消息队列存储 -mysql 表
设计
为每个 topic 创建一张表。
原因: 避免各个 topic 相互影响
在创建 topic 时,创建如下表,存储此 topic 的消息
表名: topic_xxx
id: 自增,主键索引
msg_id: 唯一索引
status: 索引:消息状态(未消费,已消费)方便过滤查询
create_time:创建时间
update_time:消费时间
为每个 topic 创建一张表。
原因: 避免各个 topic 相互影响
在创建 topic 时,创建如下表,存储此 topic 的消息
表名: topic_xxx
id: 自增,主键索引
msg_id: 唯一索引
status: 索引:消息状态(未消费,已消费)方便过滤查询
create_time:创建时间
update_time:消费时间
评论