<?php
//CLI命令
if(isset($argv[1]) && in_array($argv[1], ['start', 'restart', 'status', 'stop', 'reload']))define('CLI_COMMAND', $argv[1]);
else define('CLI_COMMAND', 'start');
define('ROOT',__DIR__);
define('TMP_PATH',ROOT.DIRECTORY_SEPARATOR.'tmp'.DIRECTORY_SEPARATOR);
define('APP_NAME','mySwoole');
require_once 'ServerCallFun.php';
Class Root
{static public $Ip  = '127.0.0.1';static public $port  = 9510;//swoole对象Static Public $serv = null;//进程对象Static Public $worker = null;/*** 主框架运行*/Static Public function run(){$command = 'Root::' . CLI_COMMAND;$command();}/*** 启动框架*/Static Private function start(){if(is_file(TMP_PATH . 'server.pid')){$pid = @file_get_contents(TMP_PATH . 'server.pid');if($pid && \swoole_process::kill($pid, 0))die("Framework has been started!" . PHP_EOL);}echo "Framework Starting...", PHP_EOL;date_default_timezone_set('Asia/Shanghai');$setup = ['pid_file' => TMP_PATH.'server.pid',//在Server启动时自动将master进程的PID写入到文件，在Server关闭时自动删除PID文件'reactor_num' => 4,//reactor_num建议设置为CPU核数的1-4倍'worker_num' => 4,'backlog' => 128,//Listen队列长度，如backlog => 128，此参数将决定最多同时有多少个等待accept的连接。'max_request' => 100,//设置worker进程的最大任务数，默认为0，一个worker进程在处理完超过此数值的任务后将自动退出，进程退出后会释放所有内存和资源。'dispatch_mode' =>3,//抢占模式，主进程会根据Worker的忙闲状态选择投递，只会投递给处于闲置状态的Worker'daemonize'=>true,'log_file' => TMP_PATH .'swoole.log',//开启守护进程模式后(daemonize => true)，标准输出将会被重定向到log_file。在PHP代码中echo/var_dump/print等打印到屏幕的内容会写入到log_file文件日志标号
];self::$serv = new swoole_server(self::$Ip,self::$port) or die('Swoole Starting Failed!' . PHP_EOL);self::$serv->set($setup);self::$serv->on('start', 'ServerCallFun::start');//在主进程start后调用self::$serv->on('managerstart', 'ServerCallFun::managerStart');//管理进程开启后//设置工作/任务进程启动回调self::$serv->on('workerstart', 'ServerCallFun::onWorkstart');/*self::$serv->on('request',function ($request, $response) {$response->header("Content-Type", "text/html; charset=utf-8");$response->end("<h1>Hello Swoole. #".rand(1000, 9999)."</h1>");});*///监听连接进入事件self::$serv->on('connect',function ($serv, $fd) {echo "Client: Connect.\n";});//监听数据接收事件self::$serv->on('receive','ServerCallFun::onReceive');//监听连接关闭事件self::$serv->on('close',function ($serv, $fd) {echo "Client: Close.\n";});//在启动之前添加一个全局的内存tabel监控所有的进程状态//实例启动前执行(start前的状态全部是程序全局期)self::$serv->start();}Static Private function stop(){$pid = @file_get_contents(TMP_PATH . 'server.pid');if($pid){if(\swoole_process::kill($pid, 0))\swoole_process::kill($pid, 15);else{foreach(glob(TMP_PATH . '*.pid') as $filename){$pid = @file_get_contents($filename);if(\swoole_process::kill($pid, 0))\swoole_process::kill($pid, 9);@unlink($filename);}}die('Stop of Framework Success!' . PHP_EOL);}die('Framework not started!' . PHP_EOL);}}
Root::run();

<?php
require_once 'CmdController.php';
class ServerCallFun{static function start(\swoole_server $server){\swoole_set_process_name("Master process");//绑定状态事件//\swoole_process::signal(SIGUSR1, '\Root\Http::status');//绑定重载事件\swoole_process::signal(SIGUSR2, function() use ($server){$server->reload();});}static function managerStart(\swoole_server $server){$num = count(glob(TMP_PATH . 'manager_*.pid'));file_put_contents(TMP_PATH . 'manager_'. $num .'.pid', $server->manager_pid);\swoole_set_process_name("Manager[{$num}] process");}static Public function onWorkstart(\swoole_server $server, int $worker_id){//实例化进程对象Root::$worker = new self();if($server->taskworker) {file_put_contents(TMP_PATH . "task_{$worker_id}.pid", $server->worker_pid);\swoole_set_process_name("Tasker[{$worker_id}] process ");echo "TaskID[{$worker_id}] PID[". $server->worker_pid ."] creation finish!" . PHP_EOL;} else {file_put_contents(TMP_PATH . "worker_{$worker_id}.pid", $server->worker_pid);\swoole_set_process_name("Worker[{$worker_id}] process");echo "WorkerID[{$worker_id}] PID[". $server->worker_pid ."] creation finish!" . PHP_EOL;}}static Public function onConnect($serv, $fd){}static Public function onReceive($serv, $fd, $from_id, $data){$msg = CmdController::run($data,$fd,$from_id);$serv->send($fd,json_encode($msg));}static Public function onClose($serv, $fd){}
}

<?php
class CmdController{static public $count = 0;static public function run($recive,$fd,$fromId){self::$count++;$returnArr = ['ret'=>-1,'data'=>'','msg'=>''];if($recive){$returnArr['ret']  = 0;$returnArr['data'] = self::$count.";{$fd}-{$fromId}:getRequest[{$recive}]->getReponse[Success]";}return $returnArr;}
}