• 我们为什么要用消息队列中间件?
  • 发布于 2个月前
  • 809 热度
    0 评论
  • 遥歌
  • 2 粉丝 55 篇博客
  •   
消息队列是一种“先进先出”的数据结构,其应用场景主要包含以下3个方面:
1、应用解耦
系统的耦合性越高,容错性就越低。以电商应用为例,用户创建订单后,如果耦合调用库存系统、物流系统、支付系统,任何一个子系统出了故障或者因为升级等原因暂时不可用,都会造成下单操作异常,影响用户使用体验。

使用消息队列解耦合,系统的耦合性就会提高了。比如物流系统发生故障,需要几分钟才能来修复,在这段时间内,物流系统要处理的数据被缓存到消息队列中,用户的下单操作正常完成。当物流系统回复后,补充处理存在消息队列中的订单消息即可,终端系统感知不到物流系统发生过几分钟故障。

2、流量削峰
应用系统如果遇到系统请求流量的瞬间猛增,有可能会将系统压垮。有了消息队列可以将大量请求缓存起来,分散到很长一段时间处理,这样可以大大提到系统的稳定性和用户体验。

一般情况,为了保证系统的稳定性,如果系统负载超过阈值,就会阻止用户请求,这会影响用户体验,而如果使用消息队列将请求缓存起来,等待系统处理完毕后通知用户下单完毕,这样总不能下单体验要好。

处于经济考量目的:
业务系统正常时段的QPS如果是1000,流量最高峰是10000,为了应对流量高峰配置高性能的服务器显然不划算,这时可以使用消息队列对峰值流量削峰

3、数据分发

通过消息队列可以让数据在多个系统更加之间进行流通。数据的产生方不需要关心谁来使用数据,只需要将数据发送到消息队列,数据使用方直接在消息队列中直接获取数据即可。


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,但是其中还涉及了创建订单、付款、完成订单这三类消息,如何去区分?

总结:

消息队列中间件作分布式系统的重要组成部分,已广泛用于电商,支付等高并发应用场景。

用户评论