亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

詳解PHP框架EasySwoole

 更新時(shí)間：2021年05月31日 10:30:42   作者：八重櫻  
EasySwoole是一款常駐內(nèi)存型的分布式swoole框架，專為API而生，支持同時(shí)混合監(jiān)聽(tīng)HTTP、WebSocket、自定義TCP、UDP協(xié)議，且擁有豐富的組件，例如協(xié)程 連接池、TP風(fēng)格的協(xié)程ORM、協(xié)程微信SDK等諸多組件。讓開(kāi)發(fā)者編寫出多進(jìn)程，可異步，高可用的應(yīng)用服務(wù)。

安裝

使用 Composer 安裝

composer require easyswoole/easyswoole=3.xphp vendor/bin/easyswoole install

啟動(dòng)框架

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; 獲取真實(shí)IP地址

運(yùn)行

project              項(xiàng)目部署目錄

----------------------------------

├─App        應(yīng)用目錄

│  └─HttpController      應(yīng)用的控制器目錄

│     └─Index.php    默認(rèn)控制器文件

----------------------------------

Index.php

<?php
namespace App\HttpController;
use EasySwoole\Http\AbstractInterface\Controller;
class Index extends Controller
{
 function index()
 {
 // TODO: Implement index() method.
 $this->response()->write('hello world');
 }
}

編輯根目錄下的composer.json 文件

注冊(cè)應(yīng)用的命名空間

{
 "autoload": {
 "psr-4": {
 "App\\": "App/"
 }
 },
 "require": {
 "easyswoole/easyswoole": "3.x-dev"
 }
}

意思就是設(shè)置自動(dòng)加載

最后執(zhí)行composer dumpautoload

命令更新命名空間，可以開(kāi)始編寫業(yè)務(wù)邏輯

# 更新命名空間映射

composer dumpautoload

# 啟動(dòng)框架

php easyswoole start

目錄結(jié)構(gòu)

project                   項(xiàng)目部署目錄

├─App                     應(yīng)用目錄(可以有多個(gè))

│  ├─HttpController       控制器目錄

│  │  └─Index.php         默認(rèn)控制器

│  └─Model                模型文件目錄

├─Log                     日志文件目錄

├─Temp                    臨時(shí)文件目錄

├─vendor                  第三方類庫(kù)目錄

├─composer.json           Composer架構(gòu)

├─composer.lock           Composer鎖定

├─EasySwooleEvent.php     框架全局事件

├─easyswoole              框架管理腳本

├─easyswoole.install      框架安裝鎖定文件

├─dev.php                 開(kāi)發(fā)配置文件

├─produce.php             生產(chǎn)配置文件

生命周期

配置文件說(shuō)明

<?php
 /**
 * Created by PhpStorm.
 * User: yf
 * Date: 2019-01-01
 * Time: 20:06
 */
 return [
 'SERVER_NAME' => "EasySwoole",//服務(wù)名
 'MAIN_SERVER' => [
 'LISTEN_ADDRESS' => '0.0.0.0',//監(jiān)聽(tīng)地址
 'PORT' => 9501,//監(jiān)聽(tīng)端口
 'SERVER_TYPE' => EASYSWOOLE_WEB_SERVER, //可選為 EASYSWOOLE_SERVER  EASYSWOOLE_WEB_SERVER EASYSWOOLE_WEB_SOCKET_SERVER
 'SOCK_TYPE' => SWOOLE_TCP,//該配置項(xiàng)當(dāng)為SERVER_TYPE值為TYPE_SERVER時(shí)有效
 'RUN_MODEL' => SWOOLE_PROCESS,// 默認(rèn)Server的運(yùn)行模式
 'SETTING' => [// Swoole Server的運(yùn)行配置（ 完整配置可見(jiàn)[Swoole文檔](https://wiki.swoole.com/wiki/page/274.html) ）
 'worker_num' => 8,//運(yùn)行的  worker進(jìn)程數(shù)量
 'max_request' => 5000,// worker 完成該數(shù)量的請(qǐng)求后將退出，防止內(nèi)存溢出
 'task_worker_num' => 8,//運(yùn)行的 task_worker 進(jìn)程數(shù)量
 'task_max_request' => 1000,// task_worker 完成該數(shù)量的請(qǐng)求后將退出，防止內(nèi)存溢出
 'reload_async' => true,//設(shè)置異步重啟開(kāi)關(guān)。設(shè)置為true時(shí)，將啟用異步安全重啟特性，Worker進(jìn)程會(huì)等待異步事件完成后再退出。
 'task_enable_coroutine' => true//開(kāi)啟后自動(dòng)在onTask回調(diào)中創(chuàng)建協(xié)程
 ]
 ],
 'TEMP_DIR' => null,//臨時(shí)文件存放的目錄
 'LOG_DIR' => null,//日志文件存放的目錄
 'CONSOLE' => [//console控制臺(tái)組件配置
 'ENABLE' => true,//是否開(kāi)啟
 'LISTEN_ADDRESS' => '127.0.0.1',//監(jiān)聽(tīng)地址
 'PORT' => 9500,//監(jiān)聽(tīng)端口
 'USER' => 'root',//驗(yàn)權(quán)用戶名
 'PASSWORD' => '123456'//驗(yàn)權(quán)用戶名
 ],
 'FAST_CACHE' => [//fastCache組件
 'PROCESS_NUM' => 0,//進(jìn)程數(shù),大于0才開(kāi)啟
 'BACKLOG' => 256,//數(shù)據(jù)隊(duì)列緩沖區(qū)大小
 ],
 'DISPLAY_ERROR' => true,//是否開(kāi)啟錯(cuò)誤顯示
 ];

