swoole怎么异步调用

swoole  /  管理员 发布于 5年前   371

swoole怎么异步调用？

Swoole中的异步使用

测试案例：

改写ws_server.php

$this->ws->set(    [        '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']); public function onOpen($ws, $request) {    var_dump($request->fd);} public function onMessage($ws, $frame) {    echo "ser-push-message:{$frame->data}\n";    $data = [        'task' => 1,        'fd' => $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接受数据并输出。

用户页面：

<!DOCTYPE html><head><meta charset="UTF-8"><meta http-equiv="Content-Type" content="text/html; charset=utf-8" /><title></title></head><body><h1>chuangxiang--测试</h1><script>var wsUrl = "ws://192.168.0.103:8812"; var websocket = new WebSocket(wsUrl); //实例对象的onopen属性websocket.onopen = function(evt) {    websocket.send("Hello chaungxiang");//输出到服务器端,即发送信息    console.log("connected-swoole-success");//输出在页面} //实例化 onmessagewebsocket.onmessage = function(evt) {    console.log("ws-server-return-data:"+evt.data);} //实例化onclosewebsocket.onclose = function(evt) {    console.log("close");} //实例化onerrorwebsocket.onerror =function(evt,e) {    console.log("error:"+evt.data);}</script></body></html>

浏览器：(客户端)

65de160c45f01014cb87fb4f264d54f.png

服务器：

20996977ed9135881f4f3b428e8dead.png

第一行数据为服务端输出，一开始建立连接的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 = [        'task' => 1,        'fd' => $frame->fd,    ];    $ws->task($data);    $ws->push($frame->fd, "server-push:".date("Y-m-d H:i:s"));}

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

以上就是swoole怎么异步调用的详细内容，更多请关注其它相关文章！


  • 上一条：
    php json转换相关知识(小结)
    下一条：
    oppo无法连接swoole怎么办

    • 昵称：

    邮箱：

    1条评论 (评论内容有缓存机制,请悉知!)
    Top

    Copyright·© 2019 侯体宗版权所有· 粤ICP备20027696号 PHP交流群

    侯体宗的博客