五,ESP8266 TCP服务器多连接(基于Lua脚本语言)

简介: 一些时间去准备朋友的元器件了...接着写,,争取今天写完所有的文章,,因为答应了朋友下周5之前要做好朋友的东西对于TCP大家在玩AT指令的时候有没有发现客户端最多连接5个,,,再连接就不行了??所以在用AT指令开发的时候单片机程序一定要记得清除多余的连接现在看用LUA语言怎么做直接先上菜Init.

一些时间去准备朋友的元器件了...

接着写,,争取今天写完所有的文章,,因为答应了朋友下周5之前要做好朋友的东西

对于TCP大家在玩AT指令的时候有没有发现客户端最多连接5个,,,再连接就不行了??

所以在用AT指令开发的时候单片机程序一定要记得清除多余的连接

现在看用LUA语言怎么做

直接先上菜

Init.lua

 

gpio.mode(4,gpio.OUTPUT)
gpio.mode(2,gpio.OUTPUT)
gpio.write(4,1)

tmr.alarm(0, 1000, 1, function()
    gpio.write(4,1-gpio.read(4))
end)

tmr.alarm(1, 1000, 0, function()
    dofile("wifi.lua")
end)

wifi.lua

 

wifi.setmode(wifi.STATIONAP)


cfg={}
cfg.ssid="Hellow8266"
cfg.pwd="11223344"
wifi.ap.config(cfg)


apcfg={}
apcfg.ssid="qqqqq"
apcfg.pwd="11223344"
wifi.sta.config(apcfg)
wifi.sta.connect()


TCPSever=net.createServer(net.TCP,28800) 


TcpConnectCnt = 0
TcpSocketTable={}
TCPSever:listen(8080,function(socket) 
  
    if  TcpConnectCnt == 4 then
        if  TcpSocketTable[0] ~= nil then 
            TcpSocketTable[0]:close()
            TcpSocketTable[0] = nil
        end    
    else
        if  TcpSocketTable[TcpConnectCnt+1] ~= nil then 
            TcpSocketTable[TcpConnectCnt+1]:close()
            TcpSocketTable[TcpConnectCnt+1] = nil
        end 
    end
    
    TcpSocketTable[TcpConnectCnt] = socket
    
    print(TcpConnectCnt.."-Connect")
    
    
    TcpConnectCnt = TcpConnectCnt + 1
    if  TcpConnectCnt == 5 then
        TcpConnectCnt = 0
    end
    
    
    socket:on("receive",function(socket,data) 
          uart.write(0,data) 
    end) 


    socket:on("disconnection",function(sck,c) 
        for i=0,4 do
            if  TcpSocketTable[i] == sck then
                TcpSocketTable[i] = nil
                print(i.."-Disconnect")
            end
        end
    end)
    
end)






uart.on("data",0,function(data) 


    for i=0,5 do
        if  TcpSocketTable[i] ~= nil then
            TcpSocketTable[i]:send(data)
        end
    end
        
end, 0)




printip = 0
wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
    printip = 0
end)




wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
   if printip == 0 then
      print("+IP"..T.IP)
   end
   printip = 1
end)

下面看解释.............

 

wifi.setmode(wifi.STATIONAP)--模式AP+STATION就不说了

cfg={}
cfg.ssid="Hellow8266"
cfg.pwd="11223344"
wifi.ap.config(cfg)--设置模块的无线和密码

apcfg={}
apcfg.ssid="qqqqq"
apcfg.pwd="11223344"
wifi.sta.config(apcfg)--设置模块连接路由器的无线和密码

--wifi.sta.connect()连接路由器,断开后可能就不自动连接了,可以用下面的
wifi.sta.autoconnect(1)可以用这个断开后自动连接路由器




TCPSever=net.createServer(net.TCP,28800) --创建服务器超过28800S不通信断开已有的连接

