为什么使用MQTT
! W5 a, _2 g0 p, k( H0 r* @MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。特别是物联网（IoT）和嵌入式。
4 T/ g- H2 ~: E7 IMQTT包容不稳定的网络，MQTT和MQ可以从诸如断开连接之类的故障中恢复，无需进一步的代码要求。但是，HTTP本身无法实现此目标，并且客户端必须重试编码，这会增加身份问题。
低功耗MQTT专为低功耗目标而设计。 HTTP设计未考虑此因素，这会增加功耗。
MQTT使用的发布/订阅消息模式，它提供了一对多的消息分发机制，从而实现与应用程序的解耦。这是一种消息传递模式，消息不是直接从发送器发送到接收器（即点对点），而是由MQTT server（或称为 MQTT Broker）分发的。客户端可以发布消息（发送方）、订阅消息（接收方）或两者兼而有之，从而可以实现多对多通信。
7 s0 V. W, S  ?+ j' ?有三种消息发布服务质量：
“至多一次”，消息发布完全依赖底层TCP/IP网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。这一种方式主要普通APP的推送，倘若你的智能设备在消息推送时未联网，推送过去没收到，再次联网也就收不到了。
; v" E( G6 v/ R, }. b8 i“至少一次”，确保消息到达，但消息重复可能会发生。
“只有一次”，确保消息到达一次。在一些要求比较严格的计费系统中，可以使用此级别。在计费系统中，消息重复或丢失会导致不正确的结果。这种最高质量的消息发布服务还可以用于即时通讯类的APP的推送，确保用户收到且只会收到一次。
2 B# c! k5 ], }项目概述
gitee项目地址
6 X1 F' s( ~5 E; |8 J

: s; {  p5 w& i) B
移植ONENET开源代码
& W8 {2 u* H4 Q3 m7 I& Y+ X7 j2 V+ o" O将服务质量2修改为服务质量0;

  K* X# y$ u* f; P1 f

& h9 ?! {9 a+ i9 A. K' y9 m6 N8 D9 ~修改服务器地址

/ u+ r9 `: M3 J: c

1. #define SERVER_HOST                 "broker.emqx.io"                //  MQTT服务器域名或IP
   ' f* m2 m3 g0 R0 S' E) S9 x2 V( T
2. #define SERVER_PORT                   "1883"                           // MQTT服务器端口（一般为1883不用改）

复制代码

修改接收数据解析
$ _! H# g- R4 N
4 I+ T' y; a& B

1. case MQTT_PKT_PUBLISH:                                                       //接收的Publish消息
   
2.                
   
3.                         result = MQTT_UnPacketPublish(cmd, &cmdid_topic, &topic_len, &req_payload, &req_len, &qos, &pkt_id);
   
4.                         if(result == 0)
   
5.                         {
     d9 h& M! C$ o* s  `' Z- _
6.                                 UsartPrintf(USART_DEBUG, "topic: %s, topic_len: %d, payload: %s, payload_len: %d\r\n",
   
7.                                                                                                                                         cmdid_topic, topic_len, req_payload, req_len);
   : R# y+ ?$ q$ ]: _+ @" S
8.                                 
   ( [: w  A6 D% t
9.                                 // 对数据包req_payload进行JSON格式解析
   5 |# z+ Q% b. l
10.                                 json = cJSON_Parse(req_payload);
    6 D# k  R$ j0 {% B
11.                                 if (!json)UsartPrintf(USART_DEBUG,"Error before: [%s]\n",cJSON_GetErrorPtr());
    
12.                                 else
    
13.                                 {
    7 j+ ]% s6 U$ ~8 [# P. z
14.                                         json_value = cJSON_GetObjectItem(json , "LED");
    
15.                                        
    
16.                                         UsartPrintf(USART_DEBUG,"json_value: [%d]\n",json_value->valueint);
    4 M  h2 x2 `( D7 G0 b. V* a! o
17.                                        
    
18.                                         if(json_value->valueint)//json_value > 0且为整形
    2 C: t* y3 }* r$ J8 Z6 j  ^5 c9 g1 K
19.                                         {
    
20.                                                 ucLed = 1;//打开LED0
    
21.                                         }
    . z0 P/ A% x9 N1 M, \  R
22.                                         else
    / E+ H# J0 P/ e& @
23.                                         {
    : R9 q2 v- }* m7 q( r* o
24.                                                 ucLed = 0;//关闭LED0
    ) C3 I5 Y2 z3 w$ `) l
25.                                         }
    9 ?/ s; a+ D  |, q) j
26.                                 }
    ) W  C% B- x# h+ c, t* H8 e0 c6 N
27.                                 cJSON_Delete(json);
    5 G3 a1 D) R  M4 I  r1 n) z
28.                                 MQTT_DeleteBuffer(&mqttPacket);                                                                        //删包
    
29.                         }
    $ Y: P! x$ q" }: D  _; [1 N
30.                 break;

复制代码

使用场景
引用



$ a/ B( B& P2 F8 d

# @1 Z1 f8 F( O+ L* T: f( _————————————————
; O5 ~( g( k7 u版权声明：Flynnsin
! v8 F1 X2 ~/ ?) b1 K3 `2 {% s
. U, V) u  p+ T" e
( V' p  l& B  A. {