zoukankan      html  css  js  c++  java
  • 13.app后端为什么要用到消息队列

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


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


    1. 为什么要用消息队列?



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


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


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


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


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



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


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


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


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


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


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


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


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



      RabbitMQ:


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


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


      Redis:


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


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


      ZeroMq:


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


      ActiveMQ:


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


    ---------------------------------------------------------------------------------------------------------------------------

    打开链接  app后端系列文章总目录 总目录 ,能查看本人发表过的所有原创“app后端”文章。

    【作者】曾健生
    【QQ】190678908
    【qq群】254659220 
    【微信公众号】 appbackend
    【新浪微博】 @newjueqi
    【博客】http://blog.csdn.net/newjueqi 


    版权声明:本文为博主原创文章,未经博主允许不得转载。

  • 相关阅读:
    模仿.Net ThreadPool的线程池控件
    ThreadPool for Delphi
    Thread Pool Engine, and Work-Stealing scheduling algorithm
    Delphi ThreadPool 线程池(Delphi2009以上版本适用)
    Object Pascal对象模型中构造函数之研究
    TExternalThread TThread -- Delphi -- Cannot terminate an externally created thread ?
    Trapping Messages Sent to an Application
    Correct thread terminate and destroy
    Delphi thread exception mechanism
    VCL -- Understanding the Message-Handling System
  • 原文地址:https://www.cnblogs.com/dingxiaoyue/p/4926743.html
Copyright © 2011-2022 走看看