C# M2mqtt 双向认证 demo

M2Mqtt是一个用于.NET平台的轻量级MQTT客户端库，它支持双向认证，即客户端到服务器和服务器到客户端的身份验证。在C#中使用M2Mqtt做双向认证的Demo通常涉及以下几个步骤：

1. **安装依赖**：
首先，你需要安装`M2Mqtt.Net`包。你可以通过NuGet包管理器添加`M2Mqtt`包。

2. **设置证书**：
创建或获取一把公钥私钥对，服务器和客户端都应持有相同的证书。将证书加载到`MqttClientOptions`中，例如：

var clientOptions = new MqttClientOptionsBuilder()
    .WithClientId("client_id")
    .WithServer("broker_url")
    .WithCredentials(username, password) // 使用用户名和密码进行身份验证
    .WithTls(clientCert: certificate, caCertificates: rootCaCertificate) // 或者证书和根CA证书
    .Build();

这里的`username`和`password`用于初始连接，而`certificate`和`rootCaCertificate`用于TLS双向认证。

3. **建立连接**：
使用`MqttClient.ConnectAsync()`开始连接，并启用SSL/TLS：

using var mqttClient = new MqttClient(clientOptions);
await mqttClient.ConnectAsync();

4. **安全消息交换**：
连接成功后，你可以发送安全的消息（如`Connect Acknowledgement`）并等待服务器响应。双向认证通常会在连接过程中完成。

5. **示例完整代码片段**：

   async Task Main()
   {
       // ... (设置选项和证书)
       
       await mqttClient.ConnectAsync();

       // 发送一条带有身份验证信息的安全MQTT消息
       var message = new MqttApplicationMessageBuilder()
           .WithTopic("secure/topic")
           .WithPayload("Authentication payload")
           .WithExactlyOnceQoS()
           .WithApplicationProperties(new Dictionary<string, object>
               { { "Auth", "Client Certificate" } })
           .Build();

       await mqttClient.PublishAsync(message);

       // 等待并处理服务器响应
       var receivedMessage = await mqttClient.ReceiveAsync();
   }

6. **断开连接**：
当你完成通信后，记得调用`DisconnectAsync()`关闭连接。

注意：实际应用中，你需要处理错误、重连等异常情况，并确保正确的证书管理和密钥保护。