首页 > 其他分享> > ESA2GJK1DH1K基础篇: 移植官方+本人进行二次封装的MQTT包,让TCP实现MQTT功能(以GPRS模块为例)

ESA2GJK1DH1K基础篇: 移植官方+本人进行二次封装的MQTT包,让TCP实现MQTT功能(以GPRS模块为例)

2019-10-30 18:56:52 作者：互联网

前言

　　该程序需要的基础知识: https://www.cnblogs.com/yangfengwu/category/1566194.html 所有源码开源,请自行学习

这节代码将在这一节的基础上实现

拷贝第一节测试里面的MQTT文件夹到当前工程

当前工程建个MQTT的文件夹,用于存放那个MQTT文件夹里面的内容

添加文件到里面

添加头文件到 include.h

设置一下头文件路径

注意,如果不是用的我的工程底板,会报错一个地方,自己去定义一个数组去数组大小先设置200吧,放到这里,

这个数组是存放服务器发过来的数据.

具体看我后面的介绍.

控制模块TCP连接上MQTT

注意,我是AT指令通过串口控制GPRS连接的TCP服务器(MQTT软件)

大家如果用的其它不是通过串口控制连接的,请自己写控制模块连接TCP的函数

            case 0://关闭移动场景,彻底关闭TCP/IP 连接
                SendConfigFunction("AT+CIPSHUT\r\n",NULL,"SHUT OK",NULL,FunctionParseCompare,CompareValue);break;
            case 1://读取SIM状态正常
                SendConfigFunction("AT+CPIN?\r\n",NULL,"OK",NULL,FunctionParseCompare,CompareValue);break;
            case 2://GPRS注册状态            
                SendConfigFunction("AT+CGREG?\r\n",NULL,"+CGREG: 0,1",NULL,FunctionParseCompare,CompareValue);break;
            case 3://是否附着了GPRS  
                SendConfigFunction("AT+CGATT?\r\n",NULL,"+CGATT: 1",NULL,FunctionParseCompare,CompareValue);break;            
            case 4://设置为单链接
                SendConfigFunction("AT+CIPMUX=0\r\n",NULL,"OK",NULL,FunctionParseCompare,CompareValue);break;            
            case 5://透传模式 
                SendConfigFunction("AT+CIPMODE=1\r\n",NULL,"OK",NULL,FunctionParseCompare,CompareValue);break;
            case 6://设置APN
                SendConfigFunction("AT+CSTT\r\n",NULL,"OK",NULL,FunctionParseCompare,CompareValue);break;
            case 7://激活移动场景
                SendConfigFunction("AT+CIICR\r\n",NULL,"OK",NULL,FunctionParseCompare,CompareValue);break;
            case 8://连接TCP 服务器
                SendConfigFunction("AT+CIPSTART=\"TCP\",\"47.92.31.46\",1883\r\n",NULL,"CONNECT",NULL,FunctionParseCompare,CompareValue);break;