注冊用戶即可下載全站資源 關注Java幫幫微信公眾號
 

Docker學習之搭建ActiveMQ消息服務

7
發表時間:2018-11-08 11:54來源:Java幫幫-微信公眾號


前言

日本韩国三级aⅴ在线观看ActiveMQ 是Apache出品,最流行的,能力強勁的開源消息總線。ActiveMQ 是一個完全支持JMS1.1和J2EE 1.4規范的 JMS Provider實現,盡管JMS規范出臺已經是很久的事情了,但是JMS在當今的J2EE應用中間仍然扮演著特殊的地位。

在生產項目中,很多時候需要消息中間件來進行分布式系統間的通信。它具有低耦合、可靠投遞、廣播、流量控制、最終一致性等一系列功能。本篇主要介紹ActiveMQ 相關概念以及安裝說明,后面會著重介紹 SpringBoot 集成實現秒殺消息隊列。

概念

JMS消息模式

點對點或隊列模式

日本韩国三级aⅴ在线观看包含三個角色:消息隊列(Queue),發送者(Sender),接收者(Receiver)。每個消息都被發送到一個特定的隊列,接收者從隊列中獲取消息。隊列保留著消息,直到他們被消費或超時。

  • 每個消息只有一個消費者(Consumer),即一旦被消費,消息就不再在消息隊列中

  • 發送者和接收者之間在時間上沒有依賴性,也就是說當發送者發送了消息之后,不管接收者有沒有正在運行,它不會影響到消息被發送到隊列

  • 日本韩国三级aⅴ在线观看接收者在成功接收消息之后需向隊列應答成功

Pub/Sub 發布/訂閱模式

日本韩国三级aⅴ在线观看包含三個角色:主題(Topic),發布者(Publisher),訂閱者(Subscriber) 。多個發布者將消息發送到Topic,系統將這些消息傳遞給多個訂閱者。

  • 每個消息可以有多個消費者

  • 日本韩国三级aⅴ在线观看發布者和訂閱者之間有時間上的依賴性。針對某個主題(Topic)的訂閱者,它必須創建一個訂閱者之后,才能消費發布者的消息。

  • 為了消費消息,訂閱者必須保持運行的狀態。

為了緩和這樣嚴格的時間相關性,JMS允許訂閱者創建一個可持久化的訂閱。這樣,即使訂閱者沒有被激活(運行),它也能接收到發布者的消息。

如果希望發送的消息可以不被做任何處理、或者只被一個消息者處理、或者可以被多個消費者處理的話,那么可以采用Pub/Sub模型。

JMS消息基本組件

ConnectionFactory

創建Connection對象的工廠,針對兩種不同的jms消息模型,分別有QueueConnectionFactory和TopicConnectionFactory兩種。可以通過JNDI來查找ConnectionFactory對象。

Destination

Destination的意思是消息生產者的消息發送目標或者說消息消費者的消息來源。對于消息生產者來說,它的Destination是某個隊列(Queue)或某個主題(Topic);對于消息消費者來說,它的Destination也是某個隊列或主題(即消息來源)。
所以,Destination實際上就是兩種類型的對象:Queue、Topic可以通過JNDI來查找Destination。

Connection

Connection表示在客戶端和JMS系統之間建立的鏈接(對TCP/IP socket的包裝)。Connection可以產生一個或多個Session。跟ConnectionFactory一樣,Connection也有兩種類型:QueueConnection和TopicConnection。

Session

Session是操作消息的接口。可以通過session創建生產者、消費者、消息等。Session提供了事務的功能。當需要使用session發送/接收多個消息時,可以將這些發送/接收動作放到一個事務中。同樣,也分QueueSession和TopicSession。

消息的生產者

日本韩国三级aⅴ在线观看消息生產者由Session創建,并用于將消息發送到Destination。同樣,消息生產者分兩種類型:QueueSender和TopicPublisher。可以調用消息生產者的方法(send或publish方法)發送消息。

消息消費者

消息消費者由Session創建,用于接收被發送到Destination的消息。兩種類型:QueueReceiver和TopicSubscriber。可分別通過session的createReceiver(Queue)或createSubscriber(Topic)來創建。當然,也可以session的creatDurableSubscriber方法來創建持久化的訂閱者。

MessageListener

消息監聽器。如果注冊了消息監聽器,一旦消息到達,將自動調用監聽器的onMessage方法。EJB中的MDB(Message-Driven Bean)就是一種MessageListener。

Transport傳輸方式

