[C#] MessageQueueの使い方

   using System.Messaging; // MessageQueueを使用するための名前空間

   partial class MyForm : Form
   {
       private MessageQueue messageQueue;
       public MyForm()
       {
           InitializeComponent(); // フォームの初期化
           messageQueue = new MessageQueue(@".\Private$\MyQueue"); // キューの作成
       }
   }

   if (!MessageQueue.Exists(@".\Private$\MyQueue"))
   {
       MessageQueue.Create(@".\Private$\MyQueue"); // キューを作成
   }

partial class MyForm : Form
{
    private MessageQueue messageQueue;
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
        // キューのパスを指定
        string queuePath = @".\Private$\MyQueue"; 
        // キューが存在しない場合は作成
        if (!MessageQueue.Exists(queuePath))
        {
            MessageQueue.Create(queuePath); // キューを作成
        }
        // MessageQueueのインスタンスを作成
        messageQueue = new MessageQueue(queuePath); 
    }
}

private void SendMessage(string messageContent)
{
    // メッセージを作成
    Message message = new Message
    {
        Body = messageContent, // メッセージの内容
        Label = "Sample Message" // メッセージのラベル
    };
    // メッセージをキューに送信
    messageQueue.Send(message); 
}

private string ReceiveMessage()
{
    // メッセージを受信
    Message receivedMessage = messageQueue.Receive(); 
    // メッセージの内容を取得
    string messageContent = receivedMessage.Body.ToString(); 
    return messageContent; // メッセージの内容を返す
}

private void DeleteQueue()
{
    // キューのパスを指定
    string queuePath = @".\Private$\MyQueue"; 
    // キューを削除
    if (MessageQueue.Exists(queuePath))
    {
        MessageQueue.Delete(queuePath); // キューを削除
    }
}

[Serializable] // シリアライズ可能なクラス
public class MyData
{
    public string Name { get; set; } // 名前
    public int Age { get; set; } // 年齢
}

private MyData DeserializeMessage(Message message)
{
    // メッセージのボディをバイト配列として取得
    byte[] messageBody = (byte[])message.Body; 
    // メモリストリームを使用してデシリアライズ
    using (MemoryStream memoryStream = new MemoryStream(messageBody))
    {
        BinaryFormatter formatter = new BinaryFormatter(); // バイナリフォーマッタを作成
        return (MyData)formatter.Deserialize(memoryStream); // デシリアライズしてオブジェクトを返す
    }
}

private async Task SendMessageAsync(string messageContent)
{
    // メッセージを作成
    Message message = new Message
    {
        Body = messageContent, // メッセージの内容
        Label = "Async Message" // メッセージのラベル
    };
    // 非同期でメッセージを送信
    await Task.Run(() => messageQueue.Send(message)); 
}

private async Task<string> ReceiveMessageAsync()
{
    // 非同期でメッセージを受信
    Message receivedMessage = await Task.Run(() => messageQueue.Receive()); 
    // メッセージの内容を取得
    string messageContent = receivedMessage.Body.ToString(); 
    return messageContent; // メッセージの内容を返す
}

private void SendMessageWithTransaction(string messageContent)
{
    // トランザクションを開始
    using (var transaction = new MessageQueueTransaction())
    {
        transaction.Begin(); // トランザクションの開始
        try
        {
            // メッセージを作成
            Message message = new Message
            {
                Body = messageContent, // メッセージの内容
                Label = "Transactional Message" // メッセージのラベル
            };
            // トランザクションを指定してメッセージを送信
            messageQueue.Send(message, transaction); 
            // トランザクションをコミット
            transaction.Commit(); 
        }
        catch
        {
            // エラーが発生した場合はロールバック
            transaction.Rollback(); 
        }
    }
}

private void ReceiveMessageWithTransaction()
{
    // トランザクションを開始
    using (var transaction = new MessageQueueTransaction())
    {
        transaction.Begin(); // トランザクションの開始
        try
        {
            // トランザクションを指定してメッセージを受信
            Message receivedMessage = messageQueue.Receive(transaction); 
            // メッセージの内容を取得
            string messageContent = receivedMessage.Body.ToString(); 
            // メッセージを処理する(ここに処理ロジックを追加)
            // トランザクションをコミット
            transaction.Commit(); 
        }
        catch
        {
            // エラーが発生した場合はロールバック
            transaction.Rollback(); 
        }
    }
}

private void SendMessageWithErrorHandling(string messageContent)
{
    try
    {
        // メッセージを作成
        Message message = new Message
        {
            Body = messageContent, // メッセージの内容
            Label = "Error Handling Message" // メッセージのラベル
        };
        // メッセージを送信
        messageQueue.Send(message); 
    }
    catch (MessageQueueException mqEx)
    {
        // メッセージキューに関連するエラー処理
        Console.WriteLine($"メッセージ送信エラー: {mqEx.Message}");
    }
    catch (Exception ex)
    {
        // その他のエラー処理
        Console.WriteLine($"一般的なエラー: {ex.Message}");
    }
}

private string ReceiveMessageWithErrorHandling()
{
    try
    {
        // メッセージを受信
        Message receivedMessage = messageQueue.Receive(); 
        // メッセージの内容を取得
        return receivedMessage.Body.ToString(); 
    }
    catch (MessageQueueException mqEx)
    {
        // メッセージキューに関連するエラー処理
        Console.WriteLine($"メッセージ受信エラー: {mqEx.Message}");
        return null; // エラー時はnullを返す
    }
    catch (Exception ex)
    {
        // その他のエラー処理
        Console.WriteLine($"一般的なエラー: {ex.Message}");
        return null; // エラー時はnullを返す
    }
}

private void CheckQueueErrorState()
{
    try
    {
        // キューの状態を確認
        if (MessageQueue.Exists(@".\Private$\MyQueue"))
        {
            using (MessageQueue queue = new MessageQueue(@".\Private$\MyQueue"))
            {
                // キューのプロパティを取得
                var queueProperties = queue.GetAllMessages(); 
                // キューのメッセージ数を表示
                Console.WriteLine($"キュー内のメッセージ数: {queueProperties.Length}");
            }
        }
        else
        {
            Console.WriteLine("指定されたキューは存在しません。");
        }
    }
    catch (Exception ex)
    {
        // エラー処理
        Console.WriteLine($"キュー状態確認中のエラー: {ex.Message}");
    }
}