通過訊息producer(生產者)傳送訊息,必須初始化就啟動
consumer(消費者)監控訊息佇列,接收並處理訊息,初始化就啟動
根專案pom.xml增加
4.1.0-incubating-snapshotrocketmq-client.version>
org.apache.rocketmqgroupid>
rocketmq-clientartifactid>
$version>
dependency>
service專案pom.xml增加
org.apache.rocketmqgroupid>
rocketmq-clientartifactid>
dependency>
config.properties配置
#rocketmq config
rocketmq.address=tgdev-mq.hrocloud
.com:9876
rocketmq.group
.log=tiangong_******
#tg test
#rocketmq.address=tgtest-mq.hrocloud.com:9876
#rocketmq.group.log=tiangong_syslog
context:component-scan>
訊息佇列MQ
目錄 一 簡介 二 為什麼需要訊息佇列 mq 三 介紹 訊息佇列 message queuing 在電腦科學中,是一種程序間通訊或同一程序間不同執行緒的通訊方式。廣義上講訊息佇列是解決分布式系統中,各個功能模組間的資訊傳遞通訊方式。與檔案傳輸和rpc相比,訊息佇列具有更好的平台無關性,並能夠很好地支...
MQ訊息佇列
1.解耦 系統a將userid寫到訊息佇列中,系統c和系統d從訊息佇列中拿資料。這樣有什麼好處?系統a只負責把資料寫到佇列中,誰想要或不想要這個資料 訊息 系統a一點都不關心。即便現在系統d不想要userid這個資料了,系統b又突然想要userid這個資料了,都跟系統a無關,系統a一點 都不用改。系...
MQ訊息佇列應用
很榮幸,原來一直聽說的訊息佇列終於在前段時間用到了自己的專案中。為什麼會用到訊息佇列?毫無疑問,當然是傳輸訊息。這裡訊息一般是一串字串,當然,訊息的含義很多,可以是 hello world 可以是 你吃飯了嗎?可以是一串正式的xml報文。也可以是乙個txt檔案或者xml檔案 在用active mq的...