MQ 是一款穩定、安全又可靠的消息傳遞中間件。它使用消息和隊列來支持應用程序、系統、服務和文件之間的信息交換。它可以簡化和加速多個平台中不同應用程序和業務數據的集成。支持各種 API 和語言,並可以在本地、雲和混合雲中部署。
建立消息隊列方法
1.在linux服務器192.168.0.151上新建兩個隊列管理器QM1:
mqm@mq:~> crtmqm QM1
2.啟動QM1
mqm@mq:~> strmqm QM1
3.運行MQSeries命令
runmqsc QM1
4.創建QM1的通道:MSG_CHL
DEFINE CHANNEL ('MSG_CHL') CHLTYPE(SVRCONN) +
TRPTYPE(TCP) +
DESCR(' ') +
HBINT(300) +
MAXMSGL(4194304) +
MCAUSER('mqm') +
RCVDATA(' ') +
RCVEXIT(' ') +
SCYDATA(' ') +
SCYEXIT(' ') +
SENDDATA(' ') +
SENDEXIT(' ') +
SSLCAUTH(REQUIRED) +
SSLCIPH(' ') +
SSLPEER(' ') +
KAINT(AUTO) +
MONCHL(QMGR) +
COMPMSG(NONE) +
COMPHDR(NONE) +
SHARECNV(10) +
MAXINST(999999999) +
MAXINSTC(999999999) +
REPLACE
5. 創建偵聽器:(端口號:7001)
DEFINE LISTENER ('LISTENER_TCP') +
TRPTYPE(TCP) +
IPADDR(' ') +
PORT(9000) +
BACKLOG(0) +
DESCR(' ') +
CONTROL(QMGR) +
REPLACE
6.創建QM2的隊列:MSG_QUE
DEFINE QLOCAL ('MSG_QUE') +
PUT(ENABLED) +
DEFPSIST(YES) +
DEFPRESP(SYNC) +
CLWLUSEQ(QMGR) +
SCOPE(QMGR) +
GET(ENABLED) +
PROPCTL(COMPAT) +
DEFREADA(NO) +
MAXDEPTH(20000) +
MAXMSGL(4194304) +
USAGE(NORMAL) +
NOTRIGGER +
TRIGTYPE(FIRST) +
QDPMAXEV(ENABLED) +
QDPHIEV(DISABLED) +
QDPLOEV(DISABLED) +
STATQ(QMGR) +
MONQ(QMGR) +
ACCTQ(QMGR) +
DEFBIND(OPEN) +
REPLACE
7.重啟消息隊列管理器
結束本地隊列管理器 endmqm MQ1
啟動本地隊列管理器 strmqm MQ1
若偵聽沒啟動,執行 runmqlsr LISTENER_TCP
8.發送報文測試 運行
mqm@mq:~/sh> amqsput QR QM1
輸入“this is a test!”,雙擊回車結束
9.通過隊列深度或日志查看消息是否成功發送到隊列上。
MQ腳本可查看下篇LR之MQ協議性能測試腳本