2. 程式人生 > >IBM WebSphere MQ 在AIX環境服務端和模擬客戶端配置步驟

IBM WebSphere MQ 在AIX環境服務端和模擬客戶端配置步驟

阿新 • • 發佈：2019-01-01

                           IBM WebSphere MQ 在AIX環境配置服務端和模擬客戶端的步驟

首先，配置AIX的本地服務端佇列管理器，建立接收佇列、接收通道、傳送佇列、遠端傳送佇列、遠端傳送通道，建立監聽等。

其次，在本地配製另一佇列管理器，模擬WINDOWS客戶端或者遠端MQ伺服器，與本地服務端佇列管理器進行通訊。配置步驟基本同本地的服務端相同，對應好兩邊的通道，佇列，監聽埠即可。

這樣就省了WIiNDOWS客戶端或者遠端MQ伺服器等另外一臺機器的安裝。

具體步驟如下：

 *********************************
------一、   AIX的本地服務端配置

*********
Aix下建立mq佇列的步驟說明
1. 安裝mqm程式包
2. 建立佇列管理器：QMECDS，注意/usr/mqm/log/是日誌存放路徑，要求mqm使用者有寫許可權。
#crtmqm -ld /usr/mqm/log/ -lc -lp 10 -ls 5 QMECDS

3. 啟動佇列管理器
#strmqm QMECDS

4. 進行佇列管理器命令窗
#runmqsc QMECDS

5. 建立一個接收佇列（本地）:ECDS_RCVL
def ql(ECDS_RCVL) maxdepth(10000) defpsist(yes) replace

6. 建立一個接收通道: ECDS_CHLR   應對對方的遠端傳送通道
def chl(TEST_CHLR) chltype(rcvr) trptype(tcp) replace

7. 建立一個傳送佇列（本地）: ECDS_SNDL
def ql(ECDS_SNDL) usage(XMITQ) defpsist(YES) maxdepth(10000) trigger trigtype(FIRST) trigdata(ECDS_CHLS) initq(SYSTEM.CHANNEL.INITQ) replace

8. 建立一個傳送佇列（遠端）: ECDS_SNDR，注意TEST_RCVL,QMTEST是對方模擬器的本地接收佇列，與佇列管理器名。
def qr(ECDS_SNDR) rname(TEST_RCVL) rqmname(QMTEST) xmitq ( ECDS_SNDL ) defpsist(yes) replace

9. 建立一個傳送通道: ECDS_CHLS
def chl(ECDS_CHLS) chltype(SDR) conname('130.1.9.126(9000)') xmitq(ECDS_SNDL) trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace

10. 建立一個偵聽器
def listener(ECDS_LISTEN) TRPTYPE(TCP) PORT(9001) CONTROL(MANUAL) BACKLOG(0)
start listener(ECDS_LISTEN)

11. 建立一個死信佇列
def ql(DEADQ) defpsist(yes) maxdepth(20000) replace
alter qmgr deadq(DEADQ)

12. 建立一個錯誤佇列
def ql(ERRMSG) defpsist(yes) maxdepth(20000) replace

13. 修改ccsid為1386，否則無法將傳輸特殊漢字如：弢
alter qmgr force ccsid(1386)

14. 退出mq命令窗
end
15. 重啟mqm
endmqm QMECDS
strmqm QMECDS
16. 

*********************
**  二、 模擬客戶端配置
*********************
2. 建立佇列管理器：QMtest，注意/usr/mqm/log/是日誌存放路徑，要求mqm使用者有寫許可權。
#crtmqm -ld /usr/mqm/log/ -lc -lp 10 -ls 5 QMTEST

3. 啟動佇列管理器
#strmqm QMTEST

4. 進行佇列管理器命令窗
#runmqsc QMTEST

5. 建立一個接收佇列（本地）:TEST_RCVL
def ql(TEST_RCVL) maxdepth(10000) defpsist(yes) replace

6. 建立一個接收通道: ECDS_CHLS      應對對方的遠端通道
def chl(ECDS_CHLS) chltype(rcvr) trptype(tcp) replace

7. 建立一個傳送佇列（本地）: TEST_SNDL
def ql(TEST_SNDL) usage(XMITQ) defpsist(YES) maxdepth(10000) trigger trigtype(FIRST) trigdata(TEST_CHLR) initq(SYSTEM.CHANNEL.INITQ) replace

8. 建立一個傳送佇列（遠端）: TEST_SNDR，注意ECDS_RCVL,QMECDS是對方模擬器的本地接收佇列，與佇列管理器名。
def qr(TEST_SNDR) rname(ECDS_RCVL) rqmname(QMECDS) xmitq ( TEST_SNDL ) defpsist(yes) replace

