消息队列(MQ)介绍

1.MQ使用场景

异步通信 

有些业务不想也不需要立即处理消息。消息队列提供了异步处理机制&＃xff0c;允许用户把消息放入队列&＃xff0c;但并不立即处理它。想在队列中放入多少消息就放多少&＃xff0c;然后在需要的时候再去处理他。

解耦 

降低工程间的强依赖程度&＃xff0c;针对异构系统进行适配。在项目启动之初来预测将来项目会碰到什么需求&＃xff0c;是极其困难的。通过消息系统在处理过程中间插入了一个隐含的、基于数据的接口层&＃xff0c;两边的处理过程都要实现这一接口&＃xff0c;当应用发生变化时&＃xff0c;可以独立的扩展或修改两边的处理过程&＃xff0c;只要确保它们遵守同样的接口约束。

冗余 

有些情况下&＃xff0c;处理数据的过程会失败。除非数据被持久化&＃xff0c;否则将造成丢失。消息队列把数据进行持久化直到它们已经被完全处理&＃xff0c;通过这一方式规避了数据丢失风险。许多消息队列所采用的"插入-获取-删除"范式中&＃xff0c;在把一个消息从队列中删除之前&＃xff0c;需要你的处理系统明确的指出该消息已经被处理完毕&＃xff0c;从而确保你的数据被安全的保存直到你使用完毕。

扩展性 

因为消息队列解耦了你的处理过程&＃xff0c;所以增大消息入队和处理的频率是很容易的&＃xff0c;只要另外增加处理过程即可。不需要改变代码、不需要调节参数。便于分布式扩容。

过载保护 

在访问量剧增的情况下&＃xff0c;应用仍然需要继续发挥作用&＃xff0c;但是这样的突发流量无法提取预知&＃xff1b;如果以为了能处理这类瞬间峰值访问为标准来投入资源随时待命无疑是巨大的浪费。使用消息队列能够使关键组件顶住突发的访问压力&＃xff0c;而不会因为突发的超负荷的请求而完全崩溃。

可恢复性 

系统的一部分组件失效时&＃xff0c;不会影响到整个系统。消息队列降低了进程间的耦合度&＃xff0c;所以即使一个处理消息的进程挂掉&＃xff0c;加入队列中的消息仍然可以在系统恢复后被处理。

顺序保证 

在大多使用场景下&＃xff0c;数据处理的顺序都很重要。大部分消息队列本来就是排序的&＃xff0c;并且能保证数据会按照特定的顺序来处理。

缓冲 

在任何重要的系统中&＃xff0c;都会有需要不同的处理时间的元素。消息队列通过一个缓冲层来帮助任务最高效率的执行&＃xff0c;该缓冲有助于控制和优化数据流经过系统的速度。以调节系统响应时间。

数据流处理 

分布式系统产生的海量数据流&＃xff0c;如&＃xff1a;业务日志、监控数据、用户行为等&＃xff0c;针对这些数据流进行实时或批量采集汇总&＃xff0c;然后进行大数据分析是当前互联网的必备技术&＃xff0c;通过消息队列完成此类数据收集是最好的选择。

2.MQ原理

2.1MQ模型

Pub/Sub发布订阅&＃xff08;广播&＃xff09;&＃xff1a;使用topic作为通信载体 

PTP点对点:使用queue作为通信载体 

2.2 MQ的组成

Broker&＃xff1a;消息服务器&＃xff0c;作为server提供消息核心服务

Producer:消息生产者&＃xff0c;业务的发起方&＃xff0c;负责生产消息传输给broker

Consumer&＃xff1a;消息消费者&＃xff0c;业务的处理方&＃xff0c;负责从broker获取消息并进行业务逻辑处理

Topic:主题&＃xff0c;发布订阅模式下的消息统一汇集地&＃xff0c;不同生产者向topic发送消息&＃xff0c;由MQ服务器分发到不同的订阅者&＃xff0c;实现消息的广播

Queue&＃xff1a;队列&＃xff0c;PTP模式下&＃xff0c;特定生产者向特定queue发送消息&＃xff0c;消费者订阅特定的queue完成指定消息的接收