TcpConnectCnt = 0--连接个数计数
TcpSocketTable={}--存储socket
TCPSever:listen(8080,function(socket) 

    如果0号连接就把1号关掉,,,1号连接就把2号关掉....4号连接就把0号关掉,这样子循环,
    当然您会问可以连接5个,,这样子只可以连接四个了,,,为什么....因为如果连接了5个就进不
    来这个监听函数了.......所以必须留下一个空位
    
    if  TcpConnectCnt == 4 then
        if  TcpSocketTable[0] ~= nil then 
            TcpSocketTable[0]:close()
            TcpSocketTable[0] = nil
        end    
   else
        if  TcpSocketTable[TcpConnectCnt+1] ~= nil then 
            TcpSocketTable[TcpConnectCnt+1]:close()
            TcpSocketTable[TcpConnectCnt+1] = nil
        end 
   end

    TcpSocketTable[TcpConnectCnt] = socket--把连接的socket存到数组

    
    print(TcpConnectCnt.."-Connect")--打印几号连接了  对了 .. 是连接符
    
    
    TcpConnectCnt = TcpConnectCnt + 1--连接个数加一
    if  TcpConnectCnt == 5 then --归零
        TcpConnectCnt = 0
    end
    
    
    socket:on("receive",function(socket,data) 
          uart.write(0,data) --把接收到的数据发到串口
    end) 

    socket:on("disconnection",function(sck,c) 
        for i=0,4 do --判断是哪个断开了连接,,就把对应的socket变量置为 nil
            if  TcpSocketTable[i] == sck then
                TcpSocketTable[i] = nil
                print(i.."-Disconnect")
            end
        end
    end)
    
end)



uart.on("data",0,function(data) 

    for i=0,4 do  --把串口的数据发向不为 nil 的连接
        if  TcpSocketTable[i] ~= nil then
            TcpSocketTable[i]:send(data)
        end
    end
        
end, 0)

--下面是连接路由器和没有连接路由器的监听函数,,好像是1S检测一次
printip = 0
wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
    printip = 0
end)


wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
   if printip == 0 then
      print("+IP"..T.IP)
   end
   printip = 1
end)

 

现在把程序下进去

测试软件呢在这里下载--也可以自己下载个网络调试助手

https://item.taobao.com/item.htm?spm=686.1000925.0.0.4a155084jlU4Rd&id=558508797404

 连接了路由器了....

 

 第一个连接

 

 测试数据

 

 再来几个连接

 

 

 

 

 现在再连接一个

 

 

 

 

 

 我现在随意断开一个,看一看串口应该打印哪一个断开了连接

 

 

 

 现在发数据

 

 

 

 

 好现在呢控制就用多个客户端控制继电器

 

 

 

控制的指令呢咱就配置成----

http://www.cnblogs.com/yangfengwu/p/7513097.html

这篇文章最后的指令,,毕竟最终咱们就要做成那样子.....这样的话8266就应该使用的非常顺手和轻松了

对了在

http://www.cnblogs.com/yangfengwu/p/7520260.html

http://www.cnblogs.com/yangfengwu/p/7524326.html

这篇两文章中有提及......这次是用多个TCP客户端控制,,还会加上CRC校验

可以直接用软件上的这两个按钮控制

 

 

先写不带CRC校验数据的

为了是程序好浏览,,就定义一个函数,,然后调用

现在的wifi.lua

 

wifi.setmode(wifi.STATIONAP)

cfg={}
cfg.ssid="Hellow8266"
cfg.pwd="11223344"
wifi.ap.config(cfg)

apcfg={}
apcfg.ssid="qqqqq"
apcfg.pwd="11223344"
wifi.sta.config(apcfg)
wifi.sta.connect()

TCPSever=net.createServer(net.TCP,28800) 

TcpConnectCnt = 0
TcpSocketTable={}

TCPSever:listen(8080,function(socket) 
  
    if  TcpConnectCnt == 4 then
        if  TcpSocketTable[0] ~= nil then 
            TcpSocketTable[0]:close()
            TcpSocketTable[0] = nil
        end    
    else
        if  TcpSocketTable[TcpConnectCnt+1] ~= nil then 
            TcpSocketTable[TcpConnectCnt+1]:close()
            TcpSocketTable[TcpConnectCnt+1] = nil
        end 
    end
    
    TcpSocketTable[TcpConnectCnt] = socket
    
    print(TcpConnectCnt.."-Connect")
    
    
    TcpConnectCnt = TcpConnectCnt + 1
    if  TcpConnectCnt == 5 then
        TcpConnectCnt = 0
    end
    
    
    socket:on("receive",function(socket,data) 
          uart.write(0,data) 
          control(data)
    end) 

    socket:on("disconnection",function(sck,c) 
        for i=0,4 do
            if  TcpSocketTable[i] == sck then
                TcpSocketTable[i] = nil
                print(i.."-Disconnect")
            end
        end
    end)
    
end)


