|
|
|
@ -0,0 +1,129 @@ |
|
|
|
<?php |
|
|
|
|
|
|
|
namespace App\GatewayWorker; |
|
|
|
|
|
|
|
use GatewayWorker\Lib\Gateway; |
|
|
|
use Illuminate\Support\Facades\DB; |
|
|
|
use Illuminate\Support\Facades\Log; |
|
|
|
use App\Common\ReturnData; |
|
|
|
use App\Common\Helper; |
|
|
|
|
|
|
|
class Events |
|
|
|
{ |
|
|
|
/** |
|
|
|
* 当businessWorker进程启动时触发，每个进程生命周期内都只会触发一次 |
|
|
|
* 可以在这里为每一个businessWorker进程做一些全局初始化工作，例如设置定时器，初始化redis等连接等 |
|
|
|
* 不要在onWorkerStart内执行长时间阻塞或者耗时的操作，这样会导致BusinessWorker无法及时与Gateway建立连接，造成应用异常 |
|
|
|
* @param mixed $worker Worker对象 |
|
|
|
*/ |
|
|
|
public static function onWorkerStart($businessWorker) |
|
|
|
{ |
|
|
|
echo "onWorkerStart\r\n"; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 当客户端连接上gateway进程时(TCP三次握手完毕时)触发的回调函数 |
|
|
|
* onConnect事件仅仅代表客户端与gateway完成了TCP三次握手，这时客户端还没有发来任何数据，此时除了通过$_SERVER['REMOTE_ADDR']获得对方ip，没有其他可以鉴别客户端的数据或者信息，所以在onConnect事件里无法确认对方是谁。要想知道对方是谁，需要客户端发送鉴权数据，例如某个token或者用户名密码之类，在onMesssge里做鉴权 |
|
|
|
* @param int $client_id |
|
|
|
*/ |
|
|
|
public static function onConnect($client_id) |
|
|
|
{ |
|
|
|
echo "onConnect\r\n"; |
|
|
|
Gateway::sendToClient($client_id, json_encode(['type' => 'onConnect', 'client_id' => $client_id])); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 当客户端连接上gateway完成websocket握手时触发的回调函数 |
|
|
|
* 注意：此回调只有gateway为websocket协议并且gateway没有设置onWebSocketConnect时才有效 |
|
|
|
* @param int $client_id |
|
|
|
* @param mixed $data websocket握手时的http头数据，包含get、server等变量 |
|
|
|
*/ |
|
|
|
public static function onWebSocketConnect($client_id, $data) |
|
|
|
{ |
|
|
|
Log::info('onWebSocketConnect，client_id:' . $client_id . '-' . json_encode($data)); |
|
|
|
echo "onWebSocketConnect\r\n"; |
|
|
|
if (!isset($data['get']['token'])) { |
|
|
|
echo "closeClient\r\n"; |
|
|
|
return Gateway::closeClient($client_id); |
|
|
|
} |
|
|
|
$access_token = $data['get']['token']; |
|
|
|
//通过client_id绑定用户ID
|
|
|
|
$res = self::bing_client($client_id, ['access_token' => $access_token]); |
|
|
|
if ($res['code'] != ReturnData::SUCCESS) { |
|
|
|
return Gateway::sendToClient($client_id, json_encode($res)); |
|
|
|
} |
|
|
|
Gateway::sendToClient($client_id, json_encode(ReturnData::create(ReturnData::SUCCESS))); |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 有消息时 |
|
|
|
* @param int $client_id 发消息的client_id |
|
|
|
* @param mixed $message 完整的客户端请求数据，数据类型取决于Gateway所使用协议的decode方法返的回值类型 |
|
|
|
*/ |
|
|
|
public static function onMessage($client_id, $data) |
|
|
|
{ |
|
|
|
echo "onMessage\r\n"; |
|
|
|
// Debug输出
|
|
|
|
echo "client:{$_SERVER['REMOTE_ADDR']}:{$_SERVER['REMOTE_PORT']} gateway:{$_SERVER['GATEWAY_ADDR']}:{$_SERVER['GATEWAY_PORT']} client_id:$client_id session:" . json_encode($_SESSION) . " onMessage:" . $message . "\n"; |
|
|
|
|
|
|
|
// data = {"type":"login", "uid":"666"}
|
|
|
|
$data = json_decode($data, true); |
|
|
|
Log::info('onMessage，client_id:' . $client_id . '-' . json_encode($data)); |
|
|
|
|
|
|
|
// 没有传消息类型视为非法请求，关闭连接
|
|
|
|
if (!isset($data['type'])) { |
|
|
|
return Gateway::closeClient($client_id); |
|
|
|
} |
|
|
|
|
|
|
|
$uid = Gateway::getUidByClientId($client_id); |
|
|
|
|
|
|
|
// 判断绑定的UID为空，消息类型不是心跳视为非法请求，关闭连接
|
|
|
|
if (empty($uid) && $data['type'] !== 'heart') { |
|
|
|
return Gateway::closeClient($client_id); |
|
|
|
} |
|
|
|
|
|
|
|
switch ($data['type']) { |
|
|
|
case 'heart': //心跳回复
|
|
|
|
Gateway::sendToCurrentClient(json_encode(ReturnData::create(ReturnData::SUCCESS))); |
|
|
|
break; |
|
|
|
default: |
|
|
|
Gateway::sendToCurrentClient(json_encode(ReturnData::create(ReturnData::PARAMS_ERROR))); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 当客户端断开连接时 |
|
|
|
* @param integer $client_id 断开连接的客户端client_id |
|
|
|
* @return void |
|
|
|
*/ |
|
|
|
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"; |
|
|
|
|
|
|
|
Log::info('Workerman close connection，client_id:' . $client_id); |
|
|
|
echo "onClose\r\n"; |
|
|
|
} |
|
|
|
|
|
|
|
/** |
|
|
|
* 通过client_id绑定用户ID |
|
|
|
* @param int $client_id |
|
|
|
* @param mixed $message ['access_token'] |
|
|
|
*/ |
|
|
|
public static function bing_client($client_id, $message) |
|
|
|
{ |
|
|
|
if (!Gateway::isOnline($client_id)) { |
|
|
|
return ReturnData::create(ReturnData::PARAMS_ERROR, null, 'client_id错误'); |
|
|
|
} |
|
|
|
|
|
|
|
//client_id绑定用户ID
|
|
|
|
$token = DB::table('token')->where(['token' => $message['access_token']])->first(); |
|
|
|
if (!$token) { |
|
|
|
return ReturnData::create(ReturnData::PARAMS_ERROR, null, '鉴权失败'); |
|
|
|
} |
|
|
|
Gateway::bindUid($client_id, $token->uid); |
|
|
|
|
|
|
|
return ReturnData::create(ReturnData::SUCCESS); |
|
|
|
} |
|
|
|
|
|
|
|
} |
Fanli2
4 years ago