消息中間件通也被稱為消息隊列服務器,是當今分布式應用架構(gòu)中經(jīng)常采用的技術(shù)遣鼓。
在系統(tǒng)軟件中,操作系統(tǒng)重贺、數(shù)據(jù)庫骑祟、中間件三駕馬車回懦,對于專業(yè)人士來說,中間件也是最神秘的次企。中間件是一個專業(yè)化非常強的細分產(chǎn)業(yè)怯晕,中間件的技術(shù)門檻較高。但是從 2008 年開始中間件得到了蓬勃發(fā)展缸棵,開發(fā)者對中間件這個詞不再陌生舟茶,周圍被各種中間件圍繞。
其中消息隊列是開發(fā)中經(jīng)常用到的一種中間件技術(shù)堵第。
什么是消息中間件吧凉?
消息中間件是利用高效可靠的消息傳遞機制進行平臺無關(guān)的數(shù)據(jù)通信來達到分布式系統(tǒng)的集成目的,通過提供消息傳遞和消息排隊模型踏志,可以在分布式架構(gòu)下擴展進程之間的通信阀捅。對于消息中間件,常見的角色就是Producer(生產(chǎn)者)针余、Consumer(消費者) 饲鄙、broker(消息中間件實例)。
消息隊列發(fā)展史
世界上第一個現(xiàn)代消息隊列軟件 The Information Bus(TIB)圆雁,采用發(fā)布訂閱的模式解決不同程序直接的通信需求忍级, TIB 的發(fā)展引起了IBM的注意,于是IBM開發(fā)了自己的消息隊列軟件“IBM WebSphere MQ”伪朽,后來微軟發(fā)布了自己的(MSMQ)颤练。
隨著IT信息時代的發(fā)展,程序之間互聯(lián)互通的需求越來越強烈驱负,但是各大IT廠商們還是牢牢建立著各種技術(shù)壁壘嗦玖,保證自己的商業(yè)利益,消息中間件依舊是各大型企業(yè)能夠用的起的東西跃脊。
各大廠商直接的協(xié)議不通宇挫,導致了開發(fā)成本的增加,一個開發(fā)人員既要懂IBM的酪术,又要懂微軟的器瘪,對開發(fā)人員來說也充滿了壓力,2001年sun發(fā)布了 JMS ( Java Message Service)技術(shù)绘雁,試圖在各大廠商的基礎(chǔ)上再包裝一層統(tǒng)一的 Java 規(guī)范橡疼, Java 程序只需要針對 JMS API 編程就可以了,不需要關(guān)注使用了什么樣的消息中間件庐舟,但是 JMS 僅僅適用于 Java 欣除。
2004年 AMQP (高級消息隊列協(xié)議)誕生了,真正促進了消息隊列的繁榮發(fā)展挪略,任何人都可以針對 AMQP 的標準進行編碼历帚,并和實現(xiàn)了 AMQP 的中間件供應商進行通信滔岳。
加上互聯(lián)網(wǎng)分布式應用的迅猛發(fā)展,使得消息中間件一飛沖天挽牢,開源消息中間件層出不窮谱煤,常見比較流行的有 ActiveMQ、RabbitMQ禽拔、Kafak刘离、阿里的 RocketMQ 等,在互聯(lián)網(wǎng)應用中消息隊列中間件基本上成為標配睹栖。
消息隊列的應用場景
在高并發(fā)環(huán)境下硫惕,我們會利用消息隊列進行異步,解耦磨淌,流量削峰疲憋。
異步處理+系統(tǒng)解耦
拿“用戶注冊”這個業(yè)務來說,除了要把用戶信息保存到數(shù)據(jù)庫之外梁只,注冊成功后缚柳,我們還需要給用戶短信發(fā)送注冊結(jié)果,通知積分系統(tǒng)為用戶贈送積分等等搪锣。
假設這3個操作秋忙,每個操作需要1秒鐘,那么整個注冊過程就需要3秒鐘才能響應給用戶构舟。其實對注冊服務來說灰追,最重要的就是信息入庫,后面的短信提醒和贈送積分可以采用異步執(zhí)行狗超,提高系統(tǒng)的響應能力弹澎。
實行異步化處理,可以采用多線程的方式實現(xiàn)努咐,但是對于消息的持久化苦蒿,消息的重發(fā)來說,多線程的方式不能很好的支持渗稍,因此我們可以借助一些開源中間件來解決佩迟。
通過異步處理,給用戶響應的時間可以提高到1秒竿屹,同時短信提醒和贈送積分可以并行操作报强,提升了系統(tǒng)的處理效率,提高了系統(tǒng)性能拱燃。
把信息入庫秉溉,短信提醒,贈送積分等等操作寫到不同的系統(tǒng)里,做成不同的服務坚嗜,使系統(tǒng)之間做到解耦夯膀,不必把這些操作都放到注冊服務里诗充,同時可以做到系統(tǒng)解耦苍蔬。
流量削峰
在高并發(fā)環(huán)境下,前端請求流量會非常大蝴蜓,通過消息隊列的方式可以很好的緩解高流量的問題碟绑,比如秒殺業(yè)務。前端請求先寫入消息隊列茎匠,然后給用戶返回格仲,當消息隊列超過指定的長度,直接丟棄诵冒;秒殺服務負責處理核心業(yè)務凯肋,接收消息隊列的消息進行秒殺處理,以達到流量的削峰汽馋。
ActiveMQ 簡介以及下載安裝
Apache ActiveMQ 是最流行的開源侮东,多協(xié)議,基于Java JMS 規(guī)范的消息服務器豹芯。ActiveMQ 主要應用在分布式系統(tǒng)架構(gòu)中悄雅,構(gòu)建高可用、 高性能铁蹈、可伸縮的面向消息服務的系統(tǒng)宽闲,它支持行業(yè)標準協(xié)議,使用 AMQP 協(xié)議集成多平臺應用程序握牧,使用 STOMP 通過 websockets 在 Web 應用程序之間交換消息容诬,ActiveMQ 提供強大的功能以支持任何消息的傳遞。
由于 ActiveMQ 是一個純 Java 程序沿腰,因此只需要操作系統(tǒng)支持 Java 虛擬機览徒,ActiveMQ 便可執(zhí)行。
1矫俺、完全支持 JMS 1.1 和 J2EE 1.4規(guī)范吱殉;2、Spring 支持厘托,以便ActiveMQ可以輕松嵌入到Spring應用程序中友雳,并使用Spring的XML配置機制進行配置
ActiveMQ 的安裝
1、下載地址:Download Archives
選擇你想安裝的版本進行下載
Linux系統(tǒng)選擇tar.gz版本铅匹,windows系統(tǒng)選擇bin.zip版本進行下載押赊。
2、把下載好的壓縮包拷貝到服務器上,進行解壓
解壓命令:tar -zxvf apache-activemq-5.15.0-bin.tar.gz
解壓后流礁,activemq的文件目錄結(jié)構(gòu)為如下:
目錄名稱 | 目錄說明 |
---|---|
data | log文件和kahadb文件 |
lib | 一些jia包 |
bin | 啟動腳本等shell目錄 |
conf | activemq.xml等配置文件 |
activemq-all-5.15.0.jar | 開發(fā)所需jar包 |
docs | 使用文檔 |
examples | 使用樣例 |
webapps | 監(jiān)控服務 |
3涕俗、啟動運行,到bin目錄下執(zhí)行命令進行啟動activeMQ服務
啟動命令:sh activemq start
4神帅、檢查是否啟動
ActiveMQ 默認采用 61616 端口提供消息服務再姑,使用 8161 端口提供管理監(jiān)控服務。
執(zhí)行以下命令可以檢查是否成功啟動 ActiveMQ 服務:
netstat an|grep 61616
或者執(zhí)行以下命令檢查是否成功啟動 ActiveMQ 服務:
ps -ef|grep activemq
可以通過啟動日志查看找御,是否有異常:
tail -fn500 ../data/activemq.log
5元镀、通過 http://你的ip地址:8161 訪問 activeMQ 管理頁面,如下:
默認帳號/密碼:admin/admin
這樣霎桅,說明ActiveMQ 服務已經(jīng)啟動栖疑。
6、關(guān)閉 ActiveMQ 服務: sh activemq stop