WorkerMan 入门学习之(三)基础教程-Timer类的使用


1、ServerTimer.php 代码:

<?php /** * 定时器学习 */
require_once __DIR__ . '/Workerman/Autoloader.php'; use Workerman\Worker; use Workerman\Lib\Timer; // 创建一个容器
$worker = new Worker('websocket://0.0.0.0:12345'); // 连接回调
$worker->onConnect = function ($connection) { // 每10s 检查客户端是否有name属性 
   Timer::add(10, function () use ($connection) { if (!isset($connection->name)) { $connection->close("auth timeout and close"); } }, null, false); }; $worker->onMessage = function ($connection, $data) { if (!isset($connection->name)) { $data = json_decode($data,true); if (!isset($data['name']) || !isset($data['password'])) { return $connection->close("auth fail and close"); } // 如果客户端name存在,mysql,这里使用动态给对象赋值属性name,标记该对象已经通过验证
        $connection->name = $data['name']; // 广播给所有用户,该用户加入
        return broadcast($connection->name . " join \n"); } // 简单的连接器
    return broadcast($connection->name . ' said : ' . $data); }; function broadcast($msg) { // 引入$worker 对象
    global $worker; // $worker->connections 为客户端连接的所有对象
    foreach ($worker->connections as $connection) { if (!isset($connection->name)) { //忽略掉
            continue; } $connection->send($msg); } } $worker::runAll();/

2、开启服务

3、打开谷歌浏览器测试

(1)没有携带name和password 

  

(2)携带name和password

  

(3)两个客户端互相通信

  客户端001

  

  客户端002

  

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM