存储消息队列的 mysql 数据表

每个消息队列对应一个 MySQL 表。

• 表名

数据表以消息队列名命名。

• 字段

1. ID uint32 唯一标识 主键 数据库自增

2. 生产者标识 string 当前消息的生产者

3. 消费者标识 string 当前消息的消费者

4. 消息的内容 string

5. 消息创建时间戳 int(32) unsigned

6. 消息读取时间戳 int(32) unsigned 若消息未被读取则为 0

• 索引

1. id

主键

2. 生产者标示

过滤出某个生产者产生的所有消息

3. 消费者标示

过滤出某个生产者消费的所有消息

4. 创建时间戳

过滤队列里某个时间之后创建的消息

5. 读取时间戳

过滤队列里某个时间之后尚未处理的消息