9. 建立一個傳送通道:ECDS_CHLR 對應對方接收通道。
def chl(TEST_CHLR) chltype(SDR) conname('130.1.9.126(9001)') xmitq(TEST_SNDL) trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace

10. 建立一個偵聽器
def listener(TEST_LISTEN) TRPTYPE(TCP) PORT(9000) CONTROL(MANUAL) BACKLOG(0)
start listener(TEST_LISTEN)

11. 建立一個死信佇列
def ql(TEST_DEADQ) defpsist(yes) maxdepth(20000) replace
alter qmgr deadq(TEST_DEADQ)

12. 建立一個錯誤佇列
def ql(TEST_ERRMSG) defpsist(yes) maxdepth(20000) replace

13. 修改ccsid為1386，否則無法將傳輸特殊漢字如：弢
alter qmgr force ccsid(1386)

14. 退出mq命令窗
end

15. 重啟mqm
endmqm QMTEST
strmqm QMTEST
***************************
******三、   AIX的本地服務端配置步驟執行結果
 $ pwd
/usr/mqm/bin
$ crtmqm -ld /usr/mqm/log/ -lc -lp 10 -ls 5 QMECDS
WebSphere MQ queue manager created.
Creating or replacing default objects for QMECDS.
Default objects statistics : 40 created. 0 replaced. 0 failed.
Completing setup.
Setup completed.
$ strmqm QMECDS
WebSphere MQ queue manager 'QMECDS' starting.
5 log records accessed on queue manager 'QMECDS' during the log replay phase.
Log replay for queue manager 'QMECDS' complete.
Transaction manager state recovered for queue manager 'QMECDS'.
WebSphere MQ queue manager 'QMECDS' started.
$ runmqsc QMECDS
5724-H72 (C) Copyright IBM Corp. 1994, 2005.  ALL RIGHTS RESERVED.
Starting MQSC for queue manager QMECDS.


def ql(ECDS_RCVL) maxdepth(10000) defpsist(yes) replace
     1 : def ql(ECDS_RCVL) maxdepth(10000) defpsist(yes) replace
AMQ8006: WebSphere MQ queue created.
def chl(TEST_CHLR) chltype(rcvr) trptype(tcp) replace
     2 : def chl(TEST_CHLR) chltype(rcvr) trptype(tcp) replace
AMQ8014: WebSphere MQ channel created.
def ql(ECDS_SNDL) usage(XMITQ) defpsist(YES) maxdepth(10000) trigger trigtype(FIRST) trigdata(ECDS_CHLS) initq(SYSTEM.CHANNEL.INITQ) replace
     3 : def ql(ECDS_SNDL) usage(XMITQ) defpsist(YES) maxdepth(10000) trigger trigtype(FIRST) trigdata(ECDS_CHLS) initq(SYSTEM.CHANNEL.INITQ) replace
AMQ8006: WebSphere MQ queue created.
def qr(ECDS_SNDR) rname(TEST_RCVL) rqmname(QMTEST) xmitq ( ECDS_SNDL ) defpsist(yes) replace
     4 : def qr(ECDS_SNDR) rname(TEST_RCVL) rqmname(QMTEST) xmitq ( ECDS_SNDL ) defpsist(yes) replace
AMQ8006: WebSphere MQ queue created.
def chl(ECDS_CHLS) chltype(SDR) conname('130.1.9.126(9000)') xmitq(ECDS_SNDL) trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace
     5 : def chl(ECDS_CHLS) chltype(SDR) conname('130.1.9.126(9000)') xmitq(ECDS_SNDL) trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace
AMQ8014: WebSphere MQ channel created.
def listener(ECDS_LISTEN) TRPTYPE(TCP) PORT(9001) CONTROL(MANUAL) BACKLOG(0)
     6 : def listener(ECDS_LISTEN) TRPTYPE(TCP) PORT(9001) CONTROL(MANUAL) BACKLOG(0)
AMQ8626: WebSphere MQ listener created.
start listener(ECDS_LISTEN)
     7 : start listener(ECDS_LISTEN)
AMQ8021: Request to start WebSphere MQ Listener accepted.
def ql(DEADQ) defpsist(yes) maxdepth(20000) replace
     8 : def ql(DEADQ) defpsist(yes) maxdepth(20000) replace
AMQ8006: WebSphere MQ queue created.
alter qmgr deadq(DEADQ)
     9 : alter qmgr deadq(DEADQ)
