1)創(chuàng)建消息隊(duì)列管理器(create mq manager)
crtmqm -q GW.QUEUE.MANAGER
2)啟動消息隊(duì)列管理器(start mq manager)
strmqm GW.QUEUE.MANAGER
3)運(yùn)行消息隊(duì)列腳本命令(run mq shell command)
runmqsc SMS.GW.QUEUE.MANAGER
定義隊(duì)列 和 通道
DEFINE QL (MYSQL.LOG.Q) DEFPSIST(YES) MAXDEPTH(100000)
DEFINE CHANNEL(MYSQL.LOG.C) CHLTYPE(SVRCONN) TRPTYPE(TCP)
DEFINE QL (ORACAL.LOG.Q) DEFPSIST(YES) MAXDEPTH(100000)
DEFINE CHANNEL(ORACAL.LOG.C) CHLTYPE(SVRCONN) TRPTYPE(TCP)
end
4)運(yùn)行消息隊(duì)列監(jiān)聽器(run mq listener)
runmqlsr -m GW.QUEUE.MANAGER -t TCP -p 1415 &
5)向隊(duì)列插入一條消息
amqsput? MYSQL.LOG.Q
回車,然后輸入您要插入的消息內(nèi)容,回車,再回車。 提示成功。
6)從隊(duì)列讀消息
amqsget MYSQL.LOG.Q
Trackback: http://tb.blog.csdn.net/TrackBack.aspx?PostId=626691