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

很多没有实际项目经验的小伙伴&＃xff0c;对消息队列系统非常陌生&＃xff0c;看着很多架构的介绍中&＃xff0c;都提到消息队列。但是&＃xff0c;不知道为什么要用消息队列&＃xff1f;什么是消息队列&＃xff1f;常见的消息队列产品有哪些&＃xff1f;

通过阅读本文&＃xff0c;帮你解开以上的疑惑。

1.为什么要用消息队列&＃xff1f;

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

做到某个小任务时&＃xff0c;发现这个小任务需要花很多时间完成&＃xff0c;而且这个小任务迟点完成也不影响整个任务的完成进度。于是&＃xff0c;老大把这个小任务交个一个小弟去做&＃xff0c;自己去接着完成其他的任务。

在上面的例子中&＃xff0c;老大就是后台系统&＃xff0c;小弟就是消息队列系统&＃xff0c;当后台系统发现完成某些小任务需要花很多时间&＃xff0c;而且迟点完成也不影响整个任务的&＃xff0c;就会把这些小任务交给消息队列系统。

在实际的app后端中&＃xff0c;发送邮件&＃xff0c;发送短信&＃xff0c;推送等这些任务&＃xff0c;都非常适合在消息队列系统中做的。大家想想&＃xff0c;这些任务是不是都需要花比较多的时间&＃xff0c;而且迟点完成也不影响的。把这些任务放在队列中&＃xff0c;可加快请求的响应时间。

2.消息队列是怎么工作&＃xff1f;

消息队列系统&＃xff0c;一般都包含3个角色&＃xff1a;队列服务端&＃xff0c;队列的生产者&＃xff0c;队列的消费者。

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

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

消息队列的服务端&＃xff0c;现在有大量的开源的应用&＃xff0c;例如RabbitMQ&＃xff0c;ZeroMQ&＃xff0c;redis等。

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

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

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

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

RabbitMQ:

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

同时&＃xff0c;RabbitMQ自带了一个web监控界面&＃xff0c;可方便监控队列的情况。

Redis&＃xff1a;

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

在app后端架构中&＃xff0c;redis是被广泛使用&＃xff0c;如果同时把它作为消息队列使用&＃xff0c;就减少了运维上的成本。

ZeroMq&＃xff1a;

号称最快的消息队列系统&＃xff0c;尤其针对大吞吐量的需求场景。

ActiveMQ&＃xff1a;

是Apache下的一个子项目。类似于ZeroMQ&＃xff0c;它能够以代理人和点对点的技术实现队列。