Create MQTT_Client_DHT11(ThingSpeak)

[goodcheney]

#include <dht.h>
#include <SPI.h>
#include <RH_RF95.h>

// Singleton instance of the radio driver
RH_RF95 rf95;
float frequency = 868.0;
dht DHT;
#define DHT11_PIN A0
float temperature,humidity,tem,hum;
String datastring1="";
String datastring2="";
char tem_1[8]={"\0"},hum_1[8]={"\0"};
char *node_id = "<5678>";
uint8_t datasend[36];
unsigned int count = 1;

void setup()
{
Serial.begin(9600);
Serial.println(F("Start MQTT Example"));
if (!rf95.init())
Serial.println(F("init failed"));
rf95.setFrequency(frequency);
rf95.setTxPower(13);
}

void dhtTem()
{
temperature = DHT.read11(DHT11_PIN); //Read Tmperature data
tem = DHT.temperature1.0;
humidity = DHT.read11(DHT11_PIN); //Read humidity data
hum = DHT.humidity 1.0;
Serial.println(F("The temperature and humidity:"));
Serial.print("[");
Serial.print(tem);
Serial.print("℃");
Serial.print(",");
Serial.print(hum);
Serial.print("%");
Serial.print("]");
Serial.println("");
delay(2000);
}
void dhtWrite()
{
char data[50] = "\0";
for(int i = 0; i < 50; i++)
{
data[i] = node_id[i];
}

dtostrf(tem,0,1,tem_1);
dtostrf(hum,0,1,hum_1);

// Serial.println(tem_1);
 strcat(data,"field1=");
 strcat(data,hum_1);
 strcat(data,"&field2=");
 strcat(data,tem_1);
 strcpy((char *)datasend,data);

//Serial.println((char *)datasend);
//Serial.println(sizeof datasend);

}

void SendData()
{
Serial.println(F("Sending data to LG01"));

  rf95.send((char *)datasend,sizeof(datasend));  
  rf95.waitPacketSent();  // Now wait for a reply

  uint8_t buf[RH_RF95_MAX_MESSAGE_LEN];
  uint8_t len = sizeof(buf);

 if (rf95.waitAvailableTimeout(3000))

{
// Should be a reply message for us now
if (rf95.recv(buf, &len))
{

  Serial.print("got reply from LG01: ");
  Serial.println((char*)buf);
  Serial.print("RSSI: ");
  Serial.println(rf95.lastRssi(), DEC);    
}
else
{
  Serial.println("recv failed");
}

}
else
{
Serial.println("No reply, is LoRa server running?");
}
delay(5000);
}

void loop()
{
Serial.print("########### ");
Serial.print("COUNT=");
Serial.print(count);
Serial.println(" ###########");
count++;
dhtTem();
dhtWrite();
SendData();
}