EasySwoole 基础入门

<?php
 /**
 * Created by PhpStorm.
 * User: yf
 * Date: 2019-01-01
 * Time: 20:06
 */
 return [
 'SERVER_NAME' => "EasySwoole",//服务名
 'MAIN_SERVER' => [
 'LISTEN_ADDRESS' => '0.0.0.0',//监听地址
 'PORT' => 9501,//监听端口
 'SERVER_TYPE' => EASYSWOOLE_WEB_SERVER,//可选为 EASYSWOOLE_SERVER  EASYSWOOLE_WEB_SERVER EASYSWOOLE_WEB_SOCKET_SERVER
 'SOCK_TYPE' => SWOOLE_TCP,//该配置项当为SERVER_TYPE值为TYPE_SERVER时有效
 'RUN_MODEL' => SWOOLE_PROCESS,// 默认Server的运行模式
 'SETTING' => [// Swoole Server的运行配置（ 完整配置可见[Swoole文档](https://wiki.swoole.com/wiki/page/274.html) ）
 'worker_num' => 8,//运行的  worker进程数量
 'max_request' => 5000,// worker 完成该数量的请求后将退出，防止内存溢出
 'task_worker_num' => 8,//运行的 task_worker 进程数量
 'task_max_request' => 1000,// task_worker 完成该数量的请求后将退出，防止内存溢出
 'reload_async' => true,//设置异步重启开关。设置为true时，将启用异步安全重启特性，Worker进程会等待异步事件完成后再退出。
 'task_enable_coroutine' => true//开启后自动在onTask回调中创建协程
 ]
 ],'TEMP_DIR' => null,//临时文件存放的目录
 'LOG_DIR' => null,//日志文件存放的目录
 'CONSOLE' => [//console控制台组件配置
 'ENABLE' => true,//是否开启
 'LISTEN_ADDRESS' => '127.0.0.1',//监听地址
 'PORT' => 9500,//监听端口
 'USER' => 'root',//验权用户名
 'PASSWORD' => '123456'//验权用户名
 ],'FAST_CACHE' => [//fastCache组件
 'PROCESS_NUM' => 0,//进程数,大于0才开启
 'BACKLOG' => 256,//数据队列缓冲区大小
 ],'DISPLAY_ERROR' => true,//是否开启错误显示
 ];

<?php
$instance = EasySwooleEasySwooleConfig::getInstance();
// 获取配置 按层级用点号分隔
$instance->getConf('MAIN_SERVER.SETTING.task_worker_num');
// 设置配置 按层级用点号分隔
$instance->setConf('DATABASE.host','localhost');
// 获取全部配置
$conf = $instance->getConf();
// 用一个数组覆盖当前配置项
$conf['DATABASE'] = [
 'host' => '127.0.0.1','port' => 13306
];
$instance->load($conf);

'MYSQL' => [
 'host' => '192.168.75.1','port' => '3306','user' => 'root','timeout' => '5','charset' => 'utf8mb4','password' => 'root','database' => 'cry','POOL_MAX_NUM' => '20','POOL_TIME_OUT' => '0.1',],/*################ REDIS CONFIG ##################*/
'REDIS' => [
 'host' => '127.0.0.1','port' => '6379','auth' => '','POOL_MIN_NUM' => '5',

php easyswoole start produce

<?php
Di::getInstance()->set(SysConst::ERROR_HANDLER,function (){});//配置错误处理回调
Di::getInstance()->set(SysConst::SHUTDOWN_FUNCTION,function (){});//配置脚本结束回调
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_NAMESPACE,'AppHttpController');//配置控制器命名空间
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_MAX_DEPTH,5);//配置http控制器最大解析层级
Di::getInstance()->set(SysConst::HTTP_EXCEPTION_HANDLER,function (){});//配置http控制器异常回调
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_POOL_MAX_NUM,15);//http控制器对象池最大数量

<?php
 Config::getInstance()->setDynamicConf('test_config_value',0);//配置一个动态配置项
 $test_config_value_1 = Config::getInstance()->getDynamicConf('test_config_value');//获取一个配置
 Config::getInstance()->delDynamicConf('test_config_value');//删除一个配置

php easyswoole
 install       安装easySwoole
 start         启动easySwoole
 stop          停止easySwoole(守护模式下使用)
 reload        重启easySwoole(守护模式下使用)
 help          查看命令的帮助信息
easyswoole help -start

php easyswoole start d 

php easyswoole start produce

php easyswoole stop 

php easyswoole reload 只重启task进程
php easyswoole reload all  重启task + worker进程

<?php
/**
 * Created by PhpStorm.
 * User: evalor
 * Date: 2018-11-26
 * Time: 23:18
 */
namespace AppProcess;
use EasySwooleComponentProcessAbstractProcess;
use EasySwooleEasySwooleServerManager;
use EasySwooleUtilityFile;
use SwooleProcess;
use SwooleTable;
use SwooleTimer;
/**
 * 暴力热重载
 * Class HotReload
 * @package AppProcess
 */
