消息队列存储消息数据的 MySQL 表

存储 topic 信息的表 topic_info

id 自增 主键，唯一索引

topic_name

full_flag 每个 topic 绑定的消费者数，到一定数量后就不可以绑定了

create_time

update_time

update_by 更新人的 id

create_by

del_flg 该条数据是否被删除

存储消费者和 topic 关系的 rlt_topic_consumer，topici_id 和 consumer_id 创建联合索引

id 自增，主键，唯一索引

topic_id

consume_id 连接到某一个 topic 的消费者 id

max_send_cnt 发送失败最大重试次数，默认 0，不重试

create_time

update_time

update_by

create_by

del_flg 该条数据是否被删除

存储消息本身的表，根据 topic_name 区分，一个 topic 出问题不影响其他 topic, msg_{topic_name}

id 自增，主键，唯一索引

topic_id

msg 消息体

create_time

update_time

update_by

create_by

del_flg 该条数据是否被删除

存储消费者消费结果的表 msg_consumer_result，（msg_id，consumer_id）创建联合索引，根据 msg_id 快速查询消费情况

id 自增，主键，唯一索引

msg_id

consumer_id

consumer_status

send_status 发生失败重试，达到一定次数就不在重试

create_time

update_time

update_by

create_by

del_flg 该条数据是否被删除