当前位置：网站首页>Swoole定时器

Swoole定时器

2022-07-27 22:38:00 【生命不止、战斗不息】

简介

常规定时器：linux crontab

Swoole定时器
swoole_timer_tick
swoole_timer_after

别名

tick()、after()、clear() 都拥有一个函数风格的别名

应用

Ws.php

<?php
/*ws 优化 基础类库*/
class Ws{
  CONST HOST = "0.0.0.0";
  CONST PORT = 8812;
  public $ws = null;
  public function __construct(){
    $this->ws = new Swoole\WebSocket\Server("0.0.0.0",8812);
    
    $this->ws->set(
      [
        # 设置启动的 Worker 进程数。【默认值：CPU 核数】
        'worker_num'=>2,
        # 配置 Task 进程的数量
        '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连接事件
  public function onOpen($ws,$request)
  {
    var_dump($request->fd);

    if($request->fd==1)
    {
      /*
       tick() 别名函数 swoole_timer_tick
       设置一个间隔时钟定时器。

       与 after 定时器不同的是 tick 定时器会持续触发，直到调用 Timer::clear 清除。
       */
      //每2秒执行
      swoole_timer_tick(2000,function($timer_id){
        echo "2s：timerId：{$timer_id}\n";
      });
    }

  }

  # 监听ws消息事件
  public function onMessage($ws,$frame)
  {
    echo "接收前端发来的信息：{$frame->data}\n";

    // todo 10s
    $data = [
      'task'=>1,
      'fd'=>$frame->fd,
    ];

    /*
    after()
    在指定的时间后执行函数。Swoole\Timer::after 函数是一个一次性定时器，执行完成后就会销毁。

    此函数与 PHP 标准库提供的 sleep 函数不同，after 是非阻塞的。而 sleep 调用后会导致当前的进程进入阻塞，将无法处理新的请求。
     */
    swoole_timer_after(5000,function() use($ws,$frame)
    {
      echo "5s-after\n";
      $ws->push($frame->fd,"5秒后发送给前台的消息：".date("Y-m-d H:i:s"));
    });

    $ws->push($frame->fd,"发送给前台的消息:".date("Y-m-d H:i:s"));

  }
  public function onTask($serv,$taskId,$workerId,$data){
    print_r($data);
    //耗时场景
    sleep(10);
    return "on task finish";//告诉work
  }
  public function onFinish($serv,$taskId,$data){
    echo "taskId:{$taskId}\n";
    echo "执行完成的异步：{$data}\n";
  }

  # close
  public function onClose($ws,$fd){
    echo "client:{$fd}\n";
  }

}

$obj=new Ws();

 运行服务

 

 

 

index.html 

<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="UTF-8">
<title>client</title>
</head>

<h1>willem-swoole-ws测试</h1>

<script>
  var wsUrl = "ws://www.swoole.com:9501";
  var websocket=new WebSocket(wsUrl);
  //实例对象的onopen属性
  websocket.onopen=function(evt){
    websocket.send("发送 hello-willem");
    console.log("conected-swoole-success");
  }
  //实例化 onmessage
  websocket.onmessage=function(evt){
	alert(evt.data+"：接收到后端发来的信息弹窗");
    console.log("ws-server-return-data:"+evt.data);
  }
  //onclose
  websocket.onclose=function(evt){
    console.log("close");
  }
  //onerror
  websocket.onerror=function(evt,e){
    console.log("error:"+evt.data);
  }
</script>

</body>
</html>

原网站

版权声明
本文为[生命不止、战斗不息]所创，转载请带上原文链接，感谢
https://blog.csdn.net/MrWangisgoodboy/article/details/126011394

边栏推荐

猜你喜欢

随机推荐