### C# WinForm 中通过 WebSocket (ws://) 连接到 MQTT 服务器的实现代码 在 C# WinForm 应用程序中，可以通过结合 WebSocket 和 MQTT 协议来实现连接到 MQTT 服务器的功能。以下是一个完整的示例代码，展示了如何使用 Fleck（WebSocket 库）和 MQTTnet（MQTT 客户端库）来实现这一目标。 #### 引入必要的 NuGet 包 首先需要安装以下 NuGet 包： - `Fleck`：用于 WebSocket 的实现。 - `MQTTnet`：用于 MQTT 客户端的实现。 可以通过 NuGet Package Manager Console 安装： ```shell Install-Package Fleck Install-Package MQTTnet ``` #### 示例代码 以下是完整的代码实现： ```csharp using System; using System.Collections.Generic; using System.Threading.Tasks; using Fleck; // WebSocket 库 using MQTTnet; // MQTT 客户端库 using MQTTnet.Client; using MQTTnet.Client.Options; namespace WinFormWebSocketMQTT { public class WebSocketMQTTConnector { private readonly List<IWebSocketConnection> _allSockets = new List<IWebSocketConnection>(); private readonly WebSocketServer _server; public WebSocketMQTTConnector(string wsUrl) { _server = new WebSocketServer(wsUrl); } public void StartWebSocketServer() { _server.Start(socket => { socket.OnOpen = () => { Console.WriteLine("WebSocket Open!"); _allSockets.Add(socket); }; socket.OnClose = () => { Console.WriteLine("WebSocket Close!"); _allSockets.Remove(socket); }; socket.OnMessage = message => { Console.WriteLine($"WebSocket Message: {message}"); PublishMQTTMessage(message); // 将接收到的消息发布到 MQTT 服务器 }; }); } private async void PublishMQTTMessage(string message) { var mqttFactory = new MqttFactory(); using (var mqttClient = mqttFactory.CreateMqttClient()) { var options = new MqttClientOptionsBuilder() .WithTcpServer("localhost", 1883) // 设置 MQTT 服务器地址和端口 .WithCleanSession() // 开启新的会话清理模式 .Build(); await mqttClient.ConnectAsync(options); // 连接 MQTT 服务器 var topic = "test/topic"; // 设置主题 var qosLevel = MQTTnet.Protocol.MQTTQualityOfServiceLevel.AtLeastOnce; // 设置 QoS 等级 await mqttClient.PublishAsync(new MqttApplicationMessageBuilder() .WithTopic(topic) .WithPayload(message) // 使用 WebSocket 接收到的消息作为 MQTT 消息内容 .WithQualityOfServiceLevel(qosLevel) .Build()); Console.WriteLine($"MQTT Message Published: {message}"); await mqttClient.DisconnectAsync(); // 断开 MQTT 连接 } } } public class Program { public static void Main(string[] args) { var connector = new WebSocketMQTTConnector("ws://0.0.0.0:7181"); connector.StartWebSocketServer(); Console.WriteLine("WebSocket Server Started. Press Enter to Exit."); Console.ReadLine(); } } } ``` #### 代码说明 1. **WebSocket 部分**：使用 Fleck 创建了一个 WebSocket 服务器，监听指定的 URL 和端口[^1]。当客户端连接时，将消息转发到 MQTT 服务器。 2. **MQTT 部分**：使用 MQTTnet 创建了一个 MQTT 客户端，连接到指定的 MQTT 服务器，并将从 WebSocket 接收到的消息发布到指定的主题[^2]。 3. **整合部分**：WebSocket 接收到的消息会被直接传递给 MQTT 客户端进行发布。 #### 注意事项 - 确保 WebSocket 服务器的 URL 和端口与实际需求一致。 - MQTT 服务器的地址、端口、主题等参数需要根据实际情况调整。 - 如果需要更高的性能或可靠性，可以考虑优化代码结构，例如将 MQTT 客户端改为长连接模式。