Swoole AsyncIO實(shí)例
2022-07-12 11:26 更新
Swoole AsyncIO異步文件讀寫介紹
swoole1.6.12后增加了異步文件讀寫，異步DNS等特性。自此建立了完整的異步并行API。
- swoole_server的
Task進(jìn)程是同步阻塞的，沒有EventLoop，因此無(wú)法使除定時(shí)器之外的用任何異步IO - signalfd是Linux2.6.27提供文件句柄方式處理信號(hào)特性，優(yōu)點(diǎn)是可以將信號(hào)加入到EventLoop中，Reactor操作不會(huì)被信號(hào)打斷提高了性能。缺點(diǎn)是有些同步阻塞的程序可能會(huì)出現(xiàn)問(wèn)題，無(wú)法從阻塞中中斷，可以使用
swoole_async_set關(guān)閉signalfd特性
Swoole支持3種類型的異步文件讀寫IO，可以使用swoole_async_set來(lái)設(shè)置AIO模式。
swoole_async_set
此函數(shù)可以設(shè)置異步IO相關(guān)的選項(xiàng)。
swoole_async_set(array $setting);
- thread_num 設(shè)置異步文件IO線程的數(shù)量
- aio_mode 設(shè)置異步文件IO的操作模式，目前支持
SWOOLE_AIO_BASE（使用類似于Node.js的線程池同步阻塞模擬異步）、SWOOLE_AIO_LINUX（Linux Native AIO） 2種模式 - enable_signalfd 開啟和關(guān)閉signalfd特性的使用
- socket_buffer_size 設(shè)置SOCKET內(nèi)存緩存區(qū)尺寸
- socket_dontwait 在內(nèi)存緩存區(qū)已滿的情況下禁止底層阻塞等待
Linux Native AIO的優(yōu)點(diǎn)是由內(nèi)核支持是真正的異步文件IO，缺點(diǎn)是只支持DirectIO，無(wú)法利用到系統(tǒng)的PageCache
swoole_async模塊目前為實(shí)驗(yàn)性質(zhì)，不建議在生產(chǎn)環(huán)境使用，請(qǐng)使用PHP的文件讀寫函數(shù)。
Linux原生異步IO
基于Linux Native AIO系統(tǒng)調(diào)用，是真正的異步IO，并非阻塞模擬。
優(yōu)點(diǎn)：
- 所有操作均在一個(gè)線程內(nèi)完成，不需要開線程池
- 不依賴線程執(zhí)行IO，所以并發(fā)可以非常大
缺點(diǎn)：
- 只支持DriectIO，無(wú)法利用PageCache，所有對(duì)文件讀寫都會(huì)直接操作磁盤
線程池模式異步IO
基于線程池模擬實(shí)現(xiàn)，文件讀寫請(qǐng)求投遞到任務(wù)隊(duì)列，然后由AIO線程讀寫文件，完成后通知主線程。AIO線程本身是同步阻塞的。所以并非真正的異步IO。
優(yōu)點(diǎn)：
- 可以利用操作系統(tǒng)PageCache，讀寫熱數(shù)據(jù)性能非常高，等于讀內(nèi)存
可修改
thread_num項(xiàng)設(shè)置啟用的AIO線程數(shù)量
缺點(diǎn)：
- 并發(fā)較差，不支持同時(shí)讀寫大量文件，最大并發(fā)受限與AIO的線程數(shù)量
簡(jiǎn)單實(shí)例：
$fp = stream_socket_client("tcp://127.0.0.1:80", $code, $msg, 3);
$http_request = "GET /index.html HTTP/1.1\r\n\r\n";
fwrite($fp, $http_request);
Swoole\Event::add($fp, function($fp){
echo fread($fp, 8192);
swoole_event_del($fp);
fclose($fp);
});
Swoole\Timer::after(2000, function() {
echo "2000ms timeout\n";
});
Swoole\Timer::tick(1000, function() {
echo "1000ms interval\n";
});以上內(nèi)容是否對(duì)您有幫助：
更多建議：