资源描述：
《mqtt后台服务及接口函数说明》由会员上传分享，免费在线阅读，更多相关内容在应用文档-天天文库。
1、mqtt服务及接口函数说明1、概述AiMaster,AiMaker系列可编程产品采用系统服务方式支持mqtt协议，开发者只需调用接口函数，即可零代码实现mqtt的发布、订阅功能。通讯过程中的网络错误检测、自动重连，均由后台线程自动完成。系统会自动启动mqtt后台服务，以服务索引编号0～7的方式来使用，mqtt接口函数通过服务索引来实现启动mqtt服务、发布、订阅、接收发布等功能。mqtt函数表：函数库：mqtt启动mqtt服务并连接到指定的mqtt服务器：mqtt.startmqtt设置订阅主题函数：mqtt.settopic取消订阅函数：mqtt.unsu
2、bs向服务器发布数据函数：mqtt.publish等待服务器发布数据消息函数：mqtt.waitpublish读取服务器发布数据消息函数：mqtt.readpublish发布数据的简单示例：只需2行代码即可实现发布功能。启动mqtt服务0，连接mqtt服务器192.168.192.11:1883，接收超时为0。mqtt客户端ID为88888。mqtt.startmqtt(0,"192.168.192.11",1883,20,1000,"888888","user1","pwd1",0)使用mqtt服务0向mqtt服务器的hello主题，发送testmqtt字
3、符串。mqtt.publish(0,"hello","testmqtt",0)订阅、接收服务器发布的简单示例：只需3行代码实现接收发布。下行代码一直等待mqtt服务器发布数据。mqtt.waitpublish(-1);--读取服务器的发布数据i1,s1,s2=mqtt.readpublish()print(string.format("r索引:%d,主题:%s,数据:%s",i1,s1,s2));--通知mqtt后台服务，完成本次数据接收操作。mqtt.responsepublish();1、与mqtt服务器建立连接启动mqtt服务函数startmqt
4、t，此函数启动指定编号的mqtt服务，然后用指定的客户端ID，用户名、密码连接mqtt服务器--参数1:mqtt客户端服务索引，有效值0～7，共支持8个mqtt服务，可以同时建立8个mqttclient连接。--参数2:远程ip，mqtt服务器IP--参数3:远程端口，mqtt服务器端口--参数4:接收超时，此连接只向服务器发布数据，而不接收服务器的发布，所以接收超时设置为0。--参数5:重试连接间隔，如果与服务器中断连接，后台服务在暂停此间隔后，重试连接。--参数6:客户端ID，此mqtt的客户端标识。--参数7:用户名--参数8:密码--参数9:连接标志
5、，默认为0。--返回：如果启动成功返回大于0的值，否则返回小于、等于0的值。下行代码作用是：启用编号0的mqtt服务，并且与192.168.192.11:1883的mqtt服务器建立连接。接收超时为0秒（只用于向服务器单向发布数据时设置为0），重试连接间隔是1秒。mqtt客户端ID为888888，用户名为user，密码为pwd1。mqtt.startmqtt(0,"192.168.192.11",1883,20,1000,"888888","user1","pwd1",0)1、发布数据--向发布数据函数publish--参数1：mqtt客户端服务索引。必须是
6、已经通过startmqtt函数正确启动的索引。--参数2：发布的主题，为ASCII码字符串格式。--参数3：发布的数据，为ASCII码字符串格式。--返回：如果返回值大于0，为发送成功，否则为发送失败。下行代码的含义是：使用0号mqtt服务，向demotopic主题发布字符串“aabb=12342;ssss=22132”mqtt.publish(0,"demotopic","aabb=12342;ssss=22132",0)2、设置订阅主题首先设置待订阅的主题，在startmqtt函数启动mqtt客户端，并与服务器建立连接后，会自动订阅此主题，订阅过程无需用
7、户干预。--设置订阅主题函数settopic--参数1：mqtt客户端服务索引--参数2：订阅主题组索引，有效值为0～7。每个mqtt客户端服务可同时支持8个订阅主题，对应索引0～7。--参数3：订阅的主题，为ASCII码字符串格式。--参数4：保留参数，默认为0下行代码为mqtt客户端服务1，设置一个订阅主题topicrec，使用主题的0号索引。mqtt.settopic(1,0,"topicrec",0)1、响应、读取mqtt服务器发布的数据如果需要接收来自mqtt服务器的发布数据，则必须首先使用settopic来订阅待接收数据的主题。采用消息方式响应来
8、自服务器发布数据。首先调用waitpublish函数
