swoole入门教程02-Swoole的Task使用以及swoole_client

第二章 Swoole的task使用以及swoole_client

环境说明： 系统：Ubuntu14.04 （安装教程包括CentOS6.5）
PHP版本：PHP-5.5.10
swoole版本：1.7.6-stable

上一章已经简单介绍了如何写一个简单的Echo服务器，并了解了onReceive等几个核心回调函数的使用方法。这一章，我将介绍如何使用Swoole的异步任务Task。

1.Task简介

Swoole的业务逻辑部分是同步阻塞运行的，若是遇到一些耗时较大的操做，例如访问数据库、广播消息等，就会影响服务器的响应速度。所以Swoole提供了Task功能，将这些耗时操做放到另外的进程去处理，当前进程继续执行后面的逻辑。

2.开启Task功能

开启Task功能只须要在swoole_server的配置项中添加task_worker_num一项便可，以下：

$serv->set(array(
    'task_worker_num' => 8
));

便可开启task功能。此外，必须给swoole_server绑定两个回调函数：onTask和onFinish。这两个回调函数分别用于执行Task任务和处理Task任务的返回结果。

3.使用Task

首先是发起一个Task，代码以下：

public function onReceive( swoole_server $serv, $fd, $from_id, $data ) {
        echo "Get Message From Client {$fd}:{$data}\n";
        // send a task to task worker.
        $param = array(
            'fd' => $fd
        );
        // start a task
        $serv->task( json_encode( $param ) );

        echo "Continue Handle Worker\n";
    }

能够看到，发起一个任务时，只需经过swoole_server对象调用task函数便可发起一个任务。swoole内部会将这个请求投递给task_worker，而当前Worker进程会继续执行。

当一个任务发起后，task_worker进程会响应onTask回调函数，以下：

public function onTask($serv,$task_id,$from_id, $data) {
        echo "This Task {$task_id} from Worker {$from_id}\n";
        echo "Data: {$data}\n";
        for($i = 0 ; $i < 10 ; $i ++ ) {
            sleep(1);
            echo "Taks {$task_id} Handle {$i} times...\n";
        }
        $fd = json_decode( $data , true )['fd'];
        $serv->send( $fd , "Data in Task {$task_id}");
        return "Task {$task_id}'s result";
    }

这里我用sleep函数和循环模拟了一个长耗时任务。在onTask回调中，咱们经过task_id和from_id(也就是worker_id)来区分不一样进程投递的不一样task。当一个task执行结束后，经过return一个字符串将执行结果返回给Worker进程。Worker进程将经过onFinish回调函数接收这个处理结果。

下面来看onFinish回调：

public function onFinish($serv,$task_id, $data) {
        echo "Task {$task_id} finish\n";
        echo "Result: {$data}\n";
    }

在onFinish回调中，会接收到Task任务的处理结果$data。在这里处理这个返回结果便可。 （Tip: 能够经过在传递的data中存放fd、buff等数据，来延续投递Task以前的工做）

点此查看完整示例

4.swoole_client

之因此在这里讲解如何使用swoole_client是由于，在写服务端代码的时候，不可避免的须要用到客户端来进行测试。swoole提供了swoole_client用于编写测试客户端，下面我将讲解如何使用这个工具。

swoole_client有两种工做模式：同步阻塞模式和异步回调模式。其中，同步阻塞模式在上一章中已经给出示例，其使用和通常的socket基本无异。所以，我将重点讲解swoole_client的异步回调模式。

建立一个异步client的代码以下：

$client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC);

其中，SWOOLE_SOCK_ASYNC选项即代表建立一个异步client。

既然是异步，那固然须要回调函数。swoole_client一共有四个回调函数，以下：

$client->on("connect", function($cli) {
    $cli->send("hello world\n");
});
$client->on("receive", function($cli, $data){
    echo "Received: ".$data."\n";
});
$client->on("error", function($cli){
    echo "Connect failed\n";
});
$client->on("close", function($cli){
    echo "Connection close\n";
});

这几个回调函数的做用基本和swoole_server相似，只有参数不一样，所以再也不赘述。 点此查看完整示例

进阶：简易聊天室

我用swoole扩展写了一个简单的聊天室Demo（点此查看） 这个Demo虽然用到了一些其余的架构，可是核心功能仍然是依托swoole扩展实现的。

• 经过onReceive回调接收数据，根据预先规定的字段找到对应的处理函数。
• 经过onTask处理发送数据、广播这样的耗时内容。

Server.php是所有的Swoole回调函数实现的类。

下章预告：Timer计时器、心跳检测及Task进阶实例：mysql链接池。