geArrive株洲

它的函数原型如下：

DLLExport int MQTTSubscribe(MQTTClient* client, const char* topicFilter, enum QoS, messageHandler);
其中：

MQTTClient* c ：我们前面定义的MQTTClient结构体

const char* topicFilter：订阅的主题

messageHandler messageHandler ：接收到主题信息后的回调处理函数。

例如上面我们的回调函数是  messageArrived ，它的原型如下：

void messageArrived(MessageData* md)
{
 MQTTMessage* message = md->message;
 //打印接收到的消息的长度、和消息内容
 printf("%.*s", (int)message->payloadlen, (char*)message->payload);
}
 

5. 发送消息

发送消息也比较简单，我们只需要设置好我们的主题和消息内容即可

memset(&pubmsg, '\0', sizeof(pubmsg));
 //消息内容为 hello harmonyOS !
   pubmsg.payload = (void*)"hello harmonyOS !";
 //消息长度
   pubmsg.payloadlen = strlen((char*)pubmsg.payload);
   pubmsg.qos = QOS0;
   pubmsg.retained = 0;
   pubmsg.dup = 0;
 
 //推送消息，主题为 pubtest
 

标签：geArrive,pubmsg,株洲,char,消息,message,payload,messageHandler
来源： https://blog.csdn.net/m0_53241909/article/details/110632781