Lua开发的Nginx上游服务器健康检查工具

需积分: 10 3 下载量 155 浏览量 更新于2024-11-20 收藏 16KB ZIP 举报
它允许用户对上游服务器进行健康检查,从而确保流量只被导向正常运行的服务器。" 知识点详细说明: 1. Nginx 上游服务器的运行状况检查: Nginx 作为一款高性能的 HTTP 和反向代理服务器,通常会作为负载均衡器与多个上游服务器协同工作。在这样的环境中,确保后端服务器能够正常响应请求是至关重要的。通过上游服务器的运行状况检查,可以有效地避免将用户请求发送到故障服务器,从而提高整体的服务可靠性和用户体验。 2. lua-resty-upstream-healthcheck 功能和特点: lua-resty-upstream-healthcheck 是一个运行在 Nginx 上,用 Lua 编写的模块,其主要功能包括监控上游服务器的状态,实现故障转移(failover)以及基于策略的健康检查。这个模块可以灵活地配置健康检查的参数,例如检查间隔、超时时间、检查端口、失败后的重试逻辑等,以适应不同的运行环境和需求。 3. Lua 语言和 OpenResty: 该模块使用 Lua 语言编写,Lua 是一种轻量级的脚本语言,经常被嵌入到应用程序中为应用程序提供灵活的扩展和定制功能。OpenResty 是一个集成了标准 Nginx 核心和许多扩展的 Nginx 发行版。它将 Nginx 与 Lua 脚本语言进行结合,允许开发者直接在 Nginx 服务器中运行 Lua 代码,完成复杂的业务逻辑和网络请求处理。lua-resty-upstream-healthcheck 正是基于 OpenResty 的技术栈构建的,它利用了 OpenResty 提供的功能强大的 Lua API。 4. 使用场景和配置方法: lua-resty-upstream-healthcheck 适用于多种场景,如微服务架构中,服务间互相调用的场景;传统的客户端/服务器模式中的服务器端健康检查;以及任何需要细粒度控制流量分发的环境。在配置该模块时,需要将 Lua 包路径添加到 Nginx 配置中,并在 upstream 块中为每个上游服务器设置健康检查相关的参数。这样做可以确保 Nginx 在接收到请求时,会先进行健康检查,只有通过检查的服务器才会接收到实际的业务请求。 5. 模块的开发状态和适用性: 根据文档描述,lua-resty-upstream-healthcheck 尽管仍在早期开发阶段,但它已经足够稳定以用于生产环境。早期开发意味着该模块可能正在不断地添加新功能,修复发现的问题,并优化性能。因此,用户在使用时需要注意跟踪模块的最新版本,并在生产环境中部署时保持谨慎。 6. 版权和许可: 文档中提到了版权和许可信息,这对于用户来说是一个重要提示。它意味着在使用该模块时,用户需要遵守相应的许可协议,理解可能的限制,并且在需要时进行合规的使用。 总结来说,lua-resty-upstream-healthcheck 作为一个高效、可配置且易于集成的健康检查模块,是 Nginx 和 OpenResty 用户在构建高可用架构时的有力工具。它的出现简化了上游服务器健康状态的管理过程,降低了服务因故障服务器而导致的系统整体可用性问题。
501 浏览量
Lua-Resty-Checkups是一个基于lua的upstream管理和健康检查模块,由又拍云开源。特点:支持周期性upstream服务管理操作支持管理和健康检查支持upstream动态更新有利于加权轮询或哈希平衡支持 Nginx C upstream同步操作可使用级别和键值实现集群使用简介:-- config.lua _M = {} _M.global = {     checkup_timer_interval = 15,     checkup_shd_sync_enable = true,     shd_config_timer_interval = 1, } _M.ups1 = {     cluster = {         {             servers = {                 {host="127.0.0.1", port=4444, weight=10, max_fails=3, fail_timeout=10},             }         },     }, }lua_package_path "/path/to/lua-resty-checkups/lib/checkups/?.lua;/path/to/config.lua;;"; lua_shared_dict state 10m; lua_shared_dict mutex 1m; lua_shared_dict locks 1m; lua_shared_dict config 10m; server {     listen 12350;     return 200 12350; } server {     listen 12351;     return 200 12351; } init_worker_by_lua_block {     local config = require "config"     local checkups = require "resty.checkups.api"     checkups.prepare_checker(config)     checkups.create_checker() } server {     location = /12350 {         proxy_pass http://127.0.0.1:12350/;     }     location = /12351 {         proxy_pass http://127.0.0.1:12351/;     }     location = /t {         content_by_lua_block {             local checkups = require "resty.checkups.api"             local callback = function(host, port)                 local res = ngx.location.capture("/" .. port)                 ngx.say(res.body)                 return 1             end             local ok, err             -- connect to a dead server, no upstream available             ok, err = checkups.ready_ok("ups1", callback)             if err then ngx.say(err) end             -- add server to ups1             ok, err = checkups.update_upstream("ups1", {                     {                         servers = {                             {host="127.0.0.1", port=12350, weight=10, max_fails=3, fail_timeout=10},                         }                     },                 })             if err then ngx.say(err) end             ngx.sleep(1)             ok, err = checkups.ready_ok("ups1", callback)             if err then ngx.say(err) end             ok, err = checkups.ready_ok("ups1", callback)             if err then ngx.say(err) end             -- add server to new upstream             ok, err = checkups.update_upstream("ups2", {                     {                         servers = {                             {host="127.0.0.1", port=12351},                         }                     },                 })             if err then ngx.say(err) end             ngx.sleep(1)             ok, err = checkups.ready_ok("ups2", callback)             if err then ngx.say(err) end             -- add server to ups2, reset rr state             ok, err = checkups.update_upstream("ups2", {                     {                         servers = {                             {host="127.0.0.1", port=12350, weight=10, max_fails=3, fail_timeout=10},                             {host="127.0.0.1", port=12351, weight=10, max_fails=3, fail_timeout=10},                         }                     },                 })             if err then ngx.say(err) end             ngx.sleep(1)             ok, err = checkups.ready_ok("ups2", callback)             if err then ngx.say(err) end             ok, err = checkups.ready_ok("ups2", callback)             if err then ngx.say(err) end     } }Lua 配置示例:_M = {} -- Here is the global part _M.global = {     checkup_timer_interval = 15,     checkup_timer_overtime = 60,     default_heartbeat_enable = true,     checkup_shd_sync_enable = true,     shd_config_timer_interval = 1, } -- The rests parts are cluster configurations _M.redis = {     enable = true,     typ = "redis",     timeout = 2,     read_timeout = 15,     send_timeout = 15,     protected = true,     cluster = {         {   -- level 1             try = 2,             servers = {                 { host = "192.168.0.1", port = 6379, weight=10, max_fails=3, fail_timeout=10 },                 { host = "192.168.0.2", port = 6379, weight=10, max_fails=3, fail_timeout=10 },             }         },         {   -- level 2             servers = {                 { host = "192.168.0.3", port = 6379, weight=10, max_fails=3, fail_timeout=10 },             }         },     }, } _M.api = {     enable = false,     typ = "http",     http_opts = {         query = "GET /status HTTP/1.1\r\nHost: localhost\r\n\r\n",         statuses = {             [500] = false,             [502] = false,             [503] = false,             [504] = false,         },     },     mode = "hash",     cluster = {         dc1 = {             servers = {                 { host = "192.168.1.1", port = 1234, weight=10, max_fails=3, fail_timeout=10 },             }         },         dc2 = {             servers = {                 { host = "192.168.1.2", port = 1234, weight=10, max_fails=3, fail_timeout=10 },             }         }     } } _M.ups_from_nginx = {     timeout = 2,     cluster = {         {   -- level 1             upstream = "api.com",         },         {   -- level 2             upstream = "api.com",             upstream_only_backup = true,         },     }, } return _M