Слияние кода завершено, страница обновится автоматически
#!/usr/bin/php
<?php
use \EasySwoole\Core\Utility\File;
use EasySwoole\Core\Core;
use EasySwoole\Config as Conf;
define( 'EASYSWOOLE_ROOT', realpath( getcwd() ) );
require __DIR__.'/vendor/autoload.php';
Command::exec();
// build 发布版本，把没用的去掉
Class Command
{
static function parse()
{
global $argv;
$command = '';
$options = [];
if( isset( $argv[1] ) ){
$command = $argv[1];
}
foreach( $argv as $item ){
if( substr( $item, 0, 2 ) === '--' ){
$temp = trim( $item, "--" );
$temp = explode( "-", $temp );
$key = array_shift( $temp );
$options[$key] = array_shift( $temp ) ?: '';
}
}
return [
'command' => $command,
'options' => $options,
];
}
static function exec()
{
global $argv;
$info = Command::parse();
switch( $info['command'] ){
case 'build':
$buildResult = Command::build();
if($buildResult && isset($argv[2]) && strstr($argv[2],'fashop-v')){
$copyResult = \EasySwoole\Core\Utility\File::copyDir('dist',$argv[2]);
if($copyResult===true){
shell_exec( "tar -zcvf {$argv[2]}.tar.gz ./{$argv[2]} && rm -rf ./{$argv[2]}" );
echo "\e[32m./$argv[2].tar.gz 版本创建完毕\n\e[0m";
}else{
echo "\e[32m./$argv[2].tar.gz 版本创建失败\n\e[0m";
}
}
break;
default:
Core::getInstance();
EasySwooleCommand::envCheck();
EasySwooleCommand::commandHandler();
break;
}
}
static function build()
{
$dist = './dist';
if( !is_dir( $dist ) ){
File::createDir( $dist );
} else{
File::clearDir( $dist );
}
File::createDir( $dist.'/Upload' );
$paths = [
[
'path' => './a',
'targetPath' => $dist.'/a',
'type' => 'dir',
],
[
'path' => './App',
'targetPath' => $dist.'/App',
'type' => 'dir',
],
[
'path' => './Resource/Conf',
'targetPath' => $dist.'/Conf',
'type' => 'dir',
],
[
'path' => './Resource/.gitignore',
'targetPath' => $dist.'/.gitignore',
'type' => 'file',
],
[
'path' => './Resource/fashop',
'targetPath' => $dist.'/fashop',
'type' => 'file',
],
[
'path' => './Resource/README.md',
'targetPath' => $dist.'/README.md',
'type' => 'file',
],
[
'path' => './Install/Install.php',
'targetPath' => $dist.'/Install/Install.php',
'type' => 'file',
],
[
'path' => './Resource/README.md',
'targetPath' => $dist.'/Install/README.md',
'type' => 'file',
],
[
'path' => './composer.json',
'targetPath' => $dist.'/composer.json',
'type' => 'file',
],
[
'path' => './EasySwooleEvent.php',
'targetPath' => $dist.'/EasySwooleEvent.php',
'type' => 'file',
],
[
'path' => './Resource/Db/fashop.sql',
'targetPath' => $dist.'/Install/fashop.sql',
'type' => 'file',
],
];
foreach( $paths as $path ){
if( $path['type'] === 'dir' ){
File::copyDir( $path['path'], $path['targetPath'] );
} else{
$aimDir = dirname( $path['targetPath'] );
File::createDir( $aimDir );
File::copyFile( $path['path'], $path['targetPath'] );
}
}
// 删除一些没用的
File::deleteDir( $dist.'/App/Plugin' );
File::deleteDir( $dist.'/App/Task' );
File::deleteDir( $dist.'/App/Update' );
// todo 加版权和版本号
echo "\e[32m编译完成\n\e[0m";
return true;
}
}
Class EasySwooleCommand
{
static function commandHandler()
{
list( $command, $options ) = self::commandParser();
switch( $command ){
case 'start':
self::serverStart( $options );
break;
case 'stop':
self::serverStop( $options );
break;
case 'reload':
self::serverReload( $options );
break;
case 'restart':
self::serverRestart( $options );
break;
case 'help':
default:
self::showHelp( $options );
}
}
static function commandParser()
{
global $argv;
$command = '';
$options = [];
if( isset( $argv[1] ) ){
$command = $argv[1];
}
foreach( $argv as $item ){
if( substr( $item, 0, 2 ) === '--' ){
$temp = trim( $item, "--" );
$temp = explode( "-", $temp );
$key = array_shift( $temp );
$options[$key] = array_shift( $temp ) ?: '';
}
}
return [$command, $options];
}
static function opCacheClear()
{
if( function_exists( 'apc_clear_cache' ) ){
apc_clear_cache();
}
if( function_exists( 'opcache_reset' ) ){
opcache_reset();
}
}
static function envCheck()
{
if( version_compare( phpversion(), '7.1', '<' ) ){
die( "PHP version\e[31m must >= 7.1\e[0m\n" );
}
if( version_compare( phpversion( 'swoole' ), '1.9.5', '<' ) ){
die( "Swoole extension version\e[31m must >= 1.9.5\e[0m\n" );
}
if( !class_exists( 'EasySwoole\Core\Core' ) ){
die( "Autoload fail!\nPlease try to run\e[31m composer install\e[0m in ".EASYSWOOLE_ROOT."\n" );
}
}
static function showHelp( $options )
{
$opName = '';
$args = array_keys( $options );
if( $args )
$opName = $args[0];
switch( $opName ){
case 'start':
echo <<<HELP_START
\e[33m操作:\e[0m
\e[31m easyswoole start\e[0m
\e[33m简介:\e[0m
\e[36m 执行本命令可以启动框架 可选的操作参数如下\e[0m
\e[33m参数:\e[0m
\e[32m --d \e[0m 以守护模式启动框架
\e[32m --ip\e[34m-address \e[0m 指定服务监听地址
\e[32m --p\e[34m-portNumber \e[0m 指定服务监听端口
\e[32m --pid\e[34m-fileName \e[0m 指定服务PID存储文件
\e[32m --workerNum\e[34m-num \e[0m 设置worker进程数
\e[32m --taskWorkerNum\e[34m-num \e[0m 设置Task进程数
\e[32m --user\e[34m-userName \e[0m 指定以某个用户身份执行
\e[32m --group\e[34m-groupName \e[0m 指定以某个用户组身份执行
\e[32m --cpuAffinity \e[0m 开启CPU亲和\n
HELP_START;
break;
case 'stop':
echo <<<HELP_STOP
\e[33m操作:\e[0m
\e[31m easyswoole stop\e[0m
\e[33m简介:\e[0m
\e[36m 执行本命令可以停止框架 可选的操作参数如下\e[0m
\e[33m参数:\e[0m
\e[32m --f \e[0m 强制停止服务
\e[32m --pid\e[34m-pidFile \e[0m 指定服务PID存储文件\n
HELP_STOP;
break;
case 'reload':
echo <<<HELP_STOP
\e[33m操作:\e[0m
\e[31m easyswoole reload\e[0m
\e[33m简介:\e[0m
\e[36m 执行本命令可以重启所有Worker 可选的操作参数如下\e[0m
\e[33m参数:\e[0m
\e[32m --all \e[0m 重启所有进程
\e[32m --pid\e[34m-pidFile \e[0m 指定服务PID存储文件\n
HELP_STOP;
break;
case 'install':
echo <<<HELP_INSTALL
\e[33m操作:\e[0m
\e[31m easyswoole install\e[0m
\e[33m简介:\e[0m
\e[36m 安装并初始化easySwoole相关目录\e[0m
\e[33m参数:\e[0m
\e[32m 本操作没有相关的参数\e[0m\n
HELP_INSTALL;
break;
case 'restart':
echo <<<HELP_INSTALL
\e[33m操作:\e[0m
\e[31m easyswoole restart\e[0m
\e[33m简介:\e[0m
\e[36m 停止并重新启动服务\e[0m
\e[33m参数:\e[0m
\e[32m 本操作没有相关的参数\e[0m\n
HELP_INSTALL;
break;
default:
self::showLogo();
echo <<<DEFAULTHELP
\n欢迎使用为API而生的\e[32m EasySwoole\e[0m 框架 当前版本: \e[34m2.x\e[0m
\e[33m使用:\e[0m
easyswoole [操作] [选项]
\e[33m操作:\e[0m
\e[32m install \e[0m 初始化EasySwoole
\e[32m start \e[0m 启动服务
\e[32m stop \e[0m 停止服务
\e[32m reload \e[0m 重载服务
\e[32m restart \e[0m 重启服务
\e[32m help \e[0m 查看命令的帮助信息\n
\e[31m有关某个操作的详细信息 请使用\e[0m help \e[31m命令查看 \e[0m
\e[31m如查看\e[0m start \e[31m操作的详细信息 请输入\e[0m easyswoole help --start\n\n
DEFAULTHELP;
}
}
static function showLogo()
{
echo <<<LOGO
______ _____ _
| ____| / ____| | |
| |__ __ _ ___ _ _ | (___ __ __ ___ ___ | | ___
| __| / _` | / __| | | | | \___ \ \ \ /\ / / / _ \ / _ \ | | / _ \
| |____ | (_| | \__ \ | |_| | ____) | \ V V / | (_) | | (_) | | | | __/
|______| \__,_| |___/ \__, | |_____/ \_/\_/ \___/ \___/ |_| \___|
__/ |
|___/
LOGO;
}
static function showTag( $name, $value )
{
echo "\e[32m".str_pad( $name, 20, ' ', STR_PAD_RIGHT )."\e[34m".$value."\e[0m\n";
}
static function serverStart( $options )
{
self::showLogo();
$conf = Conf::getInstance();
$inst = Core::getInstance()->initialize();
$version = \EasySwoole\Core\Component\Di::getInstance()->get( \EasySwoole\Core\Component\SysConst::VERSION );
echo "\n\e[31mEasySwoole\e[0m framework \e[34mVersion {$version}\e[0m\n\n";
// listen host set
if( isset( $options['ip'] ) ){
$conf->setConf( "MAIN_SERVER.HOST", $options['ip'] );
}
self::showTag( 'listen address', $conf->getConf( 'MAIN_SERVER.HOST' ) );
// listen port set
if( !empty( $options['p'] ) ){
$conf->setConf( "MAIN_SERVER.PORT", $options['p'] );
}
self::showTag( 'listen port', $conf->getConf( 'MAIN_SERVER.PORT' ) );
// pid file set
if( !empty( $options['pid'] ) ){
$pidFile = $options['pid'];
$conf->setConf( "MAIN_SERVER.SETTING.pid_file", $pidFile );
}
// worker num set
if( isset( $options['workerNum'] ) ){
$conf->setConf( "MAIN_SERVER.SETTING.worker_num", $options['workerNum'] );
}
self::showTag( 'worker num', $conf->getConf( 'MAIN_SERVER.SETTING.worker_num' ) );
// task worker num set
if( isset( $options['taskWorkerNum'] ) ){
$conf->setConf( "MAIN_SERVER.SETTING.task_worker_num", $options['taskWorkerNum'] );
}
self::showTag( 'task worker num', $conf->getConf( 'MAIN_SERVER.SETTING.task_worker_num' ) );
// run at user set
$user = get_current_user();
if( isset( $options['user'] ) ){
$conf->setConf( "MAIN_SERVER.SETTING.user", $options['user'] );
$user = $conf->getConf( 'MAIN_SERVER.SETTING.user' );
}
self::showTag( 'run at user', $user );
// daemonize set
$label = 'false';
if( isset( $options['d'] ) ){
$conf->setConf( "MAIN_SERVER.SETTING.daemonize", true );
$label = 'true';
}
self::showTag( 'daemonize', $label );
// cpuAffinity set
if( isset( $options['cpuAffinity'] ) ){
$conf->setConf( "MAIN_SERVER.SETTING.open_cpu_affinity", true );
}
self::showTag( 'debug enable', $conf->getConf( 'DEBUG' ) ? 'true' : 'false' );
self::showTag( 'swoole version', phpversion( 'swoole' ) );
self::showTag( 'swoole pid', getmypid() );
$inst->run();
}
static function serverStop( $options )
{
Core::getInstance()->initialize();
$Conf = Conf::getInstance();
$pidFile = $Conf->getConf( "MAIN_SERVER.SETTING.pid_file" );
if( !empty( $options['pid'] ) ){
$pidFile = $options['pid'];
}
if( file_exists( $pidFile ) ){
$pid = file_get_contents( $pidFile );
if( !swoole_process::kill( $pid, 0 ) ){
echo "PID :{$pid} not exist \n";
return false;
}
if( in_array( '-f', $options ) ){
swoole_process::kill( $pid, SIGKILL );
} else{
swoole_process::kill( $pid );
}
//等待5秒
$time = time();
$flag = false;
while( true ){
usleep( 1000 );
if( !swoole_process::kill( $pid, 0 ) ){
echo "server stop at ".date( "y-m-d h:i:s" )."\n";
if( is_file( $pidFile ) ){
unlink( $pidFile );
}
$flag = true;
break;
} else{
if( time() - $time > 5 ){
echo "stop server fail.try -f again \n";
break;
}
}
}
return $flag;
} else{
echo "PID file does not exist, please check whether to run in the daemon mode!\n";
return false;
}
}
static function serverReload( $options )
{
Core::getInstance()->initialize();
$Conf = Conf::getInstance();
$pidFile = $Conf->getConf( "MAIN_SERVER.SETTING.pid_file" );
if( !empty( $options['pid'] ) ){
$pidFile = $options['pid'];
}
if( file_exists( $pidFile ) ){
if( isset( $options['onlyTask'] ) ){
$sig = SIGUSR2;
} else{
$sig = SIGUSR1;
}
self::opCacheClear();
$pid = file_get_contents( $pidFile );
if( !swoole_process::kill( $pid, 0 ) ){
echo "pid :{$pid} not exist \n";
return;
}
swoole_process::kill( $pid, $sig );
echo "send server reload command at ".date( "y-m-d h:i:s" )."\n";
} else{
echo "PID file does not exist, please check whether to run in the daemon mode!\n";
}
}
static function serverRestart( $options )
{
if( self::serverStop( $options ) ){
$options['d'] = '';
self::serverStart( $options );
}
}
}
Вы можете оставить комментарий после Вход в систему
Неприемлемый контент может быть отображен здесь и не будет показан на странице. Вы можете проверить и изменить его с помощью соответствующей функции редактирования.
Если вы подтверждаете, что содержание не содержит непристойной лексики/перенаправления на рекламу/насилия/вульгарной порнографии/нарушений/пиратства/ложного/незначительного или незаконного контента, связанного с национальными законами и предписаниями, вы можете нажать «Отправить» для подачи апелляции, и мы обработаем ее как можно скорее.
Опубликовать ( 0 )