| | |
|---|
| | | Topic = $"/user/{MqttInfoConfig.Current.HomeGatewayInfo.gatewayId}/app/thing/property/send", |
|---|
| | | QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce |
|---|
| | | }; |
|---|
| | | var topicBusStatus = new MqttTopicFilter() |
|---|
| | | { |
|---|
| | | Topic = $"/BusGateWayToClient/MacMask/Common", |
|---|
| | | QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce |
|---|
| | | }; |
|---|
| | | //var topicBusStatus = new MqttTopicFilter() |
|---|
| | | //{ |
|---|
| | | // Topic = $"/BusGateWayToClient/{}/Common", |
|---|
| | | // QualityOfServiceLevel = MQTTnet.Protocol.MqttQualityOfServiceLevel.AtMostOnce |
|---|
| | | //}; |
|---|
| | | |
|---|
| | | Utlis.WriteLine("开始订阅！"); |
|---|
| | | var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] { topicFilterBusGateWayToClient, topicFilterPush2, topicAlinkStatus, topicBusStatus }); |
|---|
| | | var result = await RemoteMqttClient.SubscribeAsync(new MqttTopicFilter[] { topicFilterBusGateWayToClient, topicFilterPush2, topicAlinkStatus }); |
|---|
| | | if (result.Items[0].ResultCode == MQTTnet.Client.Subscribing.MqttClientSubscribeResultCode.GrantedQoS0) |
|---|
| | | { |
|---|
| | | isSubscribeSuccess = true; |
|---|
