重裝上陣

作者 cctvx1
?關(guān)鍵字:ActiveMQ,實(shí)踐?

??? 一.安裝ActiveMQ

?????? 首先去http://activemq.apache.org/download.html 下載最新版本4.1.0release (http://activemq.apache.org/activemq-410-release.html),
??? 解壓apache-activemq-4.1-incubator.zip(或者apache-activemq-4.1-incubator.tar.gz)目錄如下:
??????
?????? +bin?????? (windows下面的bat和unix/linux下面的sh)
?????? +conf????? (activeMQ配置目錄,包含最基本的activeMQ配置文件)
?????? +data????? (默認(rèn)是空的)
?????? +docs????? (index,replease版本里面沒有文檔,-.-b不知道為啥不帶)
?????? +example?? (幾個例子
?????? +lib?????? (activemMQ使用到的lib)
?????? -apache-activemq-4.1-incubator.jar? (ActiveMQ的binary)
?????? -LICENSE.txt??????
?????? -NOTICE.txt???????
?????? -README.txt
?????? -user-guide.html

?????? 你可以使用bin\activemq.bat(activemq) 啟動,如果一切順利,你就會看見類似下面的信息
????? (細(xì)節(jié)可能不一樣,比如路徑,或者jmx,jdbc信息)

? ACTIVEMQ_HOME: D:\java\framework_and_lib\activemq\apache-activemq-4.1-incubator\
bin\..
Loading message broker from: xbean:activemq.xml
INFO? BrokerService????????????????? - ActiveMQ null JMS Message Broker (localho
st) is starting
INFO? BrokerService????????????????? - For help or more information please see:
http://incubator.apache.org/activemq/
INFO? ManagementContext????????????? - JMX consoles can connect to service:jmx:r
mi:///jndi/rmi://localhost:1099/jmxrmi
INFO? JDBCPersistenceAdapter???????? - Database driver recognized: [apache_derby
_embedded_jdbc_driver]
INFO? DefaultDatabaseLocker????????? - Attempting to acquire the exclusive lock
to become the Master broker
INFO? DefaultDatabaseLocker????????? - Becoming the master on dataSource: org.ap
ache.derby.jdbc.EmbeddedDataSource@1d840cd
INFO? JournalPersistenceAdapter????? - Journal Recovery Started from: Active Jou
rnal: using 5 x 20.0 Megs at: D:\java\framework_and_lib\activemq\apache-activemq
-4.1-incubator\activemq-data\journal
INFO? JournalPersistenceAdapter????? - Journal Recovered: 0 message(s) in transa
ctions recovered.
INFO? TransportServerThreadSupport?? - Listening for connections at: tcp://P-SUW
EI:61616
WARN? MulticastDiscoveryAgent??????? - brokerName not set
INFO? TransportConnector???????????? - Connector default Started
INFO? TransportServerThreadSupport?? - Listening for connections at: stomp://P-S
UWEI:61613
INFO? TransportConnector???????????? - Connector stomp Started
INFO? NetworkConnector?????????????? - Network Connector default Started
INFO? BrokerService????????????????? - ActiveMQ JMS Message Broker (localhost, I
D:P-SUWEI-1207-1170916242296-1:0) started?????

???????? *。幾個小提示
? 1. 這個僅僅是最基礎(chǔ)的ActiveMQ的配置,很多地方都沒有配置因此不要直接使用這個配置用于生產(chǎn)系統(tǒng)
? 2. 有的時候由于端口被占用,導(dǎo)致ActiveMQ錯誤,ActiveMQ可能需要以下端口1099(JMX),61616(默認(rèn)的TransportConnector)
? 3. 如果沒有物理網(wǎng)卡,或者M(jìn)S的LoopBackAdpater Multicast會報(bào)一個錯誤

???? 二. 測試你的ActiveMQ
???????
????????? 由于ActiveMQ是一個獨(dú)立的jms provider,所以我們不需要其他任何第三方服務(wù)器就可以馬上做我們的測試了.編譯
???? example目錄下面的程序
?????????
?? ProducerTool/ConsumerTool 是JMS參考里面提到的典型應(yīng)用,Producer產(chǎn)生消息,Consumer消費(fèi)消息
?? 而且這個例子還可以加入?yún)?shù)幫助你測試剛才啟動的本地ActiveMQ或者是遠(yuǎn)程的ActiveMQ

