API Server由http改为tcp的问题

dqsife

Hi,

请教一个小白问题

我在用openresty作为基于HTTP的API Server，现在想改为基于TCP的长连接，但是保持原来Http的API。

目前，我是这么做的：

1. 引入stream-lua-nginx-module和lua-resty-http

2. nginx.conf里添加stream:

stream {

# define a TCP server listening on the port 1234:

server {

listen 1234;

content_by_lua_file /opt/openresty/nginx/lua/stream.lua;

}

3. stream.lua里监听接口，并将接收到的信息作为参数，通过lua-resty-http请求原http的接口:

local cjson = require "cjson.safe”

--判断table里面是否包含某些element的函数

local function tableContains(table, element)

if not table then

return false

end for key, value in pairs(table) do

if key == element then

return true

end

return false

end

function handleSocket()

--建立socket

local tcp_req,err = ngx.req.socket(true)

if not tcp_req then

ngx.log(ngx.ERR,"--->get req socket err:",err)

end

--开启监听，如果包含key为’body’的参数，则为有效包，其他为心跳包等

while true do

local req_data

req,err = tcp_req:receive()

if not req then

ngx.log(ngx.ERR,"--->get req_data err:",err,"\n”)

return

end

local jsonResp = req

local req_data = cjson.decode(req)

local param

if tableContains(req_data,"body") then

local body = req_data["body”]

local body_data

if body then

body_data = cjson.decode(body)

else

return false

end

if tableContains(body_data,"param”) then

param = body_data["param”]

end

-- send HTTP request，该param为之前http的参数

if param ~= nil then

local http = require "resty.http”

local httpc = http.new()

local response, err

response, err = httpc:request_uri("http://example.cn"..param)

if not response then

ngx.log(ngx.ERR,"#####--->failed to request: ",err)

return

else

resp= {value = response.body};

tcp_req:send(cjson.encode(resp))

tcp_req:send("\r\n”)

ngx.log(ngx.ERR,"#####--->response:",cjson.encode(resp)," #####\n”)

end

else

tcp_req:send(jsonResp)

tcp_req:send("\r\n”)

end

handleSocket()

有两个问题：

1.这种方式，会报error:no lua_resolver defined to resolve "example.cn " while handling client connection

2.请问这么做是否合理？

谢谢，

周末愉快

yuansheng_335c

On Fri, Apr 21, 2017 at 9:25 PM, JohnTai <dq...@gmail.com> wrote:

Hi,
请教一个小白问题
我在用openresty作为基于HTTP的API Server，现在想改为基于TCP的长连接，但是保持原来Http的API。

目前，我是这么做的：
1. 引入stream-lua-nginx-module和lua-resty-http

2. nginx.conf里添加stream:
stream {
   # define a TCP server listening on the port 1234:
   server {
   listen 1234;
   content_by_lua_file /opt/openresty/nginx/lua/stream.lua;
   }
}

3. stream.lua里监听接口，并将接收到的信息作为参数，通过lua-resty-http请求原http的接口:

local cjson = require "cjson.safe”
--判断table里面是否包含某些element的函数
local function tableContains(table, element)
if not table then
return false
end for key, value in pairs(table) do
if key == element then
return true
end
end
return false
end

function handleSocket()
--建立socket
local tcp_req,err = ngx.req.socket(true)
if not tcp_req then
ngx.log(ngx.ERR,"--->get req socket err:",err)
end

--开启监听，如果包含key为’body’的参数，则为有效包，其他为心跳包等
while true do
local req_data
req,err = tcp_req:receive()
if not req then
ngx.log(ngx.ERR,"--->get req_data err:",err,"\n”)
return
end
local jsonResp = req
local req_data = cjson.decode(req)

TCP 数据是没有边界的，所以你无法确定这里的 req 数据是否是单个完整请求 json 数据，一般需要 head+body 方式解决（比如长度+内容）

local param
if tableContains(req_data,"body") then
local body = req_data["body”]
local body_data
if body then
body_data = cjson.decode(body)
else
return false
end
if tableContains(body_data,"param”) then
param = body_data["param”]
end
end

-- send HTTP request，该param为之前http的参数
if param ~= nil then
local http = require "resty.http”

require 的对象应是 top level 级别的，不应当放到代码块中

local httpc = http.new()
local response, err
response, err = httpc:request_uri("http://example.cn"..param)
if not response then
ngx.log(ngx.ERR,"#####--->failed to request: ",err)
return
else
resp= {value = response.body};
tcp_req:send(cjson.encode(resp))
tcp_req:send("\r\n”)
ngx.log(ngx.ERR,"#####--->response:",cjson.encode(resp)," #####\n”)
end
else
tcp_req:send(jsonResp)
tcp_req:send("\r\n”)
end
end
end
handleSocket()

有两个问题：
1.这种方式，会报error:no lua_resolver defined to resolve "example.cn " while handling client connection

错误信息说的明确，缺少 resolver 配置 http://nginx.org/en/docs/http/ngx_http_core_module.html#resolver

2.请问这么做是否合理？

可以这么玩的，不过感觉你对 tcp 报文传输不是很熟悉，更推荐你用 http 方式解决。

谢谢，
周末愉快

--

membphis

dqsife

谢谢指导！

我添加了resolver后，又报"nginx: [emerg] "resolver" directive is not allowed here"，请问是什么原因呢？

stream {

# define a TCP server listening on the port 1234:

server {

listen 1234;

resolver 127.0.0.1 [::1]:5353

content_by_lua_file /opt/openresty/nginx/lua/stream.lua;

}

在 2017年4月21日星期五 UTC+8下午9:25:40，JohnTai写道：

Hi,
请教一个小白问题
我在用openresty作为基于HTTP的API Server，现在想改为基于TCP的长连接，但是保持原来Http的API。

目前，我是这么做的：
1. 引入stream-lua-nginx-module和lua-resty-http

2. nginx.conf里添加stream:
stream {
   # define a TCP server listening on the port 1234:
   server {
   listen 1234;
   content_by_lua_file /opt/openresty/nginx/lua/stream.lua;
   }
}

3. stream.lua里监听接口，并将接收到的信息作为参数，通过lua-resty-http请求原http的接口:

local cjson = require "cjson.safe”
--判断table里面是否包含某些element的函数
local function tableContains(table, element)
if not table then
return false
end for key, value in pairs(table) do
if key == element then
return true
end
end
return false
end

function handleSocket()
--建立socket
local tcp_req,err = ngx.req.socket(true)
if not tcp_req then
ngx.log(ngx.ERR,"--->get req socket err:",err)
end

--开启监听，如果包含key为’body’的参数，则为有效包，其他为心跳包等
while true do
local req_data
req,err = tcp_req:receive()
if not req then
ngx.log(ngx.ERR,"--->get req_data err:",err,"\n”)
return
end
local jsonResp = req
local req_data = cjson.decode(req)
local param
if tableContains(req_data,"body") then
local body = req_data["body”]
local body_data
if body then
body_data = cjson.decode(body)
else
return false
end
if tableContains(body_data,"param”) then
param = body_data["param”]
end
end

-- send HTTP request，该param为之前http的参数
if param ~= nil then
local http = require "resty.http”
local httpc = http.new()
local response, err
response, err = httpc:request_uri("http://example.cn"..param)
if not response then
ngx.log(ngx.ERR,"#####--->failed to request: ",err)
return
else
resp= {value = response.body};
tcp_req:send(cjson.encode(resp))
tcp_req:send("\r\n”)
ngx.log(ngx.ERR,"#####--->response:",cjson.encode(resp)," #####\n”)
end
else
tcp_req:send(jsonResp)
tcp_req:send("\r\n”)
end
end
end
handleSocket()

有两个问题：
1.这种方式，会报error:no lua_resolver defined to resolve "example.cn " while handling client connection
2.请问这么做是否合理？

谢谢，
周末愉快

dqsife

我知道了应该是lua_resolver

在 2017年4月22日星期六 UTC+8下午4:28:34，JohnTai写道：

谢谢指导！
我添加了resolver后，又报"nginx: [emerg] "resolver" directive is not allowed here"，请问是什么原因呢？

stream {
# define a TCP server listening on the port 1234:
server {
listen 1234;

resolver 127.0.0.1 [::1]:5353

content_by_lua_file /opt/openresty/nginx/lua/stream.lua;
}
}

在 2017年4月21日星期五 UTC+8下午9:25:40，JohnTai写道：
Hi,
请教一个小白问题
我在用openresty作为基于HTTP的API Server，现在想改为基于TCP的长连接，但是保持原来Http的API。

目前，我是这么做的：
1. 引入stream-lua-nginx-module和lua-resty-http

2. nginx.conf里添加stream:
stream {
   # define a TCP server listening on the port 1234:
   server {
   listen 1234;
   content_by_lua_file /opt/openresty/nginx/lua/stream.lua;
   }
}

3. stream.lua里监听接口，并将接收到的信息作为参数，通过lua-resty-http请求原http的接口:

local cjson = require "cjson.safe”
--判断table里面是否包含某些element的函数
local function tableContains(table, element)
if not table then
return false
end for key, value in pairs(table) do
if key == element then
return true
end
end
return false
end

function handleSocket()
--建立socket
local tcp_req,err = ngx.req.socket(true)
if not tcp_req then
ngx.log(ngx.ERR,"--->get req socket err:",err)
end

--开启监听，如果包含key为’body’的参数，则为有效包，其他为心跳包等
while true do
local req_data
req,err = tcp_req:receive()
if not req then
ngx.log(ngx.ERR,"--->get req_data err:",err,"\n”)
return
end
local jsonResp = req
local req_data = cjson.decode(req)
local param
if tableContains(req_data,"body") then
local body = req_data["body”]
local body_data
if body then
body_data = cjson.decode(body)
else
return false
end
if tableContains(body_data,"param”) then
param = body_data["param”]
end
end

-- send HTTP request，该param为之前http的参数
if param ~= nil then
local http = require "resty.http”
local httpc = http.new()
local response, err
response, err = httpc:request_uri("http://example.cn"..param)
if not response then
ngx.log(ngx.ERR,"#####--->failed to request: ",err)
return
else
resp= {value = response.body};
tcp_req:send(cjson.encode(resp))
tcp_req:send("\r\n”)
ngx.log(ngx.ERR,"#####--->response:",cjson.encode(resp)," #####\n”)
end
else
tcp_req:send(jsonResp)
tcp_req:send("\r\n”)
end
end
end
handleSocket()

有两个问题：
1.这种方式，会报error:no lua_resolver defined to resolve "example.cn " while handling client connection
2.请问这么做是否合理？

谢谢，
周末愉快