热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

PHP的Web運行原理(4)-Reactor的實現之Swoole

本篇文章,咱們將要在說明另一個在php實現reactor模式的東西本篇文章分為以下幾個章節:swoole官網寫到:

本篇文章,咱們將要在說明另一個在 php 實現 reactor 模式的東西 swoole

本篇文章分為以下幾個章節 :

  • Swoole 的架構
  • Swoole 非阻塞 I/O 的處理
  • Swoole 的 Coroutine
  • Swoole 實際使用的注意事項

swoole 的架構

swoole 官網寫到 :

event-driven asynchronous & coroutine-based concurrency networking communication engine with high performance written in C and C++ for PHP.

swoole 它是一個用 c++ 所寫的 php extension,一個非常高效能的通訊引擎,而它能達到高效能的基礎在於以下幾個重點 :

  • event-drivent
  • coroutine

一句話來說他可以幹麻。

它可以讓我們建立一個高效能的網路服務

下面就是它實現非阻塞 I/O 的架構圖。

當它建立一個 http server 以後,你會看到產生出下圖這些 process 與 thread,基本上可以分為幾個部份 :

PHP 的 Web 運行原理 ( 4 ) - Reactor 的實現之 Swoole
  • Master Process : 用來管理 reactor thread,主要就是當 client 發送一個 http 請求後,由它來決定那個 reactor thread 來接客。
  • Reactor Thread : 每個 thead 中都有使用 I/O 多路復用的技術來監聽多個 socket,當有事件(讀或寫資料)進來時,會發送給某個 worker process 來處理。
  • Manager Process : 用來管理 worker process,也是用來決定那個 worker process 來接客。
  • Worker Process : 實際運行 php 代碼的地方,它這裡也有使用 I/O 多路復用技術來監聽 socket。這裡提供同步阻塞或是異步非阻塞操作。
  • Task Process : 一樣 php 代碼運行的地方,它會接受由 worker 丟過來的任務(開發者自已撰寫),通常都是一些 cpu 密集的運算。這裡只能同步阻塞操作。

上面是主要的架構,然後我們來理一下所謂的阻塞 I/O 會在那幾個地方,而 swoole 又是如何解決。

Swoole 非阻塞 I/O 的處理

這裡基本上可以分成兩個地方來看。

高併發建立連線的地方

swoole 這裡是在 reactor thread 實作 reactor 模式來解決,而 reactor 最主要透過的技術為 I/O 多路復用技術來做到大量 socket I/O 監控,並且在將事情丟給 worker process 處理。

順到說一下,與 nodejs 或 reactPHP 相比,swoole 這裡勝在它開啟多個 thread 來監控多條連線,理論上它這樣應該可以承受的比 nodejs 與 reactPHP 更多的併發量。

Worker process 中大量的 db 或 redis 操作

swoole 有提供幾個機制可以給 worker process 實現非阻塞 I/O 操作。

  • reactor 模式 (網路 I/O)
  • 丟 task worker 處理 (網路、檔案 I/O)
  • 底層使用 aio 處理 (檔案 I/O)

reactor 模式 (網路 I/O)

首先第一個 reactor 模式就與 reactor thread 的機制一樣,都是會使用 I/O 多路復用來監聽 socket,當有事件進來時,就執行 handler (callback)。

下面為範例,當在 worker 執行了這段程式碼以後,會將連 redis 的這條 socket 丟到 reactor 來進行監控,當有事件進來時,會執行 callback。

而這就是所謂的 異步非阻塞 。( 異步: callback 非阻塞: 不會卡住 process )

connect('127.0.0.1', 6379, function (swoole_redis $client, $result) {
    // callback function
    if ($result === false) {
        echo "connect to redis server failed.\n";
        return;
    }
    $client->set('key', 'swoole', function (swoole_redis $client, $result) {
        var_dump($result);
    });
});

而所謂的 同步阻塞 的範例如下,假設你在 worker 中直接使用 predis 來操作 redis,那這就是所謂的同步阻塞。

同步就是依順序走,而阻塞就是指會在 $cient->get("foo") 那會卡住整個 process。

