<?php
/**
* Created by PhpStorm.
* User: yf
* Date: 2017/1/23
* Time: 上午12:06
*/
namespaceConf;
useApp\Model\Chat\Chat;
useCore\AbstractInterface\AbstractEvent;
useCore\AutoLoader;
useCore\Component\Di;
useCore\Component\Logger;
useCore\Component\Version\Control;
useCore\Http\Request;
useCore\Http\Response;
useCore\Swoole\SwooleHttpServer;
useCore\Swoole\Timer;
useApp\Utility\Mysql;
classEvent extendsAbstractEvent
{
functionframeInitialize()
{
// TODO: Implement frameInitialize() method.
date_default_timezone_set('Asia/Shanghai');
$loader= AutoLoader::getInstance();
$loader->requireFile("App/Vendor/MysqliDb/MysqliDb.php");
$loader->requireFile("App/Vendor/Smarty/Smarty.class.php");
}
functionbeforeWorkerStart(\swoole_http_server $server)
{
// TODO: Implement beforeWorkerStart() method.
//udp 请勿用receive事件
//添加自带多协议监听
$udp= $server->addlistener("0.0.0.0", 9502, SWOOLE_SOCK_UDP);
$udp->on('packet', function(\swoole_server $server, $data, $addr) {
Logger::console("receive data {$data}");
$server->sendto($addr['address'], $addr['port'], "Swoole: $data");
});
// $listener = $server->addlistener("0.0.0.0",9502,SWOOLE_TCP);
// //混合监听tcp时 要重新设置包解析规则 才不会被HTTP覆盖，且端口不能与HTTP SERVER一致 HTTP本身就是TCP
// $listener->set(array(
// "open_eof_check"=>false,
// "package_max_length"=>2048,
// ));
// $listener->on("connect",function(\swoole_server $server,$fd){
// Logger::console("client connect");
// });
// $listener->on("receive",function(\swoole_server $server,$fd,$from_id,$data){
// Logger::console("received connect");
// $server->send($fd,"swoole ".$data);
// $server->close($fd);
// });
// $listener->on("close",function (\swoole_server $server,$fd){
// Logger::console("client close");
// });
$server->on("handshake", function(\swoole_http_request $request, \swoole_http_response $response) {
Logger::console("handshake");
//自定定握手规则，没有设置则用系统内置的（只支持version:13的）
if(!isset($request->header['sec-websocket-key'])) {
//'Bad protocol implementation: it is not RFC6455.'
$response->end();
returnfalse;
}
if(0 === preg_match('#^[+/0-9A-Za-z]{21}[AQgw]==$#', $request->header['sec-websocket-key'])
|| 16 !== strlen(base64_decode($request->header['sec-websocket-key']))
) {
//Header Sec-WebSocket-Key is illegal;
$response->end();
returnfalse;
}
$key= base64_encode(sha1($request->header['sec-websocket-key']
. '258EAFA5-E914-47DA-95CA-C5AB0DC85B11',
true));
$headers= array(
'Upgrade'=> 'websocket',
'Connection'=> 'Upgrade',
'Sec-WebSocket-Accept'=> $key,
'Sec-WebSocket-Version'=> '13',
'KeepAlive'=> 'off',
);
foreach($headersas$key=> $val) {
$response->header($key, $val);
}
$response->status(101);
$response->end();
$result['status'] = true;
$result['fd'] = $request->fd;
SwooleHttpServer::getInstance()->getServer()->push($request->fd, json_encode($result));
});
//添加websocket回调事件
$server->on("message", function(\swoole_websocket_server $server, \swoole_websocket_frame $frame) {
Logger::console("接收数据:". $frame->data);
$data= json_decode($frame->data, 1);
$chat_model= newChat();
//验证用户
$user_info= $chat_model->get_info('select id,
user_login,
user_nicename,
user_email,
avatar,
coin,
mobile,
money,
freeze_money,
sex
from dm_users WHERE login_key="' . $data['key'] . '"limit 1');
//这段的sql代码参考\example\multiUsage_01\App\Model\Goods\goods.php 的Mysql基类 方法
if(!$user_info) {
$result= array();
$result['status'] = false;
$result['info'] = '你没有登陆账号!';
$server->push($frame->fd, json_encode($result));
} else{
if(empty($user_info['avatar'])){
$user_info['avatar']='admin.gif';
}
$data['user_info'] = $user_info;
unset($data['key']);
$data['status']=true;
$data['msg'] = htmlentities($data['msg']);
foreach($server->connections as$key=> $value) {
$server->push($value, json_encode($data));
}
}
});
$server->on("close", function(\swoole_http_server $server, $fd) {
$info= SwooleHttpServer::getInstance()->getServer()->connection_info($fd);
if($info['websocket_status']) {
Logger::console("websocket 客户端 {$fd} 关闭");
}
});
//添加websocket回调事件结束
}
functiononStart(\swoole_http_server $server)
{
// TODO: Implement onStart() method.
//使用event loop实现自定义 socket监听
$listener= stream_socket_server(
"udp://0.0.0.0:9503",
$error,
$errMsg,
STREAM_SERVER_BIND
);
if($errMsg) {
thrownew\Exception("listen fail");
} else{
//加入event loop
swoole_event_add($listener, function($listener) {
$data= stream_socket_recvfrom($listener, 9503, 0, $client);
Logger::console("rec data {$data} in event loop");
stream_socket_sendto($listener, "hello this is event loop", 0, $client);
});
}
}
functiononShutdown(\swoole_http_server $server)
{
// TODO: Implement onShutdown() method.
}
functiononWorkerStart(\swoole_server $server, $workerId)
{
// TODO: Implement onWorkerStart() method.
//为第一个worker添加一个定时器
/* if ($workerId == 0) {
//10秒
Timer::loop(10 * 1000, function () {
Logger::console("this is timer");
});
}*/
}
functiononWorkerStop(\swoole_server $server, $workerId)
{
// TODO: Implement onWorkerStop() method.
}
functiononRequest(Request $request, Response $response)
{
// TODO: Implement onRequest() method.
}
functiononDispatcher(Request $request, Response $response, $targetControllerClass, $targetAction)
{
// TODO: Implement onDispatcher() method.
}
functiononResponse(Request $request, Response $response)
{
// TODO: Implement afterResponse() method.
}
functiononTask(\swoole_http_server $server, $taskId, $fromId, $taskObj)
{
// TODO: Implement onTask() method.
}
functiononFinish(\swoole_http_server $server, $taskId, $fromId, $taskObj)
{
// TODO: Implement onFinish() method.
}
functiononWorkerError(\swoole_http_server $server, $worker_id, $worker_pid, $exit_code)
{
// TODO: Implement onWorkerError() method.
}
}
|
