1

duan

2024-08-21 e7761be3fd250c91c3b03265876ac246651f065a

 src/WindowsFormsApp1/Form1.cs

@@ -328,7 +328,7 @@
                client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed;  //取消订阅主题成功后调用
                client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;  //当接收到订阅主题的消息时调用
                client.ConnectionClosed += client_ConnectionClosed;  //连接断开后调用
                MessageBox.Show("连接成功。", "信息");
                MessageBox.Show("连接成功。", "信息");// 
            }
            catch (Exception ex)
            {
@@ -377,12 +377,12 @@
                client.MqttMsgSubscribed += client_MqttMsgSubscribed;  //订阅主题成功后调用
                client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed;  //取消订阅主题成功后调用
                client.MqttMsgPublishReceived += client_MqttMsgPublishReceived;  //当接收到订阅主题的消息时调用
                client.ConnectionClosed += client_ConnectionClosed;  //连接断开后调用
                client.ConnectionClosed += client_ConnectionClosed;//连接断开后调用

                string[] subscribeTopic = Toprie_MotifList().Split(',');  //可以同时订阅多个主题的消息，各主题之间用逗号分隔
                byte[] qosLevels = new byte[] { MqttMsgBase.QOS_LEVEL_AT_LEAST_ONCE };

                foreach (var item in subscribeTopic) {
                foreach (var item in subscribeTopic){
                    string[] MotifNameList ={ item };
                    client.Subscribe(MotifNameList, qosLevels);
                }
@@ -390,7 +390,7 @@
                MessageBox.Show("订阅主题成功。", "信息");
            }
            catch (Exception ex){
                MessageBox.Show(ex.Message.ToString(), "异常");
                MessageBox.Show(ex.Message.ToString(),"异常");
            }
           
        }