日本韩国三级aⅴ在线观看ActiveMQ目前支持的Transport有:VM Transport、TCP Transport、NIO Transport、SSL Transport、Peer Transport、UDP Transport、Multicast Transport、HTTP and HTTPS Transport、WebSockets Transport、Failover Transport、Fanout Transport、Discovery Transport、ZeroConf Transport等。

  • VM Transport:允許客戶端和Broker直接在VM內部通信,采用的連接不是Socket連接,而是直接的方法調用,從而避免了網絡傳輸的開銷。應用場景也僅限于Broker和客戶端在同一JVM環境下。

  • TCP Transport:客戶端通過TCP Socket連接到遠程Broker。配置語法:

  • 日本韩国三级aⅴ在线观看tcp://hostname:port?transportOptions

  • 日本韩国三级aⅴ在线观看HTTP and HTTPS Transport:允許客戶端使用REST或者Ajax的方式進行連接。這意味著可以直接使用Javascript向ActiveMQ發送消息。

  • 日本韩国三级aⅴ在线观看WebSockets Transport:允許客戶端通過HTML5標準的WebSockets方式連接到Broker。

  • Failover Transport:青龍系統MQ采用的就是這種連接方式。這種方式具備自動重新連接的機制,工作在其他Transport的上層,用于建立可靠的傳輸。允許配置任意多個的URI,該機制將會自動選擇其中的一個URI來嘗試連接。配置語法:

  • 日本韩国三级aⅴ在线观看failover:(tcp://localhost:61616,tcp://localhost:61617,.....)?transportOptions

  • Fanout Transport:主要適用于生產消息發向多個代理。如果多個代理出現環路,可能造成消費者接收重復的消息。所以,使用該協議時,最好將消息發送給多個不相連接的代理。

Persistence持久化存儲

AMQ Message Store

ActiveMQ 5.0 的缺省持久化存儲方式。

Kaha Persistence

這是一個專門針對消息持久化的解決方案。它對典型的消息使用模式進行了優化。

JDBC Persistence

日本韩国三级aⅴ在线观看目前支持的數據庫有:Apache Derby, Axion, DB2, HSQL, Informix, MaxDB, MySQL, Oracle, Postgresql, SQLServer, Sybase。

Disable Persistence

不應用持久化存儲。

集群方案(Master / Slave)

Pure Master Slave

  • 無單點故障;

  • 不需要依賴共享文件系統或是共享數據庫,使用 KahaDB的方式持久化存儲;

  • 日本韩国三级aⅴ在线观看一個Master只能帶一個Slave;

  • 日本韩国三级aⅴ在线观看Master工作期間,會將消息狀況自動同步到Slave;

  • Master一旦崩潰,Slave自動接替其工作,已發送并尚未消費的消息繼續有效;

  • 日本韩国三级aⅴ在线观看Slave接手后,必須停止Slave才能重啟先前的Master;

Shared File System Master Slave

JDBC Master Slave

  • 日本韩国三级aⅴ在线观看配置上,不存在Master和Slave的區分,多個共享數據源的Broker構成JDBC Master Slave;

  • 首先搶到資源(數據庫鎖)的Broker成為Master,其他Broker定期嘗試搶占資源;

  • 日本韩国三级aⅴ在线观看一旦Master崩潰,其他Broker搶占資源,最終只有一臺搶到,立刻成為Master,之前的Master即便重啟成功,也只能作為Slave等待;

安裝說明

這里使用Docker安裝,查詢Docker鏡像:

docker search activemq

日本韩国三级aⅴ在线观看下載Docker鏡像:

docker pull webcenter/activemq

創建&運行ActiveMQ容器:

docker run -d --name myactivemq -p 61617:61616 -p 8162:8161 webcenter/activemq

日本韩国三级aⅴ在线观看61616是 activemq 的容器使用端口(映射為61617),8161是 web 頁面管理端口(對外映射為8162)

查看創建的容器,如果存在說明安裝成功:

docker ps

查看WEB管理頁面:

瀏覽器輸入:8162 點擊Manage ActiveMQ broker使用默認賬號/密碼:admin/admin進入查看。

配置訪問密碼

進入Docker容器:

docker exec -it myactivemq /bin/bash

日本韩国三级aⅴ在线观看控制臺界面設置用戶名和密碼:

# 位于根目錄 conf 目錄下vi jetty-realm.properties# 修改密碼# username: password [,rolename ...]admin: admin, admin

配置連接密碼

日本韩国三级aⅴ在线观看編輯activemq.xml文件,放置到 shutdownHooks 下方即可。

<!-- 添加訪問ActiveMQ的賬號密碼 --><plugins>    <simpleAuthenticationPlugin>    <users>        <authenticationUserusername="${activemq.username}"password="${activemq.password}"groups="users,admins"/>    </users>    </simpleAuthenticationPlugin></plugins>

日本韩国三级aⅴ在线观看修改conf中credentials.properties文件進行密碼設置:

activemq.username=adminactivemq.password=123456guest.password=123456

注意事項

日本韩国三级aⅴ在线观看如果是云服務器,記得開放相關端口(61617/8160)


支付寶贊助-Java幫幫社區
微信贊助-Java幫幫社區
Java幫幫公眾號生態

Java幫幫公眾號生態

總有一款適合你

Java幫幫-微信公眾號

Java幫幫-微信公眾號

將分享做到極致

Python幫幫-公眾號

Python幫幫-公眾號

人工智能,爬蟲,學習教程

大數據驛站-微信公眾號

大數據驛站-微信公眾號

一起在數據中成長

九點編程-公眾號

九點編程-公眾號

深夜九點學編程

程序員生活志-公眾號

程序員生活志-公眾號

互聯網,職場,程序員那些事兒

Java幫幫學習群生態

Java幫幫學習群生態

總有一款能幫到你

Java學習群

Java學習群

與大牛一起交流

大數據學習群

大數據學習群

在數據中成長

九點編程學習群

九點編程學習群

深夜九點學編程

python學習群

python學習群

人工智能,爬蟲

測試學習群

測試學習群

感受測試的魅力

Java幫幫生態承諾

Java幫幫生態承諾

一直堅守,不負重望

初心
勤儉
誠信
正義
分享
合作品牌 非盈利生態-優質內容分享傳播者
關于我們
友鏈申請
友鏈交換:加幫主QQ2524138991 留言即可 24小時內答復  
全站內容非商業用途,內容來源于網友,并遵循 許可,如有異議請聯系客服。
會員登錄
獲取驗證碼
登錄
登錄
我的資料
留言
回到頂部