function control(data)  
    if  data == "++MD610" then
        gpio.write(2,1)
        print("Relay=1")
    end
    if  data == "++MD600" then
        gpio.write(2,0)
        print("Relay=0")
    end
end  


uart.on("data",0,function(data) 

    for i=0,4 do
        if  TcpSocketTable[i] ~= nil then
            TcpSocketTable[i]:send(data)
        end
    end
        
end, 0)


printip = 0
wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
    printip = 0
end)


wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
   if printip == 0 then
      print("+IP"..T.IP)
   end
   printip = 1
end)

 

 好现在控制一下

 

现在用另一个断开

 

对了最好把信息发给网络对不对,,,控制一下最好通过网络有一个回复

现在的wifi.lua

wifi.setmode(wifi.STATIONAP)

cfg={}
cfg.ssid="Hellow8266"
cfg.pwd="11223344"
wifi.ap.config(cfg)

apcfg={}
apcfg.ssid="qqqqq"
apcfg.pwd="11223344"
wifi.sta.config(apcfg)
wifi.sta.connect()

TCPSever=net.createServer(net.TCP,28800) 

TcpConnectCnt = 0
TcpSocketTable={}
NowSocket=nil
TCPSever:listen(8080,function(socket) 
  
    if  TcpConnectCnt == 4 then
        if  TcpSocketTable[0] ~= nil then 
            TcpSocketTable[0]:close()
            TcpSocketTable[0] = nil
        end    
    else
        if  TcpSocketTable[TcpConnectCnt+1] ~= nil then 
            TcpSocketTable[TcpConnectCnt+1]:close()
            TcpSocketTable[TcpConnectCnt+1] = nil
        end 
    end
    
    TcpSocketTable[TcpConnectCnt] = socket
    
    print(TcpConnectCnt.."-Connect")
    
    
    TcpConnectCnt = TcpConnectCnt + 1
    if  TcpConnectCnt == 5 then
        TcpConnectCnt = 0
    end
    
    
    socket:on("receive",function(socket,data) 
          NowSocket = socket
          uart.write(0,data) 
          control(data)
    end) 

    socket:on("disconnection",function(sck,c) 
        for i=0,4 do
            if  TcpSocketTable[i] == sck then
                TcpSocketTable[i] = nil
                print(i.."-Disconnect")
            end
        end
    end)
    
end)


function control(data)  
    if  data == "++MD610" then
        gpio.write(2,1)
        print("Relay=1")
        if  NowSocket ~= nil then
            NowSocket:send("Relay=1")
            NowSocket = nil
        end
    end
    if  data == "++MD600" then
        gpio.write(2,0)
        print("Relay=0")
        if  NowSocket ~= nil then
            NowSocket:send("Relay=0")
            NowSocket = nil
        end
    end
end  


uart.on("data",0,function(data) 

    for i=0,4 do
        if  TcpSocketTable[i] ~= nil then
            TcpSocketTable[i]:send(data)
        end
    end
        
end, 0)


printip = 0
wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
    printip = 0
end)


wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
   if printip == 0 then
      print("+IP"..T.IP)
   end
   printip = 1
end)

 

 

 

 

 

好了现在加入CRC16校验数据

现在的wifi.lua

wifi.setmode(wifi.STATIONAP)

cfg={}
cfg.ssid="Hellow8266"
cfg.pwd="11223344"
wifi.ap.config(cfg)

apcfg={}
apcfg.ssid="qqqqq"
apcfg.pwd="11223344"
wifi.sta.config(apcfg)
wifi.sta.connect()

TCPSever=net.createServer(net.TCP,28800) 

TcpConnectCnt = 0
TcpSocketTable={}
NowSocket=nil
TCPSever:listen(8080,function(socket) 
  
    if  TcpConnectCnt == 4 then
        if  TcpSocketTable[0] ~= nil then 
            TcpSocketTable[0]:close()
            TcpSocketTable[0] = nil
        end    
    else
        if  TcpSocketTable[TcpConnectCnt+1] ~= nil then 
            TcpSocketTable[TcpConnectCnt+1]:close()
            TcpSocketTable[TcpConnectCnt+1] = nil
        end 
    end
    
    TcpSocketTable[TcpConnectCnt] = socket
    
    print(TcpConnectCnt.."-Connect")
    
    
    TcpConnectCnt = TcpConnectCnt + 1
    if  TcpConnectCnt == 5 then
        TcpConnectCnt = 0
    end
    
    
    socket:on("receive",function(socket,data) 
          NowSocket = socket
          uart.write(0,data) 
          control(data)
    end) 

    socket:on("disconnection",function(sck,c) 
        for i=0,4 do
            if  TcpSocketTable[i] == sck then
                TcpSocketTable[i] = nil
                print(i.."-Disconnect")
            end
        end
    end)
    
end)


