# KeepAlive
在OpenResty中,连接池在使用上如果不加以注意,容易产生数据写错地方,或者得到的应答数据异常以及类似的问题,当然使用短连接可以规避这样的问题,但是在一些企业用户环境下,短连接+高并发对企业内部的防火墙是一个巨大的考验,因此,长连接自有其勇武之地,使用它的时候要记住,长连接一定要保持其连接池中所有连接的正确性。
~~~
-- 错误的代码
local function send()
for i = 1, count do
local ssdb_db, err = ssdb:new()
local ok, err = ssdb_db:connect(SSDB_HOST, SSDB_PORT)
if not ok then
ngx.log(ngx.ERR, "create new ssdb failed!")
else
local key,err = ssdb_db:qpop(something)
if not key then
ngx.log(ngx.ERR, "ssdb qpop err:", err)
else
local data, err = ssdb_db:get(key[1])
-- other operations
end
end
end
ssdb_db:set_keepalive(SSDB_KEEP_TIMEOUT, SSDB_KEEP_COUNT)
end
-- 调用
while true do
local ths = {}
for i=1,THREADS do
ths[i] = ngx.thread.spawn(send) ----创建线程
end
for i = 1, #ths do
ngx.thread.wait(ths[i]) ----等待线程执行
end
ngx.sleep(0.020)
end
~~~
以上代码在测试中发现,应该得到get(key)的返回值有一定几率为key。
原因即是在ssdb创建连接时可能会失败,但是当得到失败的结果后依然调用ssdb_db:set_keepalive将此连接并入连接池中。
正确地做法是如果连接池出现错误,则不要将该连接加入连接池。
~~~
local function send()
for i = 1, count do
local ssdb_db, err = ssdb:new()
local ok, err = ssdb_db:connect(SSDB_HOST, SSDB_PORT)
if not ok then
ngx.log(ngx.ERR, "create new ssdb failed!")
return
else
local key,err = ssdb_db:qpop(something)
if not key then
ngx.log(ngx.ERR, "ssdb qpop err:", err)
else
local data, err = ssdb_db:get(key[1])
-- other operations
end
ssdb_db:set_keepalive(SSDB_KEEP_TIMEOUT, SSDB_KEEP_COUNT)
end
end
end
~~~
所以,当你使用长连接操作db出现结果错乱现象时,首先应该检查下是否存在长连接使用不当的情况。
- 序
- Lua简介
- Lua环境搭建
- 基础数据类型
- 表达式
- 控制结构
- if/else
- while
- repeat
- 控制结构for的使用
- break,return
- Lua函数
- 函数的定义
- 函数的参数
- 函数的返回值
- 函数回调
- 模块
- String库
- Table库
- 日期时间函数
- 数学库函数
- 文件操作
- 元表
- 面向对象编程
- FFI
- LuaRestyRedisLibrary
- select+set_keepalive组合操作引起的数据读写错误
- redis接口的二次封装(简化建连、拆连等细节)
- redis接口的二次封装(发布订阅)
- pipeline压缩请求数量
- script压缩复杂请求
- LuaCjsonLibrary
- json解析的异常捕获
- 稀疏数组
- 空table编码为array还是object
- 跨平台的库选择
- PostgresNginxModule
- 调用方式简介
- 不支持事务
- 超时
- 健康监测
- SQL注入
- LuaNginxModule
- 执行阶段概念
- 正确的记录日志
- 热装载代码
- 阻塞操作
- 缓存
- sleep
- 定时任务
- 禁止某些终端访问
- 请求返回后继续执行
- 调试
- 调用其他C函数动态库
- 我的lua代码需要调优么
- 变量的共享范围
- 动态限速
- shared.dict 非队列性质
- 如何添加自己的lua api
- 正确使用长链接
- 如何引用第三方resty库
- 使用动态DNS来完成HTTP请求
- 缓存失效风暴
- Lua
- 下标从1开始
- 局部变量
- 判断数组大小
- 非空判断
- 正则表达式
- 不用标准库
- 虚变量
- 函数在调用代码前定义
- 抵制使用module()函数来定义Lua模块
- 点号与冒号操作符的区别
- 测试
- 单元测试
- API测试
- 性能测试
- 持续集成
- 灰度发布
- web服务
- API的设计
- 数据合法性检测
- 协议无痛升级
- 代码规范
- 连接池
- c10k编程
- TIME_WAIT问题
- 与Docker使用的网络瓶颈
- 火焰图
- 什么时候使用
- 显示的是什么
- 如何安装火焰图生成工具
- 如何定位问题