訊息中介軟體的學習

2021-09-09 06:19:29 字數 1729 閱讀 6954

使用者名稱密碼預設為admin

第二種以服務啟動

installservice.bat以管理員身份執行

服務中有activemq

linux

解壓壓縮包

進入bin 輸入 activemq start,啟動完成

系統環境變數配置

變數名:rocketmq_home

變數值:mq解壓路徑\mq資料夾名

啟動先啟動nameserver

cmd命令框執行進入至『mq資料夾\bin』下,然後執行『start mqnamesrv.cmd』,啟動nameserver。成功後會彈出提示框,此框勿關閉

然後啟動broker

cmd命令框執行進入至『mq資料夾\bin』下,然後執行『start mqbroker.cmd -n 127.0.0.1:9876 autocreatetopicenable=true』,啟動broker。成功後會彈出提示框,此框勿關閉。

關閉命令

.\mqshutdown namesrv

.\mqshutdown broker

import org.apache.rocketmq.client.exception.mqclientexception;

import org.apache.rocketmq.client.producer.defaultmqproducer;

import org.apache.rocketmq.client.producer.sendresult;

import org.apache.rocketmq.common.message.message;

/** * 傳送訊息

* created by on 2019/1/17.

*/public class producer

catch (exception e)

}producer.shutdown();

}}

執行後報錯,如下:

org.apache.rocketmq.client.exception.mqclientexception: no route info of this topic

解決辦法:將依賴版本修改為本地安裝版本,之後執行就會成功。

org.apache.rocketmq

rocketmq-client

4.3.3

執行結果如下:

sendresult [sendstatus=send_ok, msgid=c0a82ff1354858644d46560855f60000, offsetmsgid=c0a82ff100002a9f00000000000000b2, messagequeue=messagequeue [topic=topictest, brokername=houxia, queueid=2], queueoffset=0]

sendresult [sendstatus=send_ok, msgid=c0a82ff1354858644d46560856ec0001, offsetmsgid=c0a82ff100002a9f0000000000000164, messagequeue=messagequeue [topic=topictest, brokername=houxia, queueid=3], queueoffset=0]

個人發現個奇怪的事情,執行成功後將依賴修改為其他版本也可執行成功,原因目前未知。

將個人經歷分享給大家,謝謝!

中介軟體 訊息中介軟體學習總結

冪等 在程式設計中.乙個冪等操作的特點是其任意多次執行所產生的影響均與一次執行的影響相同。冪等函式,或冪等方法,是指可以使用相同引數重複執行,並能獲得相同結果的函式。這些函式 不會影響系統狀態,也不用擔心重複執行會對系統造成改變。例如,getusername 和settrue 函式就是乙個冪等函式....

訊息中介軟體

1.訊息的優先順序 2.訊息排序 3.訊息過濾 4.訊息持久化 5.訊息重試 6.事務的支援 7.broker滿 生產者,佇列,消費者 訊息佇列的優點 1 解耦2 非同步訊息,系統響應 在jms中,有兩種訊息模型 點對點模式和發布訂閱模式。1.在點對點模式中 有三種角色 1 訊息佇列,傳送者,接受者...

訊息中介軟體

如何理解訊息中介軟體?訊息中介軟體是儲存訊息的乙個容器,與資料庫不同的是資料庫儲存的資料是可以被修改的,而訊息中介軟體一般不會被修改 訊息中介軟體在消費的生產者與消費者產生,相當於乙個中間人的角色,提供了路由保證訊息的傳遞,如果消費者不能及時接收,訊息會保留下來,知道消費者上線 保證在存活期內 訊息...