nginx使用ngx_lua访问后端Thrift-Server实现和介绍

一时失言乱红尘 2022-07-14 12:16 165阅读 0赞

## http://www.blogs8.cn/posts/ypZbd5d    ##

## 背景 ##

随着openresty的出现，让nginx使用lua解决一些业务的能力大幅度提高，ngx\_lua可以使用nginx自生的基于事件驱动的IO模型，和后端的存储，业务等系统实现非阻塞的连接交互。

如何使用ngx\_lua连接后端的Thrift-Server呢？

基于这个需求，本人为ngx\_lua做了一下增强。

## 增强后的业务架构图 ##

![449477-20160407200829218-1379970197.png][]

前端使用http对外提供服务，将请求的数据调用ngx\_lua逻辑，使用定义好的Thrift的IDL文件生成lua代码，调用Thrift的服务，实现业务逻辑。

开源实现github：[https://github.com/gityf/ngx\_lua\_thrift][https_github.com_gityf_ngx_lua_thrift]

## **支持的协议protocol** ##

Support protocol: binary,compact and JSON.
    binary: TBinaryProtocol.lua
    compact: TCompactProtocol.lua
    JSON: TJsonProtocol.lua
    Support transport: RawSocket,Buffered,Framed and Http.

## **支持的socket** ##

使用nginx的tcp实现socket通信 socket: ngx.socket.tcp()

## 安装步骤 ##

下载 https://openresty.org/download/openresty-x.y.z.a.tar.gz .
    install openresty.
    To copy all files in lualib to directory openresty/lualib/
    To cpoy all conf file to directory openresty/nginx/conf/
    compile source in directory openresty/lualib/libthrift/c
    Start openresty nginx server.

## Nginx的配置 ##

location = /v1/lua_thrift{
                access_log logs/access.log main;
                add_header 'Content-Type' 'text/html';
                content_by_lua '
                    local cln = require "test_cln"
                    ngx.say(cln.demoFunc());
                ';
            }

## ngx\_lua的thrift客户端代码 ##

function _M.demoFunc()
        local socket = TSocket:new{
            host='127.0.0.1',
            port=8090
        }
        --local protocol = TBinaryProtocol:new{
        -- local protocol = TCompactProtocol:new{
            --trans = socket
        --}
        local protocol = TJSONProtocolFactory:getProtocol(socket)
        --local protocol = TCompactProtocolFactory:getProtocol(socket)
        client = RpcServiceClient:new{
            protocol = protocol
        }
        local argStruct = ArgStruct:new{
          argByte = 53,
          argString = "str 测试字符串\"\t\n\r\'\b\fvalue",
          argI16 = 54,
          argI32 = 12.3,
          argI64 = 43.32,
          argDouble = 11.22,
          argBool = true
        }
        -- Open the socket  
        socket:open()
        pmap = {}
        pmap.name = "namess"
        pmap.pass = "vpass"
        pistrmap = {}
        pistrmap[10] = "val10"
        pistrmap[20] = "val20"
        ret = client:funCall(argStruct, 53, 54, 12, 34, 11.22, "login", pmap,
            pistrmap,
            {"ele1", "ele2", "ele3"},
            {11,22,33},
            {"l1.","l2."}, false);
        res = ""
        for k,v in pairs(ret)
        do
            print(k, v)
            res = res .. k .."." .. v .. "
    "
        end
        return res
    end

## 简单的demo测试  ##

To access web url http://127.0.0.1:8000/v1/lua_thrift and get result.
    
          1.return 1 by FunCall.
          2.return 2 by FunCall.

## 参考 ##

[https://github.com/apache/thrift/tree/master/lib/lua][https_github.com_apache_thrift_tree_master_lib_lua]

[http://openresty.org/][http_openresty.org]

[449477-20160407200829218-1379970197.png]: http://img.tuwenba.com/get/http://images2015.cnblogs.com/blog/449477/201604/449477-20160407200829218-1379970197.png
[https_github.com_gityf_ngx_lua_thrift]: https://github.com/gityf/ngx_lua_thrift
[https_github.com_apache_thrift_tree_master_lib_lua]: https://github.com/apache/thrift/tree/master/lib/lua
[http_openresty.org]: http://openresty.org/