alex9ufo 聰明人求知心切: MQTT Json file extract

2018年8月25日星期六

MQTT Json file extract

Basic ESP8266 MQTT example

To install the ESP8266 board, (using Arduino 1.6.4+):

- Add the following 3rd party board manager under "File -> Preferences -> Additional Boards Manager URLs":

http://arduino.esp8266.com/stable/package_esp8266com_index.json

- Open the "Tools -> Board -> Board Manager" and click install for the ESP8266"

- Select your ESP8266 in "Tools -> Board"

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

#include <OneWire.h>

#include <DallasTemperature.h>

#include <ArduinoJson.h>

#include <dht.h>

dht DHT;

//********************************************************************

// Update these with values suitable for your network.

//const char* ssid = "PTS-2F";

//const char* password = "";

const char* ssid = "74170287";

const char* password = "24063173";

//const char* ssid = "your_ssid";

//const char* password = "your_password";

#define MQTTid "" //id of this mqtt client

#define MQTTip "broker.mqtt-dashboard.com" //ip address or hostname of the mqtt broker

#define MQTTport 1883 //port of the mqtt broker

#define MQTTuser "alex9ufo" //username of this mqtt client

#define MQTTpsw "alex9981" //password of this mqtt client

//#define MQTTuser "your_username" //username of this mqtt client

//#define MQTTpsw "your_password" //password of this mqtt client

#define MQTTpubQos 2 //qos of publish (see README)

#define MQTTsubQos 1 //qos of subscribe

//********************************************************************

long lastMsg = 0;

char jsonChar[100];

#define DHTTYPE DHT11 //DHT11 or DHT22

#define DHTPIN D5

#define ONE_WIRE_BUS D6

OneWire oneWire(ONE_WIRE_BUS);

DallasTemperature sensor(&oneWire);

float humi, temp_DHT , temp_DS1820 ; // Values read from sensor

char dev_name[50] , json_buffer[512] , json_buffer_status[512] , my_ip_s[16];

boolean pendingDisconnect = false;

void mqttConnectedCb(); // on connect callback

void mqttDisconnectedCb(); // on disconnect callback

void mqttDataCb(char* topic, byte* payload, unsigned int length); // on new message callback

WiFiClient wclient;

PubSubClient client(MQTTip, MQTTport, mqttDataCb, wclient);

/********************************************************************

* FunctionName: mqttConnectedCb

* Description :

* Parameters :

* Returns :

*********************************************************************/

void mqttConnectedCb() {

Serial.println("connected");

// Once connected, publish an announcement...

client.publish("alex9ufo/DS18B20/temp", jsonChar, MQTTpubQos, true); // true means retain

client.publish("alex9ufo/DHT11/temp_humi", jsonChar, MQTTpubQos, true); // true means retain

// ... and resubscribe

client.subscribe("alex9ufo/inTopic", MQTTsubQos);

}

/********************************************************************

* FunctionName: mqttDisconnectedCb

* Description :

* Parameters :

* Returns :

*********************************************************************/

void mqttDisconnectedCb() {

Serial.println("disconnected");

}

/********************************************************************

* FunctionName: mqttDataCb

* Description :

* Parameters :

* Returns :

*********************************************************************/

void mqttDataCb(char* topic, byte* payload, unsigned int length) {

you can convert payload to a C string appending a null terminator to it;

this is possible when the message (including protocol overhead) doesn't

exceeds the MQTT_MAX_PACKET_SIZE defined in the library header.

you can consider safe to do so when the length of topic plus the length of

message doesn't exceeds 115 characters

char* message = (char *) payload;

message[length] = 0;

Serial.print("Message arrived [");

Serial.print(topic);

Serial.print("] ");

Serial.println(message);

}

/********************************************************************

* FunctionName: setup_wifi

* Description :

* Parameters :

* Returns :

*********************************************************************/

void setup_wifi() {

delay(10);

// We start by connecting to a WiFi network

Serial.println();

Serial.print("Connecting to ");

Serial.println(ssid);

WiFi.begin(ssid, password);

while (WiFi.status() != WL_CONNECTED) {

delay(500);

Serial.print(".");

}

Serial.println("");

Serial.println("WiFi connected");

Serial.println("IP address: ");

Serial.println(WiFi.localIP());

}

/********************************************************************

* FunctionName: setup

* Description :

* Parameters :

* Returns :

*********************************************************************/

void setup() {

Serial.begin(115200);

setup_wifi();

Serial.println( "Booting" );

Serial.println();

Serial.printf( "Sketch size: %u\n", ESP.getSketchSize() );

Serial.printf( "Free size: %u\n", ESP.getFreeSketchSpace() );

Serial.printf( "Heap: %u\n", ESP.getFreeHeap() );

Serial.printf( "Boot Vers: %u\n", ESP.getBootVersion() );

Serial.printf( "CPU: %uMHz\n", ESP.getCpuFreqMHz() );

Serial.printf( "SDK: %s\n", ESP.getSdkVersion() );

Serial.printf( "Chip ID: %u\n", ESP.getChipId() );

Serial.printf( "Flash ID: %u\n", ESP.getFlashChipId() );

Serial.printf( "Flash Size: %u\n", ESP.getFlashChipRealSize() );

Serial.printf( "Vcc: %u\n", ESP.getVcc() );

Serial.println();

show_basicmessage();

}

/********************************************************************

* FunctionName: process_mqtt

* Description :

* Parameters :

* Returns :

*********************************************************************/