set('foo', 'bar');
$value = $client->get('foo');

丟 task worker 處理 (網路、檔案 I/O)

而下面為處理 file 的範例,但這裡要注意,這種處理檔案的方式受限於 task process 的數量,假設我們 task 的數量為二,那當如果開啟三個 task 來處理檔案時,第三個就會無法處理。

set(array(
    'worker_num' => 1,
    'task_worker_num' => 2
));

$server->on('request', function ($request, $response) use ($server) {

    // ----------------------------------------------------
    var_dump('wait...');
    $server->task("hi", 0);
    var_dump('done !...');
    // ----------------------------------------------------

    $response->header("Content-Type", "text/html; charset=utf-8");
    $response->end("

Hello Swoole. #".rand(1000, 9999)."

"); }); $server->on('task', function($server, $task_id, $from_id, $data){ $request = file_get_contents('file 位置'); }); $server->on('Finish', function (swoole_server $serv, $task_id, $data) { echo "Task#$task_id finished, data_len=".strlen($data).PHP_EOL; }); $server->start();

底層使用 aio 處理 (檔案 I/O)

這裡注意要將 runtime 的 coroutine 開啟,才能讓 file_get_contents 使用底層 aio 來完成同步非阻塞操作。

 
 

Q&A 為什麼 Reactor 的機制無法處理 filesystem 的東西呢 ?

目前筆者只知道,如果你將檔案的 file descriptor 註冊到 I/O 多路復用(epoll) 中,會發生以下的錯誤:

EPERM The target file fd does not support epoll.

這也是為什麼需要使用其它 process 來處理,而在 nodejs 中碰到這種檔案類型的操作,則是開啟 thread 來進行處理,詳細可看此篇文章。

Nodejs 之運行機制原理 - 馬克筆

Swoole 中的 Coroutine

swoole 中有提供一個 coroutine 的功能,那它是做什麼呢 ?

它可以讓 worker 做到同步非阻塞的操作

剛剛上面有說 worker 可以提供以下兩種 I/O 操作型式 :

  • 同步阻塞 ( 同步:程式碼順序走 阻塞: 會卡住整個 process )
  • 異步非阻塞 ( 異步: callback 機制 非阻塞: 不會卡住整個 process )

但實際上它還有提供第三種 :

  • 同步非阻塞 ( 同步: 程式碼順序走 非阻塞: 不會卡住整個 process )

而實現的方法就是使用 coroutine 也就是協程。

coroutine 使用範例

使用情景如下程式碼,那在 go 裡面的這段程式碼就會開一個被稱為 coroutine 協程的東西來處理這一段,這樣就可以做到 同步非阻塞 操作。

go(function () {
    $redis = new Swoole\Coroutine\Redis();
    $redis->connect('127.0.0.1', 6379);
    $val = $redis->get('key');
});

而如果沒有用 coroutine 的話,那就只能做到 異步非阻塞操作 ,如下程式碼,也就是一堆 callback。

$client = new swoole_redis;
$client->connect('127.0.0.1', 6379, function (swoole_redis $client, $result) {
    $client->GET('key', 'swoole', function (swoole_redis $client, $result) {
        var_dump($result);
    });
});

Q&A - Coroutine 是實現非阻塞 I/O 的技術嗎 ?

不是。

coroutine 很多人會說它是一個比 thread 還較更小單位的操作單位,所以就會想,那我每一個阻塞 I/O 就開一個協程來處理,那這樣不就可以實現非阻塞 I/O 操作了嗎 ? 就像 multi thread 原理一樣,而且我協程更省資源。

NoNoNo ~

process 為操作系統的最小資源管理單位,而 thread 為操作系統最小操作單位。

而 coroutine 是一個比 thread 更小的操作單位,但是它的操作是 用戶 (application) 所操作,而不是像 thread 一樣是操作系統所操作。

而 I/O 的操作是指操作系統的操作,當一個阻塞 I/O 執行時,讓 process 阻塞的是操作系統,所以如果你在一個協程內開啟一個阻塞 I/O 它仍然會卡住整個 process。

coroutine 嚴格來說只能幫你做到 同步非阻塞 ,非阻塞還是需要有 reactor 機制來實現。

備註: go 語言的 coroutine 就比較特殊了,這之後會另開篇章討論。

Swoole 的實際使用注意

與 reactPHP 的範例一樣,我們一樣使用 swoole 來建立一個 http server。

set(array(
    'worker_num' => 1,
    'task_worker_num' => 0
));

$server->on('request', function ($request, $response) {

    // ----------------------------------------------------
    var_dump('wait...');
    $request = file_get_contents('http://127.0.0.1:3000');
    var_dump('done !...');
    // ----------------------------------------------------

    $response->header("Content-Type", "text/html; charset=utf-8");
    $response->end("

Hello Swoole. #".rand(1000, 9999)."

"); }); $server->on('task', function($server, $task_id, $from_id, $data){ }); $server->start();

如果這時發兩條 http 請求會如何呢 ?

答案: 1 次 wait ( 因為第一次就卡住 process )

主要的原因基本上在於,你沒將這 I/O 操作丟到這個 worker 的 reactor 機制中,所以這個 I/O 操作仍然會是阻塞的。

然後有些人在測試時可能會收到二次 wait,但是有一點你要注意,那就是 worker_num 你設多少,如果你設 2 ,它當然可以收到二次,因為是由不同的 process 接受,但是接下來的第三次,你絕對收不到。

正確版

首先第一種是官方現在推薦使用 coroutine 的 同步非阻塞 的寫法。

set(array(
    'worker_num' => 2,
    'task_worker_num' => 0
));

$server->on('request', function ($request, $response) {

    // ----------------------------------------------------
    var_dump('wait...');
    $client = new Swoole\Coroutine\Http\Client('127.0.0.1', 3000);
    $client->get('/');
    echo $client->body;
    var_dump('done !...');
    // ----------------------------------------------------
});

$server->start();

而另一種就是使用 callback 的 異步非阻塞 的寫法。

set(array(
    'worker_num' => 2,
    'task_worker_num' => 0
));

$server->on('request', function ($request, $response) {

    // ----------------------------------------------------
    var_dump('wait...');
    $client = new swoole_http_client('127.0.0.1', 3000);
    $client->get('/', function ($client) {
        echo "Length: " . strlen($client->body) . "\n";
        echo $client->body;
    });
    var_dump('done !...');
    // ----------------------------------------------------
});

$server->start();

參考資料


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 我们


推荐阅读
  • 本文详细介绍了在 CentOS 7 系统中配置 fstab 文件以实现开机自动挂载 NFS 共享目录的方法,并解决了常见的配置失败问题。 ... [详细]
  • 在 Ubuntu 中遇到 Samba 服务器故障时,尝试卸载并重新安装 Samba 发现配置文件未重新生成。本文介绍了解决该问题的方法。 ... [详细]
  • 本文总结了一些开发中常见的问题及其解决方案,包括特性过滤器的使用、NuGet程序集版本冲突、线程存储、溢出检查、ThreadPool的最大线程数设置、Redis使用中的问题以及Task.Result和Task.GetAwaiter().GetResult()的区别。 ... [详细]
  • 优化后的标题:深入探讨网关安全:将微服务升级为OAuth2资源服务器的最佳实践
    本文深入探讨了如何将微服务升级为OAuth2资源服务器,以订单服务为例,详细介绍了在POM文件中添加 `spring-cloud-starter-oauth2` 依赖,并配置Spring Security以实现对微服务的保护。通过这一过程,不仅增强了系统的安全性,还提高了资源访问的可控性和灵活性。文章还讨论了最佳实践,包括如何配置OAuth2客户端和资源服务器,以及如何处理常见的安全问题和错误。 ... [详细]
  • 本文详细介绍了一种利用 ESP8266 01S 模块构建 Web 服务器的成功实践方案。通过具体的代码示例和详细的步骤说明,帮助读者快速掌握该模块的使用方法。在疫情期间,作者重新审视并研究了这一未被充分利用的模块,最终成功实现了 Web 服务器的功能。本文不仅提供了完整的代码实现,还涵盖了调试过程中遇到的常见问题及其解决方法,为初学者提供了宝贵的参考。 ... [详细]
  • 小王详解:内部网络中最易理解的NAT原理剖析,挑战你的认知极限
    小王详解:内部网络中最易理解的NAT原理剖析,挑战你的认知极限 ... [详细]
  • Ihavetwomethodsofgeneratingmdistinctrandomnumbersintherange[0..n-1]我有两种方法在范围[0.n-1]中生 ... [详细]
  • 开机自启动的几种方式
    0x01快速自启动目录快速启动目录自启动方式源于Windows中的一个目录,这个目录一般叫启动或者Startup。位于该目录下的PE文件会在开机后进行自启动 ... [详细]
  • .NET Core 托管服务优化与实践
    在.NET Core应用中,托管服务的形式主要分为进程内托管(InProcess)和进程外托管(OutOfProcess)。这两种托管方式各有优缺点,本文将深入探讨它们的特点,并结合实际案例,介绍如何根据具体需求选择合适的托管模式,以实现性能优化和资源利用的最大化。此外,文章还将分享一些实用的配置技巧和最佳实践,帮助开发者提升应用的稳定性和可维护性。 ... [详细]
  • 本文详细解析了使用C++实现的键盘输入记录程序的源代码,该程序在Windows应用程序开发中具有很高的实用价值。键盘记录功能不仅在远程控制软件中广泛应用,还为开发者提供了强大的调试和监控工具。通过具体实例,本文深入探讨了C++键盘记录程序的设计与实现,适合需要相关技术的开发者参考。 ... [详细]
  • Java Socket 关键参数详解与优化建议
    Java Socket 的 API 虽然被广泛使用,但其关键参数的用途却鲜为人知。本文详细解析了 Java Socket 中的重要参数,如 backlog 参数,它用于控制服务器等待连接请求的队列长度。此外,还探讨了其他参数如 SO_TIMEOUT、SO_REUSEADDR 等的配置方法及其对性能的影响,并提供了优化建议,帮助开发者提升网络通信的稳定性和效率。 ... [详细]
  • 在Cisco IOS XR系统中,存在提供服务的服务器和使用这些服务的客户端。本文深入探讨了进程与线程状态转换机制,分析了其在系统性能优化中的关键作用,并提出了改进措施,以提高系统的响应速度和资源利用率。通过详细研究状态转换的各个环节,本文为开发人员和系统管理员提供了实用的指导,旨在提升整体系统效率和稳定性。 ... [详细]
  • Web开发框架概览:Java与JavaScript技术及框架综述
    Web开发涉及服务器端和客户端的协同工作。在服务器端,Java是一种优秀的编程语言,适用于构建各种功能模块,如通过Servlet实现特定服务。客户端则主要依赖HTML进行内容展示,同时借助JavaScript增强交互性和动态效果。此外,现代Web开发还广泛使用各种框架和库,如Spring Boot、React和Vue.js,以提高开发效率和应用性能。 ... [详细]
  • 在Java Web服务开发中,Apache CXF 和 Axis2 是两个广泛使用的框架。CXF 由于其与 Spring 框架的无缝集成能力,以及更简便的部署方式,成为了许多开发者的首选。本文将详细介绍如何使用 CXF 框架进行 Web 服务的开发,包括环境搭建、服务发布和客户端调用等关键步骤,为开发者提供一个全面的实践指南。 ... [详细]
  • 本文介绍了如何利用 Delphi 中的 IdTCPServer 和 IdTCPClient 控件实现高效的文件传输。这些控件在默认情况下采用阻塞模式,并且服务器端已经集成了多线程处理,能够支持任意大小的文件传输,无需担心数据包大小的限制。与传统的 ClientSocket 相比,Indy 控件提供了更为简洁和可靠的解决方案,特别适用于开发高性能的网络文件传输应用程序。 ... [详细]
author-avatar
卟105932097
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有