架构训练营模块 8

接收方采用拉的模式，每次来获取最新的数据，或从某一个时间点开始重新消费

发送方采用推的模式

• ts：时间戳，消息接收到的时间

• topic：队列名称

• msg：消息体，存储具体的消息

• 索引：对时间戳和队列名称添加索引，每次都需要获取最新数据，可以让客户端将上次拉取的时间戳带过来，此时就需要使用时间戳和 topic 进行过滤操作

• 分表：可以根据时间戳来分表，因为消息不会永久保留，过期的数据可以进行清理，如果某一个 topic 量非常大，可以单独将该 topic 提出来