AMQ8005: WebSphere MQ queue manager changed.
def ql(ERRMSG) defpsist(yes) maxdepth(20000) replace
    10 : def ql(ERRMSG) defpsist(yes) maxdepth(20000) replace
AMQ8006: WebSphere MQ queue created.
alter qmgr force ccsid(1386)
    11 : alter qmgr force ccsid(1386)
AMQ8005: WebSphere MQ queue manager changed.
end
    12 : end
11 MQSC commands read.
No commands have a syntax error.
All valid MQSC commands were processed.
$ endmqm QMECDS
Quiesce request accepted. The queue manager will stop when all outstanding work
is complete.
$ strmqm QMECDS
WebSphere MQ queue manager 'QMECDS' starting.
5 log records accessed on queue manager 'QMECDS' during the log replay phase.
Log replay for queue manager 'QMECDS' complete.
Transaction manager state recovered for queue manager 'QMECDS'.
WebSphere MQ queue manager 'QMECDS' started.
$
*******************************************************
****** 四、 模擬客戶端配置步驟執行結果

$ crtmqm -ld /usr/mqm/log/ -lc -lp 10 -ls 5 QMTEST
WebSphere MQ queue manager created.
Creating or replacing default objects for QMTEST.
Default objects statistics : 40 created. 0 replaced. 0 failed.
Completing setup.
Setup completed.
$ strmqm QMTEST
WebSphere MQ queue manager 'QMTEST' starting.
5 log records accessed on queue manager 'QMTEST' during the log replay phase.
Log replay for queue manager 'QMTEST' complete.
Transaction manager state recovered for queue manager 'QMTEST'.
WebSphere MQ queue manager 'QMTEST' started.

$ runmqsc QMTEST
5724-H72 (C) Copyright IBM Corp. 1994, 2005.  ALL RIGHTS RESERVED.
Starting MQSC for queue manager QMTEST.


def ql(TEST_RCVL) maxdepth(10000) defpsist(yes) replace
     1 : def ql(TEST_RCVL) maxdepth(10000) defpsist(yes) replace
AMQ8006: WebSphere MQ queue created.

       :
def chl(ECDS_CHLS) chltype(rcvr) trptype(tcp) replace
     2 : def chl(ECDS_CHLS) chltype(rcvr) trptype(tcp) replace
AMQ8014: WebSphere MQ channel created.

       :
def ql(TEST_SNDL) usage(XMITQ) defpsist(YES) maxdepth(10000) trigger trigtype(FIRST) trigdata(TEST_CHLR) initq(SYSTEM.CHANNEL.INITQ) replace
     3 : def ql(TEST_SNDL) usage(XMITQ) defpsist(YES) maxdepth(10000) trigger trigtype(FIRST) trigdata(TEST_CHLR) initq(SYSTEM.CHANNEL.INITQ) replace
AMQ8006: WebSphere MQ queue created.

       :
def qr(TEST_SNDR) rname(ECDS_RCVL) rqmname(QMECDS) xmitq ( TEST_SNDL ) defpsist(yes) replace
     4 : def qr(TEST_SNDR) rname(ECDS_RCVL) rqmname(QMECDS) xmitq ( TEST_SNDL ) defpsist(yes) replace
AMQ8006: WebSphere MQ queue created.

       :
def chl(TEST_CHLR) chltype(SDR) conname('130.1.9.126(9001)') xmitq(TEST_SNDL) trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace
     5 : def chl(TEST_CHLR) chltype(SDR) conname('130.1.9.126(9001)') xmitq(TEST_SNDL) trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace
AMQ8014: WebSphere MQ channel created.

       :
def listener(TEST_LISTEN) TRPTYPE(TCP) PORT(9000) CONTROL(MANUAL) BACKLOG(0)
     6 : def listener(TEST_LISTEN) TRPTYPE(TCP) PORT(9000) CONTROL(MANUAL) BACKLOG(0)
AMQ8626: WebSphere MQ listener created.

       :
start listener(TEST_LISTEN)
     7 : start listener(TEST_LISTEN)
AMQ8021: Request to start WebSphere MQ Listener accepted.

       :
def ql(TEST_DEADQ) defpsist(yes) maxdepth(20000) replace
     8 : def ql(TEST_DEADQ) defpsist(yes) maxdepth(20000) replace
AMQ8006: WebSphere MQ queue created.

       :
alter qmgr deadq(TEST_DEADQ)
     9 : alter qmgr deadq(TEST_DEADQ)
AMQ8005: WebSphere MQ queue manager changed.

       :
