[嵌入式]EC20模组使用MQTT库对接EMQX，基于STM32F407

一、说明

本lib库基于STM32F407编译，其他的cortexM4内核也支持，采用串口和EC20模组通信。

库包括两个文件：ec20_mqtt.h和ec20_mqtt.lib。使用时添加lib文件到工程中，头文件引用ec20_mqtt.h即可。

下载：https://gitee.com/eiri_jackmaster/ec20_mqtt_cm4-lib

二、功能

提供了创建mqtt客户端、连接服务器、订阅、发布、取消订阅、断开连接、获取imei号等API接口。

/*! -------------------------------------------------------------------------- */
/*! Public function prototype */ 
EC20_status EC20_initialize(void);
EC20_status EC20_mqttClientCreate(uint8_t pClientID,char* pIPv4, uint32_t pPort);
EC20_status EC20_mqttClientConnectServer(uint8_t pClientID, char* pClientIDStr,char* pName, char* pPswd);
EC20_status EC20_mqttClientSubscribe(uint8_t pClientID, char* pTopic, uint8_t pQos);
EC20_status EC20_mqttClientUnSubscribe(uint8_t pClientID, char* pTopic);
EC20_status EC20_mqttClientPublish(uint8_t pClientID, char* pTopic, uint8_t pQos, uint8_t pRetain, uint8_t *pData, uint32_t pSize);
EC20_status EC20_mqttClientDisConnectServer(uint8_t pClientID);
extern void EC20_moduleHardReset(void);
size_t      EC20_getIMEI(char *pIMEIBuff);

三、移植

在头文件指定相应的串口操作函数和毫秒级基本延时即可。此外，需要外部实现EC20模组的复位操作，一般是对rst管脚拉高一段时间，复位函数需要指定函数为void EC20_moduleHardReset(void)。

/*! macro defination for porting */
/*! ec20 uart default 115200 8 N 1 */
#define EC20_SENDDATA(a,b)        USART2_sendData(a,b)    /*! uart redefine */
#define EC20_SENDSTR(a)           USART2_sendString(a)
#define EC20_RXFLAG               usart2Rx.flag                        
#define EC20_RXBUFF               usart2Rx.buff
#define EC20_RXLEN                usart2Rx.size
#define EC20_BUFF_SIZE            UART2_BUFF_SIZE       /*! buffsize define */
#define EC20_DELAYMS              HAL_Delay
#define PRINT_ENABLE              0x10        /*! 0x00=enable, other=disable*/

四、实例

以下为STM32F407使用ec20的mqtt库，实现对接自建EMQX。

1、工程添加ec20_mqtt.lib

2、头文件引入

定义变量和私有mqtt服务器信息（我使用了订阅认证和鉴权）：

??3、实现EC20模组复位接口

?4、调用接口

（1）初始化

（2）创建mqtt客户端，连接服务器

（3）订阅和发布主题

?4、执行结果

?

?可以看到发布和订阅正常。