class HotReload extends AbstractProcess
{
 /** @var swoole_table $table */
 protected $table;
 protected $isReady = false;
 protected $monitorDir; // 需要监控的目录
 protected $monitorExt; // 需要监控的后缀
 /**
 * 启动定时器进行循环扫描
 */
 public function run($arg)
 {
 // 此处指定需要监视的目录 建议只监视App目录下的文件变更
 $this->monitorDir = !empty($arg['monitorDir']) ? $arg['monitorDir'] : EASYSWOOLE_ROOT . '/App';
 // 指定需要监控的扩展名 不属于指定类型的的文件 无视变更 不重启
 $this->monitorExt = !empty($arg['monitorExt']) && is_array($arg['monitorExt']) ? $arg['monitorExt'] : ['php'];
 if (extension_loaded('inotify') && empty($arg['disableInotify'])) {
 // 扩展可用 优先使用扩展进行处理
 $this->registerInotifyEvent();
 echo "server hot reload start : use inotifyn";
 } else {
 // 扩展不可用时 进行暴力扫描
 $this->table = new Table(512);
 $this->table->column('mtime',Table::TYPE_INT,4);
 $this->table->create();
 $this->runComparison();
 Timer::tick(1000,function () {
 $this->runComparison();
 });
 echo "server hot reload start : use timer tick comparisonn";
 }
 }
 /**
 * 扫描文件变更
 */
 private function runComparison()
 {
 $startTime = microtime(true);
 $doReload = false;
 $dirIterator = new RecursiveDirectoryIterator($this->monitorDir);
 $iterator = new RecursiveIteratorIterator($dirIterator);
 $inodeList = array();
 // 迭代目录全部文件进行检查
 foreach ($iterator as $file) {
 /** @var SplFileInfo $file */
 $ext = $file->getExtension();
 if (!in_array($ext,$this->monitorExt)) {
 continue; // 只检查指定类型
 } else {
 // 由于修改文件名称 并不需要重新载入 可以基于inode进行监控
 $inode = $file->getInode();
 $mtime = $file->getMTime();
 array_push($inodeList,$inode);
 if (!$this->table->exist($inode)) {
 // 新建文件或修改文件 变更了inode
 $this->table->set($inode,['mtime' => $mtime]);
 $doReload = true;
 } else {
 // 修改文件 但未发生inode变更
 $oldTime = $this->table->get($inode)['mtime'];
 if ($oldTime != $mtime) {
 $this->table->set($inode,['mtime' => $mtime]);
 $doReload = true;
 }
 }
 }
 }
 foreach ($this->table as $inode => $value) {
 // 迭代table寻找需要删除的inode
 if (!in_array(intval($inode),$inodeList)) {
 $this->table->del($inode);
 $doReload = true;
 }
 }
 if ($doReload) {
 $count = $this->table->count();
 $time = date('Y-m-d H:i:s');
 $usage = round(microtime(true) - $startTime,3);
 if (!$this->isReady == false) {
 // 监测到需要进行热重启
 echo "severReload at {$time} use : {$usage} s total: {$count} filesn";
 ServerManager::getInstance()->getSwooleServer()->reload();
 } else {
 // 首次扫描不需要进行重启操作
 echo "hot reload ready at {$time} use : {$usage} s total: {$count} filesn";
 $this->isReady = true;
 }
 }
 }
 /**
 * 注册Inotify监听事件
 */
 private function registerInotifyEvent()
 {
 // 因为进程独立 且当前是自定义进程 全局变量只有该进程使用
 // 在确定不会造成污染的情况下 也可以合理使用全局变量
 global $lastReloadTime;
 global $inotifyResource;
 $lastReloadTime = 0;
 $files = File::scanDirectory(EASYSWOOLE_ROOT . '/App');
 $files = array_merge($files['files'],$files['dirs']);
 $inotifyResource = inotify_init();
 // 为当前所有的目录和文件添加事件监听
 foreach ($files as $item) {
 inotify_add_watch($inotifyResource,$item,IN_CREATE | IN_DELETE | IN_MODIFY);
 }
 // 加入事件循环
 swoole_event_add($inotifyResource,function () {
 global $lastReloadTime;
 global $inotifyResource;
 $events = inotify_read($inotifyResource);
 if ($lastReloadTime < time() && !empty($events)) { // 限制1s内不能进行重复reload
 $lastReloadTime = time();
 ServerManager::getInstance()->getSwooleServer()->reload();
 }
 });
 }
 public function onShutDown()
 {
 // TODO: Implement onShutDown() method.
 }
 public function onReceive(string $str)
 {
 // TODO: Implement onReceive() method.
 }
}

public static function mainServerCreate(EventRegister $register)
{
 $swooleServer = ServerManager::getInstance()->getSwooleServer();
 $swooleServer->addProcess((new HotReload('HotReload',['disableInotify' => false]))->getProcess());
}