订阅与发布时指某个生产者向某个Topic发送消息,消息的订阅是指某个消费者关注了某个topic中带有某些tag的消息,进而从该topic消费数据。
消息的集合Topic
Topic是订阅主题,RocketMQ中有多个Topic,但每一条消息只能属于一个Topic,所以Topic是消息订阅的基本单位,topic中每一条消息的id都是唯一的。
标签(tag)
为消息设置的标志,用于同一topoc下区分不同类型的消息。来自同一业务单元的消息,可以根据不同业务目的在同一主题下设置不同标签,也可以根据不同的tag,编写不同的业务逻辑。
Broker Server
负责接收生产者消息并对其进行存储以及将消息下发至订阅Topic对应的消费者。
一类消息在消费时需要保持生产的顺序才有意义(订单创建、订单支付、订单完成),同时订单时可以保持并行消费,RocketMQ可以保持严格的消息有序。