EEPW论坛

写法应该跟CONNECE差不多，大概就是下边这样

void OneNet_Publish(const char *topic, const char *msg) { MQTT_PACKET_STRUCTURE mqttPacket = {NULL, 0, 0, 0}; UsartPrintf("Publish Topic: %s, Msg: %s\r\n", topic, msg); if(MQTT_PacketPublish(MQTT_PUBLISH_ID, topic, msg, strlen(msg), MQTT_QOS_LEVEL0, 0, 1, &mqttPacket) == 0) { ESP8266_SendData(mqttPacket._data, mqttPacket._len); MQTT_DeleteBuffer(&mqttPacket); } }

其中 topic就是发送的主题，msg就是所要上传的信息

主题可以直接定义好，类似下边

const char devPubTopic[] = "$sys/407529/G0701/dp/post/json";

msg跟之前的POST一样，是json数据，这里依然使用字符串拼接的方法。

void OneNet_FillBuf(char *buf) { char buf1[64]; memset(buf1, 0, sizeof(buf1)); sprintf(buf1, "{\"id\":123,\"dp\":{\"tem\":[{\"v\":%.1f,}],",pv.tem); strcat(buf, buf1); memset(buf1, 0, sizeof(buf1)); sprintf(buf1, "\"hum\":[{\"v\":%d,}],",pv.hum); strcat(buf, buf1); memset(buf1, 0, sizeof(buf1)); sprintf(buf1, "\"lux\":[{\"v\":%d,}]}}",pv.lux_16); strcat(buf, buf1); }

下边就是把程序整合起来

while (1) { if(time6_count1>10) { time6_count1 = 0; AHT10ReadData(&pv.tem,&pv.hum); BH1750_Read_Dat(pv.lux);//读取数据 pv.lux_16 = BH1750_Dat_To_Lux(pv.lux);//转换数据 printf("lux:%d\r\n",pv.lux_16); printf("tem:%.1f\r\nhum:%d%%\r\n",pv.tem,pv.hum); BH1750_Send_Cmd(ONCE_H_MODE);//单次模式 sprintf(buf,"tem:%.1f",pv.tem); OLED_P8x16Str(0u,4u,(uint8_t *)buf); sprintf(buf,"hum:%d%%",pv.hum); OLED_P8x16Str(64u,4u,(uint8_t *)buf); sprintf(buf,"lux:%d ",pv.lux_16); OLED_P8x16Str(0u,6u,(uint8_t *)buf); } if(time6_count>120) { time6_count = 0; memset(PUB_BUF, 0, sizeof(PUB_BUF)); OneNet_FillBuf(PUB_BUF); printf("PUB_BUF:%s\r\n",PUB_BUF); OneNet_Publish(devPubTopic, PUB_BUF); } }

5s中采集一次并刷新一次OLED屏幕，然后一分钟上传一次