1.常用消息队列介绍
  本部分主要介绍四种常用的消息队列(RabbitMQ/ActiveMQ/RocketMQ/Kafka)的主要特性、优、缺。
  1.1RabbitMQ
  RabbitMQ2007年发布，一个在AMQP(高级消息队列协议)基础上完成的，可复用的消息系统，当前最主流的消息中间件之一。
windows server 2012四个版本
  主要特性：
  1.可靠性:了多种技术可以让你在性能和可靠性之间进行权衡。这些技术包括持久性机制、投递确认、发布者证实和高可用性机制;
  2.灵活的路由：消息在到达队列前通过交换机进行路由的。RabbitMQ为典型的路由逻辑了多种内置交换机类型。如果你有更复杂的路由需求，可以将这些交换机组合起来使用，你甚至可以实现自己的交换机类型，并且当RabbitMQ的件来使用;
  3.消息集：在相同局域网中的多个RabbitMQ器可以聚合在，作为一个独立的逻辑代理来使用;
  4.队列高可用：队列可以在集中的机器上进行镜像，以确保在硬件问题下还保证消息;
  5.多种协议的支持：支持多种消息队列协议;
  6.器端用Erlang语言编写，支持只要你能想到的所有编程语言;
  7.管理界面:RabbitMQ有一个易用的用户界面，使得用户可以监控和管理消息Broker的许多方面;
  8.跟踪机制：如果消息异常，RabbitMQ消息跟踪机制，使用者可以出发生了什么;
  9.件机制：了许多件，来从多方面进行扩展，也可以编写自己的件;
  使用RabbitMQ需要：
  lErLang语言包
  lRabbitMQ包
  RabbitMQ可以运行在Erlang语言所支持的之上：
  lSolaris
  lBSD
  lLinux
  lMacOSX
  lTRU64
  lWindowsNT/2000/XP/Vista/Windows7/Windows8
  lWindowsServer2003/2008/2012
  lWindows95,98
  lVxWorks
  优：
  1.由于erlang语言的特性，mq性能较好，高并发;
  2.健壮、稳定、易用、跨、支持多种语言、文档齐全;
  3.有消息确认机制和持久化机制，可靠性高;
  4.高度可定制的路由;
  5.管理界面较丰富，在互联网也有较规模的应用;
  6.社区活跃度高;
  缺：
  1.尽管结合erlang语言本身的并发优势，性能较好，但不利于二次发和维护;
  2.实现了代理架构，意味着消息在到客户端之前可以在中央节上排队。此特性使得RabbitMQ易于使用和部署，但使得其运行速度较慢，因为中央节增加了延迟，消息装后也
