C#实现MQTT协议

【实例简介】
本例是对MQTT协议的C#实现，网络上搜集来的代码，留作备份，并与诸同仁共享之。
【实例截图】
【核心代码】
c实现MQTT协议
├── M2Mqtt
│   ├── bin
│   │   └── Debug
│   │   ├── M2Mqtt.dll
│   │   └── M2Mqtt.pdb
│   ├── Exceptions
│   │   ├── MqttClientException.cs
│   │   ├── MqttCommunicationException.cs
│   │   ├── MqttConnectionException.cs
│   │   └── MqttTimeoutException.cs
│   ├── IMqttNetworkChannel.cs
│   ├── M2Mqtt.csproj
│   ├── M2Mqtt.csproj.user
│   ├── Messages
│   │   ├── MqttMsgBase.cs
│   │   ├── MqttMsgConnack.cs
│   │   ├── MqttMsgConnect.cs
│   │   ├── MqttMsgContext.cs
│   │   ├── MqttMsgDisconnect.cs
│   │   ├── MqttMsgPingReq.cs
│   │   ├── MqttMsgPingResp.cs
│   │   ├── MqttMsgPuback.cs
│   │   ├── MqttMsgPubcomp.cs
│   │   ├── MqttMsgPublish.cs
│   │   ├── MqttMsgPublishedEventArgs.cs
│   │   ├── MqttMsgPublishEventArgs.cs
│   │   ├── MqttMsgPubrec.cs
│   │   ├── MqttMsgPubrel.cs
│   │   ├── MqttMsgSuback.cs
│   │   ├── MqttMsgSubscribe.cs
│   │   ├── MqttMsgSubscribedEventArgs.cs
│   │   ├── MqttMsgUnsuback.cs
│   │   ├── MqttMsgUnsubscribe.cs
│   │   └── MqttMsgUnsubscribedEventArgs.cs
│   ├── MqttClient.cs
│   ├── MqttNetworkChannel.cs
│   ├── MqttSettings.cs
│   ├── obj
│   │   └── Debug
│   │   ├── DesignTimeResolveAssemblyReferencesInput.cache
│   │   ├── M2Mqtt.csproj.FileListAbsolute.txt
│   │   ├── M2Mqtt.dll
│   │   └── M2Mqtt.pdb
│   ├── Properties
│   │   └── AssemblyInfo.cs
│   └── Utility
│   └── QueueExtension.cs
├── MqttBroker
│   ├── bin
│   │   └── Debug
│   │   ├── MqttBroker.dll
│   │   └── MqttBroker.pdb
│   ├── Exceptions
│   │   ├── MqttClientException.cs
│   │   ├── MqttCommunicationException.cs
│   │   ├── MqttConnectionException.cs
│   │   └── MqttTimeoutException.cs
│   ├── IMqttNetworkChannel.cs
│   ├── Messages
│   │   ├── MqttMsgBase.cs
│   │   ├── MqttMsgConnack.cs
│   │   ├── MqttMsgConnect.cs
│   │   ├── MqttMsgConnectEventArgs.cs
│   │   ├── MqttMsgContext.cs
│   │   ├── MqttMsgDisconnect.cs
│   │   ├── MqttMsgPingReq.cs
│   │   ├── MqttMsgPingResp.cs
│   │   ├── MqttMsgPuback.cs
│   │   ├── MqttMsgPubcomp.cs
│   │   ├── MqttMsgPublish.cs
│   │   ├── MqttMsgPublishedEventArgs.cs
│   │   ├── MqttMsgPublishEventArgs.cs
│   │   ├── MqttMsgPubrec.cs
│   │   ├── MqttMsgPubrel.cs
│   │   ├── MqttMsgReceivedEventArgs.cs
│   │   ├── MqttMsgSuback.cs
│   │   ├── MqttMsgSubscribe.cs
│   │   ├── MqttMsgSubscribedEventArgs.cs
│   │   ├── MqttMsgSubscribeEventArgs.cs
│   │   ├── MqttMsgUnsuback.cs
│   │   ├── MqttMsgUnsubscribe.cs
│   │   ├── MqttMsgUnsubscribedEventArgs.cs
│   │   └── MqttMsgUnsubscribeEventArgs.cs
│   ├── MqttBroker.csproj
│   ├── MqttBrokerNetCf39.csproj
│   ├── MqttClientConnectedEventArgs.cs
│   ├── MqttClientContext.cs
│   ├── MqttCommunicationLayer.cs
│   ├── MqttController.cs
│   ├── MqttNetworkChannel.cs
│   ├── MqttServer.cs
│   ├── MqttSettings.cs
│   ├── MqttSubscriberManager.cs
│   ├── MqttUacManager.cs
│   ├── obj
│   │   └── Debug
│   │   ├── DesignTimeResolveAssemblyReferencesInput.cache
│   │   ├── MqttBroker.csproj.FileListAbsolute.txt
│   │   ├── MqttBroker.dll
│   │   └── MqttBroker.pdb
│   ├── Properties
│   │   └── AssemblyInfo.cs
│   └── Utility
│   └── QueueExtension.cs
└── MqttBrokerServer
├── app.config
├── bin
│   └── Debug
│   ├── MqttBroker.dll
│   ├── MqttBroker.pdb
│   ├── MqttBrokerServer.exe
│   ├── MqttBrokerServer.exe.config
│   ├── MqttBrokerServer.pdb
│   ├── MqttBrokerServer.vshost.exe
│   ├── MqttBrokerServer.vshost.exe.config
│   └── MqttBrokerServer.vshost.exe.manifest
├── MqttBrokerServer.csproj
├── obj
│   └── x86
│   └── Debug
│   ├── DesignTimeResolveAssemblyReferencesInput.cache
│   ├── MqttBrokerServer.csproj.FileListAbsolute.txt
│   ├── MqttBrokerServer.csprojResolveAssemblyReference.cache
│   ├── MqttBrokerServer.exe
│   ├── MqttBrokerServer.pdb
│   ├── ResolveAssemblyReference.cache
│   └── TempPE
│   └── Service References.padserver.Reference.cs.dll
├── Program.cs
├── Properties
│   └── AssemblyInfo.cs
└── Service References
└── padserver
├── configuration91.svcinfo
├── configuration.svcinfo
├── item1.xsd
├── item2.xsd
├── item3.xsd
├── item4.xsd
├── item.disco
├── item.xsd
├── MqttBrokerServer.padserver.SpecialTopicInfo.datasource
├── Reference.cs
├── Reference.svcmap
└── ServiceOfSepcialInfo.wsdl

28 directories, 117 files