[C#] MessageQueueの認証方法とセキュリティ設定

using System;
using System.Messaging;
partial class MyForm
{
    public MyForm()
    {
        InitializeComponent();
        CreateMessageQueue();
    }
    private void CreateMessageQueue()
    {
        string queuePath = @".\Private$\MyQueue"; // キューのパスを指定
        // キューが存在しない場合は新規作成
        if (!MessageQueue.Exists(queuePath))
        {
            MessageQueue.Create(queuePath); // キューを作成
        }
        // キューの設定を行う
        MessageQueue myQueue = new MessageQueue(queuePath);
        myQueue.Formatter = new XmlMessageFormatter(new String[] { "System.String,mscorlib" }); // メッセージフォーマットを設定
    }
}

using System;
using System.Messaging;
using System.Security.AccessControl;
partial class MyForm
{
    public MyForm()
    {
        InitializeComponent();
        SetQueuePermissions();
    }
    private void SetQueuePermissions()
    {
        string queuePath = @".\Private$\MyQueue"; // キューのパスを指定
        MessageQueue myQueue = new MessageQueue(queuePath);
        // アクセス制御リストを作成
        var security = new MessageQueueSecurity();
        security.SetPermissions("DOMAIN\\User", MessageQueueRights.Send); // 送信権限を設定
        security.SetPermissions("DOMAIN\\User", MessageQueueRights.Receive); // 受信権限を設定
        // ACLをキューに適用
        myQueue.SetPermissions(security);
    }
}

using System;
using System.Messaging;
using System.Security.AccessControl;
partial class MyForm
{
    public MyForm()
    {
        InitializeComponent();
        ConfigureQueueSecurity();
    }
    private void ConfigureQueueSecurity()
    {
        string queuePath = @".\Private$\MyQueue"; // キューのパスを指定
        MessageQueue myQueue = new MessageQueue(queuePath);
        // アクセス制御リストを作成
        var security = new MessageQueueSecurity();
        security.SetPermissions("DOMAIN\\User", MessageQueueRights.FullControl); // フルコントロール権限を設定
        // ACLをキューに適用
        myQueue.SetPermissions(security);
    }
}

using System;
using System.IO;
using System.Security.Cryptography;
using System.Text;
partial class MyForm
{
    private string EncryptMessage(string message, string key)
    {
        using (Aes aes = Aes.Create())
        {
            aes.Key = Encoding.UTF8.GetBytes(key);
            aes.GenerateIV();
            using (var ms = new MemoryStream())
            {
                ms.Write(aes.IV, 0, aes.IV.Length); // IVを先頭に書き込む
                using (var cs = new CryptoStream(ms, aes.CreateEncryptor(), CryptoStreamMode.Write))
                {
                    using (var sw = new StreamWriter(cs))
                    {
                        sw.Write(message); // メッセージを暗号化
                    }
                }
                return Convert.ToBase64String(ms.ToArray()); // 暗号化されたメッセージをBase64形式で返す
            }
        }
    }
    private string DecryptMessage(string encryptedMessage, string key)
    {
        byte[] fullCipher = Convert.FromBase64String(encryptedMessage);
        using (Aes aes = Aes.Create())
        {
            aes.Key = Encoding.UTF8.GetBytes(key);
            byte[] iv = new byte[aes.IV.Length];
            Array.Copy(fullCipher, 0, iv, 0, iv.Length); // IVを取得
            aes.IV = iv;
            using (var ms = new MemoryStream(fullCipher, iv.Length, fullCipher.Length - iv.Length))
            {
                using (var cs = new CryptoStream(ms, aes.CreateDecryptor(), CryptoStreamMode.Read))
                {
                    using (var sr = new StreamReader(cs))
                    {
                        return sr.ReadToEnd(); // 復号化されたメッセージを返す
                    }
                }
            }
        }
    }
}