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

一、編寫腳本

1.1 準備資料

Air780E開發(fā)板購買

Air780E開發(fā)板設計資料

LuatOS-Air780E/網(wǎng)絡加密通信程序源碼demo

合宙的 TCP/UDP 測試服務器

API介紹說明

1.2 程序詳解

1.2.1 首先配置聯(lián)網(wǎng)配置

-- 測試網(wǎng)站 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 聯(lián)網(wǎng)后，創(chuàng)建聯(lián)網(wǎng)成功后，對收發(fā)數(shù)據(jù)事件的處理函數(shù)

local function sockettest()

-- 等待聯(lián)網(wǎng)

sys.waitUntil("IP_READY")

-- 時間同步

socket.sntp()

-- 開始正在的邏輯, 發(fā)起socket鏈接,等待數(shù)據(jù)/上報心跳

local taskName = "sc"

local topic = taskName .. "_txrx"

log.info("topic", topic)

local txqueue = {}

--[[創(chuàng)建一個任務線程

@param1 function 任務函數(shù)名，用于resume喚醒時調用

@param2 string 任務名稱，用于喚醒任務id

@param3 function 接收到非目標消息時的回調函數(shù)

@param4 any 任務函數(shù)fun的可變參數(shù)

@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



       -- 等很久了,沒數(shù)據(jù)上傳/下發(fā), 發(fā)個日期心跳包吧



       table.insert(txqueue, os.date())



       sys_send(taskName, socket.EVENT, 0)



   elseif tp == "uplink" then



       -- 上行數(shù)據(jù), 主動上報的數(shù)據(jù),那就發(fā)送呀



       table.insert(txqueue, data)



       sys_send(taskName, socket.EVENT, 0)



   elseif tp == "downlink" then



       -- 下行數(shù)據(jù),接收的數(shù)據(jù), 從ipv6task來的



       -- 其他代碼可以通過 sys.publish()



       log.info("socket", "收到下發(fā)的數(shù)據(jù)了", #data,"data:",data)



   end

end

1.2.3 聯(lián)網(wǎng)函數(shù)

function sockettask(d1Name, txqueue, rxtopic)

-- 打印準備連接的服務器信息

log.info("socket", host, port, is_udp and "UDP" or "TCP", is_tls and "TLS" or "RAW")

-- 準備好所需要的接收緩沖區(qū)

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", "服務器連上了")



       --向服務器發(fā)送數(shù)據(jù)



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



   else



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



   end



   while result do



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



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



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



       if not succ then



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



           break



       end



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



       if rx_buff:used() > 0 then



           log.info("socket", "收到服務器數(shù)據(jù)，長度", rx_buff:used())



           local data = rx_buff:query() -- 獲取數(shù)據(jù)



           sys.publish(rxtopic, "downlink", data)



           rx_buff:del()



       end



       -- log.info("libnet", "調用wait開始等待消息")



       -- 等待事件, 例如: 服務器下發(fā)數(shù)據(jù), 有數(shù)據(jù)準備上報, 服務器斷開連接



       result, param, param2 = libnet.wait(d1Name, 15000, netc)



       log.info("libnet", "wait", result, param, param2)



       if not result then



           -- 網(wǎng)絡異常了, 那就斷開了, 執(zhí)行清理工作



           log.info("socket", "服務器斷開了", result, param)



           break



       elseif #txqueue > 0 then



           -- 有待上報的數(shù)據(jù),處理之



           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", "發(fā)送數(shù)據(jù)的結果", result, param)



               if not result then



                   log.info("socket", "數(shù)據(jù)發(fā)送異常", result, param)



                   break



               end



           end



       end



       -- 循環(huán)尾部, 繼續(xù)下一輪循環(huán)



   end



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



   libnet.close(d1Name, 5000, netc)



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



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