在地图中选择对应设备中名为“location”的数据流即可。
{"location":{"lat":34.0215704,"lon":108.4555422},"速度":28,"紫外线":28,"温度":28}
{"location":{"lat":34.0215704,"lon":108.4555422},"速度":29,"紫外线":29,"温度":29}
{"location":{"lat":34.0215704,"lon":108.4555422},"速度":30,"紫外线":30,"温度":30}
{"location":{"lat":34.0215704,"lon":108.4555422},"速度":31,"紫外线":31,"温度":31}
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <ArduinoJson.h>
#include <Ticker.h>
#include <SoftwareSerial.h>
//实例化软串口
SoftwareSerial mySerial(D1, D2); // RX, TX
//分割结果
#define sleng 10 //数组大小
String split_result[sleng];//手动动态调整数组大小，保证数组可以满足容量
#define WIFI_DEBUG 0 //1：使用一键配网，其它值则使用默认无线账号密码
#define ONENET_DISCONNECTED 1 //已经断开
#define ONENET_CONNECTED 2 //已经连接上
#define ONENET_RECONNECT 3 //重连成功
#define VER "ESP8266_MQTT_V1.0" //版本号
const char* ssid = "yaoyao";//wifi账号
const char* password = "love123456";//wifi密码
/*OneNet*/
PubSubClient mqttClient;
const char* mqttServer = "183.230.40.39";//mqtt服务器
const uint16_t mqttPort = 6002; //端口号
#define onenet_productId "207282" //产品ID
#define onenet_deviceId "515439794" //设备ID
#define onenet_apiKey "ZcxLlq=Pd4t6CgaFKcB=zQXzDt8=" //产品API_KEY
int state;
Ticker delayTimer;
WiFiClient espClient;
/*字符串分割
输入参数
String zifuchuan, 输入字符串
String fengefu, 分隔符号-可以是多个
String result[] 输出结果
*/
void Split(String zifuchuan,String fengefu,String result[])
{
int weizhi; //找查的位置
String temps;//临时字符串
int i=0;
do
{
weizhi = zifuchuan.indexOf(fengefu);//找到位置
if(weizhi != -1)//如果位置不为空
{
temps=zifuchuan.substring(0,weizhi);//打印取第一个字符
zifuchuan = zifuchuan.substring(weizhi+fengefu.length(), zifuchuan.length());
//分隔后只取后面一段内容 以方便后面找查
}
else
{ //上面实在找不到了就把最后的 一个分割值赋值出来以免遗漏
if(zifuchuan.length() > 0)
temps=zifuchuan;
}
result[i++]=temps;
//Serial.println(result[i-1]);//在这里执行分割出来的字符下面不然又清空了
temps="";
}
while(weizhi >=0);
}
/* 延时N秒 */
void delayNs(uint8_t m){
for(uint8_t index = 0;index<m;index ++){ delay(1000); ESP.wdtFeed();
}
}
/* 延时重启 */
void delayRestart(float t) {
Serial.print("Restart after ");
Serial.print(t);
Serial.println("s");
delayTimer.attach(t, []() {
Serial.println("\r\nRestart now!");
ESP.restart();
});
}
/* 自动连接 */
bool autoConfig()
{
WiFi.begin();
for (int i = 0; i < 20; i++)
{ if (WiFi.status() == WL_CONNECTED) {
Serial.println("AutoConfig Success");
Serial.printf("SSID:%s\r\n", WiFi.SSID().c_str());
Serial.printf("PSW:%s\r\n", WiFi.psk().c_str());
WiFi.printDiag(Serial); return true; }
else {
Serial.print("AutoConfig Waiting......");
Serial.println(WiFi.status());
delay(1000);
}
}
Serial.println("AutoConfig Faild!" );
return false;
}
/* 一键配网 */
void smartConfig()
{
WiFi.mode(WIFI_STA);
Serial.println("\r\nWait for Smartconfig");
WiFi.beginSmartConfig();
while (1)
{ Serial.print(".");
digitalWrite(LED_BUILTIN, !digitalRead(LED_BUILTIN));
if (WiFi.smartConfigDone()) { Serial.println("SmartConfig Success");
Serial.printf("SSID:%s\r\n", WiFi.SSID().c_str());
Serial.printf("PSW:%s\r\n", WiFi.psk().c_str());
WiFi.setAutoConnect(true); // 设置自动连接
break; }
delay(1000); // 这个地方一定要加延时，否则极易崩溃重启
}
}
/* 连接OneNet */
int connectToOneNetMqtt(){
int cnt = 0;
while(!mqttClient.connected()){
ESP.wdtFeed();
cnt++;
Serial.println("Connect to OneNet MQTT...");
if (mqttClient.connect(onenet_deviceId,onenet_productId,onenet_apiKey)) {
Serial.println("connect success!");
return ONENET_RECONNECT;
}
else {
Serial.print("connect fail!");
Serial.println(" try again in 5 seconds");
delay(5000);
}
if(cnt >=10){
//只做10次连接到OneNet，连接不上重启8266
cnt = 0;
delayRestart(1);
} }
return ONENET_CONNECTED;
}
/* 云端下发 */
void callback(char* topic, byte* payload, unsigned int length) {
Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
for (int i = 0; i < length; i++) {
Serial.print((char)payload[i]);
}
Serial.println();
if ((char)payload[0] == '1') {
digitalWrite(LED_BUILTIN, LOW);
}
else {
digitalWrite(LED_BUILTIN, HIGH);
}
}
/* 发布一个传感器信息
String sensorname 传感器名字
String data 数据
int sendlen=200; 数据大小
*/
void pubMQTTmsg_one_name_value(String sensorname,String data){
long lastMsg = 0;
int sendlen=200;//28 //数组大小
char msg[sendlen+22]; //数组大小
char tmp[sendlen];
char d[3];
//snprintf(tmp,sizeof(tmp),String("")+"{\""+sensorname+"\":%d}",data);
String sendmsg=String("")+"{\""+sensorname+"\":"+data+"}";
//String sendmsg="{\"mq2\":1234,\"mq3\":345}";
sendmsg.toCharArray(tmp, sendlen);
Serial.println(tmp);
uint16_t streamLen= strlen(tmp);
d[0]='\x03';
d[1] = (streamLen >> 8);
d[2] = (streamLen & 0xFF);
snprintf(msg,sizeof(msg),"%c%c%c%s",d[0],d[1],d[2],tmp);
mqttClient.publish("$dp", (uint8_t*)msg,streamLen+3,false);
}
/* 发布多个传感器信息
String sendmsg 打包数据
{"senseor1":1213,"senseor2":313.3,"senseor3":543.09,"senseor4":645.0}
注意 ” 转义字符串 \“
*/
void pubMQTTmsg_more_name_value(String sendmsg_in){
long lastMsg = 0;
int sendlen=800;//28 //数组大小
char msg[sendlen+22]; //数组大小
char tmp[sendlen];
char d[3];
//snprintf(tmp,sizeof(tmp),String("")+"{\""+sensorname+"\":%d}",data);
//String sendmsg=String("")+"{\""+sensorname+"\":"+data+"}";
String sendmsg=sendmsg_in;
sendmsg.toCharArray(tmp, sendlen);
Serial.println(tmp);
uint16_t streamLen= strlen(tmp);
d[0]='\x03';
d[1] = (streamLen >> 8);
d[2] = (streamLen & 0xFF);
snprintf(msg,sizeof(msg),"%c%c%c%s",d[0],d[1],d[2],tmp);
mqttClient.publish("$dp", (uint8_t*)msg,streamLen+3,false);
}
/* 初始化系统 */
void initSystem(){
int cnt = 0;
Serial.begin (9600);
Serial.println("\r\n\r\nStart ESP8266 MQTT");
Serial.print("Firmware Version:");
Serial.println(VER); Serial.print("SDK Version:");
pinMode(LED_BUILTIN, OUTPUT);
digitalWrite(LED_BUILTIN, HIGH);
Serial.println(ESP.getSdkVersion());
ESP.wdtEnable(5000);
if(WIFI_DEBUG==1)//开启一键配网模式
{
if (!autoConfig()) {
Serial.println("Start smartConfig");
smartConfig();
}
}
else {
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED)
{
delay(500); cnt++; Serial.print(".");
if(cnt>=40){
cnt = 0; //重启系统
delayRestart(1);
}
}
}
Serial.print("WIFI Connect \r\n");
}
/* 初始化ONENET通信 */
void initOneNetMqtt(){
mqttClient.setServer(mqttServer,mqttPort);
mqttClient.setClient(espClient);
mqttClient.setCallback(callback);
}
/* 初始化 */
void setup() {
initSystem();
initOneNetMqtt();
Serial.begin(9600);
while (!Serial) {
}
Serial.println("Goodnight moon!");
mySerial.begin(9600);
}
int i =0;
/* 主函数 */
void loop() {
ESP.wdtFeed();
state = connectToOneNetMqtt();
//Serial.println(WiFi.status());
//接收串口消息
// if (mySerial.available()){
// String split_input =mySerial.readStringUntil(';');
// //Serial.println(split_input);
//
// //分割解析
// Split(split_input,"-",split_result);//分割调用
//
// Serial.println("----------------");
// //打印消息 检查是否为空
// for(int i=0;i<sleng;i++)
// {
// if(split_result[i]!="")
// {
// Serial.println(String(i)+"-"+split_result[i]);
// }
// else
// {
// split_result[i]="0";
// }
// }
//
//
// //发送onenet
// ESP.wdtFeed();
state = connectToOneNetMqtt();
//Serial.println(WiFi.status());
if(state == ONENET_RECONNECT){
mqttClient.loop();
}
else if(state == ONENET_CONNECTED)
{
i++;
String msg=String("")+"{"
+"\"location\":"+"{\"lat\":34.0215704,\"lon\":108.4555422}"+","
+"\"速度\":"+String(i)+","
+"\"紫外线\":"+String(i)+","
+"\"温度\":"+String(i)
+"}";
// String msg=String("")+"{"
// +"\"经度\":"+String(split_result[0])+","
// +"\"纬度\":"+String(split_result[1])+","
// +"\"速度\":"+String(split_result[2])+","
// +"\"紫外线\":"+String(split_result[3])+","
// +"\"温度\":"+String(split_result[4])
//
// +"}";
pubMQTTmsg_more_name_value(msg);
mqttClient.loop();
}
delay(2000);
//}
}