鍍金池/ 教程/ Java/ 怎樣理解 cosocket
定時(shí)任務(wù)
函數(shù)的參數(shù)
超時(shí)
一個(gè) openresty 內(nèi)存“泄漏”問題
獲取 uri 參數(shù)
局部變量
sleep
灰度發(fā)布
TIME_WAIT
代碼覆蓋率
連接池
CentOS 平臺(tái)安裝
稀疏數(shù)組
如何只啟動(dòng)一個(gè) timer 工作?
變量的共享范圍
break,return 關(guān)鍵字
Nginx
SQL 注入
如何引用第三方 resty 庫
不同階段共享變量
獲取請(qǐng)求 body
動(dòng)態(tài)生成的 lua-resty-redis 模塊方法
動(dòng)態(tài)加載證書和 OCSP stapling
repeat 控制結(jié)構(gòu)
編碼為 array 還是 object
Nginx 靜態(tài)文件服務(wù)
執(zhí)行階段概念
Lua 函數(shù)
日期時(shí)間函數(shù)
健康監(jiān)測
與其他 location 配合
for 控制結(jié)構(gòu)
函數(shù)定義
HTTPS 時(shí)代
點(diǎn)號(hào)與冒號(hào)操作符的區(qū)別
String 庫
文件操作
OpenResty 最佳實(shí)踐
<code>ngx.shared.DICT</code> 非隊(duì)列性質(zhì)
使用動(dòng)態(tài) DNS 來完成 HTTP 請(qǐng)求
代碼規(guī)范
什么是 JIT?
Windows 平臺(tái)安裝
正確的記錄日志
LuaNginxModule
不用標(biāo)準(zhǔn)庫
C10K 編程
控制結(jié)構(gòu)
請(qǐng)求中斷后的處理
Lua 環(huán)境搭建
Test::Nginx 能指定現(xiàn)成的 nginx.conf,而不是自動(dòng)生成一個(gè)嗎
Lua 基礎(chǔ)數(shù)據(jù)類型
動(dòng)態(tài)限速
PostgresNginxModule
簡單API Server框架
API 測試
location 匹配規(guī)則
虛變量
單元測試
防止 SQL 注入
select + set_keepalive 組合操作引起的數(shù)據(jù)讀寫錯(cuò)誤
阻塞操作
全動(dòng)態(tài)函數(shù)調(diào)用
Web 服務(wù)
典型應(yīng)用場景
Nginx 新手起步
TLS session resumption
輸出響應(yīng)體
調(diào)用代碼前先定義函數(shù)
module 是邪惡的
怎樣理解 cosocket
模塊
Socket 編程發(fā)展
如何對(duì) Nginx Lua module 添加新 api
如何在后臺(tái)開啟輕量級(jí)線程完成定時(shí)任務(wù)?
如何定位問題
table 庫
json 解析的異常捕獲
如何安裝火焰圖生成工具
lua 中如何 continue
if 是邪惡的
為什么我們的域名不能被解析
抵制使用 module() 定義模塊
測試
body 在 location 中的傳遞
Lua 入門
子查詢
pipeline 壓縮請(qǐng)求數(shù)量
如何發(fā)起新 HTTP 請(qǐng)求
Lua 簡介
緩存失效風(fēng)暴
Ubuntu 平臺(tái)安裝
日志輸出
緩存
Lua 面向?qū)ο缶幊?/span>
Nginx 陷阱和常見錯(cuò)誤
Redis 接口的二次封裝(發(fā)布訂閱)
日志
訪問有授權(quán)驗(yàn)證的 Redis
正則表達(dá)式
lock
熱裝載代碼
調(diào)用 FFI 出現(xiàn) &quot;table overflow&quot;
數(shù)據(jù)合法性檢測
禁止某些終端訪問
控制結(jié)構(gòu) if-else
調(diào)試
與 Docker 使用的網(wǎng)絡(luò)瓶頸
PostgresNginxModule 模塊的調(diào)用方式
用 do-end 整理你的代碼
FFI
什么時(shí)候使用
簡介
環(huán)境搭建
Mac OS X 平臺(tái)安裝
火焰圖
負(fù)載均衡
while 型控制結(jié)構(gòu)
如何定位 openresty 崩潰 bug
使用 Nginx 內(nèi)置綁定變量
判斷數(shù)組大小
請(qǐng)求返回后繼續(xù)執(zhí)行
Redis 接口的二次封裝
KeepAlive
反向代理
協(xié)議無痛升級(jí)
數(shù)學(xué)庫
元表
Vanilla 介紹
HelloWorld
LuaCjsonLibrary
持續(xù)集成
代碼靜態(tài)分析
網(wǎng)上有大量對(duì) Lua 調(diào)優(yōu)的推薦,我們應(yīng)該如何看待?
script 壓縮復(fù)雜請(qǐng)求
非空判斷
性能測試
函數(shù)返回值
API 的設(shè)計(jì)
kong 介紹
表達(dá)式
不支持事務(wù)
LuaRestyDNSLibrary 簡介