function control(data)  
    local RevLen = string.len (data)
    local crc = ow.crc16(string.sub(data,1,RevLen-2))
    
    local recrc = data:byte(RevLen)
    local recrc = recrc*256
    local recrc = recrc + data:byte(RevLen-1)

    if  crc == recrc then
        if  string.sub(data,1,7) == "++MD610" then
            gpio.write(2,1)
            print("Relay=1")
            if  NowSocket ~= nil then
                NowSocket:send("Relay=1")
                NowSocket = nil
            end
        end
        if  string.sub(data,1,7) == "++MD600" then
            gpio.write(2,0)
            print("Relay=0")
            if  NowSocket ~= nil then
                NowSocket:send("Relay=0")
                NowSocket = nil
            end
        end
    else
        if  NowSocket ~= nil then
                NowSocket:send("CRC16 Faild")
                NowSocket = nil
        end   
    end       

    
end  


uart.on("data",0,function(data) 

    for i=0,4 do
        if  TcpSocketTable[i] ~= nil then
            TcpSocketTable[i]:send(data)
        end
    end
        
end, 0)


printip = 0
wifi.eventmon.register(wifi.eventmon.STA_DISCONNECTED, function(T)
    printip = 0
end)


wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, function(T)
   if printip == 0 then
      print("+IP"..T.IP)
   end
   printip = 1
end)

 

他呢,,参数要填写字符串

上位机的CRC计算函数

/// <CRC  效验  >
        /// 
        /// </summary>
        /// <param name="modbusdata"></param>
        /// <param name="length"></param>
        /// <returns></returns>
        private int crc16_modbus(byte[] modbusdata, int length)
        {
            int i, j;

            int crc = 0x0;

            try
            {
                for (i = 0; i < length; i++)
                {
                    crc ^= modbusdata[i];
                    for (j = 0; j < 8; j++)
                    {
                        if ((crc & 0x01) == 1)
                        {
                            crc = (crc >> 1) ^ 0xa001;
                        }
                        else
                        {
                            crc >>= 1;
                        }
                    }
                }
            }
            catch (Exception)
            {

                throw;
            }

            return crc;
        }


我的置高继电器函数

private void button7_Click_1(object sender, EventArgs e)
        {
            byte[] sendbyte = new byte[7];
            sendbyte[0] = (byte)'+';//2B
            sendbyte[1] = (byte)'+';
            sendbyte[2] = (byte)'M';//4D
            sendbyte[3] = (byte)'D';//44
            sendbyte[4] = (byte)'6';//6
            sendbyte[5] = (byte)'1';//1

            if (comboBox3.Text=="继电器")//pin2
            {
                sendbyte[6] = (byte)'0';
            }
            else if (comboBox3.Text == "CS")//pin8
            {
                sendbyte[6] = (byte)'1';
            }
            else if (comboBox3.Text == "MOSI")//pin7
            {
                sendbyte[6] = (byte)'2';
            }
            else if (comboBox3.Text == "MISO")//pin6
            {
                sendbyte[6] = (byte)'3';
            }
            else if (comboBox3.Text == "CLK")//pin5
            {
                sendbyte[6] = (byte)'4';
            }
            if (radioButtonNetCon.Checked)//网络发送
            {
                TcpSendDataMethod(sendbyte);
            }
            else if (radioButtonSerialCon.Checked)//串口发送
            {
                SerialSend(sendbyte);
            }
        }
/// <TCP发送数据>
        /// 
        /// </summary>
        /// <param name="byt"></param>
        private void TcpSendDataMethod(byte[] byt)
        {
            int crc = 0;

            byte[] sendbyte = new byte[byt.Length + 2];

            for (int i = 0; i < byt.Length; i++)
            {
                sendbyte[i] = byt[i];
            }

            crc = crc16_modbus(byt, byt.Length);//计算CRC
            byte[] Crcbyte = System.BitConverter.GetBytes(crc);//得到CRC

            sendbyte[sendbyte.Length - 2] = Crcbyte[0];
            sendbyte[sendbyte.Length - 1] = Crcbyte[1];

            try { networkstrem.Write(sendbyte, 0, sendbyte.Length); }
            catch (Exception) { MessageBox.Show("请检查连接", "提示!"); }
        }

 

