不到百行Demo看清MQTT收发处理逻辑

static void messageArrived(MessageData* data)
{
	mqtt_printf(MQTT_INFO, "Message arrived on topic %s: %sn",data->topicName->lenstring.data,(char*)data->message->payload);

	/**/
	memset((char*)data->message->payload,0,(char*)data->message->payloadlen);//����
}

void MQTTTaskDemo(void *pvParameters)
{
	/* To avoid gcc warnings */
	( void ) pvParameters;
	
	/* connect to gpssensor.ddns.net, subscribe to a topic, send and receive messages regularly every 5 sec */
	MQTTClient client;
	Network network;
	unsigned char sendbuf[512], readbuf[80];
	int rc = 0, count = 0;
	MQTTPacket_connectData connectData = MQTTPacket_connectData_initializer;
//	char* address = "www.xuhongv.com";
//	char* sub_topic = "LASS/Test/Pm25Ameba/cc";
//	char* pub_topic = "LASS/Test/Pm25Ameba/FT1_018";
	connectData.MQTTVersion = 4;
	connectData.clientID.cstring = "56";
	connectData.username.cstring="66717";
	connectData.password.cstring="eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzI1NiJ9.eyJjbGllbnRJZCI6IjU2IiwidXNlcm5hbWUiOiI2NjcxNyIsInRpbWVzdGFtcCI6MTU5OTU1MDM3MjcyM30.JxIp4oBPth6OmUy6s2RW4_E20mY9IiY9LyfzJk6VwtI";
	char* address = "test-mqtt.xxxx.net";
	char* sub_topic = "2000stn/service/transmit/66717/3455/#";
	char* pub_topic = "2000stn/event/status/66717/123";
	
	NetworkInit(&network);
	MQTTClientInit(&client, &network, 30000, sendbuf, sizeof(sendbuf), readbuf, sizeof(readbuf));

	mqtt_printf(MQTT_INFO, "Wait Wi-Fi to be connected.");
	while(wifi_is_ready_to_transceive(RTW_STA_INTERFACE) != RTW_SUCCESS) {
		vTaskDelay(5000 / portTICK_PERIOD_MS);
	}
	mqtt_printf(MQTT_INFO, "Wi-Fi connected.");
	
	mqtt_printf(MQTT_INFO, "Connect Network "%s"", address);
	while ((rc = NetworkConnect(&network, address, 1883)) != 0){
		mqtt_printf(MQTT_INFO, "Return code from network connect is %dn", rc);
		vTaskDelay(1000 / portTICK_PERIOD_MS);
	}
	mqtt_printf(MQTT_INFO, ""%s" Connected", address);

	mqtt_printf(MQTT_INFO, "Start MQTT connection");
	while ((rc = MQTTConnect(&client, &connectData)) != 0){
		mqtt_printf(MQTT_INFO, "Return code from MQTT connect is %dn", rc);
		vTaskDelay(1000 / portTICK_PERIOD_MS);
	}
	mqtt_printf(MQTT_INFO, "MQTT Connected");

	mqtt_printf(MQTT_INFO, "Subscribe to Topic: %s", sub_topic);
	if ((rc = MQTTSubscribe(&client, sub_topic, QOS0, messageArrived)) != 0) 
		mqtt_printf(MQTT_INFO, "Return code from MQTT subscribe is %dn", rc);

	mqtt_printf(MQTT_INFO, "Publish Topics: %s", pub_topic);
	while (1)
	{
		MQTTMessage message;
		char payload[300];

		if (++count == 0)
			count = 1;
		
		message.qos = QOS0;
		message.retained = 0;
		message.payload = payload;
		sprintf(payload, "hello from AMEBA %d", count);
		message.payloadlen = strlen(payload);

		if ((rc = MQTTPublish(&client, pub_topic, &message)) != 0)
			mqtt_printf(MQTT_INFO,"Return code from MQTT publish is %dn", rc);
		if ((rc = MQTTYield(&client, 1000)) != 0)
			mqtt_printf(MQTT_INFO,"Return code from yield is %dn", rc);
		vTaskDelay(5000);
	}
	/* do not return */
}

这是比较简洁的mqtt处理的demo，核心处理收的就是一个回调函数messageArrived，发送和接收是不同topic的，发送其实核心就一个MQTTPublish，但是外围组织数据的逻辑靠自己业务特色来弄了，这个例子基本能搞明白MQTT咋整起来，收到数据的解析和发送数据的组织都是可以在这个基础上展开，相对没那么难搞了。

最后

以上就是受伤手套为你收集整理的不到百行Demo看清MQTT收发处理逻辑的全部内容，希望文章能够帮你解决不到百行Demo看清MQTT收发处理逻辑所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。