詳解PHP框架EasySwoole
使用 Composer 安裝
composer require easyswoole/easyswoole=3.xphp vendor/bin/easyswoole install
啟動框架
php easyswoole start
nginx轉(zhuǎn)發(fā)
server { root /data/wwwroot/; server_name local.easyswoole.com; location / { proxy_http_version 1.1; proxy_set_header Connection 'keep-alive'; proxy_set_header X-Real-IP $remote_addr; if (!-e $request_filename) { proxy_pass http://127.0.0.1:9501; } if (!-f $request_filename) { proxy_pass http://127.0.0.1:9501; } }}
proxy_set_header X-Real-IP $remote_addr; 獲取真實IP地址
運行project 項目部署目錄
----------------------------------
├─App 應用目錄
│ └─HttpController 應用的控制器目錄
│ └─Index.php 默認控制器文件
----------------------------------
Index.php
<?phpnamespace AppHttpController;use EasySwooleHttpAbstractInterfaceController;class Index extends Controller{ function index() { // TODO: Implement index() method. $this->response()->write(’hello world’); }}編輯根目錄下的composer.json 文件
注冊應用的命名空間
{ 'autoload': { 'psr-4': { 'App': 'App/' } }, 'require': { 'easyswoole/easyswoole': '3.x-dev' }}
意思就是設置自動加載
最后執(zhí)行composer dumpautoload命令更新命名空間，可以開始編寫業(yè)務邏輯
# 更新命名空間映射
composer dumpautoload
# 啟動框架
php easyswoole start
目錄結構
project 項目部署目錄
├─App 應用目錄(可以有多個)
│ ├─HttpController 控制器目錄
│ │ └─Index.php 默認控制器
│ └─Model 模型文件目錄
├─Log 日志文件目錄
├─Temp 臨時文件目錄
├─vendor 第三方類庫目錄
├─composer.json Composer架構
├─composer.lock Composer鎖定
├─EasySwooleEvent.php 框架全局事件
├─easyswoole 框架管理腳本
├─easyswoole.install 框架安裝鎖定文件
├─dev.php 開發(fā)配置文件
├─produce.php 生產(chǎn)配置文件
生命周期
<?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’,//監(jiān)聽地址 ’PORT’ => 9501,//監(jiān)聽端口 ’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進程數(shù)量 ’max_request’ => 5000,// worker 完成該數(shù)量的請求后將退出，防止內(nèi)存溢出 ’task_worker_num’ => 8,//運行的 task_worker 進程數(shù)量 ’task_max_request’ => 1000,// task_worker 完成該數(shù)量的請求后將退出，防止內(nèi)存溢出 ’reload_async’ => true,//設置異步重啟開關。設置為true時，將啟用異步安全重啟特性，Worker進程會等待異步事件完成后再退出。 ’task_enable_coroutine’ => true//開啟后自動在onTask回調(diào)中創(chuàng)建協(xié)程 ] ], ’TEMP_DIR’ => null,//臨時文件存放的目錄 ’LOG_DIR’ => null,//日志文件存放的目錄 ’CONSOLE’ => [//console控制臺組件配置 ’ENABLE’ => true,//是否開啟 ’LISTEN_ADDRESS’ => ’127.0.0.1’,//監(jiān)聽地址 ’PORT’ => 9500,//監(jiān)聽端口 ’USER’ => ’root’,//驗權用戶名 ’PASSWORD’ => ’123456’//驗權用戶名 ], ’FAST_CACHE’ => [//fastCache組件 ’PROCESS_NUM’ => 0,//進程數(shù),大于0才開啟 ’BACKLOG’ => 256,//數(shù)據(jù)隊列緩沖區(qū)大小 ], ’DISPLAY_ERROR’ => true,//是否開啟錯誤顯示 ];配置操作類
EasySwooleConfig 類
toArray 方法獲取全部配置，load 方法重載全部配置
如果設置了修改，需要更新配置的意思
<?php$instance = EasySwooleEasySwooleConfig::getInstance();// 獲取配置 按層級用點號分隔$instance->getConf(’MAIN_SERVER.SETTING.task_worker_num’);// 設置配置 按層級用點號分隔$instance->setConf(’DATABASE.host’, ’localhost’);// 獲取全部配置$conf = $instance->getConf();// 用一個數(shù)組覆蓋當前配置項$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_MAX_NUM’ => ’20’, ’POOL_MIN_NUM’ => ’5’, ’POOL_TIME_OUT’ => ’0.1’,]生產(chǎn)與開發(fā)配置分離
默認為開發(fā)模式,加載 dev.php
生成
php easyswoole start produce
DI注入配置
也就是依賴注入
<?phpDi::getInstance()->set(SysConst::ERROR_HANDLER,function (){});//配置錯誤處理回調(diào)Di::getInstance()->set(SysConst::SHUTDOWN_FUNCTION,function (){});//配置腳本結束回調(diào)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ào)Di::getInstance()->set(SysConst::HTTP_CONTROLLER_POOL_MAX_NUM,15);//http控制器對象池最大數(shù)量動態(tài)配置
每次開始了，是上一次的進程，比如你打開了舊版，現(xiàn)在更新了新版，但是舊版還是開著，沒有重啟動，也就是一直舊版，現(xiàn)在有個動態(tài)配置，表示可以平滑的修改
<?php Config::getInstance()->setDynamicConf(’test_config_value’, 0);//配置一個動態(tài)配置項 $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進程
文件熱加載由于 swoole 常駐內(nèi)存的特性，修改文件后需要重啟worker進程才能將被修改的文件重新載入內(nèi)存中
解決：Process的方式實現(xiàn)文件變動自動進行服務重載
新建文件 App/Process/HotReload.php 并添加如下內(nèi)容，也可以放在其他位置，請對應命名空間
<?phpnamespace 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; // 需要監(jiān)控的目錄 protected $monitorExt; // 需要監(jiān)控的后綴 /** * 啟動定時器進行循環(huán)掃描 */ public function run($arg) { // 此處指定需要監(jiān)視的目錄 建議只監(jiān)視App目錄下的文件變更 $this->monitorDir = !empty($arg[’monitorDir’]) ? $arg[’monitorDir’] : EASYSWOOLE_ROOT . ’/App’; // 指定需要監(jiān)控的擴展名 不屬于指定類型的的文件 無視變更 不重啟 $this->monitorExt = !empty($arg[’monitorExt’]) && is_array($arg[’monitorExt’]) ? $arg[’monitorExt’] : [’php’]; if (extension_loaded(’inotify’) && empty($arg[’disableInotify’])) { // 擴展可用 優(yōu)先使用擴展進行處理 $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進行監(jiān)控 $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 { // 修改文件 但未發(fā)生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) { // 監(jiān)測到需要進行熱重啟 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監(jiān)聽事件 */ 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(); // 為當前所有的目錄和文件添加事件監(jiān)聽 foreach ($files as $item) { inotify_add_watch($inotifyResource, $item, IN_CREATE | IN_DELETE | IN_MODIFY); } // 加入事件循環(huán) swoole_event_add($inotifyResource, function () { global $lastReloadTime; global $inotifyResource; $events = inotify_read($inotifyResource); if ($lastReloadTime < time() && !empty($events)) { // 限制1s內(nèi)不能進行重復reload $lastReloadTime = time(); ServerManager::getInstance()->getSwooleServer()->reload(); } }); } public function onShutDown() { // TODO: Implement onShutDown() method. } public function onReceive(string $str) { // TODO: Implement onReceive() method. }}
添加好后在全局的 EasySwooleEvent.php 中，注冊該自定義進程
public static function mainServerCreate(EventRegister $register){ $swooleServer = ServerManager::getInstance()->getSwooleServer(); $swooleServer->addProcess((new HotReload(’HotReload’, [’disableInotify’ => false]))->getProcess());}
以上就是詳解PHP框架EasySwoole的詳細內(nèi)容，更多關于PHP框架EasySwoole的資料請關注好吧啦網(wǎng)其它相關文章！
相關文章：
網(wǎng)公網(wǎng)安備