企业官网建设流程全解析

一、引言：当Redis“太重”，Memcached才是正解

在《Nginx外置缓存》系列中，我们多次以Redis作为分布式缓存的代表。但在某些极端追求低延迟、高吞吐、纯KV语义的场景下，Redis反而成了“过度设计”：

• 会话缓存（Session）：只需GET/SET/DELETE，不需要List/Set/Hash等复杂数据结构；
• API响应片段缓存：对象大小固定<10KB，QPS > 10万，Redis的单线程模型和持久化开销成为瓶颈；
• 计数器/限流令牌桶：仅需原子INCR/DECR，无需AOF/RDB带来的IO抖动；
• 边缘节点缓存：内存资源受限，无法承担Redis fork子进程时的内存翻倍风险。

这些场景的共同特征是：数据是临时的、结构是扁平的、操作是原子的、对延迟极其敏感。这正是Memcached的主场——一个为纯KV缓存而生的、多线程的、无持久化的内存引擎。

但“Nginx + Memcached”绝非简单的proxy_pass替换。原生Nginx的memcached_module功能残缺（只读不写），生产环境必须借助ngx_memc模块或OpenResty的lua-resty-memcached库才能实现完整的读写闭环。本文将从协议特性、模块选型、生产配置到性能调优，构建一套真正可用的Nginx + Memcached外置缓存体系。

二、为什么选Memcached而非Redis？

2.1 核心差异对比

2.2 选型决策树

你的缓存需求？ ├─ 需要复杂数据结构（List/Hash/Set） → Redis ├─ 需要持久化/主从复制 → Redis ├─ Value > 1MB → Redis └─ 纯KV + 临时数据 + 极致低延迟 → Memcached ✅ 你的QPS和延迟要求？ ├─ QPS < 5万 & P99 < 1ms → Redis足够 ├─ QPS > 10万 & P99 < 0.3ms → Memcached ✅ └─ CPU密集型序列化/反序列化 → Memcached（多线程优势）

📌核心认知：Memcached不是“简化版Redis”，而是专为KV缓存优化的专用引擎。它的价值不在于功能多，而在于把“简单的事做到极致”。

三、Nginx对接Memcached的三种路径

3.1 路径对比

⚠️重要提醒：原生memcached_module不支持写入和删除，且无连接池，生产环境严禁使用。本文聚焦lua-resty-memcached方案。

3.2 环境准备

# 安装OpenResty（内置lua-resty-memcached） wget https://openresty.org/package/openresty-1.27.1.tar.gz tar xzf openresty-1.27.1.tar.gz && cd openresty-1.27.1 ./configure --with-luajit --with-http_lua_module make && make install # 验证库可用 /usr/local/openresty/bin/resty -e 'print(require "resty.memcached")'

四、lua-resty-memcached生产级实现

4.1 核心缓存模块

创建/usr/local/openresty/lualib/mcache.lua：

local memcached = require "resty.memcached" local cjson = require "cjson.safe" local _M = {} -- Memcached连接池配置 local MC_CONF = { host = "memcached.internal", port = 11211, pool_size = 200, -- 每worker连接池大小 backlog = 500, -- 等待队列 connect_timeout = 100, -- ms read_timeout = 200, -- ms } -- 获取连接（带连接池） local function get_mc() local mc, err = memcached:new() if not mc then ngx.log(ngx.ERR, "memcached new failed: ", err) return nil, err end mc:set_timeouts(MC_CONF.connect_timeout, MC_CONF.read_timeout, MC_CONF.read_timeout) local ok, err = mc:connect(MC_CONF.host, MC_CONF.port) if not ok then ngx.log(ngx.ERR, "memcached connect failed: ", err) return nil, err end return mc, nil end -- 释放连接到池中 local function release_mc(mc) local ok, err = mc:set_keepalive(10000, MC_CONF.pool_size) if not ok then ngx.log(ngx.ERR, "memcached keepalive failed: ", err) end end -- 读取缓存 function _M.get(key) local mc, err = get_mc() if not mc then return nil, err end local res, flags, err = mc:get(key) release_mc(mc) if not res then if err == "not found" then return nil, "MISS" end return nil, err end return res, nil -- Memcached返回原始字符串，自行解码 end -- 写入缓存（带TTL） function _M.set(key, value, ttl) local mc, err = get_mc() if not mc then return false, err end local ok, err = mc:set(key, value, ttl or 300) release_mc(mc) return ok, err end -- 删除缓存 function _M.delete(key) local mc, err = get_mc() if not mc then return false, err end local ok, err = mc:delete(key) release_mc(mc) return ok, err end -- 原子递增（计数器场景） function _M.incr(key, delta, init_ttl) local mc, err = get_mc() if not mc then return nil, err end -- 先尝试incr，若key不存在则set初始值 local val, err = mc:incr(key, delta) if not val and err == "not found" then local ok, serr = mc:set(key, tostring(delta), init_ttl or 60) if ok then release_mc(mc) return delta, nil end release_mc(mc) return nil, serr end release_mc(mc) return val, err end return _M

