订阅者流程
定义
#define ADDRESS "tcp://172.16.10.139:1883"//代理主机地址 #define CLIENTID "ExampleClientSub"//客户端ID #define TOPIC "mqtt async test"//主题 #define QOS 1
MQTTClient client; //客户端 MQTTClient_connectOptions conn_opts = MQTTClient_connectOptions_initializer;//客户端初始化参数 int rc;
然后需要实现三个回调函数分别如下