ホームページ > PHPフレームワーク > Swoole > スウールタスクの使い方

スウールタスクの使い方

(*-*)浩
リリース: 2019-12-06 09:26:16
オリジナル
3313 人が閲覧しました

スウールタスクの使い方

Swoole タスクのアプリケーション。

Swoole Asynchronous Task は主に非同期タスクの呼び出しの実行を実装します。 (推奨される学習: swoole ビデオ チュートリアル )

一般的に使用されるシナリオ: 非同期支払い処理、非同期注文処理、非同期ログ処理、電子メール/SMS メッセージの非同期送信など。

Swoole の実装では、ワーカー プロセスがデータ要求を処理し、実行のためにタスク プロセスに割り当てられます。

公式紹介:

タスク 最下層は Unix ソケット パイプ通信を使用します。これはフルメモリであり、IO 消費はありません。単一プロセスの読み取りおよび書き込みパフォーマンスは 100 万/秒に達する可能性があり、異なるプロセスは異なるパイプラインを使用して通信するため、複数のコアを最大限に活用できます。

ローカル バージョン: PHP 7.2.6、Swoole 4.3.1。

早速、まずレンダリングを見てみましょう。

コード

server.php

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

70

71

72

73

74

75

76

77

78

79

80

81

82

class Server

{

    private $serv;

 

    public function __construct() {

        $this->serv = new swoole_server('0.0.0.0', 9501);

        $this->serv->set([

            'worker_num'      => 2, //开启2个worker进程

            'max_request'     => 4, //每个worker进程 max_request设置为4次

            'task_worker_num' => 4, //开启4个task进程

            'dispatch_mode'   => 2, //数据包分发策略 - 固定模式

        ]);

 

        $this->serv->on('Start', [$this, 'onStart']);

        $this->serv->on('Connect', [$this, 'onConnect']);

        $this->serv->on("Receive", [$this, 'onReceive']);

        $this->serv->on("Close", [$this, 'onClose']);

        $this->serv->on("Task", [$this, 'onTask']);

        $this->serv->on("Finish", [$this, 'onFinish']);

 

        $this->serv->start();

    }

 

    public function onStart($serv) {

        echo "#### onStart ####".PHP_EOL;

        echo "SWOOLE ".SWOOLE_VERSION . " 服务已启动".PHP_EOL;

        echo "master_pid: {$serv->master_pid}".PHP_EOL;

        echo "manager_pid: {$serv->manager_pid}".PHP_EOL;

        echo "########".PHP_EOL.PHP_EOL;

    }

 

    public function onConnect($serv, $fd) {

        echo "#### onConnect ####".PHP_EOL;

        echo "客户端:".$fd." 已连接".PHP_EOL;

        echo "########".PHP_EOL.PHP_EOL;

    }

 

    public function onReceive($serv, $fd, $from_id, $data) {

        echo "#### onReceive ####".PHP_EOL;

        echo "worker_pid: {$serv->worker_pid}".PHP_EOL;

        echo "客户端:{$fd} 发来的Email:{$data}".PHP_EOL;

        $param = [

            'fd'    => $fd,

            'email' => $data

        ];

        $rs = $serv->task(json_encode($param));

        if ($rs === false) {

            echo "任务分配失败 Task ".$rs.PHP_EOL;

        } else {

            echo "任务分配成功 Task ".$rs.PHP_EOL;

        }

        echo "########".PHP_EOL.PHP_EOL;

    }

 

    public function onTask($serv, $task_id, $from_id, $data) {

        echo "#### onTask ####".PHP_EOL;

        echo "#{$serv->worker_id} onTask: [PID={$serv->worker_pid}]: task_id={$task_id}".PHP_EOL;

 

        //业务代码

        for($i = 1 ; $i <= 5 ; $i ++ ) {

            sleep(2);

            echo "Task {$task_id} 已完成了 {$i}/5 的任务".PHP_EOL;

        }

 

        $data_arr = json_decode($data, true);

        $serv->send($data_arr[&#39;fd&#39;] , &#39;Email:&#39;.$data_arr[&#39;email&#39;].&#39;,发送成功&#39;);

        $serv->finish($data);

        echo "########".PHP_EOL.PHP_EOL;

    }

 

    public function onFinish($serv,$task_id, $data) {

        echo "#### onFinish ####".PHP_EOL;

        echo "Task {$task_id} 已完成".PHP_EOL;

        echo "########".PHP_EOL.PHP_EOL;

    }

 

    public function onClose($serv, $fd) {

        echo "Client Close.".PHP_EOL;

    }

}

 

$server = new Server();

ログイン後にコピー

client.php

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

<?php

class Client

{

    private $client;

    public function __construct() {

        $this->client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);

        $this->client->on(&#39;Connect&#39;, [$this, &#39;onConnect&#39;]);

        $this->client->on(&#39;Receive&#39;, [$this, &#39;onReceive&#39;]);

        $this->client->on(&#39;Close&#39;, [$this, &#39;onClose&#39;]);

        $this->client->on(&#39;Error&#39;, [$this, &#39;onError&#39;]);

    }

    public function connect() {

        if(!$fp = $this->client->connect("127.0.0.1", 9501 , 1)) {

            echo "Error: {$fp->errMsg}[{$fp->errCode}]".PHP_EOL;

            return;

        }

    }

    public function onConnect($cli) {

        fwrite(STDOUT, "输入Email:");

        swoole_event_add(STDIN, function() {

            fwrite(STDOUT, "输入Email:");

            $msg = trim(fgets(STDIN));

            $this->send($msg);

        });

    }

    public function onReceive($cli, $data) {

        echo PHP_EOL."Received: ".$data.PHP_EOL;

    }

    public function send($data) {

        $this->client->send($data);

    }

    public function onClose($cli) {

        echo "Client close connection".PHP_EOL;

    }

    public function onError() {

    }

}

$client = new Client();

$client->connect();

ログイン後にコピー

以上がスウールタスクの使い方の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル:
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート