php 分布式环境 启动,极简.高性能.分布式框架,可运行于多种环境(apache/php-fpm,swoole)...
常规web/app后端服务器
im即时通讯服务器
tcp/udp物联网服务器
综合性项目,各种混合协议通讯
背景
在用过 laravel
框架,发现它的 路由
和 数据库ORM
确实非常好用,但是整体确实有点慢,执行到控制器大约需要耗时30ms左右。于是打算做一个拥有非常好用的路由和orm又非常简单的框架。所以你会发现one框的 路由
和 ORM
有laravel的影子。但也有一些自己的特色,例如 ORM
支持自动化缓存(自动化读、写、刷新)保持与 数据库 同步,对外使用无感知。one框架也支持在fpm下运行,在 fpm
下框架自身整体耗时在1ms左右。
hello world
安装
composer create-project lizhichao/one-app app
cd app
php App/swoole.php
复制代码
测试
curl http://127.0.0.1:8081/
复制代码
主要功能
RESTful路由
中间件
websocket/tcp/http……任意协议路由
ORM模型
统一的session处理
mysql连接池
redis连接池
协程 tcp-client 连接池
HTTP/TCP/WEBOSCKET/UDP服务器
缓存
进程间内存共享
RPC(http,tcp,udp)
日志
RequestId跟踪
分布式(长连接,事务……)
路由
Router::get('/', \App\Controllers\IndexController::class . '@index');
// 带参数路由
Router::get('/user/{id}', \App\Controllers\IndexController::class . '@user');
// 路由分组
Router::group(['namespace'=>'App\\Test\\WebSocket'],function (){
// websocket 路由
Router::set('ws','/a','TestController@abc');
Router::set('ws','/b','TestController@bbb');
});
// 中间件
Router::group([
'middle' => [
\App\Test\MixPro\TestMiddle::class . '@checkSession'
]
], function () {
Router::get('/mix/ws', HttpController::class . '@ws');
Router::get('/mix/http', HttpController::class . '@http');
Router::post('/mix/http/loop', HttpController::class . '@httpLoop');
Router::post('/mix/http/send', HttpController::class . '@httpSend');
});
复制代码
orm 模型
定义模型
namespace App\Model;
use One\Database\Mysql\Model;
// 模型里面不需要指定主键,框架会缓存数据库结构
// 自动匹配主键,自动过滤非表结构里的字段
class User extends Model
{
// 定义模型对应的表名
CONST TABLE = 'users';
// 定义关系
public function articles()
{
return $this->hasMany('id',Article::class,'user_id');
}
// 定义事件
// 是否开启自动化缓存
// ……
}
复制代码
使用模型
fpm
swoole
// 查询一条记录
$user = User::find(1);
// 关联查询
$user_list = User::whereIn('id',[1,2,3])->with('articles')->findAll()->toArray();
// 更新
$r = $user->update(['name' => 'aaa']);
// 或者
$r = user::where('id',1)->update(['name' => 'aaa']);
// $r 为影响记录数量
复制代码
缓存
// 设置缓存 无过期时间
Cache::set('ccc',1);
// 设置缓存 1分钟过期
Cache::set('ccc',1,60);
// 获取
Cache::get('ccc');
// 或者 缓存ccc 过期10s 在tag1下面
Cache::get('ccc',function (){
return '缓存的信息';
},10,['tag1']);
// 刷新tag1下的所有缓存
Cache::flush('tag1');
复制代码
HTTP/TCP/WEBSOCKET/UDP服务器
启动一个websocket服务器,
添加http服务监听,
添加tcp服务监听
[
// 主服务器
'server' => [
'server_type' => \One\Swoole\OneServer::SWOOLE_WEBSOCKET_SERVER,
'port' => 8082,
// 事件回调
'action' => \One\Swoole\Server\WsServer::class,
'mode' => SWOOLE_PROCESS,
'sock_type' => SWOOLE_SOCK_TCP,
'ip' => '0.0.0.0',
// swoole 服务器设置参数
'set' => [
'worker_num' => 5
]
],
// 添加监听
'add_listener' => [
[
'port' => 8081,
// 事件回调
'action' => \App\Server\AppHttpPort::class,
'type' => SWOOLE_SOCK_TCP,
'ip' => '0.0.0.0',
// 给监听设置参数
'set' => [
'open_http_protocol' => true,
'open_websocket_protocol' => false
]
],
[
'port' => 8083,
// 打包 解包协议
'pack_protocol' => \One\Protocol\Text::class,
// 事件回调
'action' => \App\Test\MixPro\TcpPort::class,
'type' => SWOOLE_SOCK_TCP,
'ip' => '0.0.0.0',
// 给监听设置参数
'set' => [
'open_http_protocol' => false,
'open_websocket_protocol' => false
]
]
]
];
复制代码
RPC
像调用本项目的方法一样调用远程 服务器 的方法。跨语言,跨机器。
服务端
启动rpc服务,框架已经内置了各个协议的rpc服务,添加到到上面配置文件的 action
即可。列如: 支持 http
调用,又支持 tcp
调用。
// http 协议 rpc服务
[
'port' => 8082,
'action' => \App\Server\RpcHttpPort::class,
'type' => SWOOLE_SOCK_TCP,
'ip' => '0.0.0.0',
'set' => [
'open_http_protocol' => true,
'open_websocket_protocol' => false
]
],
// tcp 协议 rpc服务
[
'port' => 8083,
'action' => \App\Server\RpcTcpPort::class,
'type' => SWOOLE_SOCK_TCP,
'pack_protocol' => \One\Protocol\Frame::class, // tcp 打包 解包协议
'ip' => '0.0.0.0',
'set' => [
'open_http_protocol' => false,
'open_websocket_protocol' => false,
'open_length_check' => 1,
'package_length_func' => '\One\Protocol\Frame::length',
'package_body_offset' => \One\Protocol\Frame::HEAD_LEN,
]
]
复制代码
添加具体服务到rpc,
例如有个类 Abc
class Abc
{
private $a;
// 初始值
public function __construct($a = 0)
{
$this->a = $a;
}
// 加法
public function add($a, $b)
{
return $this->a + $a + $b;
}
public function time()
{
return date('Y-m-d H:i:s');
}
// 重新设初始值
public function setA($a)
{
$this->a = $a;
return $this;
}
}
复制代码
把 Abc
添加到rpc服务
// 添加Abc到rpc服务
RpcServer::add(Abc::class);
// 如果你不希望把Abc下的所有方法都添加到rpc服务,也可以指定添加。
// 未指定的方法客户端无法调用.
//RpcServer::add(Abc::class,'add');
// 分组添加
//RpcServer::group([
// // 中间件 在这里可以做 权限验证 数据加解密 等等
// 'middle' => [
// TestMiddle::class . '@aa'
// ],
// // 缓存 如果设置了 当以同样的参数调用时 会返回缓存信息 不会真正调用 单位:秒
// 'cache' => 10
//], function () {
// RpcServer::add(Abc::class);
// RpcServer::add(User::class);
//});
复制代码
客户端调用
为了方便调用我们建立一个映射类(one框架可自动生成)
class ClientAbc extends RpcClientHttp {
// rpc服务器地址
protected $_rpc_server = 'http://127.0.0.1:8082/';
// 远程的类 不设置 默认为当前类名
protected $_remote_class_name = 'Abc';
}
复制代码
调用rpc服务的远程方法, 和调用本项目的方法一样的。你可以想象这个方法就在你的项目里面。
$abc = new ClientAbc(5);
// $res === 10
$res = $abc->add(2,3);
// 链式调用 $res === 105
$res = $abc->setA(100)->add(2,3);
// 如果把上面的模型的User添加到rpc
// RpcServer::add(User::class);
// 下面运行结果和上面一样
// $user_list = User::whereIn('id',[1,2,3])->with('articles')->findAll()->toArray();
复制代码
上面是通过http协议调用的。你也可以通过其他协议调用。例如Tcp协议
class ClientAbc extends RpcClientTcp {
// rpc服务器地址
protected $_rpc_server = 'tcp://127.0.0.1:8083/';
// 远程的类 不设置 默认为当前类名
protected $_remote_class_name = 'Abc';
}
复制代码
其中类 RpcClientHttp
, RpcClientTcp
在框架里。
你也可以复制到任何其他地方使用。
php 分布式环境 启动,极简.高性能.分布式框架,可运行于多种环境(apache/php-fpm,swoole)...相关推荐
- 很多小伙伴不太了解ORM框架的底层原理,这不,冰河带你10分钟手撸一个极简版ORM框架(赶快收藏吧)
大家好,我是冰河~~ 最近很多小伙伴对ORM框架的实现很感兴趣,不少读者在冰河的微信上问:冰河,你知道ORM框架是如何实现的吗?比如像MyBatis和Hibernate这种ORM框架,它们是如何实现的 ...
- 10分钟手撸极简版ORM框架!
最近很多小伙伴对ORM框架的实现很感兴趣,不少读者在冰河的微信上问:冰河,你知道ORM框架是如何实现的吗?比如像MyBatis和Hibernte这种ORM框架,它们是如何实现的呢? 为了能够让小伙伴们 ...
- 极简微前端框架-京东MicroApp开源了
前言 MicroApp是一款基于类WebComponent进行渲染的微前端框架,不同于目前流行的开源框架,它从组件化的思维实现微前端,旨在降低上手难度.提升工作效率.它是目前市面上接入微前端成本最低的 ...
- Fiber一个Go语言构建的高效、极速、极简的Web框架
更多计算机科学于技术相关文章,欢迎
- Spring Boot 极简集成 Shiro
点击关注公众号,Java干货及时送达 1. 前言 Apache Shiro是一个功能强大且易于使用的Java安全框架,提供了认证,授权,加密,和会话管理. Shiro有三大核心组件: Subject: ...
- 负载分析及问题排查极简教程
作者 | Hollis ,来自 | Hollis 平常的工作中,在衡量服务器的性能时,经常会涉及到几个指标,load.cpu.mem.qps.rt等.每个指标都有其独特的意义,很多时候在线上出现问题时 ...
- 高效sql性能优化极简教程
一,sql性能优化基础方法论 对于功能,我们可能知道必须改进什么:但对于性能问题,有时我们可能无从下手.其实,任何计算机应用系统最终队可以归结为: cpu消耗 内存使用 对磁盘,网络或其他I/O设备的 ...
- session一致性架构设计极简教程
一,缘起 什么是session? 服务器为每个用户创建一个会话,存储用户的相关信息,以便多次请求能够定位到同一个上下文. Web开发中,web-server可以自动为同一个浏览器的访问用户自动创建se ...
- 打造淘宝极简包的轻量化框架
淘宝极简包项目分离了一个可以快速搭建极简App的框架. 如今app冗余与包大小一直都是很多业务挥之不去的优化项.行业内很多极简包如雨后春笋般冒出来.又或者是很多业务对极简包的探索也有积极的尝试. 极简 ...
最新文章
- STC用PCA测量脉宽_用于相干激光雷达的大能量长脉宽单频激光器 | COL
- 网站单页面SEO关键词该如何布局更好?
- 手机轮廓光怎么拍_摄影技巧:怎么拍影子?手机拍照教程
- Python库安装相关问题
- Google Mesa概览
- 浅谈分布式消息技术 Kafka
- JAVA jdk安装
- 基于Pytorch的多任务推荐系统开源框架
- Java 使用开源类库 Tesseract 实现图片文字识别
- 如何在 Linux 上检查可用磁盘空间 [终端和 GUI]
- 训练深度学习模型的小技巧
- 窦志成:从微软到人大,只为做有温度的AI
- 1330_硬件测试中的BCI测试
- 日历时间选择 开始时间到结束时间
- salt returner mysql_saltstack mysql returner
- 双摄像头系列原理深度剖析【转载】
- Unity学习笔记(六)——顶点动画
- 乱码问题-Quoted-printable编码
- chm打开秒退_【CHM+】CHM+下载_CHM+教程 _正版CHM+下载 -爱应用
- 实验室设计如何搭配颜色色彩