openresty+lua+kafka方案与Tomcat接口并发度对比分析

worker_processes  8;

pid        /home/xxxx/nginx.pid;


events {
    use epoll;
    worker_connections  65535;
    multi_accept on;
}


http {
    lua_package_path "/home/xxxxxx/lib/?.lua;;";
    include       mime.types;
    default_type  application/octet-stream;
    #access_log off;
    keepalive_requests 8192;
    keepalive_timeout 300s 300s;
    server_names_hash_bucket_size 128;
    client_header_buffer_size 32k;
    large_client_header_buffers 4 32k;
    client_max_body_size 1024m;
    client_body_buffer_size 10m;

    log_format  main  '$remote_addr
$time_iso8601
$request
'
                      '$status
$upstream_response_time
$request_time
'
                      '$http_user_agent
$http_x_forwarded_for';

    access_log off;
    # access_log  /home/xxxxxx/access.log  main;

    sendfile on;
    #提高I/O性能
    tcp_nodelay on;
    proxy_buffering off;
    #此请求不缓存
    #add_header Expires "Fri, 01 Jan 1980 00:00:00 GMT";
    #add_header Pragma "no-cache";
    #add_header Cache-Control "no-cache, max-age=0, must-revalidate";
    resolver xxxxx;

    # healthcheck shared
    # lua_shared_dict healthcheck 1m;

    # 数据书籍服务汇总
    include ./service_hub/*;

}

server {
        listen 8080;
        #数据上报
        # 默认读取 body
        lua_need_request_body on;
        location /xxxx {
           # access_log  /home/xxxx/risk_doubt.log  main;
           # 响应正常，内容为空
           empty_gif;
           content_by_lua_block{ 
            -- 引入lua所有api
            local topic = "xxxx"
            local cjson = require "cjson"  
            local producer = require "resty.kafka.producer"  
            -- 定义kafka broker地址，ip需要和kafka的host.name配置一致  
            local broker_list = {  
                { host = "xxx", port = 9092 },
                { host = "yyy", port = 9092 },
                { host = "zzz", port = 9092 }
            }  
            -- 定义json便于日志数据整理收集  
            local data_json = {}  
            ngx.req.read_body()
        local args = ngx.req.get_body_data()
        -- 将ip传入json参数中
        data_json["body"] = args
        data_json["ip"] = ngx.var.remote_addr
        -- 转换json为字符串
        -- ngx.log(ngx.ERR, "args:", tostring(data_json))
            local message = cjson.encode(data_json);  
            ngx.log(ngx.ERR, "args:", message)
        -- 定义kafka异步生产者  
            local bp = producer:new(broker_list, { producer_type = "async" })  
            -- 发送日志消息,send第二个参数key,用于kafka路由控制:  
            -- key为nill(空)时，一段时间向同一partition写入数据  
            -- 指定key，按照key的hash写入到对应的partition  
            -- local ok, err = bp:send(topic, nil, message)  

            -- if not ok then  
            --     ngx.log(ngx.ERR, "kafka send err:", err)  
            --     return  
            -- end  
       }
        }
       
        
}

    @PostMapping(value = "/xxxx")
    public Object test(String str, HttpServletRequest request) throws IOException
    {
        //logger.info("receive msg...");
        return null;
    }