1.下载rocketMQ3.2.6安装包https://github.com/alibaba/RocketMQ/releases/download/v3.2.6/alibaba-rocketmq-3.2.6.tar.gz2.解压安装包。

1JMS在介绍ActiveMQ之前，首先简要介绍一下JMS规范。1.1JMS的基本构件1．1．1连接工厂连接工厂是客户用来创建连接的对象，例如ActiveMQ提供的ActiveMQConnectionFactory。1．1．2连接JMSConnection封装了客户与JMS提供者之间的一个虚拟的连接。1．1．3会话JMSSession是生产和消费消息的一个单线程上下文。会话用于创建消息生产者（producer）、消息消费者（consumer）和消息（message）等。会话提供了一个事务性的上下文，在这个上下文中，一组发送和接收被组合到了一个原子操作中。1．1．4目的地目的地是客户用来指定它生产的消息的目标和它消费的消息的来源的对象。JMS1.0.2规范中定义了两种消息传递域：点对点（PTP）消息传递域和发布/订阅消息传递域。

*WebSphereMQ教程*提要WebsphereMQ介绍安装和配置WebsphereMQWebsphereMQ集群WebsphereMQ分布式队列管理WebsphereMQ故障诊断*议程MQ概念中间件MOM异步通信消息原理MQ对象演示Reference(备用)应用案例*MQ简史1992SSI(ServerSideIncludes,服务器端包含)，开发了消息产品ezBridge;IBM为网络通信定义了3个API标准：CPI-C,RPC,MQI1992-3IBM开发消息产品（代码Victory）1993IBM从SSI那里购买了ezBridge的版权之后MQSeriesversion1产生（主要运行在大型机上）1994/1995IBM发布三个平台的MQ:AIX,OS/2,和AS/400.到MQSeries5.3(WebSphereMQ5.3)已支持超过35个平台Windows,Linux,多个Unix,……2006年初WebSphereMQ6发布CPI－C(CommonProgrammingInterfaceCommunication,IBM公共通信编程接口)是一个与平台无关的API，它与一套公用的APPC（高级程序间通信）接口。简单直接，在支持CPI-C的所有平台上都可移植。

MQ的基本概念：首先了解什么是mq？mq的作用是什么？mq是通讯中间件。他的作用是省去开发人员开发通讯工具的时间，节省开发成本，提高开发效率。如何安装mq？根据以往的经验，win版的mq比较容易安装，傻瓜式，一路next就可以。aix版本的用smitty安装。linux版本用rpm-ivh安装。1)队列管理器队列管理器是MQ系统中最上层的一个概念，由它为我们提供基于队列的消息服务。简单的说就是一个大容器的管理员，这个大容器里放了很多东西。2)消息在MQ中，我们把应用程序交由MQ传输的数据定义为消息，我们可以定义消息的内容并对消息进行广义的理解，比如：用户的各种类型的数据文件，某个应用向其它应用发出的处理请求等都可以作为消息。

消息系统、协议与技术消息系统及其结构STOMP/JMS/AMQP/MQTTEIP与SEDA常见开源消息中间件ZeroMQ Fqueue ActiveMQ与ApolloKafka与MetaQ RabbitMQ MQ选型与未来发展展望消息系统、协议与技术Messaging耦合->松耦合同步->异步化直接请求->缓冲压力A系统B系统OnewayA系统B系统RequestResponseA系统B系统sendA系统B系统

为什么选择JDBC主备方式？<br> 1、 共享文件主备方式（Shared File System Master Slave）：共享文件服务器挂了后activemq就会直接挂掉。<br> 2、 LevelDB主备方式（Replicated LevelDB Store）：使用zookeeper选择主备速度快，但存在一个风险就是异步消息情况下主从切换了消息会丢失。（Unexpected results will occur if you use Delay and Schedule Message Delivery with the replicated leveldb store since that data will be not be there when the master fails over to a slave.） 3、 JDBC主备方式：<br> a) 主从切换时间在2s内。 b) activemq通过锁Oracle表的方式来获取主的状态，Oracle集群的高可用性也为activemq的主备的高可用性提供了基础。

JMS简介：Java 消息服务（Java Message Service，简称JMS）是用于访问企业消息系统的开发商中立的API。与JDBC很相似，提供了独立于特定厂商的企业消息系统访问方式JMS编程：应用程序A 发送一条消息到消息服务器的某个目得地(Destination)，然后消息服务器把消息转发给应用程序B消息组成：头，每条JMS消息都必须具有消息头，包含用于路由和识别消息的值属性，消息可以包含称作属性的可选头字段。他们是以属性名和属性值对的形式制定的。可以将属性是为消息头的扩展主体，包含要发送给接收应用程序的内容。

提纲编程步骤应用背景CORBA、DCOM、RMI等RPC中间件技术已广泛应用于各个领域。但是面对规模和复杂度都越来越高的分布式系统，这些技术也显示出其局限性：（1）同步通信：客户发出调用后，必须等待服务对象完成处理并返回结果后才能继续执行；（2）客户和服务对象的生命周期紧密耦合：客户进程和服务对象进程都必须正常运行；如果由于服务对象崩溃或者网络故障导致客户的请求不可达，客户会接收到异常；（3）点对点通信：客户的一次调用只发送给某个单独的目标对象。面向消息的中间件（Message Oriented Middleware，MOM）较好的解决了以上问题：（1）发送者将消息发送给消息服务器，消息服务器将消息存放在若干队列中，在合适的时候再将消息转发给接收者；（2）发送和接收是异步的，发送者无需等待；

