【文章內(nèi)容簡介】 費者注冊了持久訂閱。 ActiveMQ A. 產(chǎn)品概述 已有的 MOM 系統(tǒng)包括 IBM 的 MQSeries、 Microsoft 的 MSMQ 和 BEA 的 MessageQ 等。由于沒有一個通用的標準，這些系統(tǒng)很難實現(xiàn)互操作和無縫連接。 Java Message Service（ JMS）是 SUN 提出的旨在統(tǒng)一各種 MOM 系統(tǒng)接口的規(guī)范，它包含點對點（ Point to Point， PTP）和發(fā)布 /訂閱（ Publish/Subscribe， pub/sub）兩種消息模型，提供可靠消息傳輸、事務(wù)和消息過濾等機制。 JAVA 消息服務(wù)（ JMS）定義了 Java 中訪問消息中間件的接口。 JMS 只是接口，并沒有給予實現(xiàn)，實現(xiàn) JMS 接口的消息中間件稱為 JMS Provider，例如 ActiveMQ。 ActiveMQ 是現(xiàn)在最流行的功能強大的開源消息總線，完全支持 JMS 和 J2EE 規(guī)范的 JMS Provider 實現(xiàn)。盡管 JMS 規(guī)范出臺已經(jīng)是很久的事情了，但是 JMS 在當今的 J2EE 應(yīng)用中間仍然扮演著特殊的地位。 其他開源 JMS 供應(yīng)商 ，包括： Jbossmq（ jboss 4）、 jboss messaging（ jboss 5）、 joram、 openjms、mantamq、 ubermq、 SomnifugiJMS。 開源的 JMS Provider 大部分都已經(jīng)停止發(fā)展了， 但是 ActiveMQ依托于 Apache 基金組織一直持續(xù)發(fā)展 。 國源益通智能交通平臺 — GYYTITS解決方案 技術(shù)文件 北京國源益通軟件有限責(zé)任公司 01062410166/77 10 現(xiàn)在的 商業(yè)應(yīng)用程序服務(wù)器 大部分都 包含 JMS Provider 的實現(xiàn)， 但是價格昂貴，非常龐大 。 當然，也有獨立的 商業(yè) JMS 供應(yīng)商 ，其中包括： Apache MQ、 IBM WebSphere MQ、 BEA WebLogic JMS、 Oracle AQ、 Sonic JMS 等。 微軟公司提供的 MSMQ 提供了消息隊列服務(wù)，隨著 Windows 操作系統(tǒng)免費提供。 從 行業(yè)競爭 來看， ActiveMQ 明顯的競爭者并不多，因為它是作為獨立的開源 JMS Provider 出現(xiàn)的，很容易被用于多種結(jié)構(gòu)設(shè)計中，使用 ActiveMQ 作為默認 JMS Provider 的開源項目有 ServiceMix，Geronimo。 B. 產(chǎn)品 特性 ? 支持使用多種語言和協(xié)議編寫客戶端程序。編程語言： Java， C， C++， C， Ruby， Perl， Python，PHP。應(yīng)用協(xié)議： OpenWire， Stomp， WS Notification， XMPP， AMQP。 ? 完全支持企業(yè)集成模式，無論在 JMS 客戶端還是消息代理。 ? 支持許多先進的功能，如郵件組、虛擬目的地、通配符和復(fù)合目的地。 ? 完全支持 JMS 和 J2EE 規(guī)范，包括持久化、事務(wù)和 XA 消息。 ? 支持 Spring， ActiveMQ 可以很容易內(nèi)嵌到使用 Spring 的應(yīng)用程序和系統(tǒng)中去，而且也支持Spring 的特性。 ? 通過了常見 J2EE 服務(wù)器的測試，如 Geronimo， JBoss 4， GlassFish， WebLogic。其中通過 JCA 資源 適配器 的配置，可以讓 ActiveMQ 可以自動的部署到任何兼容 J2EE 商業(yè)服務(wù)器上。 ? 支持多種連接協(xié)議： inVM， TCP， SSL， NIO， UDP，組播， JGroups， JXTA。 ? 支持通過 JDBC 和 journal 提供高速的消息持久化。 ? 高性能集群設(shè)計，客戶端 /服務(wù)器模式，點對點的支持。 ? REST API 提供 了 技術(shù)語言無關(guān)的 純粹基于網(wǎng)絡(luò)消息接口。 ? 提供瀏覽器 AJAX 支持，使用瀏覽器收發(fā)消息，實現(xiàn)了實時通信。 ? 提供 CXF 和 Axis 支持，因此 ActiveMQ 很容易 嵌入 這些網(wǎng)站 服務(wù) ，提供可靠的消息傳遞 。 ? 可作為一個在內(nèi)存中的 JMS Provider，適合 JMS 的單元測試 。 Microsoft Message Queue A. 產(chǎn)品概述 MSMQ（微軟消息隊列）是微軟公司的成熟產(chǎn)品，最新版本為 MSMQ 。 MSMQ 集運行系統(tǒng)、管理工具集和開發(fā)系統(tǒng)三者于一身，既為上層應(yīng)用系統(tǒng)提供了可靠、高效的數(shù)據(jù)通信服務(wù)，又為網(wǎng)絡(luò)國源益通智能交通平臺 — GYYTITS解決方案 技術(shù)文件 北京國源益通軟件有限責(zé)任公司 01062410166/77 11 系統(tǒng)提供了實時管理和監(jiān)控的工具，同時還為編程人員提供了簡單、易用、功能強大的應(yīng)用開發(fā)接口，由于它對異構(gòu)網(wǎng)絡(luò)的透明性，并且保證消息的一次性可靠傳輸，對事 務(wù)的支持，有效的路由機制等特性，使得 MSMQ 特別適合開發(fā)分布的，松散耦合的 Windows 應(yīng)用程序。 MSMQ 技術(shù)是一種利用隊列機制實現(xiàn)部件間或者是應(yīng)用程序間通信的技術(shù)，它允許以異步、實時的方式相互傳遞信息。消息隊列是一種靈活而可靠的通信機制，并且適合于各種程序，開發(fā)人員并不需要了解許多的細節(jié)。 B. 產(chǎn)品 特性 ? 異步通信。 MSMQ 可以分布式組件并以一種異步方式進行通信，而不必擔(dān)心占用寶貴的網(wǎng)絡(luò)資源。 ? 消息路由可靠， MSMQ 保證消息只傳遞一次，這樣使兩個接收者不會意外地得到相同的消息，消息，也不會丟失。 ? 事務(wù)集成， MSMQ 可以自動地調(diào)用事務(wù)服務(wù)來保證數(shù)據(jù)的完整性。 ? 自動消息日志， MSMQ 日志保存發(fā)送和接收所有的消息，并且進行自動的審計跟蹤，發(fā)生錯誤時易于恢復(fù)。 ? 安全性， MSMQ 具有保密性、數(shù)字簽名等特性，能夠?qū)W(wǎng)絡(luò)上傳送的消息進行數(shù)字簽名及加密傳輸，而且在 MSMQ 服務(wù)端可以過濾掉未經(jīng)授權(quán)的消息，從而保證了安全性。 ? 優(yōu)先級， MSMQ 支持消息隊列優(yōu)先級機制，它將有選擇地傳送優(yōu)先級較高的消息，讓程序能夠優(yōu)先處理重要事件。 ? 協(xié)議無關(guān)性， MSMQ 消息的發(fā)送與網(wǎng)絡(luò)協(xié)議無關(guān)，只需提供消息隊列的名字即可實現(xiàn)消息的發(fā)送與接收。 Windows Server 2020 R2 / Windows 7 一起發(fā)布的 MSMQ 中，引入了下列的新功能： ? 處理大量隊列的能力 。 MSMQ 提供了處理大量隊列的能力。盡管 MSMQ 未對可創(chuàng)建的隊列數(shù)目實行特定限制，但當有數(shù)千個隊列時，還是會對性能造成負面影響。特別是將隊列加載到內(nèi)存中時，因隊列查找的算法，而大大增加了消息隊列服務(wù)的啟動時間。而對于Windows Server 2020 R Windows 7，已對消息隊列在啟動時使用的隊列查找算法進行了優(yōu)化，當系統(tǒng)上承載了大量隊列時，會顯著增 加消息隊列的啟動性能。 ? 更安全的身份驗證算法 ? MSMQ 支持安全哈希算法 （ SHA2） ，和 Windows Server 2020 R2 支持的所有高級哈希算法。默認設(shè)置為 SHA2，摘要長度為 512 位。由于 SHA消息摘要版本 2（ MD2） 、 MD國源益通智能交通平臺 — GYYTITS解決方案 技術(shù)文件 北京國源益通軟件有限責(zé)任公司 01062410166/77 12 MD5 和消息驗證代碼 （ MAC） 等算法，被認為不夠安全，因此默認情況下，對這些算法的支持在 MSMQ 中 處于禁 用狀 態(tài)。 若要 啟用 不夠安 全的 算法 ，必 須自 行添加WeakHashAlgorithms 注冊表項。 ActiveMQ 與 MSMQ 對比 1. 支持方式差異 . 發(fā)送內(nèi)容 ActiveMQ 可以發(fā)送值類型也可以發(fā)送引用類型，而 MSMQ 只能發(fā)送值類型。 . 消息格式 ActiveMQ MSMQ ITextMessage XmlMessageFormatter IMapMessage BinaryMessageFormatter IBytesMessage ActiveXMessageFormatter IObjectMessage IStreamMessage . 消息劃分 MSMQ 將消息劃分為 ? 用戶隊列 ? 公共隊列：在整個“消息隊列”網(wǎng)絡(luò)中復(fù)制，并且有可能由網(wǎng)絡(luò) 連接的所有站點訪問。 ? 專用隊列，不在整個網(wǎng)絡(luò)中發(fā)布。相反，它們僅在所駐留的本地計算機上可用。專用隊列只能由知道隊列的完整路徑名或標簽的應(yīng)用程序訪問。 ? 管理隊列，包含確認在給定“消息隊列”網(wǎng)絡(luò)中發(fā)送的消息回執(zhí)的消息。 ? 響應(yīng)隊列，包含目標應(yīng)用程序接收到消息時返回給發(fā)送應(yīng)用程序響應(yīng)消息。 ? 系統(tǒng)隊列 ? 日記隊列，可選地存儲發(fā)送消息的副本和從隊列中移除的消息副。 ? 死信隊列，存儲無法傳遞或已過期的消息的副本。 ? 報告隊列，包含指示消息到達目標所經(jīng)過的路由的消息，還可以含測試消息。每臺計算機上只能有一個報告隊列。 ? 專用系統(tǒng)隊 列，是一系列存儲系統(tǒng)執(zhí)行消息處理操作所需的管理和通知消息的專用隊列。 ActiveMQ 沒有類似的劃分 . 消息等級 國源益通智能交通平臺 — GYYTITS解決方案 技術(shù)文件 北京國源益通軟件有限責(zé)任公司 01062410166/77 13 ActiveMQ MSMQ Lowest = 0 Lowest = 0 VeryLow = 1 VeryLow = 1 Low = 2 Low = 2 AboveLow = 3 Normal = 3 BelowNormal = 4 AboveNormal = 4 Normal = 5 High = 5 AboveNormal = 6 VeryHigh = 6 High = 7 Highest = 7 VeryHigh = 8 Highest = 9 . ActiveMQ 支持軟件級別的負載均衡而 MSMQ 不支持。 . 共同支持機制 ? 都支持事務(wù) ? 都支持同步和異步兩種接收方式 ? 消息都具有快遞方式和可恢復(fù)方式（永久存儲）。 ? 快遞方式稍有差異。 MSMQ 的快遞方式只有在刪除、重啟機器的時候消息才會銷毀而ActiveMQ 可以設(shè)置保存一定時間后銷毀。 ? 都支持點對點和發(fā)布訂閱兩種模式 2. 性能對比 機器配置： CPU 雙核 ，內(nèi)存 + Windows2020 R2 . 啟動停機測試 ActiveMQ MSMQ 重啟測試： 20W 數(shù)據(jù)需要 1 分鐘， 100W 在 3 分鐘，200W 在 10 分鐘左右?；謴?fù)時間主要消耗在 kaha 上，如果使用 jdbc 存儲，所有恢復(fù)時間都在 1 分鐘之內(nèi)。 無論重啟或是停機在 20W， 100W 已及 200W 數(shù)據(jù)下都瞬間完成。但是清空百萬級別的隊列操作無法響應(yīng)，必須 KILL 進 程。（有時導(dǎo)致死機） 停機測試： ActiveMQ 停機速度很快，基本沒有出現(xiàn)過需要強制 kill 的情況 . 5 分鐘內(nèi) 25 個用戶發(fā)送性能測試對比 ActiveMQ MSMQ 隊列為空： ActiveMQ 發(fā)送 1k， 10K， 100K 發(fā)送總量為 5k， ， 平均每秒發(fā)送 19， 15， 15 25 個線程 1 分鐘 ActiveMQ 發(fā)送 1k， 10K， 100K 發(fā)送總量為 20w， 12w， 5K。 隊列為空： MSMQ 發(fā)送 1k， 10k， 100k 發(fā)送總量為 42w， 31w， 平均每秒發(fā)送 ， 1k， 286 隊列為 1W（時間為 1 分鐘）： 多線程 ActiveMQ 發(fā)送 1k， 10K， 100K 發(fā)送總量為隊列為 1W（時間為 1 分鐘）： MSMQ 發(fā)送接收 1k， 10k， 100k 發(fā)送總量為 ，國源益通智能交通平臺 — GYYTITS解決方案 技術(shù)文件 北京國源益通軟件有限責(zé)任公司 01062410166/77 14 17w， 12w， ， 平均每秒發(fā)送 956， 230， 20。 隊列為 10W（時間為 1 分鐘）： 多線程 ActiveMQ 發(fā)送 1k， 10K， 100K 發(fā)送總量為13w， 7w， 隊列為 10W（時間為 1 分鐘）： MSMQ 發(fā)送 1k， 10k， 100k 發(fā) 送總量為 ， ， 平均每秒發(fā)送 1k， 236， 19。 . 5 分鐘內(nèi) 25 個用戶發(fā)送接收性能對比 ActiveMQ MSMQ 隊列為空： ActiveMQ 發(fā)送并接收 1k， 10k， 100k 總量為 8W，4w， 6K，平均每秒 300， 100， 30 條 25 個線程 1 分鐘 Active 發(fā)送接收 1k， 10K， 100K 發(fā)送總量為 35w， 12w， 隊列為空： Msmq 發(fā)送并接收 1k， 10k， 100k 總量為 29w， ， 平均每秒 900， 250， 40 條 隊列為 1W（時間為 1 分鐘）： 多線程 ActiveMQ 發(fā)送接收