MSMQ のトランザクション メッセージ

Last Update: feedback 共有

こんにちは！Azure Integration サポート チームの 山田 です。
Azure Integration サポート チームでは Azure 製品以外にもオンプレミス製品を取り扱っております。今回は Windows に含まれる MSMQ というサービスのメッセージの種類についてご紹介します。

目次

  • MSMQ について
  • MSMQ のトランザクション メッセージ
  • MSMQ のトランザクション メッセージ送信
  • MSMQ のトランザクション メッセージ再試行
  • まとめ

MSMQ について

MSMQ とは、弊社が提供するオンプレミス製品のメッセージ キューイング サービスです。

Message Queuing (MSMQ) technology enables applications running at different times to communicate across heterogeneous networks and systems that may be temporarily offline. Applications send messages to queues and read messages from queues.

(翻訳) メッセージ キューイング（MSMQ）技術は、異なる時間に実行されるアプリケーションが、異種ネットワークや一時的にオフラインになる可能性のあるシステム間で通信することを可能にします。アプリケーションはキューにメッセージを送信し、キューからメッセージを読み取ります。

上記にも関連記事がございます。

MSMQ のトランザクション メッセージ

トランザクション キューで扱われるメッセージと、非トランザクション キューで扱われるメッセージの違いについてご説明します。端的にトランザクション キューでは、「順序を保証する」点が特徴になります。

以下のようなドキュメントをご覧いただけます。

WCF でのキュー - WCF | Microsoft Learn

MSMQ では、キューをトランザクションまたは非トランザクションとして設定できます。
トランザクション キューの場合、トランザクションによるメッセージの取り込みと配信が可能です。
メッセージは、キューに永続的に格納されます。トランザクション キューに送信されたメッセージは、正確に 1 回だけ、順序どおりに転送されます。

非トランザクション キューを使用すると、揮発性メッセージと非揮発性メッセージの両方を送信できます。非トランザクション キューに送信されたメッセージには、信頼できる転送保証がありません。したがって、メッセージが失われる可能性があります。

それぞれ以下から確認いただけます。

トランザクション キュー

非トランザクション キュー

MSMQ のトランザクション メッセージ送信

以下は、トランザクション キューに PowerShell にてメッセージを送信するサンプルです。

トランザクション メッセージ送信コマンド例

1
2
3
4
5
6
7
8
[System.Reflection.Assembly]::LoadWithPartialName("System.Messaging")
$queuePath = "FormatName:Direct=OS:<送信先 コンピューター名>\private$\<キュー名>"
$mq = new-object System.Messaging.MessageQueue($queuePath)
$tran = new-object System.Messaging.MessageQueueTransaction;
$tran.Begin()
$mq.Send("Hello transaction 1", $tran)
$mq.Send("Hello transaction 2", $tran)
$tran.Commit()

非トランザクション メッセージ送信コマンド例

以下記事で非トランザクション キューに PowerShell にてメッセージを送信するサンプルを紹介しています。合わせてご覧ください。

MSMQ を有効化する手順・メッセージを送受信する手順 | Japan Azure Integration Support Blog

MSMQ のトランザクション メッセージ再試行

コマンドの違いとしては上の通り、メッセージの送信処理の前後でトランザクションの開始、コミットを記述することで「順序通りに送る」ことを保証できる点にありますが、内部的にも、トランザクション メッセージは以下のような振る舞いをいたします。

MSMQのトランザクション メッセージは、トランザクションの完了を確認するために内部の order_queue$ というキューを使用します。通常、トランザクションの order_queue$ への ack は、MSMQ クライアントが確立したのと同じ TCP セッションで送り返されます。

トランザクション メッセージを送信すると、受信したサーバーから送信元の order_queue$ へ返答を送り返していることが分かります。

一方、一般的なネットワーク・通信エラーやその他の問題が発生した場合、TCP セッションが切断される状況もあります。その場合、送信された返答は送信キューに入れられますが、MSMQ 送信メッセージの送信再試行ポリシーで再試行されます。

SeqResend13Time | Microsoft Learn

Determines how often outgoing, transacted messages are resent because they are unacknowledged.
The value of this entry specifies the interval between resends for the first three times the message is resent. If, after the third resend, the sender still does not receive an acknowledgement from the intended recipient, the message is resent at intervals determined by the values of the following entries: SeqResend46Time , SeqResend79Time , SeqResend10Time

(翻訳) 送信されたトランザクション・メッセージが再送される頻度を指定します。このエントリの値は、メッセージが再送される最初の3回の再送間隔を指定します。3回目の再送の後、送信者がまだ意図した受信者から確認応答を受け取らない場合、メッセージは以下のエントリの値で決まる間隔で再送されます： SeqResend46Time , SeqResend79Time , SeqResend10Time

既定では、MSMQ は以下の間隔でメッセージの再送信を試みます。

関連: Message Queuing Transactions | Microsoft Learn

以上、トランザクション メッセージの特徴として、参考になりましたら幸いです。

まとめ

本記事では、以下についてご案内いたしました。

  • MSMQ について
  • MSMQ のトランザクション メッセージ
  • MSMQ のトランザクション メッセージ送信
  • MSMQ のトランザクション メッセージ再試行

トランザクション メッセージの活用と、オンプレミス製品 MSMQ についてご理解の一助として、本記事が少しでもお役に立ちましたら幸いです。最後までお読みいただき、ありがとうございました！

※本情報の内容（添付文書、リンク先などを含む）は、作成日時点でのものであり、予告なく変更される場合があります。