?? ProducerTool [url] broker的地址,默認(rèn)的是tcp://localhost:61616
??????????????? [true|flase] 是否使用topic,默認(rèn)是false
???????? [subject] subject的名字,默認(rèn)是TOOL.DEFAULT
???????? [durabl] 是否持久化消息,默認(rèn)是false
???????? [messagecount] 發(fā)送消息數(shù)量,默認(rèn)是10
???????? [messagesize] 消息長度,默認(rèn)是255
???????? [clientID] durable為true的時候,需要配置clientID
???????? [timeToLive] 消息存活時間
???????? [sleepTime] 發(fā)送消息中間的休眠時間
???????? [transacte]? 是否采用事務(wù)

?????????
????????? ConsumerTool [url] broker的地址,默認(rèn)的是tcp://localhost:61616
??????????????? [true|flase] 是否使用topic,默認(rèn)是false
???????? [subject] subject的名字,默認(rèn)是TOOL.DEFAULT
???????? [durabl] 是否持久化消息,默認(rèn)是false
???????? [maxiumMessages] 接受最大消息數(shù)量,0表示不限制
???????
???????? [clientID] durable為true的時候,需要配置clientID
????????
???????? [transacte]? 是否采用事務(wù)
???????? [sleepTime]? 接受消息中間的休眠時間,默認(rèn)是0,onMeesage方法不休眠
???????? [receiveTimeOut] 接受超時

????????? 我們這樣可以使用:
?? java -classpath .\apache-activemq-4.1-incubator.jar;example\bin ProducerTool? tcp://192.168.3.142:61616 test.mysubject
?? java -classpath .\apache-activemq-4.1-incubator.jar;example\bin ConsumerTool? tcp://192.168.3.142:61616 test.mysubject

?? 當(dāng)然你可以使用上面的參數(shù)進(jìn)行更復(fù)雜的測試,持久,事務(wù)

?? 如果出現(xiàn)下面的信息,恭喜你,你的ActiveMQ已經(jīng)能夠工作了
????????
? Connecting to URL: tcp://192.168.3.142:61616
? Publishing a Message with size 255 to queue: TOOL.DEFAULT
? Using non-durable publishing
? Sleeping between publish 0 ms
? Sending message: Message: 0 sent at: Thu Feb 08 15:05:34 CST 2007? ...
? Sending message: Message: 1 sent at: Thu Feb 08 15:05:34 CST 2007? ...
???????? 。。。。。。。。

? Connecting to URL: tcp://192.168.3.142:61616
? Consuming queue: test.mysubject
???????? Using non-durable subscription
???????? Received: Message: 0 sent at: Thu Feb 08 14:51:34 CST 2007? ...
???????? Received: Message: 1 sent at: Thu Feb 08 14:51:34 CST 2007? ...
? 。。。。

???????? 三.小結(jié)
?????
????? 我們已經(jīng)下載,啟動,并且用程序測試了我們的ActiveMQ,而后面將在這個能跑得ActiveMQ進(jìn)一步的走下去,一步一步展示ActiveMQ的高級特性。

?? 作者cctvx1
?? 關(guān)鍵字:ActiveMQ,實(shí)踐
???
?? 一.ActiveMQ是什么??
????? ActiveMQ is the most popular and powerful open source Message Bus.
???????????????????????????????????????????????? 引用ActiveMQ官方網(wǎng)站

