通过消息队列可以让数据在多个系统更加之间进行流通。数据的产生方不需要关心谁来使用数据,只需要将数据发送到消息队列,数据使用方直接在消息队列中直接获取数据即可。
RocketMQ中的几个重要角色
RocketMQ中涉及到的几个重要的角色:
NameServer:相当于微服务中的注册中心,提供broker的服务发现和注册功能,各个节点之间无相互通信,一旦broker节点启动,将会主动上报信息给NameServer。
producer:消息生产者,发送消息给broker;拥有同一个的groupId的producer为一个集群
broker:消息暂存和传输,接收producer发送的消息,采用push/pull模式传递给consumer
consumer:消息消费者,消费broker传递的消息,拥有同一个groupId的consumer为一个集群
以上四个是RocketMQ对外四种角色,另外内部还有一些重要角色,如下:
Topic:消息主题,通过Topic对不同的业务消息进行分类。
Tag:消息标签,用来进一步区分某个Topic下的消息分类,消息从生产者发出即带上的属性。
Message Queue:队列,相当于Topic的分区,用于并行发送和消费消息,一个Topic中对应多个Queue
关于Topic和Tag的区别:比如电商中的下单、支付流程,为了提高并发量通常都会使用消息队列进行异步处理,那么可以定义消息的Topic为Topic_order,但是其中还涉及了创建订单、付款、完成订单这三类消息,如何去区分?
总结:
消息队列中间件作分布式系统的重要组成部分,已广泛用于电商,支付等高并发应用场景。