Swoole-WebSocket毫秒定时器

谁借莪１个温暖的怀抱￠ 2023-10-06 18:56 15阅读 0赞

#### Swoole毫秒定时器 ####

*  简介
 *  别名
 *  应用
 *   *  Ws.php
     *  index.html

## 简介 ##

常规定时器：linux crontab

Swoole定时器  
swoole\_timer\_tick  
swoole\_timer\_after

## 别名 ##

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

<table> 
 <thead> 
  <tr> 
   <th>类静态方法</th> 
   <th>函数风格别名</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td><code>Swoole\Timer::tick()</code></td> 
   <td><code>swoole_timer_tick()</code></td> 
  </tr> 
  <tr> 
   <td><code>Swoole\Timer::after()</code></td> 
   <td><code>swoole_timer_after()</code></td> 
  </tr> 
  <tr> 
   <td><code>Swoole\Timer::clear()</code></td> 
   <td><code>swoole_timer_clear()</code></td> 
  </tr> 
 </tbody> 
</table>

## 应用 ##

### 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();

运行服务  
![在这里插入图片描述][a558e6f462374278a2bbd119f47f43c3.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][8f1edcff30294e67a71bee3e6ca374d4.png]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 1]

### 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://test.cc:8812";
      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>

[a558e6f462374278a2bbd119f47f43c3.png]: https://img-blog.csdnimg.cn/a558e6f462374278a2bbd119f47f43c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/e396d6663c234f94b8ce3ab7c3dc564e.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70
[8f1edcff30294e67a71bee3e6ca374d4.png]: https://img-blog.csdnimg.cn/8f1edcff30294e67a71bee3e6ca374d4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/83aea4e4203d4611a631132091cc59e4.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaWd1YW5nMTAy,size_16,color_FFFFFF,t_70