Swoole 入门学习（二）

Swoole 入门学习

---

swoole 之 定时器

 

　　循环触发：swoole_timer_tick    （和js的setintval相似）

　　参数1：int $after_time_ms 指定时间【毫秒】

　　参数2：mixed $callback_function 执行的函数

       参数3：mixed $user_param 用户参数

 　　清除定时器：bool swoole_timer_clear(int $timer_id)。

 

　　单次触发：swoole_timer_after

　　参数1：int $after_time_ms 指定时间【毫秒】

　　参数2：mixed $callback_function 执行的函数

       参数3：mixed $user_param 用户参数

 

　　示例：　　

<?php 
    //循环执行定时器
    swoole_timer_tick(2000,function($timer_id){
        echo "执行 $timer_id \n";
    });

    //单次执行定时器
    swoole_timer_after(3000,function(){
        echo "3秒后执行 \n";
    });
?>

---

异步TCP服务器

　　函数：

　　　　task() 投递异步任务

　　　　on('事件',function(){}) 处理函数，执行异步函数

　　　　finish()，任务处理完成后结果

　　示例：

　　

<?php 
    //建立TCP服务器
    $serv = new swoole_server('0.0.0.0',9501);
    //设置异步进程工做数
    $serv->set(array('task_worker_num'=>4));
    //投递异步任务
    $serv->on('receive',function($serv,$fd,$from_id,$data){
        $task_id = $serv->task($data);//异步ID
        echo "异步ID：$task_id\n";
    });
    //处理异步任务
    $serv->on('task',function($serv,$task_id,$from_id,$data){
        echo "执行异步ID：$task_id";
    });
    //处理结果
    $serv->on('finish',function($serv,$task_id,$data){
        echo '执行完成';
    });

    $serv->start();

?>

---

TCP客户端　

<?php
    //实例化客户端
    $client = new swoole_client(SWOOLE_SOCK_TCP);
    //链接服务
    $client->connect('192.168.1.5',8080,5) or die('链接失败');//5表示5秒内给到返回数据。
    //发送数据
    $client->send('hello world') or die('发送失败');
    //从服务器接收数据
    $data = $client->recv();
    if($data){
        var_dump($data);
    }
    //关闭客户端
    $client->close();
?>

---

TCP异步客户端

　　示例：

<?php
    //建立异步TCP客户端
    $client = new swoole_client(SWOOLE_SOCK_TCP,SWOOLE_SOCK_ASYNC);
    //注册链接成功的回调
    $client->on('connect',function($cli){
        $cli->send("hello \n");    
    });
    //注册数据接收$cli，服务端信息$data数据
    $client->on('receive',function($cli,$data){
        echo "data：$data \n");    
    });
    //注册链接失败
    $client->on('error',function($cli){
        echo "失败 \n");    
    });
    //注册关闭函数
    $client->on('close',function($cli){
        echo "关闭 \n");    
    });    
    //发起链接
    $client->connect('192.168.1.5',8080,10);
    
?>

---

swoole 之进程

　　

<?php
    
    //进程对应的执行函数
    function doProcess(swoole_process $worker){
        echo "PID",$worker->pid,"\n";
        sleep(10);
    }

    //建立进程1
    $process = new swoole_process("doProcess");
    $pid = $process->start();

    //建立进程2
    $process = new swoole_process("doProcess");
    $pid = $process->start();

    //建立进程3
    $process = new swoole_process("doProcess");
    $pid = $process->start();

    //等待结束
    swoole_process::wait();

?>