消息队列 MySQL 存储设计
消息表:
id: bigint,消息 ID,自增长
msg_type: varchar(64),消息类型
message: text,消息内容
publisher: varchar(64),消息发布者唯一标识
publish_time: timestamp,消息发布时间
id:作为主键
publisher+publish_time:创建索引,方便发布者按时间查询自己发布了哪些消息
当消息增多时,可按消息类型或消息发布时间分区
消费表:
msg_id: bigint,消息 UUID,取消息表的 id 字段
consumer: varchar(64),消息消费者唯一标识
consume_time: timestamp,消息消费时间
consumer+ consume_time:作为主键,方便消费者按时间查询自己消费了哪些消息
msg_id: 创建索引,方便看一条消息被哪些消费者消费了
评论