?今天我們來學習合宙低功耗4G模組Air780E快速入門之跟服務器之間的加密通信，伙伴們，一起學起來！

一、編寫腳本

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就是TCP

local 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 do

local 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)



   end

end

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 then



       log.info("socket", "服務器連上了")



       --向服務器發送數據



       libnet.tx(d1Name, 0, netc, "helloworld")



   else



       log.info("socket", "服務器沒連上了!!!")



   end



   while result do



       -- 連接成功之后, 先嘗試接收



       -- log.info("socket", "調用rx接收數據")



       local succ, param = socket.rx(netc, rx_buff)



       if not succ then



           log.info("服務器斷開了", succ, param, ip, port)



           break



       end



       -- 如果服務器有下發數據, used()就必然大于0, 進行處理



       if rx_buff:used() > 0 then



           log.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)



           break



       elseif #txqueue > 0 then



           -- 有待上報的數據,處理之



           while #txqueue > 0 do



               local data = table.remove(txqueue, 1)



               if not data then



                   break



               end



               result,param = libnet.tx(d1Name, 15000, netc,data)



               log.info("libnet", "發送數據的結果", result, param)



               if not result then



                   log.info("socket", "數據發送異常", result, param)



                   break



               end



           end



       end



       -- 循環尾部, 繼續下一輪循環



   end



   -- 能到這里, 要么服務器斷開連接, 要么上報(tx)失敗, 或者是主動退出



   libnet.close(d1Name, 5000, netc)



   -- log.info(rtos.meminfo("sys"))



   sys.wait(30000) -- 這是重連時長, 自行調整