Skip to content

Commit

Permalink
rebuild command manager
Browse files Browse the repository at this point in the history
  • Loading branch information
@kiss291323003
kiss291323003 committed Jan 25, 2019
1 parent a743c5a commit 15fcc3f
Show file tree
Hide file tree
Showing 19 changed files with 645 additions and 383 deletions.
366 changes: 9 additions & 357 deletions bin/easyswoole
View file
Original file line number Diff line number Diff line change
@@ -1,368 +1,20 @@
#!/usr/bin/env php
<?php

use EasySwoole\EasySwoole\Command\CommandRunner;

define('EASYSWOOLE_ROOT', realpath(getcwd()));
$file = EASYSWOOLE_ROOT.'/vendor/autoload.php';
if (file_exists($file)) {
require $file;
}else{
die("include composer autoload.php fail\n");
}
$version = phpversion('swoole');
if (version_compare(phpversion('swoole'),'4.2.6','<')){
die("the swoole extension version must be >= 4.2.6 (current: {$version})\n");
}

use EasySwoole\EasySwoole\Core;
use EasySwoole\EasySwoole\SysConst;
use EasySwoole\EasySwoole\Config;
use EasySwoole\EasySwoole\ServerManager;
use EasySwoole\EasySwoole\Console\Client;

class Install
{
public static function init()
{
Core::getInstance();
//强制更新easyswoole bin管理文件
if(is_file(EASYSWOOLE_ROOT . '/easyswoole')){
unlink(EASYSWOOLE_ROOT . '/easyswoole');
}
$path = '.'.str_replace(EASYSWOOLE_ROOT,'',__FILE__);
file_put_contents(EASYSWOOLE_ROOT . '/easyswoole',"<?php require '{$path}';");
self::releaseResource(__DIR__ . '/../src/Resource/EasySwooleEvent.tpl', EASYSWOOLE_ROOT . '/EasySwooleEvent.php');
self::releaseResource(__DIR__ . '/../src/Resource/Config.php', EASYSWOOLE_ROOT . '/dev.php');
self::releaseResource(__DIR__ . '/../src/Resource/Config.php', EASYSWOOLE_ROOT . '/produce.php');
}

static function showTag($name, $value)
{
echo "\e[32m" . str_pad($name, 30, ' ', STR_PAD_RIGHT) . "\e[34m" . $value . "\e[0m\n";
}

public static function releaseResource($source, $destination)
{
clearstatcache();
$replace = true;
if (is_file($destination)) {
$filename = basename($destination);
echo "{$filename} has already existed, do you want to replace it? [ Y / N (default) ] : ";
$answer = strtolower(trim(strtoupper(fgets(STDIN))));
if (!in_array($answer, [ 'y', 'yes' ])) {
$replace = false;
}
}
if ($replace) {
copy($source, $destination);
}
}

public static function opCacheClear()
{
if (function_exists('apc_clear_cache')) {
apc_clear_cache();
}
if (function_exists('opcache_reset')) {
opcache_reset();
}
}


public static function showLogo()
{
echo <<<LOGO
______ _____ _
| ____| / ____| | |
| |__ __ _ ___ _ _ | (___ __ __ ___ ___ | | ___
| __| / _` | / __| | | | | \___ \ \ \ /\ / / / _ \ / _ \ | | / _ \
| |____ | (_| | \__ \ | |_| | ____) | \ V V / | (_) | | (_) | | | | __/
|______| \__,_| |___/ \__, | |_____/ \_/\_/ \___/ \___/ |_| \___|
__/ |
|___/
LOGO;
}

public static function showHelpForStart()
{
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 daemonize \e[0m 以守护模式启动框架
\e[32m produce \e[0m 生产模式(加载produce.env)
HELP_START;
}

public static function showHelpForStop()
{
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 force \e[0m 强制停止服务
HELP_STOP;
}

public static function showHelpForRestart()
{
echo <<<HELP_RESTART
\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_RESTART;
}

public static function showHelpForReload()
{
echo <<<HELP_RELOAD
\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 重启所有worker和task_worker进程
HELP_RELOAD;
}

public static function showHelp()
{
$version = SysConst::EASYSWOOLE_VERSION;
echo <<<DEFAULTHELP
\n欢迎使用为API而生的\e[32m easySwoole\e[0m 框架 当前版本: \e[34m{$version}\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 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;
}
}






Install::showLogo();
$commandList = $argv;
array_shift($commandList);
$mainCommand = array_shift($commandList);

switch ($mainCommand){

case 'install':{
Install::init();
echo "install success\n";
break;
}

case 'start':{
$mode = 'develop';
if(in_array('produce',$commandList)){
$mode = 'produce';
Core::getInstance()->setIsDev(false);
}
Core::getInstance()->initialize();
$conf = Config::getInstance();
if(in_array("d",$commandList) || in_array("daemonize",$commandList)){
$conf->setConf("MAIN_SERVER.SETTING.daemonize", true);
}
//创建主服务
Core::getInstance()->createServer();
$serverType = $conf->getConf('MAIN_SERVER.SERVER_TYPE');
switch ($serverType){
case 1:{
$serverType = 'SWOOLE_SERVER';
break;
}
case 2:{
$serverType = 'SWOOLE_WEB';
break;
}
case 3:{
$serverType = 'SWOOLE_WEB_SOCKET';
break;
}
default:{
$serverType = 'UNKNOWN';
}
}
Install::showTag('main server', $serverType);
Install::showTag('listen address', $conf->getConf('MAIN_SERVER.LISTEN_ADDRESS'));
Install::showTag('listen port', $conf->getConf('MAIN_SERVER.PORT'));

$list = ServerManager::getInstance()->getSubServerRegister();
$index = 1;
foreach ($list as $serverName => $item){
$type = $item['type'] % 2 > 0 ? 'SWOOLE_TCP' : 'SWOOLE_UDP';
Install::showTag('sub server'.$index, "{$serverName} => {$type}@{$item['listenAddress']}:{$item['port']}");
$index++;
}

$ips = swoole_get_local_ip();
foreach ($ips as $eth => $val){
Install::showTag('ip@'.$eth, $val);
}
$data = $conf->getConf('MAIN_SERVER.SETTING');
foreach ($data as $key => $datum){
Install::showTag($key, (string)$datum);
}
$user = $conf->getConf('MAIN_SERVER.SETTING.user');
if(empty($user)){
$user = get_current_user();
}
Install::showTag('run at user', $user);
$daemonize = $conf->getConf("MAIN_SERVER.SETTING.daemonize");
if($daemonize){
$daemonize = 'true';
}else{
$daemonize = 'false';
}
Install::showTag('daemonize', $daemonize);
Install::showTag('swoole version', phpversion('swoole'));
Install::showTag('php version', phpversion());
Install::showTag('easy swoole', SysConst::EASYSWOOLE_VERSION);
Install::showTag('develop/produce', $mode);
Install::showTag('temp dir', EASYSWOOLE_TEMP_DIR);
Install::showTag('log dir', EASYSWOOLE_LOG_DIR);
Core::getInstance()->start();
break;
}

case 'stop':{
$force = false;
if(in_array('force',$commandList)){
$force = true;
}
if(in_array('produce',$commandList)){
Core::getInstance()->setIsDev(false);
}
Core::getInstance()->initialize();
$Conf = Config::getInstance();
$pidFile = $Conf->getConf("MAIN_SERVER.SETTING.pid_file");
if (file_exists($pidFile)) {
$pid = file_get_contents($pidFile);
if (!swoole_process::kill($pid, 0)) {
echo "PID :{$pid} not exist \n";
return false;
}
if ($force) {
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;
}
break;
}

case 'reload':{
$all = false;
if(in_array('all',$commandList)){
$all = true;
}
if(in_array('produce',$commandList)){
Core::getInstance()->setIsDev(false);
}
Core::getInstance()->initialize();
$Conf =Config::getInstance();
$pidFile = $Conf->getConf("MAIN_SERVER.SETTING.pid_file");
if (file_exists($pidFile)) {
if (!$all) {
$sig = SIGUSR2;
Install::showTag('reloadType',"only-task");
} else {
$sig = SIGUSR1;
Install::showTag('reloadType',"all-worker");
}

Install::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";
}
break;
}

case 'console':{
Core::getInstance()->initialize();
if(in_array('produce',$commandList)){
Core::getInstance()->setIsDev(false);
}
$conf = Config::getInstance()->getConf('CONSOLE');
$client = new Client($conf['HOST'],$conf['PORT']);
if($client->connect()){
swoole_event_add(STDIN,function()use($client){
$ret = trim(fgets(STDIN));
if(!empty($ret)){
$client->sendCommand($ret);
}
});
}else{
fwrite(STDOUT, "connect to tcp://".$conf['HOST'].":".$conf['PORT']." fail \n");
}
break;
}

case 'help':
default:{
$com = array_shift($commandList);
if($com == 'start'){
Install::showHelpForStart();
}else if($com == 'stop'){
Install::showHelpForStop();
}else if($com == 'reload'){
Install::showHelpForReload();
}else{
Install::showHelp();
}
break;
}
}


$args = $argv;
//trim first command
array_shift($args);
$ret = CommandRunner::getInstance()->run($args);
if(!empty($ret)){
echo $ret."\n";
}
Loading

0 comments on commit 15fcc3f

Please sign in to comment.