网站架构中为何要用到消息队列

不少没有实际项目经验的小伙伴,对消息队列系统很是陌生,看着不少架构的介绍中,都提到消息队列。可是,不知道为何要用消息队列?什么是消息队列?常见的消息队列产品有哪些? php

经过阅读本文,帮你解开以上的疑惑。 java

1.为何要用消息队列?

假设一个老大,接到一个任务要处理完。在处理这个任务时,把这个任务分解为几个小任务,只要分别完成了这几个小任务,整个任务也就完成了。 web

作到某个小任务时,发现这个小任务须要花不少时间完成,并且这个小任务迟点完成也不影响整个任务的完成进度。因而,老大把这个小任务交个一个小弟去作,本身去接着完成其余的任务。 redis

在上面的例子中,老大就是后台系统,小弟就是消息队列系统,当后台系统发现完成某些小任务须要花不少时间,并且迟点完成也不影响整个任务的,就会把这些小任务交给消息队列系统。 后端

在实际的app后端中,发送邮件,发送短信,推送等这些任务,都很是适合在消息队列系统中作的。你们想一想,这些任务是否是都须要花比较多的时间,并且迟点完成也不影响的。把这些任务放在队列中,可加快请求的响应时间。 数据结构

2.消息队列是怎么工做?

消息队列系统,通常都包含3个角色:队列服务端,队列的生产者,队列的消费者。 架构

消息队列系统相似于这个场景:有一条信息传送带不停地运转。在传送带的起点,工人a不断地把信息放在一个盒子,把盒子放到传送带上,盒子被传送带传送到终点。在终点上,工人b把盒子上的信息取出来,进行处理。 app

在上面的场景中,不停运转的传送带就是队列服务端,在传送带起点不断放盒子的工人a就是队列的生产者,在传送带终点不断取盒子的工人b就是队列的消费者。 负载均衡

消息队列的服务端,如今有大量的开源的应用,例如RabbitMQ,ZeroMQ,redis等。 运维

队列的生产者和服务者,是针对消息队列服务端开发的客户端,例如,RabbitMQ就有针对java,php等语言开发的客户端。

例如,在app后端中,用代码调用java客户端,把要发送的短信信息放在ZeroMQ中,这里java客户端是充当队列的生产者。

写一个守护进程,在守护进程中,经过代码调用java客户端把要发送的短信信息不断地从ZeroMQ取出来,而后发送出去。

3.常见的一些消息队列产品

RabbitMQ:

是使用Erlang编写的一个开源的消息队列,自己支持不少的协议:AMQP,XMPP,SMTP,STOMP,也正是如此,使的它变的很是重量级,更适合于企业级的开发。同时实现了一个经纪人(Broker)构架,这意味着消息在发送给客户端时先在中心队列排队。对路由(Routing),负载均衡(Loadbalance)或者数据持久化都有很好的支持。

同时,RabbitMQ自带了一个web监控界面,可方便监控队列的状况。

Redis:

虽然是一个key-value系统,但自身也支持队列这种数据结构,可看作是一个轻量级的消息队列系统。

在app后端架构中,redis是被普遍使用,若是同时把它做为消息队列使用,就减小了运维上的成本。

ZeroMq:

号称最快的消息队列系统,尤为针对大吞吐量的需求场景。

ActiveMQ:

是Apache下的一个子项目。相似于ZeroMQ,它可以以代理人和点对点的技术实现队列。

相关文章
相关标签/搜索