[C#] MessageQueueを使用したメッセージ送信の方法

using System.Messaging; // MessageQueueを使用するための名前空間
partial class MyForm
{
    private MessageQueue messageQueue; // MessageQueueオブジェクトの宣言
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
        CreateMessageQueue(); // メッセージキューの作成
    }
    private void CreateMessageQueue()
    {
        // メッセージキューのパスを指定
        string queuePath = @".\Private$\MyQueue"; 
        // メッセージキューが存在しない場合は作成
        if (!MessageQueue.Exists(queuePath))
        {
            messageQueue = MessageQueue.Create(queuePath); // メッセージキューの作成
        }
        else
        {
            messageQueue = new MessageQueue(queuePath); // 既存のメッセージキューに接続
        }
    }
}

private void ConnectToQueue()
{
    string queuePath = @".\Private$\MyQueue"; // メッセージキューのパス
    messageQueue = new MessageQueue(queuePath); // メッセージキューに接続
}

private void SendMessage(string messageContent)
{
    // メッセージオブジェクトの作成
    Message message = new Message(); 
    message.Body = messageContent; // メッセージの内容を設定
    message.Formatter = new XmlMessageFormatter(new String[] { "System.String,mscorlib" }); // メッセージのフォーマットを設定
    messageQueue.Send(message); // メッセージをキューに送信
}

private void PrepareToReceiveMessages()
{
    string queuePath = @".\Private$\MyQueue"; // メッセージキューのパス
    messageQueue = new MessageQueue(queuePath); // メッセージキューに接続
    messageQueue.Formatter = new XmlMessageFormatter(new String[] { "System.String,mscorlib" }); // メッセージのフォーマットを設定
}

private string ReceiveMessage()
{
    try
    {
        // メッセージを受信
        Message message = messageQueue.Receive(); 
        message.Formatter = new XmlMessageFormatter(new String[] { "System.String,mscorlib" }); // フォーマットを設定
        return (string)message.Body; // メッセージの内容を返す
    }
    catch (MessageQueueException ex)
    {
        // エラーハンドリング
        Console.WriteLine("メッセージの受信中にエラーが発生しました: " + ex.Message);
        return null; // エラーが発生した場合はnullを返す
    }
}

private void ProcessReceivedMessage()
{
    string messageContent = ReceiveMessage(); // メッセージを受信
    if (messageContent != null) // メッセージがnullでない場合
    {
        // メッセージの内容に基づいて処理を実行
        Console.WriteLine("受信したメッセージ: " + messageContent); 
        // ここにメッセージに基づく処理を追加
    }
}

private void SendMessageWithExceptionHandling(string messageContent)
{
    try
    {
        Message message = new Message(); // メッセージオブジェクトの作成
        message.Body = messageContent; // メッセージの内容を設定
        messageQueue.Send(message); // メッセージを送信
    }
    catch (MessageQueueException ex)
    {
        // メッセージキューに関連するエラーを処理
        Console.WriteLine("メッセージの送信中にエラーが発生しました: " + ex.Message);
    }
    catch (Exception ex)
    {
        // その他のエラーを処理
        Console.WriteLine("予期しないエラーが発生しました: " + ex.Message);
    }
}

private void ReceiveMessageFromAnotherApp()
{
    string queuePath = @".\Private$\MyQueue"; // メッセージキューのパス
    using (MessageQueue messageQueue = new MessageQueue(queuePath)) // メッセージキューに接続
    {
        messageQueue.Formatter = new XmlMessageFormatter(new String[] { "System.String,mscorlib" }); // フォーマットを設定
        Message message = messageQueue.Receive(); // メッセージを受信
        Console.WriteLine("受信したメッセージ: " + (string)message.Body); // メッセージの内容を表示
    }
}

private async void ReceiveMessagesAsync()
{
    string queuePath = @".\Private$\MyQueue"; // メッセージキューのパス
    using (MessageQueue messageQueue = new MessageQueue(queuePath)) // メッセージキューに接続
    {
        messageQueue.Formatter = new XmlMessageFormatter(new String[] { "System.String,mscorlib" }); // フォーマットを設定
        while (true) // 無限ループでメッセージを受信
        {
            Message message = await Task.Run(() => messageQueue.Receive()); // 非同期でメッセージを受信
            Console.WriteLine("受信したメッセージ: " + (string)message.Body); // メッセージの内容を表示
        }
    }
}

private void SendMessageWithPriority(string messageContent, MessagePriority priority)
{
    Message message = new Message(); // メッセージオブジェクトの作成
    message.Body = messageContent; // メッセージの内容を設定
    message.AppSpecific = (int)priority; // メッセージの優先度を設定
    messageQueue.Send(message); // メッセージを送信
}