配置操作類

EasySwoole\Config 類

toArray 方法獲取全部配置，load 方法重載全部配置

如果設(shè)置了修改，需要更新配置的意思

<?php
$instance = \EasySwoole\EasySwoole\Config::getInstance();
// 獲取配置 按層級(jí)用點(diǎn)號(hào)分隔
$instance->getConf('MAIN_SERVER.SETTING.task_worker_num');
// 設(shè)置配置 按層級(jí)用點(diǎn)號(hào)分隔
$instance->setConf('DATABASE.host', 'localhost');
// 獲取全部配置
$conf = $instance->getConf();
// 用一個(gè)數(shù)組覆蓋當(dāng)前配置項(xiàng)
$conf['DATABASE'] = [
 'host' => '127.0.0.1',
 'port' => 13306
];
$instance->load($conf);

添加用戶配置項(xiàng)

'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)與開(kāi)發(fā)配置分離

默認(rèn)為開(kāi)發(fā)模式,加載 dev.php

生成

php easyswoole start produce

DI注入配置

也就是依賴注入

<?php
Di::getInstance()->set(SysConst::ERROR_HANDLER,function (){});//配置錯(cuò)誤處理回調(diào)
Di::getInstance()->set(SysConst::SHUTDOWN_FUNCTION,function (){});//配置腳本結(jié)束回調(diào)
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_NAMESPACE,'App\\HttpController\\');//配置控制器命名空間
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_MAX_DEPTH,5);//配置http控制器最大解析層級(jí)
Di::getInstance()->set(SysConst::HTTP_EXCEPTION_HANDLER,function (){});//配置http控制器異?；卣{(diào)
Di::getInstance()->set(SysConst::HTTP_CONTROLLER_POOL_MAX_NUM,15);//http控制器對(duì)象池最大數(shù)量

動(dòng)態(tài)配置

每次開(kāi)始了，是上一次的進(jìn)程，比如你打開(kāi)了舊版，現(xiàn)在更新了新版，但是舊版還是開(kāi)著，沒(méi)有重啟動(dòng)，也就是一直舊版，現(xiàn)在有個(gè)動(dòng)態(tài)配置，表示可以平滑的修改

<?php
 Config::getInstance()->setDynamicConf('test_config_value', 0);//配置一個(gè)動(dòng)態(tài)配置項(xiàng)
 $test_config_value_1 = Config::getInstance()->getDynamicConf('test_config_value');//獲取一個(gè)配置
 Config::getInstance()->delDynamicConf('test_config_value');//刪除一個(gè)配置

服務(wù)管理腳本

php easyswoole

 install       安裝easySwoole

 start         啟動(dòng)easySwoole

 stop          停止easySwoole(守護(hù)模式下使用)

 reload        重啟easySwoole(守護(hù)模式下使用)

 help          查看命令的幫助信息

easyswoole help -start

守護(hù)模式啟動(dòng)

php easyswoole start d

線上

php easyswoole start produce

停止

php easyswoole stop

重啟服務(wù)

php easyswoole reload 只重啟task進(jìn)程

