zoukankan      html  css  js  c++  java
  • 服务器 一 MQTT服务器硬件

    目的:

    实现手机4G网络控制单片机,需要搭建服务器,手机或者各种控制端远程控制。

    本教程

    1  MQTT服务器硬件模块

    MQTT服务器电脑搭建

       2.1自己搭建

       2.2租阿里云服务器

    MQTT服务器手机控制端

    参考教程

    1 硬件 

    1.1MQTT--NodeMCU及MQTT接发消息体验  https://www.jianshu.com/p/701f4d31029f

    1.2 基于MQTT协议与ESP8266平台的家庭环境监控实现  https://liangshuang.name/2017/08/07/mqtt/

    2 服务器

    3 手机

    3.1 服务器调试助手----myMqtt的APPhttp://pan.baidu.com/s/1slE0cw9  

    3.2手机端具体开发--------(一)基于阿里云的MQTT远程控制(Android 连接MQTT服务器,ESP8266连接MQTT服务器实现远程通信控制----简单的连接通信)

    三 单片机程序

    3.1安装编辑器

    先要安装Arduino IDE For ESP8266
    Arduino IDE For ESP8266是根据Arduino修改的专门烧写ESP8266开发板的IDE。在装好Arduino IDE后:

    打开Arduino 文件->首选项,在 附加开发管理网站 中填入

    菜单“项目”-“加载库”-“管理库”,搜索安装“PubSubClient”

    ,然后点击确定保存
    1. 重启IDE后,打开 工具->开发板->开发板管理器;搜索ESP8266,选择esp 8266 by ESP8266 Community安装

    1. 下载完成后可以在开发板选项中看到ESP8266 Module,以及WeMos D1 mini等可选开发板
    • 将WeMos D1 mini通过usb连接到电脑,在工具下选择相应配置
    • 波特率越大烧录程序速度越快但有可能出错
      端口选择WeMos D1 mini对应端口,如果没看到端口,那是驱动没有装,装驱动可以看这里http://www.arduino.cn/thread-1008-1-1.html
    1. 打开示例选择ESP8266WiFi中的WiFiScan
    2. 烧到板子上打开窗口监视器可以看到扫描出来的附近热点
     

    3.2安装库文件

    菜单“项目”-“加载库”-“管理库”,搜索安装“PubSubClient”

     

    PubSubClient有一些示例可以打开mqtt_esp8266看下

     

    3.3烧录程序

    MQTT接发消息体验

    1. WeMos D1 mini发布消息:光照强度传感器测得环境光照强度发布到服务器,手机订阅该Topic接收光强信息

    #include <ESP8266WiFi.h>
    #include <PubSubClient.h>
    int pinLED = D2;
    
    const char* ssid = "********";//连接的路由器的名字
    const char* password = "********";//连接的路由器的密码
    const char* mqtt_server = "********";//服务器的地址 
    const int port=****;//服务器端口号
    
    WiFiClient espClient;
    PubSubClient client(espClient);
    
    int light=255;
    
    void setup_wifi() {//自动连WIFI接入网络
      delay(10);
      WiFi.begin(ssid, password);
      while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print("...");
      }
    }
    
    void callback(char* topic, byte* payload, unsigned int length) {//用于接收数据
      int l=0;
      int p=1;
      for (int i = length-1; i >=0; i--) {
        l+=(int)((char)payload[i]-'0')*p;
        p*=10;
      }
      light=l;
      Serial.println(l);//换行
    
    }
    
    void reconnect() {//等待,直到连接上服务器
      while (!client.connected()) {//如果没有连接上
        if (client.connect("biloba")+random(999999999)) {//接入时的用户名,尽量取一个很不常用的用户名
          client.subscribe("LED");//接收外来的数据时的intopic
        } else {
          Serial.print("failed, rc=");//连接失败
          Serial.print(client.state());//重新连接
          Serial.println(" try again in 5 seconds");//延时5秒后重新连接
          delay(5000);
        }
      }
    }
    
    
    void setup() {//初始化程序,只运行一遍
      Serial.begin(9600);//设置串口波特率(与烧写用波特率不是一个概念)
      setup_wifi();//自动连WIFI接入网络
      client.setServer(mqtt_server, port);//端口号
      client.setCallback(callback); //用于接收服务器接收的数据
    }
    
    
    
    void loop() {//主循环
       reconnect();//确保连上服务器,否则一直等待。
       client.loop();//MUC接收数据的主循环函数。
       analogWrite(pinLED,light);
    }
    
    
    

      先使用ESP8266WiFi库的方法连接一个wifi,连接成功后loop中获取光强并转换为json格式,发布到light的Topic主题下,可以打开服务器web管理页面,可以在Topic找到它

    2.WeMos D1 mini接收消息:连接一个led灯,用手机APP控制灯的亮度,不接受其信息

    接收LED Topic的信息,接收到转换为int设置为灯的亮度,这样就实现远程app控灯。打开myMqtt的publish,输入Topic为LED,Message为灯的亮度(0-1024),可以实时控制灯(47.93.19.134)

    #include <ESP8266WiFi.h>
    #include <PubSubClient.h>
    #include <math.h>
    
    const char* ssid = "dongdong";//连接的路由器的名字
    const char* password = "dongdong";//连接的路由器的密码
    const char* mqtt_server = "47.93.19.134";//远程服务器的地址 
    const int port=1883;//服务器端口号
    
    WiFiClient espClient;
    PubSubClient client(espClient);
    
    char pub_topic[]="LEDback";
    char rec_topic[]="LEDpwm";
    
    int pinLED = 2; // 2号-D4 led
    int l=0; // 接收数据 
    int light=255; // 灯的亮度
    
    char msg[100];// 发送话题
    
    long lastMsg = 0;// 定时器,决定发送话题的时间
    
    /* 1连接WIFI  自动连WIFI接入网络*/
    void setup_wifi() {
      delay(10);
      WiFi.begin(ssid, password);
      while (WiFi.status() != WL_CONNECTED) {
        delay(500);
        Serial.print("...");
      }
    }
    
    /* 2连接服务器   等待,直到连接上服务器*/
    void reconnect() {//等待,直到连接上服务器
      while (!client.connected()) {//如果没有连接上
        if (client.connect("Esp_LED")+random(999999999)) {//接入时的用户名,尽量取一个很不常用的用户名
          client.subscribe(rec_topic);//接收外来的数据时的intopic
           client.publish(pub_topic,"hello world from dongdong");
        } else {
          Serial.print("failed, rc=");//连接失败
          Serial.print(client.state());//重新连接
          Serial.println(" try again in 5 seconds");//延时5秒后重新连接
          delay(5000);
        }
      }
    }
    
    /* 3 接收数据处理, 服务器回掉函数*/
    void callback(char* topic, byte* payload, unsigned int length) {//用于接收数据
      //3.1 判断数据为 开启指定LED 
      if ((char)payload[0] == '1') {
        digitalWrite(4, HIGH);  
     
      } else {
        digitalWrite(4, LOW);  
      }
    
     // 3.2 数据转化int 数值 控制灯的亮度
      l=0;
      int p=1;
      for (int i = length-1; i >=0; i--) {
        l+=(int)((char)payload[i]-'0')*p;
        p*=10;
      }
      light=l;
      Serial.println(light);//换行
    
      
    }
    
    
    
    //4 初始化函数
    void setup() {//初始化程序,只运行一遍
      Serial.begin(9600);//设置串口波特率(与烧写用波特率不是一个概念)
      setup_wifi();//自动连WIFI接入网络
      client.setServer(mqtt_server, port);//端口号
      client.setCallback(callback); //用于接收服务器接收的数据
    }
    
    // 5 循环主函数
    void loop() {//主循环
    
    // 5.1 初始化连接
       reconnect();//确保连上服务器,否则一直等待。
    
    // 5.2 订阅话题等待
       client.loop();//MUC接收数据的主循环函数。
       
      // 5.3 发布话题   2S
       long now = millis();
      if (now - lastMsg > 2000) {
       lastMsg = now;
         sprintf(msg,"%ld",l);  
         client.publish(pub_topic,msg);}
    
       //5.4 逻辑处理区域
          analogWrite(pinLED,light);// 调节灯的亮度
    
          
    }
    

      

      

      接着试着用手机app订阅接收传感器发的消息(具体Android端如何实现下篇文章会讲到),在google play中下载一个myMqtt的APP,不方便的可以在这里下http://pan.baidu.com/s/1slE0cw9

    打开APP,在setting中设置你服务器ip,端口等保存,如果顶部显示绿色表明连接成功,在Subscribe中订阅light主题,返回到Dashboard就能实时收到消息

     
  • 相关阅读:
    学习java集合LinkedHastSet
    学习java,equals方法
    学习java,入门语言java的感概
    学习java哈希值,java入门编程语言
    学习java集合HashSet
    学习java集合set集合
    学习java集合LinkedList
    学习java集合Arraylist
    学习java集合list集合
    学习Java数据结构(入门选Java)
  • 原文地址:https://www.cnblogs.com/kekeoutlook/p/8455885.html
Copyright © 2011-2022 走看看