先理解 消息 ,消息队列 这两个概念,才能更好的理解什么是 消息中间件
消息(message):
指在服务之间传送的数据。可以是简单的文本消息,也可以使复杂包含嵌入对象的消息
消息队列(message queue):
指用来存放消息的队列,一般采用先见先出的队列方式
消息中间件:
指管理消息队列的一个服务。
队列的一端接收生产者的消息,另一端去取出消息供消费者消费。
其中 消息生产者 只管把 消息 发送到 消息中间件,而不用管谁来取。消息消费者 只管从 消息中间件 取出消息,而不用管是谁发布的。这样将 生产者 和 消费者 解耦开来,彼此都不用知道对方的存在,降低了彼此的业务复杂性。
为什么要使用消息中间件?
有以下几点原因
1.业务解耦;2.同步变异步;3.流量消锋;
4.消息的顺序性;5.消息的可靠性;6.降低分布式服务的复杂性
示例:
假设有以下这样的业务场景
如果采用传统模式,业务逻辑如下图:
整个业务逻辑均要走一篇,等待的时间太长。
实际上短信,email这些业务并不会影响交易的状态,可以在支付成功后做异步处理,降低等待时间。
这就得借助 消息中间件 来时间,加入 消息中间件 后的架构如下图示:
如上图调整架构,这样当订单支付成功后,发一个消息到 消息中间件,通知 积分,推送app,短信,email 这些服务去完成自己身的服务。
通过消息中间件,将部分同步服务转换为异步服务,降低了交易耗时,提高了用户体验。
至于流量削锋,比如线上的双十一秒杀,或者春节火车票抢购,会有大量的请求同时进来。这是服务承受的压力是平时的几十甚至上百倍,超过系统的最大出力能力,如果不能很好的处理这些流量,容易造成数据库的崩溃,导致服务不可用。
而如果加入 消息中间件 后,则能较好的处理这问题,方法如下:
将流量统一发送到 消息中间件 中,业务系统根据自身的处理能力,异步均速处理消息,这样可以防止流量洪峰造成系统服务崩溃
整理后的流量图如上所示