博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
WorkerMan 入门学习之(三)基础教程-Timer类的使用
阅读量:5305 次
发布时间:2019-06-14

本文共 1245 字,大约阅读时间需要 4 分钟。

1、ServerTimer.php 代码:

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

  

 

转载于:https://www.cnblogs.com/tinywan/p/7420622.html

你可能感兴趣的文章
Java多线程和并发基础
查看>>
CodeForces - 55D Beautiful numbers
查看>>
PHP CURL错误: error:140943FC
查看>>
array_combine
查看>>
[LeetCode-124] Binary Tree Maximum Path Sum
查看>>
使用JDK的zip编写打包工具类
查看>>
基于FPGA的前向纠错算法
查看>>
Python装饰器(1)
查看>>
mysql 分页查询
查看>>
金蝶数据库开发,采购订单生成收料通知单影响哪些表
查看>>
Handler没法取出消息队列中的数据的一个原因
查看>>
给 C# 中的 Guid 扩展一个 TryParse 方法
查看>>
C指针-const char* p到底是什么不可以改变
查看>>
TextField 、 FTE、 TLF 的使用情景和简单说明
查看>>
第27月第28天 iOS bundle
查看>>
LeetCode Min Stack
查看>>
阿里云上传下载文件
查看>>
sublime3安装javascript控制台环境 方法1
查看>>
中位数
查看>>
升讯威微信营销系统开发实践:(2)中控服务器的详细设计( 完整开源于 Github)...
查看>>