4.2 Nginx配置集成

http { lua_shared_dict mc_local_cache 50m; -- L1本地缓存 init_by_lua_block { mcache = require "mcache" } server { listen 80; location /api/session/ { content_by_lua_block { local session_id = ngx.var.cookie_session_id if not session_id then ngx.status = 401 return ngx.say('{"error":"unauthorized"}') end local key = "sess:" .. session_id -- L1: 本地共享字典（微秒级） local local_cache = ngx.shared.mc_local_cache local val = local_cache:get(key) if val then ngx.header["X-Cache"] = "L1-HIT" ngx.say(val) return end -- L2: Memcached local data, err = mcache.get(key) if data then local_cache:set(key, data, 3) -- L1 TTL极短 ngx.header["X-Cache"] = "MC-HIT" ngx.say(data) return end -- MISS: 回源 local res = ngx.location.capture("/internal/session_backend") if res.status == 200 then mcache.set(key, res.body, 1800) -- 30分钟 local_cache:set(key, res.body, 3) ngx.header["X-Cache"] = "MISS" ngx.say(res.body) else ngx.status = res.status ngx.say(res.body) end } } # 计数器接口（利用Memcached原子INCR） location /api/counter/ { content_by_lua_block { local key = "cnt:" .. ngx.var.uri local val, err = mcache.incr(key, 1, 3600) if val then ngx.say(tostring(val)) else ngx.log(ngx.ERR, "counter incr failed: ", err) ngx.status = 500 ngx.say('{"error":"counter unavailable"}') end } } location /internal/session_backend { internal; proxy_pass http://session_service; } } }

4.3 两层缓存架构解析

📌设计要点：Session场景下L1 TTL设为3秒而非更长，因为Session可能被其他节点修改（如登出），过长的本地缓存会导致一致性问题。

五、关键生产调优要点

5.1 Memcached服务端优化

# /etc/sysconfig/memcached 或启动参数 OPTIONS="-m 8192 -c 4096 -t 16 -I 2m -R 100 -o modern"

5.2 连接池 sizing 公式

总并发连接 = Nginx worker数 × pool_size 推荐值：worker=8, pool_size=200 → 总连接=1600 Memcached -c 应 ≥ 1600 × 1.5 = 2400

⚠️避坑：pool_size过大导致Memcached连接耗尽；过小导致Nginx排队等待。通过stats curr_connections监控实际连接数，动态调整。

5.3 Key设计规范

-- ✅ 推荐：命名空间 + 业务标识 + 版本 local key = "sess:v2:" .. session_id local key = "cnt:api:/users:list" -- ❌ 避免：过长Key（Memcached限制250字节） local key = "session:user:profile:data:" .. long_uuid -- 可能超限 -- ❌ 避免：特殊字符（空格、换行、控制符） local key = "key with space" -- 协议解析错误

5.4 二进制安全与序列化

Memcached是二进制安全的，可直接存储任意字节序列，无需Base64编码：

-- ✅ 直接存储二进制数据（如图片缩略图、protobuf） mcache.set("thumb:" .. id, binary_data, 3600) -- ✅ JSON文本也可直接存储 mcache.set("api:" .. key, cjson.encode(data), 300) -- ⚠️ 注意：get返回的是原始字符串，需自行判断是否解码 local raw = mcache.get(key) local data = cjson.decode(raw) -- 若确定是JSON才解码

📌优势：相比Redis的Lua脚本中处理二进制需额外编码，Memcached天然支持，减少CPU开销和数据膨胀。

六、一致性与故障处理

6.1 无持久化的应对策略

Memcached重启后数据全部丢失，这是特性而非Bug。应对方式：

6.2 故障降级

local data, err = mcache.get(key) if err and (err == "timeout" or err == "connection refused") then ngx.log(ngx.WARN, "memcached degraded: ", err) -- 降级：跳过缓存，直接回源 -- 或返回预设默认值 res = ngx.location.capture("/internal/backend") ngx.header["X-Cache-Degraded"] = "mc-unavailable" ngx.say(res.body) return end

📌原则：Memcached是加速层，不是数据源。永远不要让缓存故障变成服务故障。

6.3 批量操作限制

Memcached协议不支持原子批量操作。mget可批量读取，但写入/删除必须逐个执行：

-- ✅ 批量读取 local keys = {"k1", "k2", "k3"} local results, err = mc:get(keys) -- 返回table -- ❌ 无批量写入 -- 只能循环set，或使用pipeline（lua-resty-memcached不原生支持）

对于高频批量写入场景，考虑改用Redis或拆分请求。

七、监控体系

7.1 Memcached关键指标

7.2 Nginx侧指标

7.3 Grafana面板建议

• 缓存漏斗：Request → L1 HIT → MC HIT → Backend
• Memcached命中率趋势：突降关联发布或流量变化
• 连接池水位：峰值是否触及pool_size上限
• 驱逐率曲线：非零即告警，内存规划失误的信号

八、常见踩坑速查表

九、结语

感谢您的阅读！如果你有任何疑问或想要分享的经验，请在评论区留言交流！