Nginx纯配置实现日志实时上报的思路与方法

./configure --add-module=[NJS 模块路径]/NJS/nginx --with-http_auth_request_module 

make && make install 

http {
    js_import  http.js;   # 引入 js 文件
   
    server {
        listen 80;
    
        auth_request /proxy_report; # 该指令对于每个请求开始时都会触发, 创建一个子请求转发到 proxy_report 路径上
        location / { 
            index  index.html index.htm;
        }
        
        location /proxy_report {
            internal; # 限制仅接受内部请求
            # 把原请求的 uri 和 method 数据保存在 header 中. 因为auth_request 请求会修改这些数据.            
            proxy_set_header X-Original-URI $request_uri;
            proxy_set_header X-Original-METHOD $request_method;
            # 转发到另外一个 server 上
            proxy_pass http://localhost:8080/report;
        }
    }
    
    server {
        listen 8080;
        # 上报接口放在另外一个 server 中, 且该 server 中无 auth_request 指令, 避免循环触发请求
        location /report {
            # 通过 js_content 指令引入一个 js 处理脚本, 完成上报操作
            js_content http.report;
        }
    }
}

// http.js 文件

import qs from "querystring";

async function report (r) {
    let args = {
        // 从 header 中取原始的 uri 和 method 等请求数据
        uri: r.headersIn['X-Original-URI'],
        method: r.headersIn['X-Original-METHOD'],
        remoteAddress: r.remoteAddress,
        status: r.status,
        headersIn: JSON.stringifry(r.headersIn),
    }
    // 发出异步请求, 不阻塞当前请求的进程, 在后台完成上报
    ngx.fetch(`http://[上报服务路径]?${qs.stringify(args)}`, {
        method: 'GET',
    })
    // 返回200的状态码使校验指令成功
    r.return(200)
}

export default { report }