def ql(TEST_ERRMSG) defpsist(yes) maxdepth(20000) replace
    10 : def ql(TEST_ERRMSG) defpsist(yes) maxdepth(20000) replace
AMQ8006: WebSphere MQ queue created.

       :
alter qmgr force ccsid(1386)
    11 : alter qmgr force ccsid(1386)
AMQ8005: WebSphere MQ queue manager changed.

       :
end
    12 : end
11 MQSC commands read.
No commands have a syntax error.
All valid MQSC commands were processed

$ endmqm QMTEST
Quiesce request accepted. The queue manager will stop when all outstanding work
is complete.

$ strmqm QMTEST
WebSphere MQ queue manager 'QMTEST' starting.
5 log records accessed on queue manager 'QMTEST' during the log replay phase.
Log replay for queue manager 'QMTEST' complete.
Transaction manager state recovered for queue manager 'QMTEST'.
WebSphere MQ queue manager 'QMTEST' started.
$
*******************************************************
**************************************
------ 五、測試    2010年09月08   測試完成 ------
A、aix伺服器端
$ ./amqsput ECDS_SNDR QMECDS
Sample AMQSPUT0 start
target queue is ECDS_SNDR
qweasd123456
86970

Sample AMQSPUT0 end

$ ./amqsget ECDS_RCVL QMECDS
Sample AMQSGET0 start
message <123456 >
message <OK>

no more messages
Sample AMQSGET0 end

B、模擬客戶端
$ ./amqsget TEST_RCVL QMTEST
Sample AMQSGET0 start
message <qweasd123456>
message <86970>

no more messages
Sample AMQSGET0 end

$ ./amqsput TEST_SNDR QMTEST
Sample AMQSPUT0 start
target queue is TEST_SNDR
123456
OK

Sample AMQSPUT0 end
$

**************************************

**** 六、其他相關命令


    刪除佇列管理器

    dltmqm QmgrName

    啟動佇列管理器

    strmqm QmgrName

    如果是啟動預設的佇列管理器，可以不帶其名字

    停止佇列管理器

    endmqm QmgrName 受控停止

    endmqm – i QmgrName 立即停止

    endmqm – p QmgrName 強制停止

    顯示佇列管理器

    dspmq –m QmgrName

*******************************************************

 轉貼請註明出處。

相關推薦

IBM WebSphere MQ 在AIX環境服務端和模擬客戶端配置步驟

                           IBM WebSphere MQ 在AIX環境配置服務端和模擬客戶端的步驟 首先，配置AIX的本地服務端佇列管理器，建立接收佇列、接收通道、傳送佇列、遠端傳送佇列、遠端傳送通道，建立監聽等。 其次，在本地配製另一佇列管理器

ElasticSearch入門 - 安裝es服務端和Kibana客戶端

ElasticSearch是什麼？？ 和Lucene一樣,都是用來做全文檢索(建立索引和搜尋索引).只是lucene是全文檢索工具包,而ES是全文搜尋伺服器 為什麼要用全文檢索？  -->   以基於索引的搜尋代替資料庫模糊查詢,增強查詢效率

Delphi服務端和PHP客戶端通過Socket通訊

在開始之前看下效果 PHP頁面作為客戶端傳送請求給作為服務端的Delphi應用程式 PHP客戶端頁面開啟如下 Delphi服務端應用程式開啟如下 每次PHP頁面重新整理一下，Delphi的文字框都顯示"我上線啦！"做的很粗糙，但是似乎可以作為某種功能的demo PHP

SVN 服務端 和 TortoiseSVN客戶端的搭建以及使用

連結地址在這裡 ，作者寫的實在是太好了 注意 ： 如果報 item is out  of date ,一般都是表示產生了衝突，這個時候，應該先 update ,再解決衝突後提交 這裡再寫點上面沒有注意到的點東西: 在使用SVN進行版本提交時，經常容易出現離線狀態，這個

UDP 多執行緒服務端 和 簡單客戶端

首先來了解UDP協議的幾個特性 （1）UDP是一個無連線協議，傳輸資料之前源端和終端不建立連線，當UDP它想傳送時就簡單地去抓取來自應用程式的資料，並儘可能快地把它扔到網路上。在傳送端，UDP傳送資料的速度僅僅是受應用程式生成資料的速度、計算機的能力和傳輸頻寬的限制；在接收

Socket通訊——C++伺服器端和Java客戶端

//更新 這件事可以用現有的序列化框架來做 比如 protobuf 一句話來說就是，C++和Java 通過socket進行通訊、資料傳輸，通過傳送“位元組流”即可。 位元組對於C++和java來說是通用的，但是傳輸的過程有許多問題需要注意，我為了弄清楚這個過程，查了一些資料

