http {
    # 1. 導(dǎo)入 njs 腳本文件（核心指令：js_import）
    js_import http.js;

    # 2. 自定義 NGINX 變量（js_set 綁定 njs 函數(shù)）
    js_set $foo     http.foo;
    js_set $summary http.summary;

    server {
        listen 8000;
        charset utf-8;

        # 3. 自定義 content 處理器（js_content 綁定 njs 函數(shù)）
        location / {
            add_header X-Foo $foo; # 使用自定義變量
            js_content http.baz;    # 接管響應(yīng)內(nèi)容
        }

        # 直接返回自定義變量值
        location = /summary {
            return 200 $summary;
        }

        # 簡單的文本響應(yīng)
        location = /hello {
            js_content http.hello;
        }
    }
}

// 1. 自定義變量處理器：返回固定值
function foo(r) {
    r.log("執(zhí)行 foo 變量處理器"); // 寫入 NGINX 日志
    return "foo-value";
}

// 2. 自定義變量處理器：生成請求摘要信息
function summary(r) {
    let s = "請求摘要信息\n\n";
    // 讀取請求對象（r）的核心屬性
    s += "請求方法：" + r.method + "\n";
    s += "HTTP 版本：" + r.httpVersion + "\n";
    s += "請求主機(jī)：" + r.headersIn.host + "\n";
    s += "客戶端IP：" + r.remoteAddress + "\n";
    s += "請求URI：" + r.uri + "\n";
    
    // 遍歷請求頭
    s += "請求頭：\n";
    for (let h in r.headersIn) {
        s += `  ${h}: ${r.headersIn[h]}\n`;
    }
    
    // 遍歷查詢參數(shù)（r.args 自動解析 URL 查詢字符串）
    s += "查詢參數(shù)：\n";
    for (let a in r.args) {
        s += `  ${a}: ${r.args[a]}\n`;
    }
    return s;
}

// 3. 自定義 content 處理器：分步構(gòu)建響應(yīng)
function baz(r) {
    r.status = 200; // 設(shè)置響應(yīng)狀態(tài)碼
    // 設(shè)置響應(yīng)頭
    r.headersOut['Content-Type'] = "text/plain; charset=utf-8";
    r.headersOut['Content-Length'] = 15;
    // 發(fā)送響應(yīng)頭
    r.sendHeader();
    // 分段發(fā)送響應(yīng)體
    r.send("nginx");
    r.send("java");
    r.send("script");
    // 結(jié)束響應(yīng)
    r.finish();
}

// 4. 簡化的響應(yīng)方式：直接返回狀態(tài)碼+內(nèi)容
function hello(r) {
    r.return(200, "Hello njs!");
}

// 導(dǎo)出函數(shù)（供 NGINX 配置調(diào)用）
export default { foo, summary, baz, hello };

# NGINX 配置
location /filter {
    proxy_pass http://localhost:8080;
    # 清除 Content-Length（避免長度不匹配）
    js_header_filter http.clearContentLength;
    # 響應(yīng)體過濾器：轉(zhuǎn)小寫
    js_body_filter http.lowercaseFilter;
}

// http.js 新增函數(shù)
function clearContentLength(r) {
    delete r.headersOut['Content-Length'];
}

function lowercaseFilter(r, data, flags) {
    // 逐塊處理響應(yīng)體，轉(zhuǎn)小寫后傳遞給下一個(gè)過濾器
    r.sendBuffer(data.toLowerCase(), flags);
}

# NGINX 配置
location = /fetch {
    js_content http.fetch;
    js_fetch_trusted_certificate /path/to/ISRG_Root_X1.pem;
    js_fetch_keepalive 32; # 連接池最大空閑連接數(shù)
}

// http.js 新增異步函數(shù)
async function fetch(r) {
    try {
        // 并行調(diào)用兩個(gè)接口
        let results = await Promise.all([
            ngx.fetch('https://nginx.org/'),
            ngx.fetch('https://nginx.org/en/')
        ]);
        // 解析響應(yīng)并返回
        let response = [];
        for (let res of results) {
            response.push({
                status: res.status,
                body: await res.text()
            });
        }
        r.return(200, JSON.stringify(response, null, 2), {
            'Content-Type': 'application/json; charset=utf-8'
        });
    } catch (e) {
        r.return(500, `請求失?。?{e.message}`);
    }
}

# NGINX 配置：創(chuàng)建 1MB 共享字典，60s 超時(shí)，支持淘汰舊數(shù)據(jù)
js_shared_dict_zone zone=myDict:1M timeout=60s evict;

// http.js 操作共享字典
function setDict(r) {
    // 設(shè)置鍵值對
    let result = ngx.shared.myDict.set(r.args.key, r.args.value);
    r.return(200, `設(shè)置結(jié)果：${result}`);
}

function getDict(r) {
    // 獲取鍵值對
    let value = ngx.shared.myDict.get(r.args.key);
    r.return(200, `獲取結(jié)果：${value || '不存在'}`);
}

# NGINX 配置：每分鐘在所有 worker 進(jìn)程執(zhí)行定時(shí)任務(wù)
location @periodic {
    js_periodic http.periodicTask interval=60s worker_affinity=all;
    js_fetch_trusted_certificate /path/to/ISRG_Root_X1.pem;
}

// http.js 定時(shí)任務(wù)函數(shù)
async function periodicTask(s) {
    try {
        // 定時(shí)拉取頁面并寫入日志
        let res = await ngx.fetch('https://nginx.org/en/docs/njs/');
        let body = await res.text();
        ngx.log(ngx.INFO, `定時(shí)任務(wù)執(zhí)行：頁面長度 ${body.length}`);
    } catch (e) {
        ngx.log(ngx.ERR, `定時(shí)任務(wù)失?。?{e.message}`);
    }
}