1.建立佇列管理器mqesb(1414)\qmesb1(1416)\qmesb2(1416)\qmgw(1410)\qmclient(1420)\
2.啟動佇列管理器
runmqsc qmesb(qmesb1、qmesb2)
3.設定佇列管理器偵聽並啟動(也可手動啟動)
define listener(listener.tcp) trptype(tcp) port(1414) control(qmgr)
define listener(listener.tcp) trptype(tcp) port(1415) control(qmgr)
define listener(listener.tcp) trptype(tcp) port(1416) control(qmgr)
4.建立集群儲存庫
此處為了方便管理,我們將集群的完全儲存庫放到閘道器伺服器上,在生產環境中,最好能設定兩個完全儲存庫
runmqsc qmgw
alter qmgr repos(qm_cluster)
end5.建立所有對列管理器的集群接收方通道
runmqsc qmesb
define channel(to.qmesb) chltype(clusrcvr) trptype(tcp) conname('10.0.1.19(1414)') cluster(qm_cluster)
endrunmqsc qmesb1
define channel(to.qmesb1) chltype(clusrcvr) trptype(tcp) conname('10.0.1.17(1415)') cluster(qm_cluster)
endrunmqsc qmesb2
define channel(to.qmesb2) chltype(clusrcvr) trptype(tcp) conname('10.0.1.18(1416)') cluster(qm_cluster)
endrunmqsc qmgw
define channel(to.qmgw) chltype(clusrcvr) trptype(tcp) conname('10.0.1.19(1410)') cluster(qm_cluster)
end6.建立所有其他非完全儲存庫到完全儲存庫的集**送方通道
runmqsc qmesb
define channel(to.qmgw) chltype(clussdr) trptype(tcp) conname('10.0.1.19(1410)') cluster(qm_cluster)
endrunmqsc qmesb1
define channel(to.qmgw) chltype(clussdr) trptype(tcp) conname('10.0.1.19(1410)') cluster(qm_cluster)
endrunmqsc qmesb2
define channel(to.qmgw) chltype(clussdr) trptype(tcp) conname('10.0.1.19(1410)') cluster(qm_cluster)
end7.建立集群成員的共享本地佇列
runmqsc qmesb
define qlocal(qecus.ibms.amss) cluster(qm_cluster)
define qlocal(qecus.amss.ibms) cluster(qm_cluster)
endrunmqsc qmesb1
define qlocal(qecus.ibms.amss) cluster(qm_cluster)
define qlocal(qecus.amss.ibms) cluster(qm_cluster)
endrunmqsc qmesb2
define qlocal(qecus.ibms.amss) cluster(qm_cluster)
define qlocal(qecus.amss.ibms) cluster(qm_cluster)
end8.建立閘道器別名佇列
runmqsc qmgw
define qremote(to_cluster_qm)
end9.建立客戶端和閘道器的連線
9.1 建立客戶端對列管理器,監聽(1420),本地佇列
runmqsc qmclient
define qlocal(qecus.ibms.amss_c)
define qlocal(qecus.amss.ibms_c)
end9.2 建立客戶端和閘道器的傳輸佇列
runmqsc qmclient
define qlocal(qmgw) usage(xmitq)
endrunmqsc qmgw
define qlocal(qmclient) usage(xmitq)
end9.3 建立客戶端和閘道器的接收方通道
runmqsc qmclient
define channel(ch_client_rcvr) chltype(rcvr) trptype(tcp)
endrunmqsc qmgw
define channel(ch_cluster_rcvr) chltype(rcvr) trptype(tcp)
end9.4 建立客戶端和閘道器的傳送方通道
runmqsc qmclient
define channel(ch_cluster_rcvr) chltype(sdr) trptype(tcp) conname('10.0.1.19(1410)') xmitq(qmgw)
start channel(ch_cluster_rcvr)
endrunmqsc qmgw
define channel(ch_client_rcvr) chltype(sdr
MQ 集群高可用
transaction 即事務機制,手動提交和回滾 confirm 機制提供了 confirmlistener 和waitforconfirms 兩種方式。confirm 機制效率明顯會高於 transaction 機制,但後者的優勢在於強一致性。如果沒有特別的要求,建議使用 conrim 機制。2...
MQ集群的日常維護
1 mq集群的日常監控 zabbix監控mq集群 簡訊報警 如果mq集群的佇列數量超過100000就會發簡訊報警 或者mq的服務出現故障也會傳送簡訊報警 備註 此處的管理埠是56721 2 面監控 登入zabbix監控頁面檢視是否有報警 3 zabbix系統自帶的管理頁面檢視 使用admin賬戶登入...
使用MQ要考慮的問題
一般現代軟體系統都會用到mq,幾乎所有開發人員也都會想到用mq,但真正能用好的人估計不多,因為要用好mq有很多方面問題要考慮 1 在原直接互動的系統間增加mq中間層,mq的效能 可靠程度會嚴重影響原系統的效能 可靠性。activemq,rabbitmq,kafka 有那麼多開源的mq可選,究竟哪個更...