EasySwoole框架怎样安装及使用？一文带你看懂

这篇文章我们来了解一下EasySwoole框架的内容，下文会介绍EasySwoole框架的安装及使用，以及其他的相关内容，有需要的朋友可以参考，接下来就跟随小编来一起学习一下吧！

安装

使用 Composer 安装

composer require easyswoole/easyswoole=3.xphp 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地址

运行

project 项目部署目录

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

├─App 应用目录

│ └─HttpController 应用的控制器目录

│ └─Index.php 默认控制器文件

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

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 文件

注册应用的命名空间

{

 "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,//是否开启错误显示
 ];
    

配置操作类

EasySwoole\Config 类

toArray 方法获取全部配置，load 方法重载全部配置

如果设置了修改，需要更新配置的意思

?php
$instance = \EasySwoole\EasySwoole\Config::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,'App\\HttpController\\');
    //配置控制器命名空间
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
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;
     // 需要监控的目录
 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 inotify\n";

 }
 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 comparison\n";

 }

 }

 /**
 * 扫描文件变更
 */
 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}
     files\n";
    
 ServerManager::getInstance()->
    getSwooleServer()->
    reload();

 }
 else {

 // 首次扫描不需要进行重启操作
 echo "hot reload ready at {
$time}
 use : {
$usage}
 s total: {
$count}
     files\n";
    
 $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框架怎样安装及使用应该都清楚了吧，上述示例有一定的借鉴价值，有需要的朋友可以参考学习，希望对大家学习EasySwoole框架的使用有帮助，想要了解更多大家可以关注网络其它相关文章。

文本转载自脚本之家

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！