本期任务

使用LoRaUNO采集BMP180气压和温度数据通过是sx1278 LoRa模组发送到ESPLoRa单项网关，ESPLoRa单项网关获取到温湿度数据上传到MQTT服务器并通过Noderd平台进行展示。

视频：

点击查看【bilibili】

框架：

image.png

ESPLoRa接收端

  2. /*  
  3.  * 2021年2月19日11:25:18
  4. -----------------
  5. |  时间     wifi|
  6. |---------------|
  7. | LoRa    MQTT  |
  8. |RS:-128  Online|
  9. |               |
  10. -----------------
  11.  *
  12.  * 0.96OLED
  13.  */ 
  15. #include <U8g2lib.h>
  16. #include <TimeLib.h>
  17. #include <WiFi.h>
  18. #include <NTPClient.h>  
  19. #include <Ticker.h>
  20. #include <PubSubClient.h>
  21. #include <LoRa.h>
  22. #include <SPI.h>
  25. U8G2_SSD1306_128X64_NONAME_F_HW_I2C u8g2(U8G2_R2, /* reset=*/U8X8_PIN_NONE, /* clock=*/22, /* data=*/21); // ESP32使用SCL:D22 SDA:D21
  27. //开机画面---显示ESPLoRa图片
  28. const unsigned char bmp1[] U8X8_PROGMEM = { 0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xe0,0x3f,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x38,0xe0,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x0c,0x80,0x03,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x01,0x00,0x04,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xe0,0x3f,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x70,0x70,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x18,0xc0,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x08,0x80,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x80,0x0f,0x00,0x00,0x00,0x00,0x00,0x00,0xfc,0x0f,0xff,0x3f,0xff,0x3f,0xf0,0x01,0xc0,0x18,0xfe,0x7f,0x00,0x00,0x00,0x00,0xff,0x8f,0xff,0x3f,0xff,0x7f,0xf0,0x01,0x00,0x00,0xfe,0xff,0x00,0x00,0x00,0x80,0xff,0xcf,0xff,0x3f,0xff,0xff,0xf0,0x01,0x00,0x00,0xfe,0xff,0x01,0x00,0x00,0x80,0x1f,0xc0,0x0f,0x00,0x1f,0xf8,0xf0,0x01,0x00,0x00,0x3e,0xf0,0x03,0x00,0x00,0xc0,0x07,0xc0,0x03,0x00,0x1f,0xf0,0xf0,0x01,0xe0,0x0f,0x3e,0xe0,0x03,0x00,0x00,0xc0,0x07,0xc0,0x03,0x00,0x1f,0xf0,0xf1,0x01,0xf0,0x3f,0x3e,0xe0,0xe3,0x7f,0x00,0xc0,0x03,0xc0,0x03,0x00,0x1f,0xf0,0xf1,0x01,0xf8,0x3e,0x3e,0xf0,0xe1,0xff,0x00,0xc0,0xff,0xcf,0x0f,0x00,0x1f,0xf8,0xf0,0x01,0x3c,0x78,0xfe,0xff,0x01,0xf0,0x01,0xe0,0xff,0x8f,0xff,0x0f,0xff,0xff,0xf0,0x01,0x3c,0x78,0xfe,0xff,0x00,0xe0,0x01,0xc0,0xff,0x0f,0xff,0x1f,0xff,0x7f,0xf0,0x01,0x3c,0x78,0xfe,0xff,0x00,0xe0,0x01,0xc0,0x07,0x00,0x00,0x3f,0xff,0x3f,0xf0,0x01,0x3c,0xf8,0x3e,0xfc,0xe0,0xff,0x01,0xc0,0x07,0x00,0x00,0x3c,0x1f,0x00,0xf0,0x01,0x3c,0x78,0x3e,0xf0,0xf1,0xff,0x01,0xc0,0x07,0x00,0x00,0x7c,0x1f,0x00,0xf0,0x01,0x3c,0x78,0x3e,0xf0,0xf1,0xe0,0x01,0x80,0x3f,0x00,0x00,0x3f,0x1f,0x00,0xe0,0x07,0x3c,0x78,0x3e,0xe0,0xf3,0xe0,0x01,0x80,0xff,0xcf,0xff,0x3f,0x1f,0x00,0xe0,0xff,0xf9,0x3e,0x3e,0xe0,0xf3,0xe0,0x01,0x00,0xff,0xcf,0xff,0x1f,0x1f,0x00,0xc0,0xff,0xf9,0x3f,0x3e,0xe0,0xf3,0xff,0x01,0x00,0xfc,0xcf,0xff,0x0f,0x1f,0x00,0x80,0xff,0xe1,0x0f,0x3e,0xe0,0xe3,0xff,0x01,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x40,0x18,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x80,0x0f,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x08,0x80,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x18,0xc0,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x70,0x70,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xe0,0x3f,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x01,0x00,0x04,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x0e,0x80,0x03,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x38,0xe0,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xe0,0x3f,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00 };
  30. //MQTT连接成功图片
  31. const unsigned char bmp2[] U8X8_PROGMEM = { 0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xfc,0x03,0x00,0x00,0xfe,0x07,0x00,0x00,0xff,0x0f,0x00,0x80,0x07,0x1e,0x00,0xc0,0x03,0x3c,0x00,0xc0,0x03,0x3c,0x00,0xc0,0x01,0x3a,0x00,0xc0,0x01,0x3a,0x00,0xe0,0x01,0xfb,0x07,0xf8,0x81,0xff,0x0f,0xfc,0x86,0x07,0x1f,0x1c,0xc7,0x03,0x38,0x1c,0xef,0x01,0x38,0x1c,0xfe,0x01,0x38,0x1c,0xfc,0x00,0x38,0x1c,0x78,0x00,0x38,0x1c,0x30,0x00,0x38,0xf8,0x00,0x00,0x1f,0xf0,0xff,0xff,0x0f,0xe0,0xff,0xff,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00 };
  33. //MQTT连接失败图片
  34. const unsigned char bmp20[] U8X8_PROGMEM = { 0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xfc,0x03,0x00,0x00,0xfe,0x07,0x00,0x00,0xff,0x0f,0x00,0x80,0x07,0x1e,0x00,0xc0,0xf3,0x3c,0x00,0xc0,0xf3,0x3c,0x00,0xc0,0xf1,0x38,0x00,0xc0,0xf1,0x38,0x00,0xe0,0xf1,0xf8,0x07,0xf8,0xf1,0xf8,0x0f,0xfc,0x00,0x00,0x1f,0x1c,0x00,0x00,0x38,0x1c,0xf0,0x00,0x38,0x1c,0xf0,0x00,0x38,0x1c,0xf0,0x00,0x38,0x1c,0xf0,0x00,0x38,0x1c,0x00,0x00,0x38,0xf8,0x00,0x00,0x1f,0xf0,0xff,0xff,0x0f,0xe0,0xff,0xff,0x07,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00 };
  36. //Lora连接成功图片
  37. const unsigned char bmp3[] U8X8_PROGMEM = { 0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0xe0,0x03,0x00,0x00,0xfc,0x0f,0x00,0x00,0xfe,0x3f,0x00,0x00,0xff,0x7f,0x00,0x80,0x0f,0x7c,0x00,0xc0,0xe3,0xf1,0x00,0xc0,0xf3,0xe3,0x01,0xc0,0xf9,0xe7,0x01,0xe0,0xfd,0xcf,0x01,0xe0,0x3d,0xcf,0x01,0xe0,0x3d,0xce,0x01,0x00,0xc0,0x01,0x00,0x00,0xc0,0x01,0x00,0x00,0xc0,0x01,0x00,0xc0,0xff,0xff,0x03,0xe0,0xff,0xff,0x07,0xe0,0xff,0xff,0x07,0xe0,0xff,0xff,0x07,0xe0,0x39,0xff,0x07,0xe0,0x39,0xff,0x07,0xe0,0xff,0xff,0x07,0xe0,0xff,0xff,0x07,0xc0,0xff,0xff,0x03,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00,0x00 };
  39. //wifi图标
  40. const unsigned char bmp4[] U8X8_PROGMEM = { 0x00,0x00,0x00,0x00,0xc0,0x03,0xf8,0x1f,0xfe,0x7f,0x3f,0xfc,0xef,0xf7,0xf6,0x6f,0xf8,0x1f,0x38,0x1c,0xc0,0x03,0xe0,0x03,0xc0,0x03,0x80,0x01,0x00,0x00,0x00,0x00 };
  44.  //WiFi初始化
  45. #define ssid "WiFi名称"
  46. #define password "WiFi密码"
  48. //MQTT初始化
  49. #define mqttServer "MQTT服务器ip" 
  50. #define Pre_topic "Pressure"//大气
  51. #define Tem_topic "Temperature"//温度
  52. #define RSSI_topic "RSSI"//信号强度
  54. //Lora初始化 
  55. #define SS 5
  56. #define RST 14
  57. #define DI0 2
  58. #define BAND 433E6
  61. int updateTimeInterval = 0;                //更新时间时间间隔
  62. Ticker updateTimeTicker;                   //更新时间定时器
  64. int PublishInterval = 0;                //更新主题实践间隔
  65. Ticker PublishTicker;                   //更新主题定时器
  68. //MQTT服务端连接用户名密码
  69. const char* mqttUserName = "lora";
  70. const char* mqttPassword = "123456";
  72. //传感器初始化
  73. String temperature;
  74. String pressure; 
  75. String RSSI;
  78. WiFiClient wifiClient;
  79. PubSubClient mqttClient(wifiClient);
  81. WiFiUDP ntpUDP;   
  82. NTPClient timeClient(ntpUDP, "ntp1.aliyun.com", 60 * 60 * 8, 30 * 60 * 1000);
  84. String nowTime = ""; 
  86. void setup() {
  87.   Serial.begin(9600);
  88.   u8g2.begin();
  89.   //检查lora
  90.   check_lora();
  91.   WiFi.mode(WIFI_STA);
  92.     //显示启动界面
  93.   showStart();
  94.     //连接wifi
  95.   connectWifi();
  96.     //连接NTP服务器(阿里的NTP服务器)
  97.   timeClient.begin();
  98.     //开启更新时间定时
  99.   updateTimeTicker.attach(1, tickerUpdateTimeInterval);
  100.   //3秒上传一次
  101.   PublishTicker.attach(3, tickerUpdatePublishInterval);
  106.   //可以设置同步字（范围从0到0xFF）。
  107.   LoRa.setSyncWord(0xA5);
  108.   LoRa.setTxPower(20);  
  109.   Serial.println("LoRa Initializing OK!");
  111.    //连接MQTT服务器
  112.   mqttClient.setServer(mqttServer, 1883);
  113.   connectMQTTServer();
  114. }
  116. void loop() {
  119.    //时间更新显示
  120.    time_updata();
  121.    //接收lora数据包
  122.    Lora_packet();
  123.    //MQTT主题更新
  124.    Publish_updata();
  125.    //检查mqtt连接情况
  126.    mqtt_check();
  127. }
  129. //显示启动动画
  130. void showStart() {
  131.   u8g2.clearBuffer();
  132.   u8g2.drawXBMP(0,0, 128, 64, bmp1);
  133.   u8g2.sendBuffer();
  134.   delay(3000);
  135. }
  137. //更新时间中断
  138. void tickerUpdateTimeInterval() {
  139.     updateTimeInterval++;
  140. }
  142. //订阅主题中断
  143. void tickerUpdatePublishInterval(){
  144.     PublishInterval++;
  145. }
  147. //显示时间
  148. void displayTime() {
  149.   //设置字体
  150.   u8g2.setFont(u8g2_font_t0_17_tr);
  151.   u8g2.clearBuffer();
  152.   u8g2.setCursor(0,14);//时间的位置
  153.   u8g2.print(nowTime);
  154.   u8g2.drawXBMP(110,0, 16, 16, bmp4);//wifi图标
  155.   u8g2.drawLine(1,16,126,16);     //画一条平面直线
  157.   u8g2.drawXBMP(78,18, 32, 32, bmp2);//mqtt
  158.   u8g2.drawStr(70,63,"Online");//MQTT---原坐标
  160.   u8g2.drawXBMP(15,18, 32, 32, bmp3);//lora
  161.   u8g2.drawStr(0,63,"Rs:");//LORA---具体显示内容
  162.   u8g2.setCursor(28, 63);//确定刷新的位置
  163.   u8g2.print(RSSI);//为了不全屏刷新的情况下清空局部显示区域
  164.   u8g2.sendBuffer();
  165. }
  167. //连接WIFI
  168. void connectWifi() {
  169.    //连接wifi
  170.   u8g2.setFont(u8g2_font_t0_17_tr);
  171.   u8g2.clearBuffer();
  172.   u8g2.drawStr(0, 15, "Connecting to");
  173.   u8g2.drawStr(0, 38, "SSID:");  
  174.   u8g2.drawStr(45, 38, ssid);  
  175.   Serial.println("Connecting to ");
  176.   Serial.println(ssid);
  177.   WiFi.begin(ssid, password);
  178.   //连接判断
  179.   int i = 0;
  180.   while (WiFi.status() != WL_CONNECTED) {
  181.     delay(1000);
  182.     Serial.print(".");
  183.     u8g2.drawStr(i, 50, ".");
  184.     i = i + 5;
  185.     u8g2.sendBuffer();  
  186.   }
  187.   u8g2.clear();
  188.   Serial.println(" ");
  189.   Serial.println("WiFi Connected!");  
  190.   Serial.println(" "); 
  191.   u8g2.drawStr(0, 38, "WiFi Connected!");
  192.   u8g2.sendBuffer();
  193.   delay(1000);
  194. }
  196. //时间刷新
  197. void time_updata(){
  198.   //每隔1s更新一次时间
  199.   if (updateTimeInterval >= 1) {
  200.     timeClient.update();
  201.     nowTime = timeClient.getFormattedTime();
  202.     //标志位清零
  203.     //重新计时
  204.     updateTimeInterval = 0;
  205.     //显示时间
  206.     displayTime();
  207.   }
  208.   //Serial.println(nowTime);
  209. }
  211. //每隔三秒上传一次主题的内容
  212. void Publish_updata(){
  213.   if(PublishInterval >= 1)
  214. {
  215.    //发布主题消息
  216.    pubMQTTmsg();
  218.    //计时器清零
  219.     PublishInterval = 0;
  220. }
  221. }
  223. //连接MQTT云端
  224. void connectMQTTServer(){
  225.   String clientId = "ESP_Lora";
  226.   Serial.print("Attempting MQTT connection..."); 
  227.   // 连接MQTT服务器
  228.   if (mqttClient.connect(clientId.c_str(),mqttUserName, mqttPassword)) { 
  229.     Serial.println("MQTT Server Connected.");
  230.     Serial.println("Server Address: ");
  231.     Serial.println(mqttServer);
  232.     Serial.println("ClientId:");
  233.     Serial.println(clientId);
  235. // --------------------------------------
  236. //添加MQTT连接成功图标
  237.   u8g2.clearBuffer();
  238.   u8g2.drawXBMP(110,0, 16, 16, bmp4);//wifi图标
  239.   u8g2.drawLine(1,16,126,16);     //画一条平面直线
  240.   u8g2.drawXBMP(78,18, 32, 32, bmp2);//mqtt
  241.   u8g2.drawXBMP(15,18, 32, 32, bmp3);//lora
  242.   u8g2.drawStr(70,63,"Online");//MQTT---原坐标
  243.   u8g2.sendBuffer();
  244.   //连接成功后开始订阅主题消息
  245.     subscribeTopic(); // 订阅指定主题
  246. // --------------------------------------
  247.   } else {
  248.     Serial.print("MQTT Server Connect Failed. Client State:");
  249.     Serial.println(mqttClient.state());
  250. // --------------------------------------
  251. // MQTT连接失败地方
  253.   u8g2.setCursor(70, 63);//确定刷新的位置
  254.   u8g2.print("   ");//为了不全屏刷新的情况下清空局部显示区域
  255.   u8g2.drawXBMP(78,18, 32, 32, bmp20);//mqtt失败的图标
  256.   u8g2.drawStr(78,63,"Fail");//具体显示内容
  257.   u8g2.sendBuffer();
  258. //   ------------------------------------
  259.     delay(800);
  260.   }   
  261. }
  263. // 订阅指定主题
  264. void subscribeTopic(){
  265.   //气压
  266.   String topicString = "Sensor/Pressure";
  267.   char publishTopic[topicString.length() + 1];  
  268.   strcpy(publishTopic, topicString.c_str());
  270.   String messageString = pressure;
  271.   char publishMsg[messageString.length() + 1];   
  272.   strcpy(publishMsg, messageString.c_str());
  274.   // 发布信息
  275.   if(mqttClient.publish(publishTopic, publishMsg)){
  276.     Serial.print(" ");
  277.     Serial.print(F("Pressure = "));
  278.     Serial.print(pressure);
  279.     Serial.print(" hPa");   
  280.   } else {
  281.     Serial.println("Message Publish Failed."); 
  282.   }
  284. //温度
  285.   String topicString2 = "Sensor/Temperature";
  286.   char publishTopic2[topicString2.length() + 1];  
  287.   strcpy(publishTopic2, topicString2.c_str());
  289.   String messageString2 = temperature;
  290.   char publishMsg2[messageString2.length() + 1];   
  291.   strcpy(publishMsg2, messageString2.c_str());
  293.   // 发布信息
  294.   if(mqttClient.publish(publishTopic2, publishMsg2)){
  295.     Serial.print(" ");
  296.     Serial.print(F("Temperature = "));
  297.     Serial.print(temperature);
  298.     Serial.print(" *C");  
  299.   } else {
  300.     Serial.println("Message Publish Failed."); 
  301.   }
  303. //信号强度
  304.   String topicString3 = "Sensor/RSSI";
  305.   char publishTopic3[topicString.length() + 1];  
  306.   strcpy(publishTopic3, topicString3.c_str());
  308.   String messageString3 = temperature;
  309.   char publishMsg3[messageString3.length() + 1];   
  310.   strcpy(publishMsg3, messageString3.c_str());
  312.   // 发布信息
  313.   if(mqttClient.publish(publishTopic3, publishMsg3)){
  314.     Serial.print(" ");
  315.     Serial.print(" RSSI ");
  316.     Serial.println(RSSI);
  318.   } else {
  319.     Serial.println("Message Publish Failed."); 
  320.   }
  321. }
  323. // MQTT发布信息
  324. void pubMQTTmsg(){  
  326. //气压
  328.   String topicString = "Sensor/Pressure";
  329.   char publishTopic[topicString.length() + 1];  
  330.   strcpy(publishTopic, topicString.c_str());
  332.   String messageString = pressure;
  333.   char publishMsg[messageString.length() + 1];   
  334.   strcpy(publishMsg, messageString.c_str());
  336.   // 发布信息
  337.   if(mqttClient.publish(publishTopic, publishMsg)){
  338.     Serial.print(" ");
  339.     Serial.print(F("Pressure = "));
  340.     Serial.print(pressure);
  341.     Serial.print(" hPa");   
  342.   } else {
  343.     Serial.println("Message Publish Failed."); 
  344.   }
  346. //温度
  347.   String topicString2 = "Sensor/Temperature";
  348.   char publishTopic2[topicString2.length() + 1];  
  349.   strcpy(publishTopic2, topicString2.c_str());
  351.   String messageString2 = temperature;
  352.   char publishMsg2[messageString2.length() + 1];   
  353.   strcpy(publishMsg2, messageString2.c_str());
  355.   // 发布信息
  356.   if(mqttClient.publish(publishTopic2, publishMsg2)){
  357.     Serial.print(" ");
  358.     Serial.print(F("Temperature = "));
  359.     Serial.print(temperature);
  360.     Serial.print(" *C");  
  361.   } else {
  362.     Serial.println("Message Publish Failed."); 
  363.   }
  365. //信号强度
  366.   String topicString3 = "Sensor/RSSI";
  367.   char publishTopic3[topicString.length() + 1];  
  368.   strcpy(publishTopic3, topicString3.c_str());
  370.   String messageString3 = RSSI;
  371.   char publishMsg3[messageString3.length() + 1];   
  372.   strcpy(publishMsg3, messageString3.c_str());
  374.   // 发布信息
  375.   if(mqttClient.publish(publishTopic3, publishMsg3)){
  376.     Serial.print(" ");
  377.     Serial.print(" RSSI ");
  378.     Serial.println(RSSI);
  380.   } else {
  381.     Serial.println("Message Publish Failed."); 
  382.   }
  384. }
  387. //检查mqtt连接情况
  388. void mqtt_check(){
  389.   // 如果开发板未能成功连接服务器，则尝试连接服务器
  390.   if (!mqttClient.connected()) {
  391.     connectMQTTServer();
  392.   }
  393.    // 处理信息以及心跳
  394.    mqttClient.loop();
  396. }
  398. // 尝试解析数据包
  399. void Lora_packet(){
  401.   int pos1; 
  402.   int packetSize = LoRa.parsePacket();
  403.   if (packetSize) {
  404.     // 如果收到包
  405.     String LoRaData = LoRa.readString();
  406.     //Serial.print(LoRaData);
  407.     //读取数据包
  408.     while (LoRa.available()) {
  409.       Serial.print((char)LoRa.read());
  410.     }
  411.     //读取后开始拆包
  412.     pos1 = LoRaData.indexOf('/');
  413.     //解析后赋值变量
  414.     temperature= LoRaData.substring(0, pos1);
  415.     pressure = LoRaData.substring(pos1 + 1, LoRaData.length());
  416.     RSSI = LoRa.packetRssi();
  417.   }
  418.   delay(500);    
  419. }
  421. //检查lora连接是否成功
  422. void check_lora(){
  423.   while (!Serial);
  424.   Serial.println("LoRa Receiver");
  425.   LoRa.setPins(SS, RST, DI0);  
  426.   if (!LoRa.begin(BAND)) {
  427.   Serial.println("Starting LoRa failed!");
  428.   u8g2.setFont(u8g2_font_t0_17_tr);
  429.   u8g2.clearBuffer();
  430.   u8g2.drawLine(1,16,126,16);     //画一条平面直线  
  431.   u8g2.drawXBMP(15,18, 32, 32, bmp3);//lora
  432.   u8g2.drawStr(15,63,"Fail");//LORA---具体显示内容
  433.   u8g2.sendBuffer();
  434.     while (1);
  435.   }
  436. }

