在OpenWrt中使用socket通信主要就是調用nixio.socket來完成。我們可以寫一個模塊,然后在需要使用的時候使用require來引入。具體的實現如下:
core = {} local h = require "luci.http" local n = require "nixio" core.ip = "127.0.0.1" core.port = 61000 core.uri = "/BYW_ASTEST" core.method = "POST" core.charset = "UTF-8" core.rcvTimeout = 20 -- s -- 獲取get/post提交過來的數據 -- @param name 變量名稱 -- @return 返回獲取到的數據 function core.get(name) if name == "" then return "" else return string.gsub(h.formvalue(name) or "", '[&<>"]+', "") end end -- 封裝數據 -- @param data 要發送的數據 -- @return string 封裝后的http數據 function core.httpData(data) core.uri = string.upper(core.uri) return core.method .. " " .. core.uri .. " HTTP/1.1\r\n" .. "Host: " .. core.ip .. ":" .. core.port .. "\r\n" .. "Content-type: text/html;charset=" .. core.charset .. "\r\n" .. "Accept-Language: zh-cn\r\n" .. "User-Agent: Mozilla/4.0(Compatible win32; MSIE)\r\n" .. "Content-Length: " .. string.len(data) .. "\r\n" .. "Connection: close\r\n\r\n" .. data end -- 通過socket發送並接收數據 -- @param data 要發送的數據 -- @return socket運行狀態與接收到的(錯誤)數據 function core.send(data) local position local t = {} local http local socket = nixio.socket("inet", "stream") local tmp if not socket then return false, "創建socket失敗" end if not socket:connect(core.ip, core.port) then socket:close() return false, "服務無響應,連接服務器 " .. core.ip .. ":" .. core.port .. " 失敗" end socket:setopt("socket", "rcvtimeo", core.rcvTimeout) socket:send(core.httpData(data)) repeat tmp = socket:recv(100) if tmp == false then socket:close() return false, "響應超時" end tmp = tostring(tmp) t[#t + 1] = tmp until #tmp < 1 socket:close() local result = table.concat(t) position = string.find(result, "\r\n\r\n") if position == nil then return false, "返回的數據格式不合法。數據:" .. result end result = string.sub(result, string.find(result, "\r\n\r\n") + 4) return true, result end return core
使用示例如下:
<% local h = require "luci.http" local c = require "luci.core" local userName, password = c.get('userName'), c.get('password') local command = string.format("funname=Login\r\nusername=%s\r\npassword=%s", userName, password) h.write(c.send(command)) %>