抛出 'uPLibrary.Networking.M2Mqtt.Exceptions.MqttClientException' 类型的异常

Question

我正在连接到 mqtt，但收到一个无用的异常。

代码

string smsTopic = ConfigurationManager.AppSettings["MQTT_SMS_Topic"];
string emailTopic = ConfigurationManager.AppSettings["MQTT_Email_Topic"];
string pushTopic = ConfigurationManager.AppSettings["MQTT_PUSH_Topic"];
string socialTopic = ConfigurationManager.AppSettings["MQTT_SOCIAL_Topic"];

client = new MqttClient("somehostname");
string clientId = Guid.NewGuid().ToString();
client.Connect(clientId);
client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;
client.Subscribe(new string[] { smsTopic, emailTopic, pushTopic, socialTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

异常消息

Exception of type 'uPLibrary.Networking.M2Mqtt.Exceptions.MqttClientException' was thrown

异常的堆栈跟踪

at uPLibrary.Networking.M2Mqtt.Messages.MqttMsgSubscribe.GetBytes(Byte protocolVersion) in c:\Users\ppatierno\Source\Repos\m2mqtt\M2Mqtt\Messages\MqttMsgSubscribe.cs:line 187
at uPLibrary.Networking.M2Mqtt.MqttClient.Send(MqttMsgBase msg) in c:\Users\ppatierno\Source\Repos\m2mqtt\M2Mqtt\MqttClient.cs:line 1028
at uPLibrary.Networking.M2Mqtt.MqttClient.ProcessInflightThread() in c:\Users\ppatierno\Source\Repos\m2mqtt\M2Mqtt\MqttClient.cs:line 1954
at System.Threading.ThreadHelper.ThreadStart_Context(Object state)
at System.Threading.ExecutionContext.RunInternal(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state, Boolean preserveSyncCtx)
at System.Threading.ExecutionContext.Run(ExecutionContext executionContext, ContextCallback callback, Object state)
at System.Threading.ThreadHelper.ThreadStart()

我创建了一个bug on the github，但是没有解决方案

异常消息根本没有帮助，里面没有内部异常。

Answer 1

我能够通过更改以下语句解决此有线异常

client.Subscribe(new string[] { smsTopic, emailTopic, pushTopic, socialTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

至

client.Subscribe(new string[] { smsTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.Subscribe(new string[] { emailTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.Subscribe(new string[] { pushTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.Subscribe(new string[] { socialTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

同时指定多个主题时mqtt出现错误

Answer 2

好多了：

client.Subscribe(new string[] 
    { smsTopic, emailTopic, pushTopic, socialTopic }, 
    new byte[] { 
         MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, 
         MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE,
         MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE,
         MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE 
    }
);

Answer 3

我关注这个博客。 https://www.hivemq.com/blog/mqtt-client-library-encyclopedia-m2mqtt

如果你阅读订阅部分 client.Subscribe( ) 有两个数组作为输入参数：前者是你要订阅的 topics 的列表，后者是 的相关列表QoS 级别（每个主题一个）。

这意味着您需要通过 每个主题的服务质量 (QoS) 级别。

这将解决您的问题。

client.Subscribe(new string[] { smsTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.Subscribe(new string[] { emailTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.Subscribe(new string[] { pushTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });
client.Subscribe(new string[] { socialTopic }, new byte[] { MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });

抛出 'uPLibrary.Networking.M2Mqtt.Exceptions.MqttClientException' 类型的异常

Exception of type 'uPLibrary.Networking.M2Mqtt.Exceptions.MqttClientException' was thrown

c#

mqtt