LoRaUNO发送端

  1. #include <Adafruit_BMP085.h>
  2. #include <LoRa.h>
  3. #include <SPI.h>
  5. #define BAND 433E6//Lora信号
  7. //建立bmp
  8. Adafruit_BMP085 bmp;
  11. String LoRaMessage = "";//声明发送信息
  14. void setup() {
  15.   Serial.begin(9600);
  16.   //初始化BMP180
  17.   if (!bmp.begin()) {
  18.     Serial.println("Could not find a valid BMP085 sensor, check wiring!");
  19.   while(1);
  20.   }
  22.   //初始化Lora
  23.   while (!Serial);
  24.   Serial.println("LoRa Sender");
  26.   //以指定的频率初始化收发器模块
  27.   //433or434
  28.   if (!LoRa.begin(BAND)) {
  29.     Serial.println("Starting LoRa failed!");
  30.     while (1);
  31.   }
  32.   LoRa.setSyncWord(0xA5);//可以设置同步字（范围从0到0xFF）。
  33.   //LoRa.setTxPower(20);//发射功率
  35.   }
  38. void Lora_TX(){
  40.   float temperature = bmp.readTemperature();
  41.   float pressure = bmp.readPressure() / 100.0F;
  44.   LoRa.beginPacket();//准备发送信息
  45. //温度信息
  46.    LoRa.print("Temperature: ");
  47.    LoRa.print(temperature);
  48.    LoRa.print(" *C");
  50.   Serial.print(F("Temperature = "));
  51.   Serial.print(temperature);
  52.   Serial.println(F(" *C"));
  53. //气压信息  
  54.   LoRa.print("Pressure: ");
  55.   LoRa.print(pressure);
  56.   LoRa.print(" hPa");
  59.   Serial.print(F("Pressure = "));
  60.   Serial.print(pressure);
  61.   Serial.println(F("hPa"));
  62.   Serial.println();
  65.   LoRa.endPacket();//发送完毕
  66.   delay(3000);
  67. }
  69. void loop(){
  70. Lora_TX();
  71. }

APP界面展示
71FEA2B492A506F5B200E3B0EF2E8F36.jpg

本文附件：

LoRa资料包.zip