发表新帖

websocket不支持异步

{{{
<?php

//创建websocket服务器对象，监听0.0.0.0:9502端口
$ws = new swoole_websocket_server("0.0.0.0", 9502);
//设置异步任务的工作进程数量
$ws->set(array('task_worker_num' => 4));
//监听WebSocket连接打开事件
$ws->on('open', function ($ws, $request) {
    var_dump($request->fd, $request->get, $request->server);
    $ws->push($request->fd, "hello, welcome\n");
});

//监听WebSocket消息事件
$ws->on('message', function ($ws, $frame) {
    echo "Message: {$frame->data}\n";
    //投递异步任务
    $task_id = $ws->task($frame->data);
    echo "Dispath AsyncTask: id=$task_id\n";
});

//处理异步任务
$ws->on('task', function ($ws, $task_id, $from_id, $data) {
    echo "New AsyncTask[id=$task_id]".PHP_EOL;
    //返回任务执行的结果
    $ws->finish("$data -> OK");
});

//处理异步任务的结果
$ws->on('finish', function ($ws, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
});

//监听WebSocket连接关闭事件
$ws->on('close', function ($ws, $fd) {
    echo "client-{$fd} is closed\n";
});

$ws->start();

}}}

报错
PHP Warning:  swoole_server::task(): Task method cannot use, Please set task_worker_num. in /home/wwwroot/default/wordpress/swoole.php on line 16
Dispath AsyncTask: id=

发布于8年前 · 2 次浏览 · 来自提问

Var抉择