实战演示 Nginx 结合 lua-resty-upstream-healthcheck 实现上游节点的全异步主动探测-Nginx-PHP中文网

全异步主动健康检查因传统Nginx轮询阻塞worker进程，而lua-resty-upstream-healthcheck基于cosocket+timer实现非阻塞探测，每个worker独立并发探活，真正零阻塞、无额外线程或进程。

实战演示 nginx 结合 lua-resty-upstream-healthcheck 实现上游节点的全异步主动探测

为什么需要全异步主动健康检查

传统 Nginx 的 health_check 指令（如 stream 或 http 模块内置）依赖定时器轮询，且探测逻辑阻塞 worker 进程，高并发下易拖慢整体响应。而 lua-resty-upstream-healthcheck 基于 cosocket + timer 实现纯 Lua 层的非阻塞探测，在不增加系统线程、不 fork 子进程的前提下，让每个 worker 独立、并发地对上游节点发起 HTTP/TCP 探活请求——真正做到了“全异步”与“零阻塞”。

核心配置：启用健康检查模块

确保已安装 lua-resty-upstream-healthcheck（推荐通过 opm 或 luarocks 安装），并在 Nginx 配置中声明 upstream 和 healthcheck 实例：

注意：必须在 init_by_lua_block 中初始化，避免多 worker 重复创建或共享状态冲突

在 http 块中定义 upstream（仅作路由标识，不参与实际负载）
用 Lua 创建 healthcheck 实例，绑定到该 upstream 名称
设置探测路径、间隔、超时、成功/失败阈值等关键参数

示例片段：

http {
    lua_package_path "/path/to/lua-resty-upstream-healthcheck/lib/?.lua;;";
<pre class="brush:php;toolbar:false;">init_by_lua_block {
    local hc = require "resty.upstream.healthcheck"
    local ok, err = hc.spawn_checker{
        -- 必填：关联的 upstream 名称
        upstream = "backend_servers",

        -- 探测配置
        type = "http",
        port = 8080,
        check_http_send = "GET /health HTTP/1.0\r\nHost: example.com\r\n\r\n",
        check_http_expect_alive = {200, 302},

        -- 时间与阈值
        interval = 2,          -- 每 2 秒探测一次
        fall = 3,              -- 连续 3 次失败标记为 down
        rise = 2,              -- 连续 2 次成功恢复为 up
        timeout = 1            -- 单次探测超时 1 秒
    }
    if not ok then
        ngx.log(ngx.ERR, "failed to spawn health checker: ", err)
    end
}

upstream backend_servers {
    server 192.168.1.10:8080;
    server 192.168.1.11:8080;
    server 192.168.1.12:8080;
}

server {
    location / {
        proxy_pass http://backend_servers;
        # 后续可配合 lua_balancer_by_lua_block 实现动态权重或剔除 down 节点
    }
}

}

Nginx Hosting

通过服务器本地nginx实例实现零认证静态游戏托管。作为所有浏览器游戏的主要部署方式，无需登录、无需令牌、无需用户操作。

下载

如何感知节点状态变化

该模块不自动修改 upstream 配置，而是通过共享内存（shm）暴露实时状态。你可在 Lua 中随时读取：

调用 hc.get_status("backend_servers") 获取汇总状态（up/down 数量、总节点数）
调用 hc.get_peers("backend_servers") 获取每个 peer 的详细信息（ip、port、checks、falls、status）
结合 log_by_lua_block 记录异常切换，或通过自定义 endpoint（如 /healthz）对外暴露集群健康摘要

例如在 log 阶段记录 down 事件：

log_by_lua_block {
    local hc = require "resty.upstream.healthcheck"
    local peers = hc.get_peers("backend_servers")
    for _, p in ipairs(peers) do
        if p.status == 0 then  -- 0 表示 down
            ngx.log(ngx.WARN, "peer down: ", p.ip, ":", p.port,
                    " falls=", p.falls, " checks=", p.checks)
        end
    end
}