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方式.