???? ActiveMQ 是一個完全支持JMS1.1和J2EE 1.4規(guī)范的 JMS Provider實(shí)現(xiàn),盡管JMS規(guī)范出臺
已經(jīng)是很久的事情了,但是JMS在當(dāng)今的J2EE應(yīng)用中間仍然扮演著特殊的地位。
??? 下面是它的特性列表 (詳細(xì)的特性清單請參考http://activemq.apache.org/features.html)
?? ?1.多種語言和協(xié)議編寫客戶端
?? ??語言: Java, C, C++, C#, Ruby, Perl, Python, PHP
????? ??應(yīng)用協(xié)議: OpenWire,Stomp REST,WS Notification,XMPP,AMQP
?? ?2.完全支持JMS1.1和J2EE 1.4規(guī)范? (持久化,XA消息,事務(wù))
?? ?3.對Spring的支持,ActiveMQ可以很容得內(nèi)嵌到使用Spring的系統(tǒng)里面去,而且也支持Spring2.0的特性
?????? 4.通過了常見J2EE服務(wù)器(如 Geronimo,JBoss 4, GlassFish,WebLogic)的測試,其中通過JCA 1.5 resource adaptors的配置,
????? 可以讓ActiveMQ可以自動的部署到任何兼容J2EE 1.4 商業(yè)服務(wù)器上
?????? 5.支持多種傳送協(xié)議:in-VM,TCP,SSL,NIO,UDP,JGroups,JXTA
?????? 6.支持通過JDBC和journal提供高速的消息持久化
?????? 7.從設(shè)計(jì)上保證了高性能的集群,客戶端-服務(wù)器,點(diǎn)對點(diǎn)
?????? 8.支持Ajax
?????? 9.支持與Axis的整合
?????? 10.可以很容易得調(diào)用內(nèi)嵌JMS provider,進(jìn)行測試
??????
???? 二.ActiveMQ的競爭者???
???????
??????? 1.其他開源 JMS provider(資料來自 java-source.net) :
??????? jbossmq(jboss 4)
??????? jboss messaging (jboss 5)
??????? joram-4.3.21? 2006-09-22
??????? openjms-0.7.7-alpha-3.zip December 26, 2005
??????? mantamq 官網(wǎng)暫時無法訪問
??????? ubermq? 官網(wǎng)暫時無法訪問
??????? SomnifugiJMS? 2005-7-27
?????????? 開源的JMS Provider大部分都已經(jīng)停止發(fā)展了,剩下的幾個都是找到了東家,和某種J2EE 服務(wù)器掛鉤,
??????? 比如jboss mq 與jboss,joram與jonas(objectweb組織),ActiveMQ 與Geronimo(ASF APACHE基金組織),
??????? 而在這3個之間，從網(wǎng)絡(luò)底層來看,只有ActiveMQ使用了NIO,單從這個角度來看ActiveMQ在性能上會有
??????? 一定的優(yōu)勢??????

??????? 2.商業(yè)JMS provider
??????? IBM WebSphere MQ
??????? BEA WebLogic JMS
??????? Oracle AQ
??????? NonStop Server for Java Message Service(JMS)
??????? Sun Java System Message Queue
??????? Sonic jms
??????? TIBCO Enterprise For JMS
??????? iLinkMQ (國內(nèi))
?????????? 現(xiàn)在的商業(yè)J2EE 應(yīng)用服務(wù)器大部分都會有JMS Provider的實(shí)現(xiàn),畢竟應(yīng)用服務(wù)器都已經(jīng)花費(fèi)不薄,也不在乎
??????? 在里面送一個JMS Provider了,當(dāng)然還是有獨(dú)立的比如IBM WebSphere MQ,Sonic JMS ,前者肯定是商用MQ
?????? （這個概念不僅僅是JMS Provier了，只能說JMS 只是它提供的一個應(yīng)用）中間的巨無霸了。
???????
???????? 從這點(diǎn)來看,ActiveMQ明顯的競爭者并不多,因?yàn)樗亲鳛楠?dú)立的開源JMS Provider出現(xiàn)的,很容易被用于多種結(jié)構(gòu)設(shè)計(jì)中，
??????? 使用ActiveMQ作為默認(rèn)JMS Provider的開源項(xiàng)目有ServiceMix,Geronimo.
?
?????????????????????????????????????????????????????????????????????????????????????????????? (待續(xù))
??????? P.S
??????????? Monday, February 5, 2007
????? Apache ActiveMQ graduates from the incubator?
????? Apache ActiveMQ has now graduated to become a top level project (TLP) at Apache! Its new site is now hosted at http://activemq.apache.org/. Many thanks to all those in the Incubator and ActiveMQ communities for making this happen!