swoole异步调用的方法

这篇文章主要介绍了swoole异步调用的方法，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

swoole怎么异步调用？

Swoole中的异步使用

测试案例：

改写ws_server.php

$this->ws->set(
    [
        &＃39;worker_num&＃39; => 2,
        &＃39;task_worker_num&＃39; => 2,
    ]
);
 
$this->ws->on("open", [$this, &＃39;onOpen&＃39;]);
$this->ws->on("message", [$this, &＃39;onMessage&＃39;]);
$this->ws->on("task", [$this, &＃39;onTask&＃39;]);
$this->ws->on("finish", [$this, &＃39;onFinish&＃39;]);
$this->ws->on("close", [$this, &＃39;onClose&＃39;]);
 
public function onOpen($ws, $request) {
    var_dump($request->fd);
}
 
public function onMessage($ws, $frame) {
    echo "ser-push-message:{$frame->data}\n";
    $data = [
        &＃39;task&＃39; => 1,
        &＃39;fd&＃39; => $frame->fd,
    ];
    $ws->task($data);
    $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
}
 
public function onTask($serv, $taskId, $workerId, $data) {
    print_r($data);
    // 耗时场景 10s
    sleep(10);
    return "on task finish"; // 告诉worker   
}
 
 
public function onFinish($serv, $taskId, $data) {
    echo "taskId:{$taskId}\n";
    echo "finish-data-sucess:{$data}\n";
}

客户端，即ws_client.html，发送信息，服务端的onMessage接受并执行设置数据调用onTask，在onTask中打印数据3秒后返回数据给onFinish，onFinish接受数据并输出。

用户页面：

chuangxiang--测试

浏览器：(客户端)

服务器：

第一行数据为服务端输出，一开始建立连接的onOpen()，之后先由客户端(ws_client.html)通过js代码连接并发送数据；第二行为发送数据前打印；发送数据到服务端后，执行onMessage()；其中再次输出数据并建立task，调用onTask()；在其中再次输出数据并返回数据给onFinish();

服务器端直接输出是到服务器，客户端需要通过push,send等发送到服务器

客户端通过console.log打印数据到页面

异步体现

public function onMessage($ws, $frame) {
    echo "ser-push-message:{$frame->data}\n";
    $data = [
        &＃39;task&＃39; => 1,
        &＃39;fd&＃39; => $frame->fd,
    ];
    $ws->task($data);
    $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));
}

这段代码中建立一个task任务之后，不会等到任务执行完之后再push，而是会同时进行。在客户端打印并发送数据后，客户端打印的数据与onMessage中的输出间隔很短，并不会受ontask任务中sleep的影响。

感谢你能够认真阅读完这篇文章，希望小编分享的“swoole异步调用的方法”这篇文章对大家有帮助，同时也希望大家多多支持编程笔记，关注编程笔记行业资讯频道，更多相关知识等着你来学习!