MqttClientPublishMessageAsync 方法 |
命名空间: HslCommunication.MQTT
// 简单的实例化例子 MqttClient mqttClient = new MqttClient( new MqttConnectionOptions( ) { ClientId = "ABC", // 客户端的唯一的ID信息 IpAddress = "127.0.0.1", // 服务器的地址 } );
// 发布示例 HslCommunication.OperateResult connect = mqttClient.PublishMessage( new MqttApplicationMessage( ) { Topic = "A", // 主题 QualityOfServiceLevel = MqttQualityOfServiceLevel.AtMostOnce, // 如果是实时数据,适合用这个 Payload = Encoding.UTF8.GetBytes("Test data") // 发布的数据 } ); if (connect.IsSuccess) { // 发布成功 } else { // 发布失败 } // 重点说明。如果过会网络不行了,断开了,内部会自动连接服务器的,你只管publish就可以了