123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172 |
- <?php
- /**
- * This file is part of workerman.
- *
- * Licensed under The MIT License
- * For full copyright and license information, please see the MIT-LICENSE.txt
- * Redistributions of files must retain the above copyright notice.
- *
- * @author walkor<walkor@workerman.net>
- * @copyright walkor<walkor@workerman.net>
- * @link http://www.workerman.net/
- * @license http://www.opensource.org/licenses/mit-license.php MIT License
- */
- /**
- * 用于检测业务代码死循环或者长时间阻塞等问题
- * 如果发现业务卡死,可以将下面declare打开(去掉//注释),并执行php start.php reload
- * 然后观察一段时间workerman.log看是否有process_timeout异常
- */
- //declare(ticks=1);
- /**
- * 聊天主逻辑
- * 主要是处理 onMessage onClose
- */
- //use \GatewayWorker\Lib\Gateway;
- //use \GatewayWorker\Lib\DbConnection;
- use think\Db;
- use think\App;
- class Events
- {
- public static function onWorkerStart(){
- App::initCommon();
- /*$info = Db::name('mt_admin')->find(1);
- dump($info);*/
- }
- /**
- * 有消息时
- * @param int $client_id
- * @param mixed $message
- */
- public static function onMessage($client_id, $message)
- {
- dump($message);
- return ;
- }
-
- /**
- * 当客户端断开连接时
- * @param integer $client_id 客户端id
- */
- public static function onClose($client_id)
- {
- // debug
- /* echo "client:{$_SERVER['REMOTE_ADDR']}:{$_SERVER['REMOTE_PORT']} gateway:{$_SERVER['GATEWAY_ADDR']}:{$_SERVER['GATEWAY_PORT']} client_id:$client_id onClose:''\n";
-
- // 从房间的客户端列表中删除
- if(isset($_SESSION['room_id']))
- {
- $room_id = $_SESSION['room_id'];
- $new_message = array('type'=>'logout', 'from_client_id'=>$client_id, 'from_client_name'=>$_SESSION['client_name'], 'time'=>date('Y-m-d H:i:s'));
- Gateway::sendToGroup($room_id, json_encode($new_message));
- }*/
- }
-
- }
|