activemq之jdbc主从设置

本文主要讲述ActiveMQ的基本知识和使用方法，并简单结合spring使用ActiveMQ。一、ActiveMQ特性和使用总览企业消息软件从80年代起就存在，它不只是一种应用间消息传递风格，也是一种集成风格。因此，消息传递可以满足应用间的通知和互相操作。但是开源的解决方案是到最近10年才出现的。ApacheActiveMQ就是其中一种。它使应用间能以异步，松耦合方式交流。本章将向您介绍ActiveMQ。ActiveMQ是Apache软件基金下的一个开源软件，它遵循JMS1.1规范（Java Message Service），是消息驱动中间件软件（MOM）。它为企业消息传递提供高可用，出色性能，可扩展，稳定和安全保障。ActiveMQ使用Apache许可协议。

Java平台上有关面向消息中间件的技术规范，它便于消息系统中的Java应用程序进行消息交换,并且通过提供标准的产生、发送、接收消息的接口简化企业应用的开发，翻译为Java消息服务。JMS是一种与厂商无关的API，用来访问消息收发系统。

Worktile中的实时消息推送服务实现在Worktile的使用过程中，你会发现无论是右上角的消息通知，还是在任务面板中拖动任务，还有用户的在线状态，都是实时刷新。Worktile中的推送服务是采用的是基于xmpp协议、erlang语言实现的ejabberd，并在其源码基础上，结合我们的业务，对源码作了修改以适配我们自身的需求。另外，基于amqp协议也可以作为实时消息推送的一种选择，踢踢网就是采用rabbitmq+stomp协议实现的消息推送服务。

队列管理器 (Queue Manager) crtmqm 创建队列管理器 (Create Queue Manager)

JMS即Java消息服务，是由Java官方提供的API，需要第三方Provider提供实现。类似于JDBC，它也是Java官方提供的API，需要其他数据库厂商提供实现。 JMS是面向消息的中间件(Message-Oriented Middleware)，它提供了标准的产生、发送、接收消息的接口，简化企业应用的开发。

RocketMQ提供有控制台及一系列控制台命令，用于管理员对主题，集群，broker等信息的管理；  登录控制台： 首先进入RocketMQ工程，进入/RocketMQ/bin 在该目录下有个mqadmin脚本

RocketMQ使用基本概念ProducerGroup通常具有同样属性（处理的消息种类-topic、以及消息处理逻辑流程—分布式多个客户端）的一些producer可以归为同一个group。在事务消息机制中，如果某条发送某条消息的producer-A宕机，使得事务消息一直处于PREPARED状态并超时，则broker会回查同一个group的其他producer，确认这条消息应该commit还是rollback。ConsumerGroup具有同样逻辑消费同样消息的consumer，可以归并为一个group。

1、面向消息的中间件（MOM）1.1、MOM由于业务、机构和技术是不断变化的，因此为其服务的软件系统必须适应这样的变化。在合并、添加服务或扩展可用服务之后，公司可能无力负担重新创建信息系统所需的成本。正是在这个关键时刻，才需要集成新组件或者尽可能高效地扩展现有组件。要集成异类组件，最方便的方法不是将它们重新创建为同类元素，而是提供一个允许它们进行通信（不考虑它们之间的差异）的层。该层被称作中间件，它允许独立开发且运行于不同网络平台上的软件组件（应用程序、Enterprise JavaBean、Servlet和其他组件）彼此交互。

于Spring+JMS+ActiveMQ+Tomcat，我使用的版本情况如下所示： Spring 2.5 ActiveMQ 5.4.0 Tomcat 6.0.30 下面通过学习与配置，实现消息服务的基本功能：发送与接收。Spring对JMS提供了很好的支持，可以通过JmsTemplate来方便地实现消息服务。这里，我们的消息服务不涉及事务管理。

消息中间件系统中，消息接收者不需要完全复制发送者的消息。MOM系统的内置功能能够根据发送者或接收者的特定需求将消息转换。再加上路由和广播功能，一个应用程序能够按照它自己的格式发送消息，而其他应用程序可以接收到它们自己格式的消息。许多现代的MOM系统提供了专业的消息转换（映射）工具，这些工具允许程序员通过图形界面的拖拽操作来定制转换规则。

主要内容Meta是什么,特征和适用场景在公司的应用状况原理和内部实现Meta的使用性能Metamorphosis是什么？Adistributed publish-subscribe messaging system开源MQ-kafka的Java版本Linkedin开源的MQ《The metamorphosis》——卡夫卡的代表作设计原则消息都是持久的，保存在磁盘吞吐量第一消费状态保存在客户端分布式，生产者、服务器和消费者都可分布。跟kafka有什么不同?用java替换scala实现完全重写存储结构上采用自定义结构，更简洁紧凑ConsumerAPI没有采用kafka的stream方式.