详解PHP框架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());
}

以上就是详解PHP框架EasySwoole的详细内容,更多关于PHP框架EasySwoole的资料请关注我们其它相关文章!

时间: 2021-05-28

thinkphp框架类库扩展操作示例

本文实例讲述了thinkphp框架类库扩展操作.分享给大家供大家参考,具体如下: 官方文档 http://document.thinkphp.cn/manual_3_2.html#lib_extend 自定义命名空间 在项目的application->common->conf文件下添加 'AUTOLOAD_NAMESPACE' => array( 'Lib' => APP_PATH . 'Home\Lib', ) Home\Lib 表示扩展路径在application->ho

PHP框架实现WebSocket在线聊天通讯系统

ThinkPHP使用Swoole需要安装 think-swoole Composer包,前提系统已经安装好了Swoole PECL 拓展 tp5的项目根目录下执行composer命令安装think-swoole: composer require topthink/think-swoole 话不多说,直接上代码: 新建WebSocket.php控制器: (监听端口要确认服务器放行,宝塔环境还需要添加安全组规则) <?php namespace app\home\controller; use t

PHP实现用户异地登录提醒功能的方法【基于thinkPHP框架】

本文实例讲述了PHP实现用户异地登录提醒功能的方法.分享给大家供大家参考,具体如下: 对于安全性要求比较高的web网站,特别是后台管理,有时候需要甄别自己的账号是否被盗或者是否有另一个人此刻登陆了在进行后台操作,这些都会很不安全,为了避免两个人同时登录同时操作,可以强制下线一个账号. 通过IP判断当然是不行的,因为IP是随时会在某一个网段内变化的,但是有一个机制,恰巧可以解决这个,那就是session,只要使用同一个浏览器访问网站,浏览器不关闭每个来访者的session_id是不变的,这也正是解

自制PHP框架之模型与数据库

什么是模型? 我们的WEB系统一定会和各种数据打交道,实际开发过程中,往往一个类对应了关系数据库的一张或多张数据表,这里就会出现两个问题. 1.类和数据表,一方修改会导致另一方的修改,只要数据表结构不定下来,业务逻辑的开发几乎没法开工 2.获取数据时会牵涉很多SQL语句的拼接,如果数据结构变动,这些SQL需要改写 假如要开发一个博客系统,我们先设计两个Model和两张数据表 第一张数据表,表名是post,存储了博客文章,数据如下: 第二章数据表,表名是comment,存储了博客文章的评论,数据如

自制PHP框架之路由与控制器

我们为什么要使用路由?原因1:一个更漂亮的URI 1.URI的改进 刚刚开始学PHP时,我们一定写过blog.php?id=1之类的URI,使用GET方式获取参数.这样的URI有两个缺点,一是容易被SQL注射攻击,二是维护性可读性差,大家可以比较下面两种URI哪一种更具备可读性. www.mysite.com/blog.php?id=1 上面URI是我们初学PHP最常用的. www.mysite.com/blog/1 这种URI是目前最流行的URI,举个例子,比如很多读书类,电影类网站,都使用了

自制PHP框架之设计模式

为什么要使用设计模式? 设计模式,我的理解是为了达到"可复用"这个目标,而设计的一套相互协作的类. 感兴趣的读者可以阅读<Design Patterns: Elements of Reusable Object-Oriented Software>,四位作者(Gang of Four)在书中列举了业界闻名的23种设计模式. 这里先介绍我们框架要涉及的三种设计模式. 单例模式(singleton) 单例模式可以保证一个类只有一个对象实例, 常用在数据库存取类,从而节省硬件资源

thinkPHP框架乐观锁和悲观锁实例分析

本文实例讲述了thinkPHP框架乐观锁和悲观锁.分享给大家供大家参考,具体如下: 乐观锁: 例子对于一个正在出售的火爆商品,同一个时间,同时有10个人同时发起了10个线程来购买,10个线程读取到数据库的库存有20件和version为9. 那么乐观锁读取num数量和version版本两个字段,在更新的结果时候,我们就要更新条件where version=9这条语句,具体UPDATE goods SET num=num-1,version=version+1 WHERE version=9 and

easyswoole一键安装脚本及宝塔安装错误问题

常见问题 在新接触easyswoole的phper中,经常遇到以下几个问题 安装步骤多 麻烦 宝塔等集成环境下容易出错 自己会安装,但是懒 有没有一键的? 开始创造 本人作为easyswoole开发组组员之一.为生态的完善和偷懒着想,在某一天讨论中就开始有了这个想法. 并且写下了这个小脚本 需要注意的是,这只是几句很简单的命令,并且在文档中都有出现.只是文档有比较多的场景描述,可能导致有些新人没有细心观看到. 在宝塔面板中,如果按照easyswoole文档第一步骤进行安装的话,是会产生错误的,在

浅谈laravel框架与thinkPHP框架的区别

