Skip to content

M
my-yaf-project
Commit 12a7f1ac authored by chenchuanwen's avatar chenchuanwen
Browse files
Options

bridgeedit

parent 0b215f5f
Hide whitespace changes
Inline Side-by-side
Showing with 46 additions and 42 deletions
scripts/crontab/push/bridgeBase.php
View file @ 12a7f1ac
<?php <?php
// 通过链接参数热重载 worker 进程观察触发事件 // 通过链接参数热重载 worker 进程观察触发事件
$act = $request->get['act']?$request->get['act']:''; if(!empty($request->get)){
if ($act == 'reload') { $act = $request->get['act']?$request->get['act']:'';
echo ' ... Swoole Reloading ! ... ' . PHP_EOL . PHP_EOL; if ($act == 'reload') {
// 触发 reload 之后, 貌似后面的代码也还是会执行的 echo ' ... Swoole Reloading ! ... ' . PHP_EOL . PHP_EOL;
$server->reload(); // 触发 reload 之后, 貌似后面的代码也还是会执行的
echo ' ... Under Reload ! ... ' . PHP_EOL . PHP_EOL; // 看看 reload 时是否会执行后续的代码 $server->reload();
} elseif ($act == 'stop') { echo ' ... Under Reload ! ... ' . PHP_EOL . PHP_EOL; // 看看 reload 时是否会执行后续的代码
// 直接立即终止当前 worker 进程, 和 reload 的效果比较相似, 新的 worker 进程的 ID 和原来的一样 } elseif ($act == 'stop') {
// 所以程序内部应该尽量避免使用 exit 而应该抛出异常在外部 catch // 直接立即终止当前 worker 进程, 和 reload 的效果比较相似, 新的 worker 进程的 ID 和原来的一样
echo ' ... Swoole Exit ! ... ' . PHP_EOL . PHP_EOL; // 所以程序内部应该尽量避免使用 exit 而应该抛出异常在外部 catch
exit; echo ' ... Swoole Exit ! ... ' . PHP_EOL . PHP_EOL;
} elseif ($act == 'shutdown') { exit;
// 直接立即终止当前 worker 进程, 和 reload 的效果比较相似, 新的 worker 进程的 ID 和原来的一样 } elseif ($act == 'shutdown') {
// 所以程序内部应该尽量避免使用 exit 而应该抛出异常在外部 catch // 直接立即终止当前 worker 进程, 和 reload 的效果比较相似, 新的 worker 进程的 ID 和原来的一样
echo ' ... Swoole Shutdown ! ... ' . PHP_EOL . PHP_EOL; // 所以程序内部应该尽量避免使用 exit 而应该抛出异常在外部 catch
$server->shutdown(); echo ' ... Swoole Shutdown ! ... ' . PHP_EOL . PHP_EOL;
echo ' ... After Swoole Shutdown ! ... ' . PHP_EOL . PHP_EOL; $server->shutdown();
echo ' ... After Swoole Shutdown ! ... ' . PHP_EOL . PHP_EOL;
}
} }
try{ if(!empty($request->post)){
$respData=$request->post; try{
// echo json_encode($respData); $respData=$request->post;
if(isset($respData['type'])&&$respData['type']==1){ // echo json_encode($respData);
$info=$respData['content']; if(isset($respData['type'])&&$respData['type']==1){
$memberDao=$info['className']::getInstance(\Our\DbNameConst::masterDBConnectName); $info=$respData['content'];
echo json_encode($info); $memberDao=$info['className']::getInstance(\Our\DbNameConst::masterDBConnectName);
if(empty($info['params'])){ echo json_encode($info);
$res=call_user_func_array(array($memberDao,$info['method']),array()); if(empty($info['params'])){
}else{ $res=call_user_func_array(array($memberDao,$info['method']),array());
$res=call_user_func_array(array($memberDao,$info['method']),$info['params']); }else{
} $res=call_user_func_array(array($memberDao,$info['method']),$info['params']);
$res=(isset($res)&&!empty($res))?$res:false; }
unset($memberDao); $res=(isset($res)&&!empty($res))?$res:false;
\Mysql\LinkMySQLModel::unsetDbConecet(); unset($memberDao);
if($res!==false){ \Mysql\LinkMySQLModel::unsetDbConecet();
echo 'success'; if($res!==false){
$response->end(json_encode(array('status'=>1,'message'=>'执行成功','data'=>$res))); echo 'success';
$response->end(json_encode(array('status'=>1,'message'=>'执行成功','data'=>$res)));
}else{
echo 'fail1';
$response->end(json_encode(array('status'=>0,'message'=>'执行失败')));
}
}else{ }else{
echo 'fail1'; echo 'fail2';
$response->end(json_encode(array('status'=>0,'message'=>'执行失败'))); $response->end(json_encode(array('status'=>0,'message'=>'执行失败')));
} }
}else{ }catch(Exception $ex){
echo 'fail2'; throw new Exception($ex->getMessage(),$ex->getCode());
$response->end(json_encode(array('status'=>0,'message'=>'执行失败')));
} }
}catch(Exception $ex){ }
throw new Exception($ex->getMessage(),$ex->getCode());
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment