基于。netCSocketWinFormMQTT客户端开发

　　1、什么是MQTT？
　　MQTT（MessageQueuingTelemetryTransport，消息队列遥测传输协议），是一种基于发布订阅（publishsubscribe）模式的轻量级通讯协议，该协议构建于TCPIP协议上，由IBM在1999年发布。MQTT最大优点在于，可以以极少的代码和有限的带宽，为连接远程设备提供实时可靠的消息服务。作为一种低开销、低带宽占用的即时通讯协议，使其在物联网、小型设备、移动应用等方面有较广泛的应用。
　　MQTT是一个基于客户端服务器的消息发布订阅传输协议。MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。在很多情况下，包括受限的环境中，如：机器与机器（M2M）通信和物联网（IoT）。其在，通过卫星链路通信传感器、偶尔拨号的医疗设备、智能家居、及一些小型化设备中已广泛使用。
　　（具体描述自行百度）
　　本文将基于。NetCSocketWinFormMQTT客户端开发，实现服务端连接，消息发布，消息订阅，取消订阅及接收服务端返回消息功能。
　　2、连接服务端
　　客户端连接服务端，启动异步接收服务端消息。
　　1连接选项2varoptionnewMQTT。MQTTClientOption（）3｛4ClientIdthis。txtClientId。Text，5IpStringthis。txtServer。Text，6PortConvert。ToInt32（this。txtPort。Text），7UserNamethis。txtUserName。Text，8Passwordthis。txtPassword。Text9｝；10实例客户端11this。mqttClientnewMQTT。MQTTClient（）；12this。mqttClient。ClientReceivedMqttClientClientReceived；13varresultawaitthis。mqttClient。ConnectAsync（option）；14if（result。Statefalse）15｛16MessageBox。Show（result。Fail，提示，MessageBoxButtons。OK，MessageBoxIcon。Warning）；17return；18｝19开始接收20this。mqttClient。BeginReceive（）；
　　3、发布消息
　　客户端向服务端发送消息，主要包括主题，内容及消息质量。
　　发送消息程序
　　1privateshortPacketId1；2privateasyncvoidBtnPublishClick（objectsender，EventArgse）3｛4this。btnPublish。Enabledfalse；5this。CursorCursors。WaitCursor；6try7｛8shortqos0；9if（rdbLevel1。Checked）10qos1；11if（rdbLevel2。Checked）12qos2；1314vardatanewMQTT。PublishEntity（）15｛16Topicthis。txtTopic。Text，17ReloadSystem。Text。Encoding。UTF8。GetBytes（this。txtContent。Text），18Qosqos，19PacketIdPacketId20｝；21varresultawaitthis。mqttClient。PublishAsync（data，false）；22if（result。Statefalse）23｛24this。AppendText（发送失败：result。Fail）；25return；26｝27this。PacketId；28this。AppendText（发送成功，返回结果：result。Result）；29｝30finally31｛32this。btnPublish。Enabledtrue；33this。CursorCursors。Default；34｝35｝
　　4、订阅消息
　　客户端订阅消息，主要包括过滤主题及消息质量。
　　订阅消息方法：
　　1privateasyncvoidBtnSubscribeClick（objectsender，EventArgse）2｛3this。btnSubscribe。Enabledfalse；4this。CursorCursors。WaitCursor；56try7｛8stringfailstring。Empty；910shortqos0；11if（rdbQos1。Checked）12qos1；13if（rdbQos2。Checked）14qos2；1516MQTT。SubscribeEntityentitynewMQTT。SubscribeEntity（）；17entity。Filterthis。txtFilter。Text；18entity。Qosqos；1920this。AppendText（开始订阅。。。）；21if（mqttClient。Subscribe（this。txtFilter。Text，qos，outresult，outfail）false）22｛23this。AppendText（fail）；24return；25｝26varresultawaitmqttClient。SubscribeAsync（entity。Filter，entity。Qos）；27if（result。Statefalse）28｛29this。AppendText（result。Fail）；30return；31｝3233this。AppendText（订阅成功！返回结果：result。Result）；34MQTT。SubscribeHelper。Save（entity）；3536DataRowdrDatathis。dtSubscribes。NewRow（）；37drData〔Id〕entity。Id；38drData〔Filter〕entity。Filter；39drData〔Qos〕entity。Qos；40drData〔Count〕0；41dtSubscribes。Rows。Add（drData）；42｝43finally44｛45this。btnSubscribe。Enabledtrue；46this。CursorCursors。Default；47｝48｝
　　5、取消订阅
　　客户端取消某一订阅消息。双击订阅消息行，取消订阅消息。
　　取消订阅方法：
　　1privateasyncvoidDataGridView1CellDoubleClick（objectsender，DataGridViewCellEventArgse）2｛3if（this。dataGridView1。CurrentCellnull）4return；56DataRowViewdrvthis。dataGridView1。CurrentRow。DataBoundItemasDataRowView；7if（drvnull）8return；910if（MessageBox。Show（确认取消当前选择：drv〔Filter〕。ToString（）订阅？，确认，MessageBoxButtons。OKCancel，MessageBoxIcon。Question）！DialogResult。OK）11return；12try13｛14this。AppendText（开始取消订阅。。。）；15varresultawaitmqttClient。UnSubscribeAsync（drv〔Filter〕。ToString（））；16if（result。Statefalse）17｛18this。AppendText（result。Fail）；19return；20｝21this。AppendText（取消订阅成功！返回结果：result。Result）；22MQTT。SubscribeHelper。Delete（drv〔Id〕。ToString（））；23this。dataGridView1。Rows。RemoveAt（this。dataGridView1。CurrentCell。RowIndex）；24｝25catch（Exceptionex）26｛27this。AppendText（取消订阅异常：ex。ToString（））；28｝2930｝
　　6、接收服务端消息
　　客户端接收服务端转发过来的消息。
　　1privatevoidMqttClientClientReceived（MQTT。MQTTClientclient，MQTT。ReceiveResultreceive）2｛3if（receive。Data！null）4this。AppendText（DataReceivedstatereceive。Statetopicreceive。Data。TopiccontentSystem。Text。Encoding。UTF8。GetString（receive。Data。Reload））；5elseif（receive。State）6this。AppendText（DataReceivedstatereceive。Stateresultreceive。Result）；7else8this。AppendText（DataReceivedstatereceive。Statefailreceive。Fail）；9｝
　　至此，客户端工具主要功能简介完毕，不当之处，欢迎指正！
　　客户端下载地址（码云服务器）：https：gitee。comShiQuan25fullproductmanagementrawmasterWinMQTTClientWinMQTTClient。zip