MQ中將訊息傳送至遠端佇列的配置

2021-08-23 15:02:27 字數 4609 閱讀 7984

mq

中將訊息傳送至遠端佇列的配置

摘自mq資源管理器幫助文件v7

在開始學習本教程之前,您需要從系統管理員處了解標識網路上接收機器的名稱:ip位址、mq的埠號、佇列管理器、接收(遠端機器)或者是傳送的佇列(本地機器)名稱

訊息傳遞如圖示:

您將在傳送機器上設定佇列管理器和佇列(遠端佇列定義和傳輸佇列)。然後定義訊息通道。最後,您將把測試訊息放入傳送機器,並從接收機器上的佇列獲取該訊息。

完成本教程後,您應該基本了解如何使用遠端佇列定義來設定和使用websphere® mq 訊息傳遞。 一、

在傳送機器上建立佇列管理器 二、

在傳送佇列管理器上建立佇列

三、建立訊息通道

四、將測試訊息放入佇列

五、驗證是否已傳送測試訊息

一、在傳送機器上建立佇列管理器

在傳送機器上使用websphere mq 資源管理器建立佇列管理器

無法遠端完成此過程。必須在傳送機器上本地完成此過程。

啟動websphere mq 資源管理器。

在導航器檢視中,右鍵單擊佇列管理器資料夾,然後單擊新 佇列管理器 此時會開啟建立佇列管理器嚮導。

在佇列管理器名稱欄位中,輸入qm_orange。

選中設定為預設佇列管理器核取方塊。

單擊下一步兩次以轉至嚮導的步驟3。

確保選中啟動佇列管理器核取方塊。

確保選中自動啟動佇列管理器核取方塊。

單擊下一步以轉至嚮導的步驟4。

確保選中建立配置用於tcp/ip 的偵聽器核取方塊。

如果完成按鈕不可用,那麼在偵聽埠號欄位中輸入另乙個埠號。 如果當前值為1414,那麼嘗試輸入1415 或1416。

單擊完成。

websphere mq 資源管理器的導航器檢視中的佇列管理器資料夾中會顯示表示此佇列管理器的圖示,並且在您建立佇列管理器後,該佇列管理器會自動開始執行。

使用mqsc 建立傳送佇列管理器

在傳送機器上開啟命令提示符,然後按照以下步驟操作:

通過輸入以下命令來建立名為qm_orange 的預設佇列管理器:

crtmqm -q qm_orange

此時會顯示訊息,告訴您已經建立了佇列和預設websphere mq 物件。

通過輸入以下命令來啟動此佇列管理器:

strmqm

此時會顯示一條訊息,告訴您何時啟動了該佇列管理器。

現在,您必須通過輸入以下命令來建立偵聽器:

注: 如果未使用-p 引數指定任何埠,那麼使用預設埠1414,但請注意,不能對傳送方和接收方使用相同的埠號,因此,如果其中乙個為1414,那麼另乙個就應該是1415。

您現在已經建立了傳送佇列管理器。下乙個任務是在此佇列管理器上建立佇列。

二、在傳送佇列管理器上建立佇列

使用websphere mq 資源管理器在傳送佇列管理器上建立佇列

在傳送佇列管理器上:

在導航器檢視中,展開佇列管理器資料夾。

展開佇列管理器qm_orange。

右鍵單擊佇列資料夾,然後單擊新 遠端佇列定義... 此時會開啟新建遠端佇列定義嚮導。

在名稱欄位中,輸入q1。

在遠端佇列欄位中,輸入q1。 【注:這裡新建的遠端佇列的名稱,一定要和遠端機器上的佇列名稱相同,否則訊息會發出去,但是遠端機器的佇列裡面收不到訊息,如上文提到的的q1與q1,或者是如下圖的testq與testq:

單擊完成。 您現在已經建立了遠端佇列定義。

單擊qm_orange 佇列管理器。

右鍵單擊佇列資料夾,然後單擊新 本地佇列 此時會開啟新建本地佇列嚮導。

在用途欄位中,選擇傳輸。

單擊完成。 您現在已經在本地機器上建立了傳輸佇列。

如果內容檢視中未顯示這些佇列,請單擊位於內容檢視頂部的「重新整理」按鈕

使用mqsc 來在傳送佇列管理器上建立佇列

在傳送機器上開啟命令提示符,然後按照以下步驟操作:

通過輸入以下命令來啟動mqsc:

runmqsc

此時會顯示一條訊息,告訴您mqsc 會話已啟動。

此時會顯示一條訊息,告訴您何時建立了該佇列。

通過輸入以下命令來定義遠端佇列定義:

您現在已經在傳送佇列管理器上建立了佇列。下乙個任務是建立傳送佇列管理器和接收佇列管理器之間的訊息通道。

三、建立訊息通道

使用mq 資源管理器建立訊息通道

