MQTTNET 3.1.2版本,项目引用后 创建MQTT服务,接收消息等都正常,只有推送的时候,推送内容不止是客户端接收到,服务端自己也接收到。很奇怪。
/// <summary>
/// 发布消息
/// </summary>
public async static void ServerPublishMqttTopic(string topic, string payload)
{
try
{
var message = new MqttApplicationMessage()
{
Topic = topic,
Payload = Encoding.UTF8.GetBytes(payload),
QualityOfServiceLevel = MqttQualityOfServiceLevel.AtLeastOnce,
Retain = false,
};
await mqttServer.PublishAsync(message);
}
catch (Exception ex)
{
TxtWrite.WriteTxt("[" + DateTime.Now + "]发布消息失败!");
}
}
发送消息调用ServerPublishMqttTopic("xxx","0");
结果在服务端mqttServer.ApplicationMessageReceivedHandler的事件中,也接收到了“0”;自己推送自己接收了?
请问这个怎么解决啊??