void process_mqtt() {

if (WiFi.status() == WL_CONNECTED) {

if (client.connected()) {

client.loop();

} else {

// client id, client username, client password, last will topic, last will qos, last will retain, last will message

if (client.connect(MQTTid, MQTTuser, MQTTpsw, MQTTid "/status", 2, true, "0")) {

pendingDisconnect = false;

mqttConnectedCb();

}

} else {

if (client.connected())

client.disconnect();

}

if (!client.connected() && !pendingDisconnect) {

pendingDisconnect = true;

mqttDisconnectedCb();

}

/********************************************************************

* FunctionName: get_DHT_temp_humi

* Description : Read temperature and humidity from sensor DHT11 / DHT22

* Values are stored in humi and temp_C

* Parameters : None

* Returns : temp_DHT , humi

*********************************************************************/

void get_DHT_temp_humi()

{

int runs=0;

do {

delay(2000);

//temp_f = dht.readTemperature(false);

//humidity = dht.readHumidity();

int chk = DHT.read11(DHTPIN);

temp_DHT= (DHT.temperature) ;

humi = (DHT.humidity);

if(runs > 0)

Serial.println("##Failed to read from DHT sensor! ###");

Serial.print("DHT11 Temperature=");

Serial.print(String(temp_DHT ).c_str());

Serial.print(", Humidity =");

Serial.println(String(humi ).c_str());

runs++;

}

while(isnan(temp_DHT) && isnan(humi));

}

/********************************************************************

* FunctionName: get_DS1820_temp

* Description : Read temperature from sensor DS18B20

* Values are stored in temp_DS1820

* Parameters : None

* Returns : temp_DS1820

*********************************************************************/

void get_DS1820_temp()

{

int runs=0;

do {

delay(2000);

// Get the current temperature from the DS18b20 sensor

sensor.requestTemperatures();

temp_DS1820 =sensor.getTempCByIndex(0);

if(runs > 0)

Serial.println("##Failed to read from DS18B20 sensor! ###");

Serial.print("DS18B20 Temperature=");

Serial.println(String(temp_DS1820).c_str());

runs++;

}

while(isnan(temp_DS1820) > 0);

}

/********************************************************************

* FunctionName:

* Description :

* Parameters :

* Returns :

*********************************************************************/

void show_basicmessage()

{

//This one is dynamic one (just for fun). Avoid this in embeded system

//Can be changed to Static one like: StaticJsonBuffer<512> jsonDeviceStatus;

DynamicJsonBuffer jsonDeviceStatus;

JsonObject& jsondeviceStatus = jsonDeviceStatus.createObject();

sprintf(dev_name, "ESP_%d", ESP.getChipId());

IPAddress my_ip_addr = WiFi.localIP();

sprintf(my_ip_s, "%d.%d.%d.%d", my_ip_addr[0],my_ip_addr[1],my_ip_addr[2],my_ip_addr[3]);

String IPaddr = String(my_ip_s).c_str();

jsondeviceStatus ["device_name"] = dev_name;

jsondeviceStatus["type"] = "dth";

jsondeviceStatus["ipaddress"] = IPaddr ;

jsondeviceStatus["bgn"] = 3;

jsondeviceStatus["sdk"] = ESP.getSdkVersion();

jsondeviceStatus["version"] = "1";

jsondeviceStatus["uptime"] = 0;

jsondeviceStatus.printTo(json_buffer_status, sizeof(json_buffer_status));

Serial.println(json_buffer_status);

}

/********************************************************************

* FunctionName: loop

* Description :

* Parameters :

* Returns :

*********************************************************************/

void loop() {

process_mqtt();

long now = millis();

if (now - lastMsg > 6000) { // wait for 6sec

lastMsg = now;

// Get the current temperature from the DS18b20 sensor

get_DS1820_temp();

char tChar[10];

dtostrf( temp_DS1820, 6, 2, tChar);

// Convert data to JSON string

String json =

"{\"data\":{"

"\"DS18B20\": \"" + String(temp_DS1820) + "\"}"

"}";

json.toCharArray(jsonChar, json.length()+1);

//this one is static allocation

StaticJsonBuffer<512> jsonBuffer;

JsonObject & root = jsonBuffer.createObject();

get_DHT_temp_humi(); //Read temperature and humidity from sensor Values are stored in humi and temp_C

String hum , temp ;

hum = String(humi).c_str();

temp = String(temp_DHT).c_str();

char dev_name[50];

sprintf(dev_name, "ESP_%d", ESP.getChipId());

root["device_name"] = dev_name;

root["type"] = "dth";

root["temperature"] = temp;

root["humidity"] = hum;

root.printTo(json_buffer, sizeof(json_buffer));

// Convert JSON string to character array

if (client.connected()) {

Serial.println("Publish message: ");

Serial.print("alex9ufo/DS18B20/temp");

Serial.println(json);

// Publish JSON character array to MQTT topic

client.publish("alex9ufo/DS18B20/temp",jsonChar);

Serial.print("alex9ufo/DHT11/temp_humi");

Serial.println(json_buffer);

client.publish("alex9ufo/DHT11/temp_humi" , json_buffer);

} // if (client.connected()) {

} //if (now - lastMsg > 6000)

}

//*********************************************************************/

沒有留言:

張貼留言

訂閱：張貼留言 (Atom)

2018年8月25日 星期六

MQTT Json file extract

沒有留言:

張貼留言

Messaging API作為替代方案

2018年8月25日星期六