| | |
| | | client.MqttMsgUnsubscribed += client_MqttMsgUnsubscribed; //取消订阅主题成功后调用 |
| | | client.MqttMsgPublishReceived += client_MqttMsgPublishReceived; //当接收到订阅主题的消息时调用 |
| | | client.ConnectionClosed += client_ConnectionClosed; //连接断开后调用 |
| | | MessageBox.Show("连接成功。", "信息"); |
| | | MessageBox.Show("连接成功。", "信息");// |
| | | } |
| | | catch (Exception ex) |
| | | { |
| | |
| | | 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); |
| | | } |
| | |
| | | MessageBox.Show("订阅主题成功。", "信息"); |
| | | } |
| | | catch (Exception ex){ |
| | | MessageBox.Show(ex.Message.ToString(), "异常"); |
| | | MessageBox.Show(ex.Message.ToString(),"异常"); |
| | | } |
| | | |
| | | } |