怎樣理解 cosocket

筆者認(rèn)為,cosocket 是 OpenResty 世界中技術(shù)、實(shí)用價(jià)值最高部分。讓我們可以用非常低廉的成本,優(yōu)雅的姿勢,比傳統(tǒng) socket 編程效率高好幾倍的方式進(jìn)行網(wǎng)絡(luò)編程。無論資源占用、執(zhí)行效率、并發(fā)能力都非常出色。

魯迅有句名言“其實(shí)世界上本沒有路,走的人多了便有了路”,其實(shí)對(duì)于 cosocket 的中文翻譯貌似我也碰到了類似的問題。當(dāng)我想給大家一個(gè)正面解釋,爬過了官方 wiki 發(fā)現(xiàn),原來作者本人(章亦春)也沒有先給出 cosocket 定義。

看來只能通過一些側(cè)面信息,從而讓這條路逐漸的清晰起來。

cosocket = coroutine + socket

coroutine:協(xié)同程序(后面簡稱:協(xié)程) socket:網(wǎng)絡(luò)套接字

OpenResty 中的 cosocket 不僅需要協(xié)程特性支撐,它還需 Nginx 非常最重要的“事件循環(huán)回調(diào)機(jī)制”,兩部分結(jié)合在一起最終達(dá)到了 cosocket 效果,外加 Nginx 自身對(duì)各種資源的“小氣”,LuaJIT 的執(zhí)行效率,最終加分不少。在 Lua 世界中調(diào)用任何一個(gè)有關(guān) cosocket 網(wǎng)絡(luò)函數(shù)內(nèi)部關(guān)鍵調(diào)用如圖所示:

http://wiki.jikexueyuan.com/project/openresty/images/cosocket_internal.png" alt="" />

從該圖中我們可以看到,用戶的 Lua 腳本每觸發(fā)一個(gè)網(wǎng)絡(luò)操作,都會(huì)有協(xié)程的 yield 以及 resume,因?yàn)檎?qǐng)求的 Lua 腳本實(shí)際上都運(yùn)行在獨(dú)享協(xié)程之上,可以在任何需要的時(shí)候暫停自己(yield),也可以在任何需要的時(shí)候被喚醒(resume)。

暫停自己,把網(wǎng)絡(luò)事件注冊(cè)到 Nginx 監(jiān)聽列表中,并把運(yùn)行權(quán)限交給 Nginx。當(dāng)有 Nginx 注冊(cè)網(wǎng)絡(luò)事件達(dá)到觸發(fā)條件時(shí),喚醒對(duì)應(yīng)的協(xié)程繼續(xù)處理。

以此為藍(lán)板,封裝實(shí)現(xiàn) connect、read、recieve 等操作,形成了大家目前所看到的 cosocket API。

