基于openresty lua-resty-balancer 模块实现自定义分流功能

该模块为提供分流算法，抽离了hash算法, roundrobin轮询等，好处使业务灵活调用算法而分配对像。该对像不一定指服务器，也可以是数据对像或文件对像等等

1，下载https://github.com/openresty/lua-resty-balancer

编译安装balancer

基于openresty 自定义tcp 请求流量转发到不同消息处理服务器

有个消息推荐项目，netty 框架技术架构，客户端采用netty client 封装的私有tcp 协议 请求消息服务器。需要一套tcp 分流处理网关来分发请求流量到不同的tcp 消息处理器，现采用openresty 基本可以满足，主要是是用到openresy balancer

[]: https://github.com/openresty/lua-resty-balancer#name

模块技术实现，具体请参考官方文档说明

基于apisix2.4网关反向代理到websocket服务集节点

问题背景，主要是解决远程控制通信服务端单点问题，借助openresty强劲的性能，可定制化的负载均衡设计特点

apisix就是基于openresty开发分布式网关集群平台，优势现阶段轻量，易维护等

本为搭建环境，模拟集群环境，在我windows 电脑 采用docker 模拟

整体的环境说明：如下图

• 搭建环境

  docker pull django
  

• 运行python 容器

使用lua语言解析tcp私有协议包示例

为什么需要lua来解析tcp 私有协议包？

因为lua语言生态内，有强大的openresty 技术可使用，而openresty可以提供强劲的web 并发性能，能提供tcp 长链接通道 技术

首先需要lapck包对其解析

git clone  https://github.com/Kong/lua-pack 
或
git clone https://github.com/lilien1010/lpack

安装lapck包需要编译

在编译时遇到 lua.h No such file or directory #include " lua.h" ？ 问题时，需要遇增加如下参数

-DLUA_INCLUDE_DIR=/usr/local/openresty/luajit/include/luajit-2.1/ 

最终编译命令如下：

#DLUA_INCLUDE_DIR 表示lua.h 存放的位置 LUA_LIBRARY指定luajit库，so文件，
cmake ./  -DLUA_INCLUDE_DIR=/usr/local/openresty/luajit/include/luajit-2.1/  -DLUA_LIBRARY=/usr/local/lib/libluajit-5.1.so
make  #编译成so文件，得到pack.so

详细解析tcp私有代码如下

require("pack")
local mypack    = string.pack
local myunpack    = string.unpack
local sock = ngx.req.socket(true)
if sock then
    ngx.say("got the request socket")
else
    ngx.say("failed to get the request socket: ", err)
    return
end
while true do
    --先尝试读取固定头 6个字节
    local data, err = sock:receive(6)
    --如果遇到timeout,或者close的情况，则break 本次循环读取，继续下一条读取
    if err=='timeout' or err =='close' then
        break
    end
    --按pmtp协议读取返回的参数，type1为消息类型，ver2为pmtp协议版本号，time待命时间，len4为消息体的长度，不包含头的长度
    --默认字节顺序为 大端，>ccHH
    local succ,succLen,type1,Ver2,Time3,Len4 = pcall(myunpack,data,">ccHH")
    --读取剩余的消息体长度内容
    local body, err = sock:receive(Len4)
    --如果读取body为空，则退出
    if body == nil then
        break
    end
    --打印body消息内容
    ngx.log(ngx.ERR, "------bdy ", body)
end

通过客户端链接后发送tcp私有协议包的一模拟效果