# 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使用的網絡瓶頸
- 火焰圖
- 什么時候使用
- 顯示的是什么
- 如何安裝火焰圖生成工具
- 如何定位問題