当前位置：首页 > news >正文

快速入门！低功耗4G模组跟服务器之间的加密通信，千万不能错过！

news 2024/10/26 15:21:32

低功耗4G模组因其高效能和低能耗的特点，被广泛应用于各种智能设备中。然而，随着设备数量的激增和数据传输的频繁，安全问题也日益凸显。为了保障数据的安全性，加密通信成为了不可或缺的一环。

本文将为您详细介绍如何快速入门，实现低功耗4G模组与服务器之间的加密通信~

1、编写脚本

1.1 准备资料

Air780E开发板

Air780E开发板设计资料

LuatOS-Air780E/网络加密通信程序源码demo

TCP/UDP 测试服务器

API介绍说明

1.2 程序详解

1.2.1 首先配置联网配置

--=============================================================-- 测试网站 https://netlab.luatos.com/ 点击 打开TCP 获取测试端口号-- 要按实际情况修改local host = "112.125.89.8" -- 服务器ip或者域名, 都可以的local port = 45186           -- 服务器端口号local is_udp = false        -- 如果是UDP, 要改成true, false就是TCPlocal is_tls = true        -- 加密与否, 要看服务器的实际情况--=============================================================

1.2.2 联网后，创建联网成功后，对收发数据事件的处理函数

local function sockettest()-- 等待联网sys.waitUntil("IP_READY")-- 时间同步socket.sntp()-- 开始正在的逻辑, 发起socket链接,等待数据/上报心跳local taskName = "sc"local topic = taskName .. "_txrx"log.info("topic", topic)local txqueue = {}--[[创建一个任务线程@param1     function   任务函数名，用于resume唤醒时调用@param2     string     任务名称，用于唤醒任务id@param3     function   接收到非目标消息时的回调函数@param4     any        任务函数fun的可变参数@return     number     返回该任务的线程号]]sysplus.taskInitEx(sockettask, taskName, netCB, taskName, txqueue, topic)while 1 dolocal result, tp, data = sys.waitUntil(topic, 30000)log.info("event", result, tp, data)if not result then-- 等很久了,没数据上传/下发, 发个日期心跳包吧table.insert(txqueue, os.date())sys_send(taskName, socket.EVENT, 0)elseif tp == "uplink" then-- 上行数据, 主动上报的数据,那就发送呀table.insert(txqueue, data)sys_send(taskName, socket.EVENT, 0)elseif tp == "downlink" then-- 下行数据,接收的数据, 从ipv6task来的-- 其他代码可以通过 sys.publish()log.info("socket", "收到下发的数据了", #data,"data:",data)endendend

1.2.3 联网函数

function sockettask(d1Name, txqueue, rxtopic)-- 打印准备连接的服务器信息log.info("socket", host, port, is_udp and "UDP" or "TCP", is_tls and "TLS" or "RAW")-- 准备好所需要的接收缓冲区local rx_buff = zbuff.create(1024)local netc = socket.create(nil, d1Name)socket.config(netc, nil, is_udp, is_tls)log.info("任务id", d1Name)while true do-- 连接服务器, 15秒超时log.info("socket", "开始连接服务器")sysplus.cleanMsg(d1Name)local result = libnet.connect(d1Name, 15000, netc, host, port)if result thenlog.info("socket", "服务器连上了")--向服务器发送数据libnet.tx(d1Name, 0, netc, "helloworld")elselog.info("socket", "服务器没连上了!!!")endwhile result do-- 连接成功之后, 先尝试接收-- log.info("socket", "调用rx接收数据")local succ, param = socket.rx(netc, rx_buff)if not succ thenlog.info("服务器断开了", succ, param, ip, port)breakend-- 如果服务器有下发数据, used()就必然大于0, 进行处理if rx_buff:used() > 0 thenlog.info("socket", "收到服务器数据，长度", rx_buff:used())local data = rx_buff:query() -- 获取数据sys.publish(rxtopic, "downlink", data)rx_buff:del()end-- log.info("libnet", "调用wait开始等待消息")-- 等待事件, 例如: 服务器下发数据, 有数据准备上报, 服务器断开连接result, param, param2 = libnet.wait(d1Name, 15000, netc)log.info("libnet", "wait", result, param, param2)if not result then-- 网络异常了, 那就断开了, 执行清理工作log.info("socket", "服务器断开了", result, param)breakelseif #txqueue > 0 then-- 有待上报的数据,处理之while #txqueue > 0 dolocal data = table.remove(txqueue, 1)if not data thenbreakendresult,param = libnet.tx(d1Name, 15000, netc,data)log.info("libnet", "发送数据的结果", result, param)if not result thenlog.info("socket", "数据发送异常", result, param)breakendendend-- 循环尾部, 继续下一轮循环end-- 能到这里, 要么服务器断开连接, 要么上报(tx)失败, 或者是主动退出libnet.close(d1Name, 5000, netc)-- log.info(rtos.meminfo("sys"))sys.wait(30000) -- 这是重连时长, 自行调整endend