activeMQ消息中间件.docVIP

消息中间件分布式 说明书 中间件选型 Kafka Kafka是linkedin开源的MQ系统，主要特点是基于Pull的模式来处理消息消费，追求高吞吐量，一开始的目的就是用于日志收集和传输，0.8开始支持复制，不支持事务，适合产生大量数据的互联网服务的数据收集业务RabbitMQ是使用Erlang编写的一个开源的消息队列，本身支持很多的协议：AMQP，XMPP, SMTP, STOMP，也正因如此，它非常重量级，更适合于企业级的开发。结合erlang语言本身的并发优势，性能较好，但是不利于做二次开发和维护。阿里巴巴的MQ中间件，在其多个产品下使用，并能够撑住双十一的大流量，他并没有实现JMS规范，使用起来很简单。部署由一个 命名服务（nameserver）和一个代理（broker）组成，nameserver和broker以及producer都支持集群，队列的容量受机器硬盘的限制，队列满后可以支持持久化到硬盘（也可以自己适配代码，将其持久化到NOSQL数据库中），队列满后会影响吞吐量，可以采用主备来保证稳定性，支持回溯消费，可以在broker端进行消息过滤.ActiveMQ是Apache下的一个子项目。历史悠久的开源项目，已经在很多产品中得到应用，实现了JMS1.1规范，可以和spring-jms轻松融合，实现了多种协议如Ajax，REST，Stomp，支持持久化到数据库，少量代码就可以高效地实现高级应用场景 可以很好的运行在任何JVM上，而不只是集成到JBoss的应用服务器中对有很好的支持支持大量的跨语言客户端ZeroMQ号称最快的消息队列系统，尤其针对大吞吐量的需求场景。ZMQ能够实现RabbitMQ不擅长的高级/复杂的队列，但是开发人员需要自己组合多种技术框架，技术上的复杂度是对这MQ能够应用成功的挑战。扩展性好，开发比较灵活，采用C语言实现，实际上他只是一个socket库的重新封装，如果我们做为消息队列使用，需要开发大量的代码ActiveMQ消息中间件的选择从以下方面进行考虑： （1）activemq可以很好的运行在任何JVM上，而不只是集成到JBoss的应用服务器中； （2）activemq支持大量的跨语言客户端； （3）activemq支持许多不同的协议，如Ajax，REST，Stomp，OpenWire，XMPP （4）activemq支持许多高级功能，例如MessageGroups，ExclusiveConsumer，CompositeDestinations （）activemq支持可靠连接并且具有可配置的自动重连接 （）activemq对spring有很好的支持 （）activemq支持跨网络的分布式目的地 （）activemq是速度非常快；一般要比jbossmq快10倍 （）群集(Cluster)：为了简化点对点通讯模式中的系统配置，MQ提供Cluster(群集)的解决方案。群集类似于一个域(Domain)，群集内部的队列管理器之间通讯时，不需要两两之间建立消息通道，而是采用群集(Cluster)通道与其它成员通讯，从而大大简化了系统配置。此外，群集中的队列管理器之间能够自动进行负载均衡，当某一队列管理器出现故障时，其它队列管理器可以接管它的工作，从而大大提高系统的高可靠性。 Kahadb是activemq从版本5.4之后的默认消息存储引擎 一般activemq的Master Slave是基于KAHADB的阻塞来做的，先看一下原理 把master conf 目录中的jetty.xml中的端口改成8161 把slave conf 目录中的jetty.xml中的端口改成8162 此时把master和slave先后启动，其实你也可以不用管顺序，谁先启动谁会先把kahaDB directory=“/localhost/kahadb”/中的db lock住，它就成了mater，而此时另一个实例会处于“pending”状态。 当master宕机后slave会自动启动转变为master。当宕掉的master再次被启动后然后变成slave挂载在原先的slave下面变成slave’ Replicated LevelDB Store方式 这种主备方式是ActiveMQ5.9以后才新增的特性，使用ZooKeeper协调选择一个node作为master。被选择的master broker node开启并接受客户端连接。 其他node转入slave模式，连接master并同步他们的存储状态。slave不接受客户端连接。所有的存储操作都将被复制到连接至Master的slaves。