27 lines
1.1 KiB
C
27 lines
1.1 KiB
C
|
#ifndef MQTT_CLIENT_H
|
|||
|
|
#define MQTT_CLIENT_H
|
|||
|
|
|
|||
|
|
#include <stdint.h>
|
|||
|
|
|
|||
|
|
/* <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD> MQTT 3.1.1 <20>ͻ<EFBFBD><CDBB>ˣ<EFBFBD><CBA3><EFBFBD><EFBFBD><EFBFBD> ESP-01S TCP <><CDB8>֮<EFBFBD>ϡ<EFBFBD>
|
|||
|
|
* <EFBFBD>ο<EFBFBD><EFBFBD><EFBFBD><EFBFBD>̡<EFBFBD>4·<EFBFBD>̵<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ƴ<EFBFBD>WIFI<EFBFBD><EFBFBD>4G V3.4 WIFI<EFBFBD>ص<EFBFBD><EFBFBD><EFBFBD>HARDWARE/ML302/mqtt.c
|
|||
|
|
* <EFBFBD>ı<EFBFBD><EFBFBD><EFBFBD>ƴ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>д<EFBFBD><EFBFBD>ȥ<EFBFBD><EFBFBD> 6KB <EFBFBD><EFBFBD><EFBFBD>λ<EFBFBD><EFBFBD>壨RAM <EFBFBD><EFBFBD><EFBFBD>ţ<EFBFBD><EFBFBD><EFBFBD>
|
|||
|
|
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>õ<EFBFBD><EFBFBD><EFBFBD><EFBFBD>壨<EFBFBD><EFBFBD>ѭ<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>з<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ֱ<EFBFBD>Ӵӹ<EFBFBD><EFBFBD><EFBFBD> U2_CopyBuff <EFBFBD><EFBFBD>֡<EFBFBD><EFBFBD> */
|
|||
|
|
|
|||
|
|
#define MQTT_KEEPALIVE_S 60 /* CONNECT <20><><EFBFBD><EFBFBD><EFBFBD>е<EFBFBD> keepalive */
|
|||
|
|
|
|||
|
|
/* PINGREQ <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>1<EFBFBD><31><EFBFBD>յ<EFBFBD> PINGRESP <20><>0<EFBFBD><30>net_wifi <20>ݴ<EFBFBD><DDB4>ж<EFBFBD><D0B6><EFBFBD>·<EFBFBD><C2B7><EFBFBD><EFBFBD> */
|
|||
|
|
extern volatile uint8_t g_mqttc_ping_outstanding;
|
|||
|
|
|
|||
|
|
void mqttc_init(const char *client_id, const char *user, const char *pass);
|
|||
|
|
int mqttc_connect(void); /* <20><> CONNECT <20><> CONNACK, 0=<3D>ɹ<EFBFBD> */
|
|||
|
|
int mqttc_subscribe(const char *topic); /* <20><> SUBSCRIBE(QoS0) <20><> SUBACK, 0=<3D>ɹ<EFBFBD> */
|
|||
|
|
int mqttc_publish(const char *topic, const char *payload); /* QoS0 <20><><EFBFBD><EFBFBD>, 0=<3D>ɹ<EFBFBD> */
|
|||
|
|
void mqttc_ping(void); /* <20><> PINGREQ */
|
|||
|
|
|
|||
|
|
/* <20>ӹ<EFBFBD><D3B9><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ջ<EFBFBD><D5BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD> MQTT <20><><EFBFBD>ģ<EFBFBD>ճ<EFBFBD><D5B3>/<2F><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȫ<EFBFBD><C8AB><EFBFBD><EFBFBD>
|
|||
|
|
* <EFBFBD><EFBFBD><EFBFBD><EFBFBD> 1=<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><EFBFBD>(<EFBFBD><EFBFBD><EFBFBD>ٵ<EFBFBD>), 0=<EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>, -1=<EFBFBD><EFBFBD>·<EFBFBD>Ͽ<EFBFBD>(<EFBFBD>յ<EFBFBD> CLOSED) */
|
|||
|
|
int mqttc_process(void);
|
|||
|
|
|
|||
|
|
#endif /* MQTT_CLIENT_H */
|