IBM WebSphere MQ介紹安裝以及配置服務詳解

類型 linq 進入 stack 系統默認 this env suse enable 首先介紹一下MQ MQ消息隊列的簡稱是一種應用程序對應用程序的通信方法。說白了也就是通過隊列的方式來對應用程序進行數據通信。而無需專用鏈接來鏈接它們。 MQ的通訊方式

安裝和使用 IBM WebSphere MQ for Linux

第一步 安裝IBM WebSphere MQ for Linux 第二步 配置 1、 vi /var/mqm/.bash_profile  #編輯bash_profile檔案 PATH=$PATH:/opt/mqm/samp/bin:/opt/mqm/bin:bin:/

angular2^ typescript 將 文件和Json數據 合並發送到服務器（1.客戶端處理）

src ica div .html web ready 進行 form med 首先介紹下框架基本流程 （web > webservice 【前端架構】 ） > （nodejs 【 數據中轉站 】） >（api 【後臺接口】） --web （htm

IBM WebSphere MQ 7.5基本用法

所在 linux 方式 exc channel 同步 攔截 nts nec 一、下載7.5 Trial版本 http://www.ibm.com/developerworks/downloads/ws/wmq/ 這是下載網址，下載前先必須註冊IBM ID，下載完成後

ORACLE 全綠色版的PL/SQL和Oracle客戶端配置-打造綠色Oracle開發環境

 全綠色版的PL/SQL和Oracle客戶端配置-打造綠色Oracle開發環境 我的環境： win7 64 Oracle 10g伺服器、也有11g的，都可以用。 1、準備軟體 PL/SQL Developer 9.0.5.1648 綠色版註冊版 instantclient-basi

使用TCP協議，分別編寫服務端和客戶端，要求客戶端向服務端上傳檔案。(使用字元流完成)

package Test; import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.FileReader; import java.io.IOException; import java.io

.net core ——微服務內通訊Thrift和Http客戶端響應比較

目錄 1、Benchmark介紹 2、測試下微服務訪問效率 3、結果 引用連結 1、Benchmark介紹 wiki中有定義：基準測試是執行計算機程式，一組程式或其他操作的行為，以便評估物件的相對效能，通常是通過對其執行許

Linux下RocketMQ服務端和客服端安裝

Linux下RocketMQ服務端和客服端安裝 安裝條件 jdk 1.8+ Maven 3.0.5 .64位Linux系統 下載和安裝   使用xshell將下載的安裝包上傳到linux系統      

（java）IBM websphere MQ 通過PCF_CommonMethods在佇列管理器中建立佇列

IBM MQ的例子網上有很多，但是全部都是不能通過java程式碼建立佇列的，自己研究了兩天終於找到方法了 在這分享出來。 其實很簡單，在IBM MQ的安裝目錄 C:\Program Files\IBM\WebSphere MQ\Tools\pcf\samples PCF_Common

linux系統下安裝配置telnet服務和telnet客戶端

Telnet 是一種流行的用於通過 Internet 登入到遠端計算機的協議。Telnet 伺服器軟體包為遠端登入主機提供了支援。要通過 Telnet 協議與另一臺主機通訊， 您可以使用名稱或 Internet 地址格式（如 192.168.1.10）與主機聯絡。Telnet 使用命令列提示。 使用 Tel

.net core ——微服務內通信Thrift和Http客戶端響應比較

知識 type 高並發 要求 generic marker work nag comm 原文:.net core ——微服務內通信Thrift和Http客戶端響應比較 目錄1、B

node.js中ws模組建立服務端和客戶端，網頁客戶端

1.node.js中ws模組建立服務端// 載入node上websocket模組 ws; var ws = require("ws"); // 啟動基於websocket的伺服器,監聽我們的客戶端接入

對比分析--淺析SSR(服務端渲染)和SPA(客戶端渲染)

一、前言 C端專案重構成首屏服務端渲染（SSR：serve side render），對於重構成SSR，redux不是必須的。本文以vue為栗子的專案。   二、什麼是服務端渲染 將元件或頁面通過伺服器生成html字串，再發送到瀏覽器，最後將靜態標記"混合"為客戶端上完全互動的應用程式。

PL/SQL Developer 和 instantclient客戶端安裝配置

post 變量名 adding clas 解壓 margin 11g 環境變量設置 select PL/SQL Developer 和 instantclient客戶端安裝配置 　　oracle的安裝我就不寫了，不會安裝的網上隨便找一個教程就能裝上，安裝起來比