还要说一点让8266计算CRC,发现8266存储数据是大端模式......

好了现在测试一下用软件的按钮控制

 

 

好啦终于这完这一篇了....累..真心的累.............

 

目录
相关文章
|
26天前
|
域名解析 网络协议 数据库
TCP/IP服务器
【10月更文挑战第20天】TCP/IP服务器
116 65
|
1月前
|
IDE 网络安全 开发工具
IDE之vscode:连接远程服务器代码(亲测OK),与pycharm链接服务器做对比(亲自使用过了),打开文件夹后切换文件夹。
本文介绍了如何使用VS Code通过Remote-SSH插件连接远程服务器进行代码开发,并与PyCharm进行了对比。作者认为VS Code在连接和配置多个服务器时更为简单,推荐使用VS Code。文章详细说明了VS Code的安装、远程插件安装、SSH配置文件编写、服务器连接以及如何在连接后切换文件夹。此外,还提供了使用密钥进行免密登录的方法和解决权限问题的步骤。
423 0
IDE之vscode:连接远程服务器代码(亲测OK),与pycharm链接服务器做对比(亲自使用过了),打开文件夹后切换文件夹。
|
1月前
|
IDE 网络安全 开发工具
IDE之pycharm:专业版本连接远程服务器代码,并配置远程python环境解释器(亲测OK)。
本文介绍了如何在PyCharm专业版中连接远程服务器并配置远程Python环境解释器,以便在服务器上运行代码。
311 0
IDE之pycharm:专业版本连接远程服务器代码,并配置远程python环境解释器(亲测OK)。
|
1月前
|
网络协议 Java API
【网络】TCP回显服务器和客户端的构造,以及相关bug解决方法
【网络】TCP回显服务器和客户端的构造,以及相关bug解决方法
62 2
|
1月前
|
存储 网络协议 Java
【网络】UDP回显服务器和客户端的构造,以及连接流程
【网络】UDP回显服务器和客户端的构造,以及连接流程
52 2
|
1月前
|
Apache 数据中心 Windows
将网站迁移到阿里云Windows系统云服务器,访问该站点提示连接被拒绝,如何处理?
将网站迁移到阿里云Windows系统云服务器,访问该站点提示连接被拒绝,如何处理?
|
1月前
|
弹性计算 安全 Windows
通过远程桌面连接Windows服务器提示“由于协议错误,会话将被中断,请重新连接到远程计算机”错误怎么办?
通过远程桌面连接Windows服务器提示“由于协议错误,会话将被中断,请重新连接到远程计算机”错误怎么办?
|
9天前
|
机器学习/深度学习 人工智能 弹性计算
什么是阿里云GPU云服务器?GPU服务器优势、使用和租赁费用整理
阿里云GPU云服务器提供强大的GPU算力,适用于深度学习、科学计算、图形可视化和视频处理等多种场景。作为亚太领先的云服务提供商,阿里云的GPU云服务器具备灵活的资源配置、高安全性和易用性,支持多种计费模式,帮助企业高效应对计算密集型任务。
|
11天前
|
存储 分布式计算 固态存储
阿里云2核16G、4核32G、8核64G配置云服务器租用收费标准与活动价格参考
2核16G、8核64G、4核32G配置的云服务器处理器与内存比为1:8,这种配比的云服务器一般适用于数据分析与挖掘,Hadoop、Spark集群和数据库,缓存等内存密集型场景,因此,多为企业级用户选择。目前2核16G配置按量收费最低收费标准为0.54元/小时,按月租用标准收费标准为260.44元/1个月。4核32G配置的阿里云服务器按量收费标准最低为1.08元/小时,按月租用标准收费标准为520.88元/1个月。8核64G配置的阿里云服务器按量收费标准最低为2.17元/小时,按月租用标准收费标准为1041.77元/1个月。本文介绍这些配置的最新租用收费标准与活动价格情况,以供参考。
|
9天前
|
机器学习/深度学习 人工智能 弹性计算
阿里云GPU服务器全解析_GPU价格收费标准_GPU优势和使用说明
阿里云GPU云服务器提供强大的GPU算力,适用于深度学习、科学计算、图形可视化和视频处理等场景。作为亚太领先的云服务商,阿里云GPU云服务器具备高灵活性、易用性、容灾备份、安全性和成本效益,支持多种实例规格,满足不同业务需求。