php easyswoole reload all  重啟task + worker進(jìn)程

文件熱加載

由于 swoole 常駐內(nèi)存的特性，修改文件后需要重啟worker進(jìn)程才能將被修改的文件重新載入內(nèi)存中

解決：Process的方式實(shí)現(xiàn)文件變動(dòng)自動(dòng)進(jìn)行服務(wù)重載

新建文件 App/Process/HotReload.php 并添加如下內(nèi)容，也可以放在其他位置，請(qǐng)對(duì)應(yīng)命名空間

<?php
namespace App\Process;
use EasySwoole\Component\Process\AbstractProcess;
use EasySwoole\EasySwoole\ServerManager;
use EasySwoole\Utility\File;
use Swoole\Process;
use Swoole\Table;
use Swoole\Timer;
/**
 * 暴力熱重載
 * Class HotReload
 * @package App\Process
 */
class HotReload extends AbstractProcess
{
 /** @var \swoole_table $table */
 protected $table;
 protected $isReady = false;
 protected $monitorDir; // 需要監(jiān)控的目錄
 protected $monitorExt; // 需要監(jiān)控的后綴
 /**
 * 啟動(dòng)定時(shí)器進(jìn)行循環(huán)掃描
 */
 public function run($arg)
 {
 // 此處指定需要監(jiān)視的目錄 建議只監(jiān)視App目錄下的文件變更
 $this->monitorDir = !empty($arg['monitorDir']) ? $arg['monitorDir'] : EASYSWOOLE_ROOT . '/App';
 // 指定需要監(jiān)控的擴(kuò)展名 不屬于指定類型的的文件 無(wú)視變更 不重啟
 $this->monitorExt = !empty($arg['monitorExt']) && is_array($arg['monitorExt']) ? $arg['monitorExt'] : ['php'];
 if (extension_loaded('inotify') && empty($arg['disableInotify'])) {
 // 擴(kuò)展可用 優(yōu)先使用擴(kuò)展進(jìn)行處理
 $this->registerInotifyEvent();
 echo "server hot reload start : use inotify\n";
 } else {
 // 擴(kuò)展不可用時(shí) 進(jìn)行暴力掃描
 $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 comparison\n";
 }
 }
 /**
 * 掃描文件變更
 */
 private function runComparison()
 {
 $startTime = microtime(true);
 $doReload = false;
 $dirIterator = new \RecursiveDirectoryIterator($this->monitorDir);
 $iterator = new \RecursiveIteratorIterator($dirIterator);
 $inodeList = array();
 // 迭代目錄全部文件進(jìn)行檢查
 foreach ($iterator as $file) {
 /** @var \SplFileInfo $file */
 $ext = $file->getExtension();
 if (!in_array($ext, $this->monitorExt)) {
 continue; // 只檢查指定類型
 } else {
 // 由于修改文件名稱 并不需要重新載入 可以基于inode進(jìn)行監(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尋找需要?jiǎng)h除的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)測(cè)到需要進(jìn)行熱重啟
 echo "severReload at {$time} use : {$usage} s total: {$count} files\n";
 ServerManager::getInstance()->getSwooleServer()->reload();
 } else {
 // 首次掃描不需要進(jìn)行重啟操作
 echo "hot reload ready at {$time} use : {$usage} s total: {$count} files\n";
 $this->isReady = true;
 }
 }
 }
 /**
 * 注冊(cè)Inotify監(jiān)聽(tīng)事件
 */
 private function registerInotifyEvent()
 {
 // 因?yàn)檫M(jìn)程獨(dú)立 且當(dāng)前是自定義進(jìn)程 全局變量只有該進(jìn)程使用
 // 在確定不會(huì)造成污染的情況下 也可以合理使用全局變量
 global $lastReloadTime;
 global $inotifyResource;
 $lastReloadTime = 0;
 $files = File::scanDirectory(EASYSWOOLE_ROOT . '/App');
 $files = array_merge($files['files'], $files['dirs']);
 $inotifyResource = inotify_init();
 // 為當(dāng)前所有的目錄和文件添加事件監(jiān)聽(tīng)
 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)不能進(jìn)行重復(fù)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 中，注冊(cè)該自定義進(jìn)程

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

以上就是詳解PHP框架EasySwoole的詳細(xì)內(nèi)容，更多關(guān)于PHP框架EasySwoole的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

最新評(píng)論