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

摘要：于是打算做一个拥有非常好用的路由和又非常简单的框架。但也有一些自己的特色，例如支持自动化缓存自动化读写刷新保持与数据库同步，对外使用无感知。例如协议服务器地址远程的类不设置默认为当前类名其中类在框架里。

在用过laravel框架，发现它的路由和数据库ORM确实非常好用，但是整体确实有点慢，执行到控制器大于需要耗时60ms左右。于是打算做一个拥有非常好用的路由和orm又非常简单的框架。所以你会发现one框的路由和ORM有laravel的影子。但也有一些自己的特色，例如ORM支持自动化缓存(自动化读、写、刷新)保持与数据库同步，对外使用无感知。one框架也支持在fpm下运行，在fpm下框架自身整体耗时在1ms左右。

安装

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("/", AppControllersIndexController::class . "@index");

// 带参数路由
Router::get("/user/{id}", AppControllersIndexController::class . "@user");

// 路由分组 
Router::group(["namespace"=>"AppTestWebSocket"],function (){
    // websocket 路由
    Router::set("ws","/a","TestController@abc"); 
    Router::set("ws","/b","TestController@bbb"); 
});

// 中间件
Router::group([
    "middle" => [
        AppTestMixProTestMiddle::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");
});

namespace AppModel;

use OneDatabaseMysqlModel;

// 模型里面不需要指定主键，框架会缓存数据库结构
// 自动匹配主键，自动过滤非表结构里的字段
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");

启动一个websocket服务器，
添加http服务监听，
添加tcp服务监听

[
     // 主服务器
    "server" => [
        "server_type" => OneSwooleOneServer::SWOOLE_WEBSOCKET_SERVER,
        "port" => 8082,
        // 事件回调
        "action" => OneSwooleServerWsServer::class,
        "mode" => SWOOLE_PROCESS,
        "sock_type" => SWOOLE_SOCK_TCP,
        "ip" => "0.0.0.0",
        // swoole 服务器设置参数
        "set" => [
            "worker_num" => 5
        ]
    ],
    // 添加监听
    "add_listener" => [
        [
            "port" => 8081,
            // 事件回调
            "action" => AppServerAppHttpPort::class,
            "type" => SWOOLE_SOCK_TCP,
            "ip" => "0.0.0.0",
            // 给监听设置参数
            "set" => [
                "open_http_protocol" => true,
                "open_websocket_protocol" => false
            ]
        ],
        [
            "port" => 8083,
            // 打包 解包协议
            "pack_protocol" => OneProtocolText::class,
            // 事件回调
            "action" => AppTestMixProTcpPort::class,
            "type" => SWOOLE_SOCK_TCP,
            "ip" => "0.0.0.0",
            // 给监听设置参数
            "set" => [
                "open_http_protocol" => false,
                "open_websocket_protocol" => false
            ]
        ]
    ]
];

像调用本项目的方法一样调用远程服务器的方法。跨语言，跨机器。

启动rpc服务，框架已经内置了各个协议的rpc服务，添加到到上面配置文件的action即可。列如: 支持http调用，又支持tpc调用。

// http 协议 rpc服务
[
    "port"   => 8082,
    "action" => AppServerRpcHttpPort::class,
    "type"   => SWOOLE_SOCK_TCP,
    "ip"     => "0.0.0.0",
    "set"    => [
        "open_http_protocol"      => true,
        "open_websocket_protocol" => false
    ]
],
// tpc 协议 rpc服务
[
    "port"          => 8083,
    "action"        => AppServerRpcTcpPort::class,
    "type"          => SWOOLE_SOCK_TCP,
    "pack_protocol" => OneProtocolFrame::class, // tcp 打包 解包协议
    "ip"            => "0.0.0.0",
    "set"           => [
        "open_http_protocol"      => false,
        "open_websocket_protocol" => false,
        "open_length_check"       => 1,
        "package_length_func"     => "OneProtocolFrame::length",
        "package_body_offset"     => OneProtocolFrame::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在框架里。
你也可以复制到任何其他地方使用。

github

QQ交流群: 731475644