基于 swoole 的常驻内存框架 One-Frame

Apache
PHP
跨平台
2018-12-17
意简美

One - 一个极简的基于swoole常驻内存框架。

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连接池

  • 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);// 获取Cache::get('ccc');// 或者 缓存ccc 过期10s 在tag1下面Cache::get('ccc',function (){
    return '缓存的信息';
},10,['tag1']);// 刷新tag1下的所有缓存Cache::flush('tag1');

HTTP/TCP/WEBOSCKET/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调用,又支持tpc调用。

// 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
    ]
],
// tpc 协议 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协议调用的。你也可以通过其他协议调用。例如Tpc协议

class ClientAbc extends RpcClientTcp {

    // rpc服务器地址
    protected $_rpc_server = 'tcp://127.0.0.1:8083/';    // 远程的类 不设置 默认为当前类名
    protected $_remote_class_name = 'Abc';
}

其中类 RpcClientHttp,RpcClientTcp在框架里。
你也可以复制到任何其他地方使用。

更多请看文档

详细文档地址

使用列子-DEMO

的码云指数为
超过 的项目
加载中
此软件有 1 条评论,请先登录后再查看。

One 框架 2.0.13 发布

新增 新增表关系HasIn, 在场景 A表字段af保存的B表的id,id这种格式的时候适用 // 定义关系 public function b_info() { return $this->hasIn('af',BModel::class,'id'); } ...

07/14 10:41

php 框架 one 1.9.7 发布

一个极简高性能php框架,支持[swoole | php-fpm ]环境 简单、灵活、高效,让你在fpm下也能在1ms内响应请求。不需要改一行代码就可以在swoole和php-fpm之间来回切换,甚至可以共存。 新增 OR...

03/06 21:01

php 框架 one 1.9.5 发布

One - 一个极简高性能php框架,支持[swoole | php-fpm ]环境。 简单、灵活、高效,让你在fpm下也能在1ms内响应请求。不需要改一行代码就可以在swoole和php-fpm之间来回切换,甚至可以共存。 ...

02/28 17:12

分布式框架 one 1.6.7 发布,新增分布式并发模型Actor

One - 极简 . 高性能 . 松耦合 . 分布式 . 可运行于多种环境(cli,apache/php-fpm,swoole) 码云: https://gitee.com/vicself/one github: https://github.com/lizhichao/one 适用场景 常规web...

2019/05/16 14:26

PHP框架 one 1.6.0 发布

one 1.6.0 发布 one是一个极简的高性能框架。支持在swoole协程环境和常规的apache,php-fpm下运行 极简 . 高性能 . 松耦合 . 分布式 . 可同时运行在多种环境(命令行,apache/php-fpm,swoole) 码...

2019/04/15 15:02

极简的高性能框架 one 1.4.6 发布,新增参数验证器

one 1.4.6 新增参数验证器 one是一个极简的高性能框架。支持在swoole协程环境和常规的apache,php-fpm下运行 github: https://github.com/lizhichao/one gitee: https://gitee.com/vicself/on...

2019/03/08 18:27

one 1.4.1 发布,基于 Swoole 的极简常驻内存框架

One - 一个极简的基于swoole常驻内存框架 github: https://github.com/lizhichao/one 码云:https://gitee.com/vicself/one 1.4.1 发布: 优化 优化uuid生成规则 修复 缓存驱动为file时 noti...

2019/01/21 10:32

基于 swoole 的极简框架 One 1.3.3 发布

主要更新 添加功能: 捕获协成内抛出的错误 添加环境配置文件app.ini 添加队列以及push,pop,length方法 优化/修复功能: 在多个数据库情况下orm模型缓存结构有冲突可能 findAll()->toArray()...

2018/12/21 14:17

基于 swoole 的极简框架 One 1.3.1 发布

主要更新 添加Rpc服务支持内置了http,TCP协议支持 增加Tcp协程客户端连接池 增加 globalData 自增方法 背景 在用过laravel框架,发现它的路由和数据库ORM确实非常好用,但是整体确实有点慢,...

2018/12/17 12:36

没有更多内容

加载失败,请刷新页面

没有更多内容

暂无问答

frame

Jquery取得iframe中元素的几种方法(转载) iframe在复合文档中经常用到,利用jquery操作iframe可以大幅提高效率,这里收集一些基本操作 DOM方法: 父窗口操作IFRAME:window.frames["iframe...

2013/10/02 16:07
33
0
Frame和IFrame

1、frame不能脱离frameSet单独使用,iframe可以; 2、frame不能放在body中;如下可以正常显示: <!--<body>--> <frameset rows="50%,*"> <frame name="frame1" src="test1.htm"/> ...

2014/09/03 17:56
24
0
Tkinter之Frame

Frame俗称框架,用来承载放置其他GUI元素,可以理解为一个容器。 它能将 Windows 分成不同的区,然后存放不同的部件. 同时一个Frame 也能再分成多个子Frame。 在有不同的界面逻辑层级和功能区...

2019/10/30 13:59
18
0
切换frame

frameset不用切,frame需层层切! 很多人在用selenium定位页面元素的时候会遇到定位不到的问题,明明元素就在那儿,用firebug也可以看到,就是定位不到,这种情况很有可能是frame在搞鬼(原因...

2019/04/12 18:03
24
0
else for every frame. It added

else for every frame. It added

2015/04/30 10:59
2
0
Frame框架

表单元素 图像热区 功能与作用:可以实现一张图上可以做多个链接。 图像热区 img usemap="#Map" map area shape( rect circle poly ) coords <img src=”” usemap=”#Map” /> usemap="#Ma...

2018/04/09 10:31
22
0
frame使用问题:不能直接改变frame

1 在改变控件的frame时,不能直接改变控件的frame,直接改变不了,一定要这样处理: ActivityHeaderView *activityHeaderView = [[[NSBundle mainBundle] loadNibNamed:@"ActivityHeaderView...

2016/10/24 17:06
207
0
Packet 和 Frame

一般说来,数据链路层发出的数据包称为frame,地址是链路层的地址,如mac地址;网络层发出的数据包称为packet,地址是网络层地址,如ip地址;传输层发出的数据包称为segment,地址是传输层地...

2014/09/15 21:08
329
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部