右鍵單擊通道資料夾,然後單擊新 接收方通道... 此時會開啟新建接收方通道嚮導。

單擊完成。 您現在已經在接收機器上建立了接收方通道。

傳送佇列管理器qm_orange 上,建立通道的傳送方端:

展開先前建立的佇列管理器qm_orange,然後展開高階資料夾。

右鍵單擊通道資料夾,然後單擊新 傳送方通道... 此時會開啟新建傳送方通道嚮導。

在連線名稱欄位中,輸入接收機器的計算機名稱或ip 位址(您應該已經在系統管理員的幫助下獲得此資訊)。

單擊完成。

單擊通道資料夾。

從彈出選單中,單擊啟動。

單擊確定。 您現在已經在傳送機器上建立了傳送方通道。

注: 您不必啟動接收方通道,因為它會在您設定傳送方通道時自動啟動(當設定傳送方通道時,您指定了接收方通道的ip 位址)。

使用mqsc 建立訊息通道

接收機器上開啟命令提示符,然後按照以下步驟操作:

通過輸入以下命令來啟動mqsc:

runmqsc

此時會顯示一條訊息,告訴您mqsc 會話已啟動。

通過輸入以下命令來定義接收通道:

此時會顯示一條訊息,告訴您何時建立了該通道。

通過輸入以下命令來停止mqsc:

end

將顯示一些訊息,然後會顯示命令提示符。

傳送機器上開啟命令提示符,然後按照以下步驟操作:

通過輸入以下命令來啟動mqsc:

runmqsc

此時會顯示一條訊息,告訴您mqsc 會話已啟動。

通過輸入以下命令來定義傳送方通道:

值 con-name

是接收方佇列管理器的tcp 位址。

通過輸入以下命令來啟動通道:

通過輸入以下命令來停止mqsc:

end

將顯示一些訊息,然後會顯示命令提示符。

四、將測試訊息放入佇列

使用mq 資源管理器測試訊息放入佇列

點右鍵到遠端佇列上,選擇「放入測試訊息…」:

使用mqsc 來將測試訊息放入佇列

在傳送機器(主管佇列管理器qm_orange 的機器)上執行此任務。

使用amqsput樣本程式來將訊息放入您建立的佇列。

在windows®

上,預設情況下樣本程式隨websphere® mq 伺服器或客戶機一起安裝。在linux®

上,需要安裝樣本程式rpm。

開啟命令提示符,然後按照以下步驟操作:

啟動amqsput樣本程式,如下所示:

此時會顯示以下訊息:

樣本amqsput0 啟動

目標隊列為q1

在一行或多行上輸入某些訊息文字,然後按enter 鍵兩次。 此時會顯示以下訊息:

樣本amqsput0 結束

您現在已經建立了測試訊息並將其放入遠端佇列。下乙個任務是驗證是否已接收到測試訊息。

五、驗證是否已傳送測試訊息

使用websphere mq 資源管理器來驗證是否已傳送測試訊息

接收佇列管理器上:

單擊佇列資料夾。

在內容檢視中,右鍵單擊佇列q1,然後單擊瀏覽訊息...。 此時會開啟訊息瀏覽器,顯示當前q1 上的訊息列表。

雙擊列表中的最後一條訊息以檢視其屬性對話方塊。

在屬性對話方塊的資料頁上,訊息資料字段以人類可讀的格式顯示了訊息的內容。

使用mqsc 驗證是否已傳送測試訊息

樣本程式來從佇列中取回訊息。

開啟命令提示符,然後按照以下步驟操作:

啟動amqsget樣本程式,如下所示:

此時會啟動該樣本程式,並顯示您的訊息以及此佇列上的任何其他訊息。在短暫停留後,樣本程式結束,並再次顯示命令提示符。

恭喜!您現在已經完成了本教程。

訊息機制 MQ

通過訊息producer 生產者 傳送訊息,必須初始化就啟動 consumer 消費者 監控訊息佇列,接收並處理訊息,初始化就啟動 根專案pom.xml增加 4.1.0 incubating snapshotrocketmq client.version org.apache.rocketmqgro...

訊息佇列MQ

目錄 一 簡介 二 為什麼需要訊息佇列 mq 三 介紹 訊息佇列 message queuing 在電腦科學中,是一種程序間通訊或同一程序間不同執行緒的通訊方式。廣義上講訊息佇列是解決分布式系統中,各個功能模組間的資訊傳遞通訊方式。與檔案傳輸和rpc相比,訊息佇列具有更好的平台無關性,並能夠很好地支...

MQ訊息佇列

1.解耦 系統a將userid寫到訊息佇列中,系統c和系統d從訊息佇列中拿資料。這樣有什麼好處?系統a只負責把資料寫到佇列中,誰想要或不想要這個資料 訊息 系統a一點都不關心。即便現在系統d不想要userid這個資料了,系統b又突然想要userid這個資料了,都跟系統a無關,系統a一點 都不用改。系...