比较;
  3.需要学习比较复杂的接口和协议，学习和维护成本较高;
  1.2ActiveMQ
  ActiveMQ由Apache出品，ActiveMQ一个完全支持JMS1.1和J2EE1.4规范的JMSProvider实现。它非常快速，支持多种语言的客户端和协议，而且可以非常容易的嵌入到的应用环境中，并有许多高级功能。
  主要特性：
  1.服从JMS规范：JMS规范了良好的标准和保证，包括：同步或异步的消息分发，一次和仅一次的消息分发，消息接收和订阅等等。遵从JMS规范的好处在于，不论使用什么JMS实现者，这些基础特性都可用的;
  2.连接性：ActiveMQ了广泛的连接选项，支持的协议有：HTTP/S，IP多播，SSL，STOMP，TCP，UDP，XMPP等等。对众多协议的支持让ActiveMQ拥有了很好的灵活性。
  3.支持的协议种类多：OpenWire、STOMP、REST、XMPP、AMQP;
  4.持久化件和件：ActiveMQ了多种持久化选择。而且，ActiveMQ的性也可以完全依据用户需求进行自定义鉴权和授权;
  5.支持的客户端语言种类多：除了Java之外，还有：C/C++，.NET，Perl，PHP，Python，Ruby;
  6.代理集：多个ActiveMQ代理可以组成一个集来;
  7.异常简单的管理：ActiveMQ以发者思维被设计的。所以，它并不需要专门的管理员，因为它了简单又使用的管理特性。有很多中方法可以监控ActiveMQ不同层面的数据，包括使用在JConsole或者ActiveMQ的WebConsole中使用JMX，通过处理JMX的告警消息，通过使用命令行脚本，甚至可以通过监控各种类型的日志。
  使用ActiveMQ需要：
  lJavaJDK
  lActiveMQ包
  ActiveMQ可以运行在Java语言所支持的之上。
  优：
  1.跨(JAVA编写与无关有，ActiveMQ几乎可以运行在任何的JVM上)
  2.可以用JDBC：可以将数据持久化到数据库。虽然使用JDBC会降低ActiveMQ的性能，但数据库一直都发人员最熟悉的存储介质。将消息存到数据库，看得见摸得着。而且有专门的DBA去对数据库进行调优，主从分离;
  3.支持JMS：支持JMS的统一接口;
  4.支持自动重连;
  5.有机制：支持基于shiro，jaas等多种配置机制，可以对Queue/Topic进行认证和授权。
  6.监控完善：拥有完善的监控，包括WebConsole，JMX，Shell命令行，Jolokia的RESTAPI;
  7.界面友善：的WebConsole可以满足部分情况，还有很多第三方的组件可以使用，如hawtio;
  缺：
  1.社区活跃度不及RabbitMQ高;
  2.根据其他用户反馈，会出莫名其妙的问题，会丢失消息;
  3.目前重心放到activemq6.0产品-apollo，对5.x的维护较少;
  4.不适合用于上千个队列的应用场景;
  1.3RocketMQ
  RocketMQ出自阿里的源产品，用Java语言实现，在设计时参考了Kafka，并出了自己的一些改进，消息可靠性上比Kafka更好。RocketMQ在阿里集团被广泛应用在订单，交易，充值，流计算，消息推送，日志流式处理，binglog分发等场景。
  主要特性：
  1.一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特;
  2.Producer、Consumer、队列都可以分布式;
  3.Producer向一些队列轮流消息，队列集合称为Topic，Consumer如果广播消费，则一个consumer实例消费这个Topic对应的所有队列，如果集消费，则多个Consumer实例平均消费这个topic对应的队列集合;
  4.能够保证严格的消息顺序;
  5.丰富的消息拉取模式;
  6.的订阅者水平扩展能力;
  7.实时的消息订阅机制;
  8.亿级消息堆积能力;
  9.较少的依赖;
  使用RocketMQ需要：
  lJavaJDK
  lgit、Maven
  lRocketMQ包
  RocketMQ可以运行在Java语言所支持的之上。
  优：
  1.单机支持1万以上持久化队列
  2.RocketMQ的所有消息都持久化的，先写入系统PAGECACHE，然后刷盘，可以保证内存与磁盘都有一份数据，访问时，直接从内存读取。
  3.模型简单，接口易用(JMS的接口很多场合并不太实用);
  4.性能非常好，可以量堆积消息在broker中;
  5.支持多种消费，包括集消费、广播消费等。
  6.各个环节分布式扩展设计，主从HA;
  7.发度较活跃，版本更新很快。
  缺：
  1.支持的客户端语言不多，目前java及c++，其中c++不成熟;
  2.RocketMQ社区度及成熟度也不及前两者;
  3.没有web管理界面，了一个CLI(命令行界面)管理工具带来查询、管理和诊断各种问题;
  4.没有在mq核心中去实现JMS等接口;
  1.4Kafka
  ApacheKafka一个分布式消息发布订阅系统。它最初由LinkedIn基于独特的设计实现为一个分布式的提交日志系统(adistributedmitlog)，，之后成为Apache的一部分。Kafka系统快速
、可扩展并且可持久化。它的分区特性，可复制和可容错都其不错的特性。

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。