可以看到,cosocket 是依賴 Lua 協(xié)程 + Nginx 事件通知兩個(gè)重要特性拼的。

從 0.9.9 版本開始,cosocket 對(duì)象是全雙工的,也就是說,一個(gè)專門讀取的 "light thread",一個(gè)專門寫入的 "light thread",它們可以同時(shí)對(duì)同一個(gè) cosocket 對(duì)象進(jìn)行操作(兩個(gè) "light threads" 必須運(yùn)行在同一個(gè) Lua 環(huán)境中,原因見上)。但是你不能讓兩個(gè) "light threads" 對(duì)同一個(gè) cosocket 對(duì)象都進(jìn)行讀(或者寫入、或者連接)操作,否則當(dāng)調(diào)用 cosocket 對(duì)象時(shí),你將得到一個(gè)類似 "socket busy reading" 的錯(cuò)誤。

所以東西總結(jié)下來,到底什么是 cosocket,中文應(yīng)該怎么翻譯,筆者本人都開始糾結(jié)了。我們不妨從另外一個(gè)角度來審視它,它到底給我們帶來了什么。

  • 它是同步的;
  • 它是非阻塞的;
  • 它是全雙工的;

同步與異步解釋: 同步:做完一件事再去做另一件; 異步:同時(shí)做多件事情,某個(gè)事情有結(jié)果了再去處理。

阻塞與非阻塞解釋: 阻塞:不等到想要的結(jié)果我就不走了; 非阻塞:有結(jié)果我就帶走,沒結(jié)果我就空手而回,總之一句話:爺?shù)炔黄稹?/p>

異步/同步是做事派發(fā)方式,阻塞/非阻塞是如何處理事情,兩組概念不在同一個(gè)層面。

無論 ngx.socket.tcp()、ngx.socket.udp()、ngx.socket.stream()、ngx.req.socket(),它們基本流程都是一樣的,只是一些細(xì)節(jié)參數(shù)上有區(qū)別(比如 TCP 和 UDP 的區(qū)別)。下面這些函數(shù),都是用來輔助完成更高級(jí)的 socket 行為控制:

  • connect
  • sslhandshake
  • send
  • receive
  • close
  • settimeout
  • setoption
  • receiveuntil
  • setkeepalive
  • getreusedtimes

它們不僅完整兼容 LuaSocket 庫的 TCP API,而且還是 100% 非阻塞的。

這里給大家 show 一個(gè)例子,對(duì) cosocket 使用有一個(gè)整體認(rèn)識(shí)。

location /test {
    resolver 114.114.114.114;

    content_by_lua_block {
        local sock = ngx.socket.tcp()
        local ok, err = sock:connect("www.baidu.com", 80)
        if not ok then
            ngx.say("failed to connect to baidu: ", err)
            return
        end

        local req_data = "GET / HTTP/1.1\r\nHost: www.baidu.com\r\n\r\n"
        local bytes, err = sock:send(req_data)
        if err then
            ngx.say("failed to send to baidu: ", err)
            return
        end

        local data, err, partial = sock:receive()
        if err then
            ngx.say("failed to recieve to baidu: ", err)
            return
        end

        sock:close()
        ngx.say("successfully talk to baidu! response first line: ", data)
    }
}

可以看到,這里的 socket 操作都是同步非阻塞的,完全不像 node.js 那樣充滿各種回調(diào),整體看上去非常簡潔優(yōu)雅,效率還非常棒。

對(duì) cosocket 做了這么多鋪墊,到底他有多么重要呢?直接看一下官方默認(rèn)綁定包有多少是基于 cosocket 的:

效仿這些基礎(chǔ)庫的實(shí)現(xiàn)方法,可以完成不同系統(tǒng)或組件的對(duì)接,例如 syslog、beanstalkd、mongodb 等,直接 copy 這些組件的通訊協(xié)議即可。