Message&＃xff1a;消息体&＃xff0c;根据不同通信协议定义的固定格式进行编码的数据包&＃xff0c;来封装业务数据&＃xff0c;实现消息的传输

2.3 MQ常用协议

AMQP 

AMQP即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议, 

是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息&＃xff0c;并 

不受客户端/中间件不同产品&＃xff0c;不同开发语言等条件的限制。 

优点&＃xff1a;可靠、通用

MQTT协议 

MQTT&＃xff08;Message Queuing Telemetry Transport&＃xff0c;消息队列遥测传输&＃xff09;是IBM开发的一个即时通讯协 

议&＃xff0c;有可能成为物联网的重要组成部分。该协议支持所有平台&＃xff0c;几乎可以把所有联网物品和外部连接起来&＃xff0c; 

被用来当做传感器和致动器&＃xff08;比如通过Twitter让房屋联网&＃xff09;的通信协议。 

优点&＃xff1a;格式简洁、占用带宽小、移动端通信、PUSH、嵌入式系统

STOMP协议 

STOMP&＃xff08;Streaming Text Orientated Message Protocol&＃xff09;是流文本定向消息协议&＃xff0c;是一种为MOM(Message Oriented Middleware&＃xff0c;面向消息的中间件设计的简单文本协议。STOMP提供一个可互操作的连接格式&＃xff0c;允许客户端与任意STOMP消息代理&＃xff08;Broker&＃xff09;进行交互。 

优点&＃xff1a;命令模式&＃xff08;非topic\queue模式&＃xff09;

XMPP协议 

XMPP&＃xff08;可扩展消息处理现场协议&＃xff0c;Extensible Messaging and Presence Protocol&＃xff09;是基于可扩展标记语言&＃xff08;XML&＃xff09;的协议&＃xff0c;多用于即时消息&＃xff08;IM&＃xff09;以及在线现场探测。适用于服务器之间的准即时操作。核心是基于XML流传输&＃xff0c;这个协议可能最终允许因特网用户向因特网上的其他任何人发送即时消息&＃xff0c;即使其操作系统和浏览器不同。 

优点&＃xff1a;通用公开、兼容性强、可扩展、安全性高&＃xff0c;但XML编码格式占用带宽大

其他基于TCP/IP自定义的协议 

有些特殊框架&＃xff08;如&＃xff1a;redis、kafka、zeroMq等&＃xff09;根据自身需要未严格遵循MQ规范&＃xff0c;而是基于TCP\IP自行封装了一套协议&＃xff0c;通过网络socket接口进行传输&＃xff0c;实现了MQ的功能。

2.4 MQ选型

RabbitMQ 

使用Erlang编写的一个开源的消息队列&＃xff0c;本身支持很多的协议&＃xff1a;AMQP&＃xff0c;XMPP, SMTP, STOMP&＃xff0c;也正是如此&＃xff0c;使的它变的非常重量级&＃xff0c;更适合于企业级的开发。同时实现了Broker架构&＃xff0c;核心思想是生产者不会将消息直接发送给队列&＃xff0c;消息在发送给客户端时先在中心队列排队。对路由(Routing)&＃xff0c;负载均衡(Load balance)、数据持久化都有很好的支持。多用于进行企业级的ESB整合。

ZeroMQ 

又称ØMQ、0MQ、ZMQ&＃xff0c;号称最快的消息队列系统&＃xff0c;专门为高吞吐量、低延迟的场景开发&＃xff0c;在金融界的应用中经常使用&＃xff0c;偏重于实时数据通信场景。ZMQ能够实现RabbitMQ不擅长的高级/复杂的队列&＃xff0c;但是开发人员需要自己组合多种技术框架&＃xff0c;开发成本高。因此ZeroMQ具有一个独特的非中间件的模式&＃xff0c;更像一个socket library&＃xff0c;你不需要安装和运行一个消息服务器或中间件&＃xff0c;因为你的应用程序本身就是使用ZeroMQ API完成逻辑服务的角色。但是ZeroMQ仅提供非持久性的队列&＃xff0c;如果down机&＃xff0c;数据将会丢失。如&＃xff1a;Twitter的Storm中使用ZeroMQ作为数据流的传输。 ZeroMQ套接字是与传输层无关的&＃xff1a;ZeroMQ套接字对所有传输层协议定义了统一的API接口。默认支持 进程内(inproc) &＃xff0c;进程间(IPC) &＃xff0c;多播 &＃xff0c;TCP协议&＃xff0c;在不同的协议之间切换只要简单的改变连接字符串的前缀。可以在任何时候以最小的代价从进程间的本地通信切换到分布式下的TCP通信。ZeroMQ在背后处理连接建立&＃xff0c;断开和重连逻辑。 

特性&＃xff1a;

无锁的队列模型 

对于跨线程间的交互&＃xff08;用户端和session&＃xff09;之间的数据交换通道pipe&＃xff0c;采用无锁的队列算法CAS&＃xff1b;在pipe的两端注册有异步事件&＃xff0c;在读或者写消息到pipe的时&＃xff0c;会自动触发读写事件。

批量处理的算法 

对于批量的消息&＃xff0c;进行了适应性的优化&＃xff0c;可以批量的接收和发送消息。

多核下的线程绑定&＃xff0c;无须CPU切换 

区别于传统的多线程并发模式&＃xff0c;信号量或者临界区&＃xff0c; zeroMQ充分利用多核的优势&＃xff0c;每个核绑定运行一个工作者线程&＃xff0c;避免多线程之间的CPU切换开销。

ActiveMQ 

Apache下的一个子项目。使用Java完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现&＃xff0c;少量代码就可以高效地实现高级应用场景。可插拔的传输协议支持&＃xff0c;比如&＃xff1a;in-VM, TCP, SSL, NIO, UDP, multicast, JGroups and JXTA transports。RabbitMQ、ZeroMQ、ActiveMQ均支持常用的多种语言客户端 C&＃43;&＃43;、Java、.Net,、Python、 Php、 Ruby等。

Redis 

使用C语言开发的一个Key-Value的NoSQL数据库&＃xff0c;开发维护很活跃&＃xff0c;虽然它是一个Key-Value数据库存储系统&＃xff0c;但它本身支持MQ功能&＃xff0c;所以完全可以当做一个轻量级的队列服务来使用。对于RabbitMQ和Redis的入队和出队操作&＃xff0c;各执行100万次&＃xff0c;每10万次记录一次执行时间。测试数据分为128Bytes、512Bytes、1K和10K四个不同大小的数据。实验表明&＃xff1a;入队时&＃xff0c;当数据比较小时Redis的性能要高于RabbitMQ&＃xff0c;而如果数据大小超过了10K&＃xff0c;Redis则慢的无法忍受&＃xff1b;出队时&＃xff0c;无论数据大小&＃xff0c;Redis都表现出非常好的性能&＃xff0c;而RabbitMQ的出队性能则远低于Redis。

Kafka 

Apache下的一个子项目&＃xff0c;使用scala实现的一个高性能分布式Publish/Subscribe消息队列系统&＃xff0c;具有以下特性&＃xff1a; 快速持久化&＃xff1a;通过磁盘顺序读写与零拷贝机制&＃xff0c;可以在O(1)的系统开销下进行消息持久化&＃xff1b; 

高吞吐&＃xff1a;在一台普通的服务器上既可以达到10W/s的吞吐速率&＃xff1b; 

高堆积&＃xff1a;支持topic下消费者较长时间离线&＃xff0c;消息堆积量大&＃xff1b; 

完全的分布式系统&＃xff1a;Broker、Producer、Consumer都原生自动支持分布式&＃xff0c;依赖zookeeper自动实现复杂均衡&＃xff1b; 

支持Hadoop数据并行加载&＃xff1a;对于像Hadoop的一样的日志数据和离线分析系统&＃xff0c;但又要求实时处理的限制&＃xff0c;这是一个可行的解决方案。