Swoole 快速起步:Task任务机制的使用

Task任务机制实际是 将耗时进程投递到异步调用事件Task中处理,从而不阻塞主进程

 Swoole 快速起步:创建 WebSocket 服务器(聊天室)为例,在 WebSocket 服务器监听到新消息相应时,需要一些耗时的操作之后才将数据 send 给客户端,如果不使用Task任务机制时:

// 监听 WebSocket 消息事件
$server->on('message', function ($server, $frame) {
    // 开始流程
	echo date("Y-m-d H:i:s") . ":get something\n";
    
    // 耗时的任务开始
	sleep(5);
	echo date("Y-m-d H:i:s") . ":handle something\n";
    // 耗时的任务结束

    foreach ($server->connections as $k => $v) {
        $server->push($v, "会员".$frame->fd.":".$frame->data);
    }
    // 流程完成
    echo date("Y-m-d H:i:s") . ":finish it\n";
});

结果如下:

Swoole 快速起步:Task任务机制的使用

可见,在开始流程(get something)到 流程完成(finish it)一共耗时 5 秒,原因就在于 那个耗时的任务 sleep(5) !

如果将耗时任务投放到 Task 中做处理:

// 配置
$server->set([
	"worker_num" => 2,
	"task_worker_num" => 2
]);

/* ... */

// 监听 WebSocket 消息事件
$server->on('message', function ($server, $frame) {
    // 开始流程
	echo date("Y-m-d H:i:s") . ":get something\n";
    
    // 耗时的任务开始
	$data = "task go!!!";
	$server->task($data);
    // 耗时的任务结束

    foreach ($server->connections as $k => $v) {
        $server->push($v, "会员".$frame->fd.":".$frame->data);
    }
    // 流程完成
    echo date("Y-m-d H:i:s") . ":finish it\n";
});

$server->on("Task",function($server, $taskId, $workerId, $data){
	var_dump($data); // $data 来源 $server->task($data); 参数
	sleep(5);
	echo date("Y-m-d H:i:s") . ":handle something\n";
	return "task ok!!!";
});

$server->on("Finish",function($server, $taskId,  $data){
	var_dump($data);  // $data 来源 onTask($data) return 结果
});

结果:

Swoole 快速起步:Task任务机制的使用

可见,在开始流程(get something) 到 流程完成(finish it)几乎不消耗时间!因为那耗时 5 秒的任务投放在 Task 中异步处理!

发现很多所谓的 高性能 都是将进程投递到其它进程 异步处理,然后实现监听处理结果!

上一篇:strtol,strtoll,strtoul, strtoull函数的使用


下一篇:PHP 教你使用 Swoole-Tracker 秒级定位 PHP 卡死问题