OpenResty 代理 trx api部署

客官°小女子只卖身不卖艺 2022-10-10 12:56 180阅读 0赞

OpenResty 安装  
1、安装依赖库  
2、下载，编译安装  
3、下载http lua 脚本&部署  
4、部署api项目  
5、启动  
6、验证是否正确  
7、制作service 启动(可选)  
8、配置文件路径 /data/deploy/api/config.lua  
9、查看最新的节点  
OpenResty 代理 trx api 部署  
OpenResty 安装  
参照 [http://openresty.org/cn/installation.html][http_openresty.org_cn_installation.html]

1、安装依赖库  
centos:

yum install pcre-devel openssl-devel gcc curl

ubuntu:

apt-get install libpcre3-dev \
    libssl-dev perl make build-essential curl

2、下载，编译安装

wget https://openresty.org/download/openresty-1.19.3.1.tar.gz
    tar -xzvf openresty-1.19.3.1.tar.gz
    cd openresty-1.19.3.1
    ./configure  --with-http_v2_module
    make
    make install

安装完成!，openresty 安装目录：/usr/local/openresty/

注意 可能在上面./configure 步骤 提示需要zlib 则按照下面步骤安装zlib 库：（如果没有提示则不需要此步骤）

wget http://www.zlib.net/zlib-1.2.11.tar.gz
    tar -xzvf zlib-1.2.11.tar.gz
    cd zlib-1.2.11
    ./configure 
    make
    make install

3、下载http lua 脚本&部署

wget https://github.com/ledgetech/lua-resty-http/archive/v0.15.tar.gz
    tar zxvf v0.15.tar.gz
    cp -r lua-resty-http-0.15/lib/resty/*.lua  /usr/local/openresty/lualib/resty/

4、部署api项目  
创建部署目录，例如：/data/deploy/api

mkdir -p /data/deploy/api
    git clone http://gitlab.test.com/new-sgp/api.git
    \cp -r api/conf  /data/deploy/api/
    \cp -r api/*.lua  /data/deploy/api/

由于OpenResty 不能解析域名，所以需要配置域名解析dns  
在nginx.conf 文件 的 http \{\} 中添加 resolver 127.0.0.53; 指令，这里127.0.0.53为dns服务器地址，具体dns地址根据实际情况修改.(例如 可以为 cat /etc/resolv.conf 看域名服务器地址；或者 8.8.8.8 或者 本地dns地址等等)  
5、启动  
第一次启动，需要创建日志目录：

mkdir -p /data/deploy/api/logs

启动命令：

使用root 用户启动。

/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf

其他一些常用命令整理：  
停止：

/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf -s stop

修改了配置文件，需要重新加载：

/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf -s reload

6、验证是否正确  
查看nginx 进程是否ok

ps -ef|grep nginx

查看监听端口是否ok

netstat -anp|grep 8080

访问服务是否ok

curl -i http://localhost:8080/wallet/getnowblock

查看日志是否ok

tail -100f /data/deploy/api/logs/error.log
    tail -100f /data/deploy/api/logs/access.log

7、制作service 启动(可选)

vi /etc/systemd/system/openresty.service
    [Unit]
    Description=The NGINX(openresty) HTTP and reverse proxy server
    [Service]
    Type=forking
    ExecStartPre=/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf -t
    ExecStart=/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf
    ExecReload=/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf -s reload
    ExecStop=/usr/local/openresty/nginx/sbin/nginx -p /data/deploy/api/ -c /data/deploy/api/conf/nginx.conf -s stop
    PrivateTmp=true
    User=root
    [Install]
    WantedBy=multi-user.target

随系统启动

systemctl enable openresty.service

一些命令

systemctl start openresty.service
    systemctl stop openresty.service
    systemctl status openresty.service
    service openresty start
    service openresty stop
    service openresty status

8、配置文件路径 /data/deploy/api/config.lua

local config_cache = ngx.shared.config_cache
    config_cache:set('hosts','3.225.171.164,52.53.189.99,18.196.99.16,34.253.187.192,18.133.82.227,35.180.51.163,54.252.224.209,18.228.15.36,52.15.93.92,34.220.77.106,13.127.47.162,13.124.62.58,35.182.229.162,18.209.42.127,3.218.137.187,34.237.210.82')
    config_cache:set('port',8090)
    config_cache:set('grpc_port',50051)
    config_cache:set('nowblock_path','/wallet/getnowblock')
    
    config_cache:set('connect_timeout',200)
    config_cache:set('send_timeout',100)
    config_cache:set('read_timeout',400)

9、查看最新的节点

curl -i http://localhost:8080/_chain_last_host
    http://localhost:8080/wallet/getnowblock

10、最后贴上几个文件，  
1）nginx配置文件，nginx.conf

user root;
    worker_processes  auto;
    worker_rlimit_nofile 100000;
    error_log logs/error.log info;
    events { 
        worker_connections 100000;
    }
    http { 
    
        log_format  main  '$remote_addr - $remote_user [$time_local] "$request" '
                                   '$status $body_bytes_sent "$http_referer" '
                                   '"$http_user_agent" "$http_x_forwarded_for"';
    
        access_log  logs/access.log  main;
        lua_package_path "/usr/local/openresty/lualib/resty/?.lua;/usr/local/openresty/lualib/resty/kafka/?.lua;;";
        lua_shared_dict config_cache 1m;
            init_by_lua_file /data/deploy/api/config.lua;
        init_worker_by_lua_file /data/deploy/api/task.lua;
        include /data/deploy/api/conf/conf.d/*.conf;
    }

2）贴上api.conf文件内容

server { 
        listen 80 http2;
    
        location / { 
                    set $api_url "";
                    set_by_lua_file $api_url /data/deploy/api/router.lua;
    
                    if ($api_url = ""){ 
                return 404;
            }
                    proxy_pass $api_url;
        }
    
            location /_chain_last_host { 
                    content_by_lua ' local config_cache = ngx.shared.config_cache local port=config_cache:get("port") local url=ngx.var.scheme .. "://" .. config_cache:get("last_host") .. ":" .. port ngx.say(url) ';
        }
    
    }

2）贴上lua脚本router.lua

local config_cache = ngx.shared.config_cache
    local grpc_port=config_cache:get("grpc_port")
    local url="grpc://" .. ngx.shared.config_cache:get("last_host") .. ":" .. grpc_port
    ngx.log(ngx.INFO, "url:",url);
    ngx.var.api_url=url

3)lua脚本config.lua

4)lua脚本task.lua

local function split(str,reps)
        local resultStrList = { }
        string.gsub(str,'[^'..reps..']+',function ( w )
            table.insert(resultStrList,w)
        end)
        return resultStrList
    end
    
    local config_cache=ngx.shared.config_cache
    local hosts=config_cache:get("hosts")
    local port=config_cache:get("port")
    local nowblock_path=config_cache:get("nowblock_path")
    local connect_timeout=config_cache:get("connect_timeout")
    local send_timeout=config_cache:get("send_timeout")
    local read_timeout=config_cache:get("read_timeout")
    
    ngx.log(ngx.INFO, "hosts:",hosts);
    ngx.log(ngx.INFO, "port:",port);
    ngx.log(ngx.INFO, "nowblock_path:",nowblock_path);
    ngx.log(ngx.INFO, "connect_timeout:",connect_timeout);
    ngx.log(ngx.INFO, "send_timeout:",send_timeout);
    ngx.log(ngx.INFO, "read_timeout:",read_timeout);
    
    local host_array =split(hosts, ",")
    local cjson = require "cjson"
    
    
    local function get_last_number(api_url)
    	local httpc = require "resty.http".new()
    	--httpc:set_timeout(1000)
    	httpc:set_timeouts(connect_timeout,send_timeout,read_timeout)
    	local res, err = httpc:request_uri(api_url)
    	if  res and res.status == 200 then
    		local err,array = pcall(function(str)return cjson.decode(str)end,res.body)
    		if not err then
    			ngx.log(ngx.INFO, "response body Not in JSON format:",res.body);
    			return -2
    		end
    		
    		local number=array.block_header.raw_data.number;
    		--ngx.log(ngx.INFO, "number:",number);
    		return number
    	else
    		return -1
    	end
    end
    
    local num = math.random(#host_array) 
    local last_host=host_array[num]
    local lastBlockNums=0
    local function task()
    	local threads = { }
    	for i= 1, #host_array do
    		local api_url = "http://" .. host_array[i] .. ":" .. port .. nowblock_path
    		local task_thread = ngx.thread.spawn(get_last_number,api_url)
    		threads[i]=task_thread;
    	end
    	
    	for i= 1, #threads do
    		local ok, res = ngx.thread.wait(threads[i])
    		ngx.thread.kill(threads[i])
    		ngx.log(ngx.INFO, "block_header_number:",res, ",host:",host_array[i]);	
    		if res > lastBlockNums then
    			lastBlockNums=res;
    			last_host=host_array[i]
    		end
    	end
    	config_cache:set("last_host",last_host)
    	
    	ngx.timer.at(1, task)
    end
    
    if 0 == ngx.worker.id() then
        local ok,err = ngx.timer.at(1, task)
    end

5）查看下tree

├── client_body_temp
    ├── conf
    │   ├── conf.d
    │   │   └── api.conf
    │   └── nginx.conf
    ├── config.lua
    ├── fastcgi_temp
    ├── logs
    │   ├── access.log
    │   ├── error.log
    │   └── nginx.pid
    ├── proxy_temp
    ├── router.lua
    ├── scgi_temp
    ├── task.lua
    └── uwsgi_temp

6）整个api包详情请见百度云盘路径  
链接：https://pan.baidu.com/s/1ZZ6zqotojI\_EO95oaLM-Gg  
提取码：ulvt

[http_openresty.org_cn_installation.html]: http://openresty.org/cn/installation.html