EasySwoole 基礎入門
2020-07-16 10:05:54
使用 Composer 安裝
composer require easyswoole/easyswoole=3.x php vendor/bin/easyswoole install
啟動框架
php easyswoole start
nginx轉發
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地址
執行你的hellword
project 專案部署目錄 ---------------------------------- ├─App 應用目錄 │ └─HttpController 應用的控制器目錄 │ └─Index.php 預設控制器檔案 ----------------------------------
Index.php
<?php
namespace 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"
}
}意思就是設定自動載入
最後執行composer dumpautoload 命令更新名稱空間，可以開始編寫業務邏輯
# 更新名稱空間對映 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 開發組態檔 ├─produce.php 生產組態檔
生命週期，也就是流程
組態檔說明
<?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,//是否開啟錯誤顯示
];設定操作類
EasySwooleConfig 類
toArray 方法獲取全部設定，load 方法過載全部設定
如果設定了修改，需要更新設定的意思
<?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_MAX_NUM' => '20',
'POOL_MIN_NUM' => '5',
'POOL_TIME_OUT' => '0.1',
],生產與開發設定分離
預設為開發模式,載入 dev.php
生成
php easyswoole start produce
DI注入設定
也就是依賴注入
<?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進程
檔案熱載入
由於 swoole 常駐記憶體的特性，修改檔案後需要重新啟動worker進程才能將被修改的檔案重新載入記憶體中
解決：Process的方式實現檔案變動自動進行服務過載
新建檔案 App/Process/HotReload.php 並新增如下內容，也可以放在其他位置，請對應名稱空間
<?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.
}
}新增好後在全域性的 EasySwooleEvent.php 中，註冊該自定義進程
public static function mainServerCreate(EventRegister $register)
{
$swooleServer = ServerManager::getInstance()->getSwooleServer();
$swooleServer->addProcess((new HotReload('HotReload', ['disableInotify' => false]))->getProcess());
}以上就是EasySwoole 基礎入門的詳細內容，更多請關注TW511.COM其它相關文章！