主要区别:(thinkPHP更适合国人的编码习惯) 1.渲染模版方式的不同: 在Laravel框架里,使用return view()来渲染模版; 而ThinkPHP里则使用了$this->display()的方式渲染模版; 2.在Laravel框架里,由于其考虑到了跨站请求伪造, 所以如果使用form表单以post方式进行传值时,如果不再form表单中加入{{csrf_field()}}则会报出TokenMethodnotfound的语法错误; 而TP框架则需要自己手动完成防止跨站攻击的代码;

浅谈Laravel POST,PUT,PATCH 路由的区别

经常会混淆HTTP的POST/PUT方法,因为这两个方法似乎都可以用来创建或更新一个资源. 区别是细微但清楚的: POST方法用来创建一个子资源,如 /api/users,会在users下面创建一个user,如users/1 POST方法不是幂等的,多次执行,将导致多条相同的用户被创建(users/1,users/2 -而这些用户除了自增长id外有着相同的数据,除非你的系统实现了额外的数据唯一性检查) 而PUT方法用来创建一个URI已知的资源,或对已知资源进行完全替换,比如users/1, 因此

浅谈laravel框架sql中groupBy之后排序的问题

最近在用框架给公司App写接口时,碰到了一个棘手的问题: 对查询结果进行排序并进行分页(进行了简略修改),下面是最终结果代码: $example = Example::select(DB::raw('max(id) as some_id,this_id')) ->where('id', $id) ->groupBy('this_id') ->orderBy('some_id', 'desc') ->skip($offset) ->take($limit) ->get()

浅谈Laravel模板实体转义带来的坑

问题 最近在Laravel项目中用到了百度编辑器,插入到数据库我保存的是原始的html标签代码,没有进行实体转义.然后在修改的时候,需要读取到数据库中的数据,进行回显,这时候竟然在编辑器里面显示html标签代码<p>123</p>,这让我很尴尬,因为以前在tp框架中也是这样写的,但是没有问题. 搜索之路 在知道问题之后,我就开始找百度了,因为一开始的时候我并不知道是框架的原因,我以为是百度编辑器版本的原因,然后收到了许多答案,都是围绕着htmlentities和html_entit

浅谈laravel数据库查询返回的数据形式

版本:laravel5.4+ 问题描述:laravel数据库查询返回的数据不是单纯的数组形式,而是数组与类似stdClass Object这种对象的结合体,即使在查询构造器中调用了toArray(),也无法转换成单纯的数组形式. 问题解析: (以上图片来源于laravel学院5.3版本到5.4版本的升级手册) 如上图所示:Laravel不再支持在配置文件中定制PDO的"fetch mode",取而代之,总是使用PDO::FETCH_OBJ,如果你仍然想要为应用定制fetch模式,需要监

浅谈laravel中的关联查询with的问题

表结构 主表结构: Create Table CREATE TABLE `user` ( `uid` mediumint(8) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(255) COLLATE utf8mb4_unicode_ci NOT NULL, `email` varbinary(255) NOT NULL, PRIMARY KEY (`uid`) ) ENGINE=InnoDB AUTO_INCREMENT=114001 DEFA

浅谈laravel 5.6 安装 windows上使用composer的安装过程

在介绍下面的时候,先看一下 laravel 5.6 的环境要求 所以大家的php版本一定不要小于 7.1.3 ,我本地使用的是wamp 3.1.0 64位, php可以选择 7.1.9 一.下载compser 由于一些电脑直接下载composer.exe安装时会有很多问题,所以建议使用命令行安装,我在 E盘 下面建了个composer文件夹 ,打开cmd,进入 这个composer文件夹 1.执行以下命令: php -r "copy('https://getcomposer.org/instal

浅谈laravel aliases别名的原理

在laravel发现有些类可以直接use 类名,就能使用了,例如use DB;就可以使用DB类了,问题是DB这个类并不在根命名空间,这里面实际就是用到了别名. 先通过如下例子来分析基本原理 建立如下文件upload.php,内容为 <?php namespace test\test2; class upload{ public function test(){ return 123; } } 2 建立文件index.php,内容为 <?php namespace b; require('upl

浅谈laravel orm 中的一对多关系 hasMany

个人对于laravel orm 中对于一对多关系的理解 文章表 article,文章自然可以评论,表 comment 记录文章的评论,文章和评论的关系就是一对多,一篇文章可以有多个评论. 在 comment 表中有字段 article 记录评论所属文章,文章和评论的关系如下: article:id  ... ... comment : id ... ... article_id  在 comment 表中有关联 article 的外键 article_id,所以在 Comment 模型中是 be

浅谈Laravel中的三种中间件的作用

在之前一直简单的认为中间件就是往middleware里添加中间件即可.现在才知道中间件有三种类型,分别为:$middleware $middlewareGroup $routeMiddleware 通过查阅资料,终于明白了这三种类型的作用和不同. 第一种,全局中间件/$middleware: 我们的每一次请求,这里面的每个中间件都会执行. 第二种,路由中间件/$routeMiddleware: 定义在该属性内的中间件,只能在定义路由的时候引用. 假设这是我们定义的路由中间件: protected