資源描述:
《activemq簡(jiǎn)述-java開(kāi)發(fā)java經(jīng)驗(yàn)技巧》由會(huì)員上傳分享,免費(fèi)在線閱讀,更多相關(guān)內(nèi)容在工程資料-天天文庫(kù)。
1、ActivcMQ簡(jiǎn)述-編程開(kāi)發(fā)技術(shù)ActiveMQ簡(jiǎn)述原文出處:朱小廝概述ActiveMQ是Apache所提供的一個(gè)開(kāi)源的消息系統(tǒng),完全采用Java來(lái)實(shí)現(xiàn),因此,它能很好地支持J2EE提出的JMS(JavaMessageService,即Java消息服務(wù))規(guī)范。JMS是一組Java應(yīng)用程序接1_1,它提供消息的創(chuàng)建、發(fā)送、讀取等一系列服務(wù)。JMS提供了一組公共應(yīng)用程序接口和響應(yīng)的語(yǔ)法,類(lèi)似于Java數(shù)據(jù)庫(kù)的統(tǒng)一訪問(wèn)接口JDBC,它是一種與廠商無(wú)關(guān)的API,使得Java程序能夠與不同廠商的消息組件很好地進(jìn)行通信。JMS支持兩種消
2、息發(fā)送和接收模型。—種稱(chēng)為P2P(PonittoPoint)模型,即釆用點(diǎn)對(duì)點(diǎn)的方式發(fā)送消息。P2P模型是基于隊(duì)列的,消息生產(chǎn)者發(fā)送消息到隊(duì)列,消息消費(fèi)者從隊(duì)列中接收消息,隊(duì)列的存在使得消息的異步傳輸稱(chēng)為可能,P2P模型在點(diǎn)對(duì)點(diǎn)的情況卜?進(jìn)行消息傳遞時(shí)采用。ConsumerProducerConsumerConsumerProducerQueueProducerConsumerConsumer另一種稱(chēng)為Pub/Sub(Publish/Subscribe,即發(fā)布-訂閱)模型,發(fā)布-訂閱模型定義了如何向一個(gè)內(nèi)容節(jié)點(diǎn)發(fā)布和訂閱消息,
3、這個(gè)內(nèi)容節(jié)點(diǎn)稱(chēng)為topic(主題)。主題可以認(rèn)為是消息傳遞的中介,消息發(fā)布這將消息發(fā)布到某個(gè)主題,而消息訂閱者則從主題訂閱消息。主題使得消息的訂閱者與消息的發(fā)布者互相保持獨(dú)立,不需要進(jìn)行接觸即可保證消息的傳遞,發(fā)布-訂閱模型在消息的一對(duì)多廣播時(shí)采用。ActiveMQ的安裝下載最新的安裝包apache-activemq-5.13.2-bin.tar.gz(此包linux下的,案例也是針對(duì)linux系統(tǒng)進(jìn)行闡述,當(dāng)然ActiveMQ也有win版的,這里就不贅述T),可以去官網(wǎng)下載,也可以在下方留言區(qū)留下你的郵箱,博主會(huì)發(fā)給你的~卜
4、載Z后角軍壓:tar-zvxfapache-activemq一5.13?2一bin.tar.gzActiveMQ口錄內(nèi)容有:?bin目錄包含ActiveMQ的啟動(dòng)腳木?confH錄包含ActiveMQ的所冇配置文件?data目錄包含日志文件和持久性消息數(shù)據(jù)?example:ActiveMQ的示例?lib:ActiveMQ運(yùn)行所需要的lib?webapps:ActiveMQ的web控制臺(tái)和一些相關(guān)的demo運(yùn)彳亍命令:activemqstart(在activcmq/bin下運(yùn)彳?。㊣NFO:LoadingJ/users/shr/
5、apache-activemq-5?13.2//bin/env'INFO:Usingjava,/users/shr/util/JavaDir/jdk/bin/java,INFO:Starting-inspectlogfilesspecifiedinlogging,propertiesandlog4j.propertiestogetdetai1sINFO:pidfilecreated:'/users/shr/apache-activemq-5?13.2//data/activemq.pid,(pid'986')shr9861.2
6、9.71281720201936pts/5SI19:430:17/users/shr/uti1/JavaDir/jdk/bin/java~Xms64M-XmxlG-Djava.util,logging.config.file=logging.properties-Djava.security,auth.login,config=/users/shr/apache-activemq-5.13.2//conf/login.config-Dcom.sun.management,jmxremote-Djava.awt.headless
7、二true-Djava.io.tmpdir=/users/shr/apache-activemq-5.13.2//tmp-Dactivemq.classpath=/users/shr/apache-activemq-5.13.2//conf:/users/shr/apache-activemq-5.13.2//??/lib/:-Dactivemq.home=/users/shr/apache-activemq-5.13.2/-Dactivemq.base=/users/shr/apache-activemq-5.13.2/-D
8、activemq.conf=/users/shr/apache-activemq-5.13.2//conf-Dactivemq.data=/users/shr/apache-activemq-5.13.2//data-jar/users/shr/apache-activemq