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

• 前言
  
• 实现思路
  
• 实现步骤
  
  
  
  • 1. 编译 Nginx
    
  • 2. 配置文件如下
    
  
  
• 总结
  

• 每个请求都可以触发
  
• 后台上报, 不阻塞当前请求的处理进程
  

• NJS 模块安装可以参考 当JS邂逅Nginx
  
• http_auth_request_module 模块只要在编译时增加参数 --with-http_auth_request_module 即可
  

./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 }