为什么使用MQTT
MQTT协议是轻量、简单、开放和易于实现的，这些特点使它适用范围非常广泛。特别是物联网（IoT）和嵌入式。
MQTT包容不稳定的网络，MQTT和MQ可以从诸如断开连接之类的故障中恢复，无需进一步的代码要求。但是，HTTP本身无法实现此目标，并且客户端必须重试编码，这会增加身份问题。
低功耗MQTT专为低功耗目标而设计。 HTTP设计未考虑此因素，这会增加功耗。
MQTT使用的发布/订阅消息模式，它提供了一对多的消息分发机制，从而实现与应用程序的解耦。这是一种消息传递模式，消息不是直接从发送器发送到接收器（即点对点），而是由MQTT server（或称为 MQTT Broker）分发的。客户端可以发布消息（发送方）、订阅消息（接收方）或两者兼而有之，从而可以实现多对多通信。
+ C% b+ A4 M) h' U7 k有三种消息发布服务质量：
( _/ @# P, n* I8 I“至多一次”，消息发布完全依赖底层TCP/IP网络。会发生消息丢失或重复。这一级别可用于如下情况，环境传感器数据，丢失一次读记录无所谓，因为不久后还会有第二次发送。这一种方式主要普通APP的推送，倘若你的智能设备在消息推送时未联网，推送过去没收到，再次联网也就收不到了。
“至少一次”，确保消息到达，但消息重复可能会发生。
) g+ D' {7 k  f% S" Q“只有一次”，确保消息到达一次。在一些要求比较严格的计费系统中，可以使用此级别。在计费系统中，消息重复或丢失会导致不正确的结果。这种最高质量的消息发布服务还可以用于即时通讯类的APP的推送，确保用户收到且只会收到一次。
, d* l: x7 L3 d6 l4 r: i项目概述
gitee项目地址
) x3 q6 e: {. O6 X2 ^3 P4 L9 u
* W. ]& k9 I- B, Y* M

& ^* v6 W- K( }' G( t移植ONENET开源代码
0 ]8 o  B4 o5 \4 y  B) x将服务质量2修改为服务质量0;

0 a0 @, _1 l" B; @

修改服务器地址
0 `  y; U. Q9 ^' s9 ], U1 S
* Q: Z5 X8 w* ~7 \  Q# f( ]8 b; E' u

1. #define SERVER_HOST                 "broker.emqx.io"                //  MQTT服务器域名或IP
   " s7 z5 G* V# q4 r. `. _! H+ }4 w
2. #define SERVER_PORT                   "1883"                           // MQTT服务器端口（一般为1883不用改）

复制代码

修改接收数据解析
) t4 w  {! f4 b$ A0 A: G3 i

1. case MQTT_PKT_PUBLISH:                                                       //接收的Publish消息
   7 j* p" Y& C" e  |9 ~, R
2.                
     e* a+ x9 i5 }9 _. _( Q
3.                         result = MQTT_UnPacketPublish(cmd, &cmdid_topic, &topic_len, &req_payload, &req_len, &qos, &pkt_id);
   
4.                         if(result == 0)
   6 w. Q! W* X& }* Y6 V
5.                         {
   
6.                                 UsartPrintf(USART_DEBUG, "topic: %s, topic_len: %d, payload: %s, payload_len: %d\r\n",
   7 E! D2 z2 O7 \0 z
7.                                                                                                                                         cmdid_topic, topic_len, req_payload, req_len);
   6 s+ ?- O& H/ v) D/ u8 R$ n
8.                                 
   ( @9 G9 y% A7 e* C) r) S5 v
9.                                 // 对数据包req_payload进行JSON格式解析
   
10.                                 json = cJSON_Parse(req_payload);
    
11.                                 if (!json)UsartPrintf(USART_DEBUG,"Error before: [%s]\n",cJSON_GetErrorPtr());
    5 c9 ]5 }2 c3 T8 m
12.                                 else
    
13.                                 {
    * u' U& W: e  h! R. s
14.                                         json_value = cJSON_GetObjectItem(json , "LED");
    + R. R% G) i9 _, u6 Z. Z! C4 k) q
15.                                        
    - g. G  Z$ n+ j5 n4 }& P, X* S! Q
16.                                         UsartPrintf(USART_DEBUG,"json_value: [%d]\n",json_value->valueint);
    
17.                                        
    
18.                                         if(json_value->valueint)//json_value > 0且为整形
    
19.                                         {
    6 y. M! C3 t  |4 U6 T0 t& ~
20.                                                 ucLed = 1;//打开LED0
    
21.                                         }
    
22.                                         else
    
23.                                         {
    & c4 S9 i3 i' ^& ]9 K
24.                                                 ucLed = 0;//关闭LED0
    7 c! ^+ ^# K9 r% {
25.                                         }
    
26.                                 }
    
27.                                 cJSON_Delete(json);
    8 K1 r- W; W& q) m+ z
28.                                 MQTT_DeleteBuffer(&mqttPacket);                                                                        //删包
    8 o  l- y3 H8 @6 r
29.                         }
    $ V8 S0 m9 ]( H$ L
30.                 break;

复制代码

使用场景
引用


/ i/ a. E* O, ~, @7 D1 ~  [

* z) ]% v! F) y# O4 v* n, Z
, x, f, ]5 g: ?; f————————————————
' R$ z- Z/ T3 G2 S6 o4 c) g版权声明：Flynnsin