以前に宣言した通り、今回より、IBM MQを検証した結果を掲載していこうと思います。
キューマネージャ、ローカルキュー、コネクション・オブジェクトを作成し、メッセージをPutするところから始めましょう。
まずは、基本を理解していきたいところ。
IBM MQ（Message Queuing）は、IBMが提供するメッセージングソフトウェアの製品。
分散環境でアプリケーションやシステム間でメッセージを安全かつ信頼性高くやり取りするためのメッセージング・ミドルウェアを提供し、異なるプラットフォームやアプリケーション間で非同期のメッセージのやり取りを可能するものです。
検証環境について
- O/S: Windows Server 2022 Server Standard Edition
・ファイアウォール設定: 受信規則追加 TCP(1414-1415)を許可
・ユーザー情報: t_yamada を追加し、mqmグループに追加
- MQ Server: IBM MQ Ver 9.3.4.0
- InstPath: C:￥Program Files\IBM\MQ
- DataPath: C:￥ProgramData\IBM\MQ
事前準備
IBM MQ9.3のインストール
- カスタムで「MQIクライアント」を選択する
- 9.3から「MQエクスプローラー」が付属されなくなったみたい。男は黙ってCUIとする！
IBM MQ 9.3.0以降、 IBM MQ Explorer は IBM MQ インストール・パッケージから削除されました。
これは、 Fix Centralから入手できるスタンドアロン・ダウンロードとして引き続き入手できます。
（IBM MQ Explorer の概要より）
キューマネージャー
まず作成から起動です。
> crtmqm -q -lc TSQMGR
> strmqm TSQMGR
確認方法
>dspmq
QMNAME(TSQMGR) STATUS(実行中)
停止方法
> endmqm -w TSQMGR
ローカルキュー
次は、ローカルキュー作成です。
> runmqsc TSQMGR
DEFINE QL(QL.A) DESCR('QL.A Text')
END
確認（ローカルキューの全属性表示）はこちら。
> runmqsc TSQMGR
DISPLAY QL(QL.A)
END
認証設定
作成したキューマネージャーへは、ServerにあるIDとPASSでのみ接続可能とします（これで合っているのかな？）
> runmqsc TSQMGR
DEFINE AUTHINFO('MY.AUTHINFO') AUTHTYPE(IDPWOS) CHCKCLNT(REQUIRED) REPLACE
ALTER QMGR CONNAUTH('MY.AUTHINFO')
REFRESH SECURITY
END
この設定で、サーバとは別のPC上のJavaアプリケーションから、サーバ上に所属するIDとそのPASSでのみ接続できるようになりました。
CHCKCLNT(OPTIONAL)だと、別のPCのログインIDがサーバに存在しているだけでアクセス可能となりました。
MQクライアント
SVRCONNチャネルを定義し、MQクライアントが外部から接続できるにします。
> runmqsc TSQMGR
DEFINE CHL(TSQMGR_CLNT) CHLTYPE(SVRCONN) TRPTYPE(TCP)
ALTER QMGR CHLAUTH(DISABLED) CONNAUTH(' ')
REFRESH SECURITY
END
リスナー・プロセスを起動して、クライアントの接続を待ちます。
1414ポートを開けることを忘れずに...。
> runmqlsr -t TCP –p 1414 -m TSQMGR
このコマンドで応答を待ち続けることになるので、別のDOS窓で実行するといいでしょう。
サンプルコード
ここまで来たら、javaアプリケーションの準備です。
IBM MQ classes for Java and JMSを取得します。
https://mvnrepository.com/artifact/com.ibm.mq/com.ibm.mq.allclient/9.3.4.0
dependencies {
implementation group: 'com.ibm.mq', name: 'com.ibm.mq.allclient', version: '9.3.4.0'
}
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.constants.CMQC;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
public class testPutMQ {
private static final String HOST = "192.168.1.1";
private static final int PORT = 1414;
private static final int CCSID = 932;
private static final String CHANNEL = "TSQMGR_CLNT";
private static final String QMGR = "TSQMGR";
private static final String QUEUE_NAME = "QL.A";
private static final String USER = "t_yamada";
private static final String PASSWORD = "password";
public static void main(String[] args) {
try {
MQEnvironment.hostname = HOST;
MQEnvironment.port = PORT;
MQEnvironment.CCSID = CCSID;
MQEnvironment.channel = CHANNEL;
MQEnvironment.userID = USER;
MQEnvironment.password = PASSWORD;
MQQueueManager qmgr = new MQQueueManager(QMGR);
MQQueue queue = qmgr.accessQueue(QUEUE_NAME, CMQC.MQOO_OUTPUT);
MQMessage message = new MQMessage();
message.expiry = 600;
message.format = CMQC.MQFMT_STRING;
message.persistence = CMQC.MQPER_NOT_PERSISTENT;
message.characterSet = 932;
DateTimeFormatter dtf1 = DateTimeFormatter.ofPattern("yyyy/MM/dd HH:mm:ss.SSS");
String formatNowDate = dtf1.format(LocalDateTime.now());
String text = "Hello, MQ さん！: " + formatNowDate;
message.write(text.getBytes("MS932"));
MQPutMessageOptions pmo = new MQPutMessageOptions();
pmo.options = CMQC.MQPMO_NO_SYNCPOINT;
queue.put(message, pmo);
System.out.println("Message sent successfully.");
queue.close();
qmgr.disconnect();
} catch (MQException ex) {
System.err.println("MQ Exception: " + ex.reasonCode + ", " + ex.getMessage());
ex.printStackTrace();
} catch (Exception ex) {
System.err.println("Exception: " + ex.getMessage());
ex.printStackTrace();
}
}
}
ローカルキューを確認
試しにJavaアプリからは2回実行してみました。
MQサーバ側で、すでに提供されているキューの中身を確認するコマンドを実施してみます。
>amqsgbr QL.A TSQMGR
Sample AMQSGBR0 (browse) start
TSQMGR
Messages for QL.A
1 <Hello, MQ さん！: 2024/03/12 18:22:56.433>
2 <Hello, MQ さん！: 2024/03/12 18:22:59.817>
no more messages
Sample AMQSGBR0 (browse) end
下記のプログラムだと、MQMDを含めてより詳しいメッセージの中身を確認することができます。
> amqsbcg QL.A TSQMGR
まずは、第一弾なので、今日はこんなところでオッケーでしょうか。
