共计 2490 个字符，预计需要花费 7 分钟才能阅读完成。
一、执行异步任务
在 Server 程序中如果需要执行很耗时的操作，比如一个聊天服务器发送广播，Web 服务器中发送邮件。如果直接去执行这些函数就会阻塞当前进程，导致服务器响应变慢。
Swoole 提供了异步任务处理的功能，可以投递一个异步任务到 TaskWorker 进程池中执行，不影响当前请求的处理速度。
如何使用：
- onTask
- onFinish
- 设置 task_worker_num
二、代码实现
我们看 Swoole 官方文档入门指引 -> 快速起步 ->Task 执行异步任务
我们可以使用上一节我们封装的 websocket 类中使用：
ws_task.php
<?php
/**
* WS 优化基础类库
*/
class Ws
{
public $ws = null;
CONST HOST = "0.0.0.0";
CONST PORT = 80;
public function __construct()
{
// static::HOST, static::PORT
$this->ws = new swoole_websocket_server("0.0.0.0", 80);
$this->ws->set(
[
'enable_static_handler' => true, // 静态资源相关设置
'document_root' => "/work/study/code/swoole/demo/static", // 存放静态资源路径
'worker_num' => 2,
'task_worker_num' => 2,
]
);
$this->ws->on("open", [$this, "onOpen"]);
$this->ws->on("message", [$this, "onMessage"]);
$this->ws->on("task", [$this, "onTask"]);
$this->ws->on("finish", [$this, "onFinish"]);
$this->ws->on("close", [$this, "onClose"]);
$this->ws->start();}
/**
* 监听 ws 连接事件
* @param $ws
* @param $request
*/
public function onOpen($ws, $request)
{print_r("Open:" . $request->fd ."\n");
}
/**
* 监听 ws 连接消息
* @param $ws
* @param $frame
*/
public function onMessage($ws, $frame)
{echo "ser-push-message:{$frame->data}\n";
// TODO:: 加入我们这个业务需要执行超过 10s，所以，这里可以使用 task 异步来处理
$data = [
'task' => 1,
'fd' => $frame->fd,
];
// 投递一个任务
$ws->task($data);
$ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
}
/**
* 投递任务
*
* @param $serv
* @param $taskId
* @param $workerId
* @param $data
*/
public function onTask($serv, $task_id, $from_id, $data)
{
// 耗时场景 10s
sleep(10);
return "on task finish"; // 告诉 worker
}
public function onFinish($serv, $task_id, $data)
{echo "taskId:{$task_id}\n";
// 注意：此 $data 参数为 onTask 方法返回的结果：on task finish，而不是 onTask 方法的参数。echo "finish-data-success:{$data}\n";
}
/**
* 监听 WebSocket 连接关闭事件
*
* @param $ws
* @param $fd
*/
public function onClose($ws, $fd)
{echo "clientid-{$fd} is closed \n";
}
}
$ws_obj = new Ws();
前端静态页面：
ws_task_client.html
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>WebSocket TEST</title>
</head>
<body>
<h1>Swoole-TEST</h1>
<script>
var wsUrl = "ws://0.0.0.0:8880";
var websocket = new WebSocket(wsUrl);
// 实例化 onopen 对象
websocket.onopen = function(evt){websocket.send("Hello-Lily"); // 发送信息给服务端
console.log("connected-swoole-success")
}
// 实例化 onmessage
websocket.onmessage = function(evt){console.log("ws-server-return-data"+evt.data)
}
// 实例化 onclose
websocket.onclose = function(evt){console.log("close")
}
// onerror
websocket.onerror = function (evt) {console.log("error:" + evt.data)
}
</script>
</body>
</html>
我们在先开启 websocket 服务：
# php ws_task.php
然后在浏览器运行 ws_task_client.html 页面：
这时我们再看服务端打印：
# php ws_task.php
Open:3
ser-push-message:Hello-Lily
clientid-1 is closed
taskId:0
finish-data-success:on task finish我们可以看出，页面 message 及时响应，而在服务器端 Task 异步任务过了 10s 才输出来了。
正文完
