在OpenWrt中使用socket通信


在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))
%>


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM