ホームページ > 記事 > バックエンド開発 > スウールの構造解析

スウールの構造解析

不言オリジナル: 2018-08-06 10:13:382773ブラウズ

この記事の内容は swoole のアーキテクチャ解析に関するものであり、一定の参考価値がありますので、困っている方は参考にしていただければ幸いです。

構造図は次のとおりです。

swoole は、主に Master プロセス (メインプロセス) と Manager プロセスによって使用され、そのプロセスを完了します。機能。

マスタープロセス

はマルチスレッドプログラムです。 Reactor スレッドと呼ばれる非常に重要なスレッドのグループがあります。実際に TCP 接続を処理し、データを送受信するのはスレッドです。

マネージャープロセス

ワーカー/タスクプロセスを管理します。ワーカー/タスクプロセスはすべてフォークされ、Manager プロセスによって管理されます。

Reactor スレッド

新しい接続を受け入れた後、メインスレッド (マスタープロセス) は固定の Reactor スレッドに接続を割り当て、このスレッドはソケットの監視を担当します。ソケットが読み取り可能なときにデータを読み取り、プロトコル分析を実行して、リクエストをワーカープロセスに配信します。

#クライアント
TCP接続の維持、ネットワークの処理IO、プロトコルの処理、データの送受信
完全に
非同期ノンブロッキング モード
Start/ を除くすべては C コードですシャットダウン イベントコールバックを除き、PHP コードは実行されません
TCP クライアントによって送信されたデータをバッファリングし、結合し、完全なリクエストデータに分割しますパッケージ
Reactorマルチスレッドで実行

作業プロセス

phpに似ています- fpmプロセス。

Reactor スレッドによって配信されたリクエストパケットを受け入れ、PHP コールバック関数を実行してデータを処理します
応答データを生成し、
Reactor スレッドに送信します。このデータは、Reactor スレッドによって TCP クライアント # に送信されます。
Worker
マルチプロセスモードで実行します

他のタスクを非同期に処理するプロセスで、使用方法はGearmanと同様です。

Worker
プロセスによって swoole_server->task/taskwait メソッドを通じて配信されたタスクを受け入れます
swoole_server->finish
) を Worker process
TaskWorker に返します。
マルチプロセスモードで実行する

は、

Reactor

が nginx、## であると理解できます。 #Worker は php-fpm です。 Reactorスレッドはネットワーク要求を非同期かつ並行して処理し、それを処理のためにWorkerプロセスに転送します(コールバック関数で処理されます)。 Reactor と Worker は UnixSocket を通じて通信します。

イベント処理プロセス

#スウールイベント処理プロセスを理解するには、まず 2 つのネットワークイベント処理モードを理解します。

リアクターモード

メインスレッド (I/O 処理ユニット) は、ファイル記述子にイベントがあるかどうかのみを監視し、イベントがある場合は直ちにワーカースレッド/プロセスに通知する必要があります。イベントの(論理ユニット)。それ以外、メインスレッドは他の作業を行いません。データの読み取りと書き込み、新しい接続の受け入れ、顧客リクエストの処理はすべてワーカースレッドで行われます。

プロアクターモード

2 つの実装

I/O 非同期モデルを使用してプロアクターモードを実装します。原則: すべての I/O 操作はメインスレッドに渡され、メインスレッドはカーネルと連携して処理し、ビジネスロジック操作はロジックユニットに渡されます。たとえば、これを実現するには aio_read を使用します。

ワークフロー:

メインスレッドは、aio_read 関数を呼び出して、ソケット上の読み取り完了イベントをカーネルに登録します。

メインスレッドは他の I/O イベントの処理を続けます。
ソケット上のデータがユーザーバッファーに読み込まれると、カーネルはアプリケーション (論理ユニット) に信号を送信して、データが利用可能であることをアプリケーションに通知します。
アプリケーションはデータ (クライアント要求) を読み取り、処理後に aio_write 関数を呼び出して、ソケット上の書き込みイベントをカーネルに登録します。
メインスレッドは他のロジックの処理を続けます。
ユーザーバッファー内のデータがソケットに書き込まれると、カーネルはアプリケーションに信号を送信して、データが送信されたことをアプリケーションに通知します。
アプリケーションには、ソケットのクローズなどの余波を処理するための事前定義された信号処理関数があります。
I/O 同期を使用するProactor モデルを実装するためのモデル。原則: メインスレッドは I/O イベントデータの読み取りおよび書き込み操作を実行し、ビジネスロジック操作はロジックユニットに引き渡されます。たとえば、これを実現するには epoll を使用します。

ワークフロー:

メインスレッドは、ソケット上の読み取り準備完了イベントを epoll カーネルイベントテーブルに登録します。

メインスレッドは epoll_wait を呼び出して、ソケット上でデータが読み取られるのを待ちます。
epoll_wait が戻った後、メインスレッドはソケットからデータを読み取り、読み取ったデータをリクエストオブジェクト (クライアントのリクエスト) にカプセル化し、リクエストキューに挿入します。
したがって、キューのコンシューマスレッドはリクエストオブジェクトを処理し、ソケット上の書き込み準備完了イベントを epoll カーネルイベントテーブルに登録します。
メインスレッドは epoll_wait を呼び出して、ソケットが書き込み可能になるのを待ちます。
ソケットが書き込み可能になると、epoll_wait がメインスレッドに通知します。メインスレッドはリクエスト結果をソケットに書き込みます。

swoole イベントアーキテクチャ図

図からわかるように、Reactor スレッドと Work プロセスを組み合わせると、これは、ワーカースレッドの場合、swoole はリアクターイベント処理モードを使用することがわかります。

リクエストが実行するステップは次のとおりです:

1. サーバーのメインスレッドはクライアントの接続を待ちます。

2. Reactor スレッドは、接続されたソケットを処理し、ソケット上のリクエストデータを読み取り (受信)、リクエストをカプセル化し、ワークプロセスに渡します。

3. 作業プロセスは、ビジネスデータを処理する論理単位です。

4. 作業プロセスの結果は Reactor スレッドに返されます。

5. Reactor スレッドは結果をソケットに書き込みます (送信)。

各モジュールの動作については、上記の構造の紹介を参照してください。