[C#] MessageQueueの作成方法と活用法

using System.Messaging; // メッセージキューに必要な名前空間

partial class MyForm : Form
{
    private MessageQueue messageQueue; // メッセージキューのインスタンス
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
        // メッセージキューのインスタンス化
        messageQueue = new MessageQueue(@".\Private$\MyQueue");
    }
}

partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
        // キューの存在確認
        if (!MessageQueue.Exists(@".\Private$\MyQueue"))
        {
            // キューが存在しない場合は作成
            MessageQueue.Create(@".\Private$\MyQueue");
        }
    }
}

partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
    }
    private void DeleteQueue()
    {
        // キューの削除
        if (MessageQueue.Exists(@".\Private$\MyQueue"))
        {
            MessageQueue.Delete(@".\Private$\MyQueue");
        }
    }
}

partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
    }
    private void SendMessage(string message)
    {
        // メッセージを送信
        messageQueue.Send(message);
    }
}

partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
    }
    private void ReceiveMessage()
    {
        // メッセージを受信
        Message message = messageQueue.Receive();
        string receivedMessage = message.Body.ToString(); // メッセージの内容を取得
        // 受信したメッセージを表示
        MessageBox.Show(receivedMessage);
    }
}

[Serializable] // シリアライズ可能なクラス
public class MyMessage
{
    public string Text { get; set; }
}
partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
    }
    private void SendCustomMessage()
    {
        MyMessage myMessage = new MyMessage { Text = "こんにちは、メッセージキュー！" };
        messageQueue.Send(myMessage); // オブジェクトを送信
    }
}

partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
    }
    private void SendPriorityMessage(string message)
    {
        // メッセージを作成
        Message myMessage = new Message
        {
            Body = message,
            Label = "重要", // メッセージのラベル
            AppSpecific = 1 // アプリケーション固有の情報
        };
        // 優先度を設定して送信
        myMessage.Priority = MessagePriority.High; // 高優先度
        messageQueue.Send(myMessage);
    }
}

private void ProcessRequest(string request)
{
    // リクエストを非同期で処理
    SendMessage(request); // メッセージをキューに送信
    MessageBox.Show("リクエストを受け付けました。"); // ユーザーに即座に応答
}

// サーバーAからサーバーBへメッセージを送信
messageQueue.Send("サーバーAからのメッセージ");

private void LogMessage(string log)
{
    // ログメッセージをキューに送信
    messageQueue.Send(log);
}

private void WorkerProcess()
{
    while (true)
    {
        // メッセージを受信して処理
        Message message = messageQueue.Receive();
        ProcessMessage(message.Body.ToString()); // メッセージを処理
    }
}

partial class MyForm : Form
{
    public MyForm()
    {
        InitializeComponent(); // フォームの初期化
    }
    private void SetQueueSecurity()
    {
        // キューのセキュリティ設定
        MessageQueue myQueue = new MessageQueue(@".\Private$\MyQueue");
        myQueue.SetPermissions("DOMAIN\\User", MessageQueueAccessRights.SendMessage);
    }
}

// プロセスA
private void SendMessageToProcessB(string message)
{
    MessageQueue queue = new MessageQueue(@".\Private$\MyQueue");
    queue.Send(message); // プロセスBにメッセージを送信
}
// プロセスB
private void ReceiveMessageFromProcessA()
{
    MessageQueue queue = new MessageQueue(@".\Private$\MyQueue");
    Message message = queue.Receive(); // プロセスAからメッセージを受信
    string receivedMessage = message.Body.ToString();
}

private void RealTimeDataProcessing()
{
    while (true)
    {
        Message message = messageQueue.Receive(); // リアルタイムでメッセージを受信
        ProcessData(message.Body.ToString()); // データを処理
    }
}

private void BatchProcessingWorker()
{
    while (true)
    {
        Message message = messageQueue.Receive(); // メッセージを受信
        ProcessBatch(message.Body.ToString()); // バッチ処理を実行
    }
}