極簡.高性能.分佈式框架，可運行於多種環境（apache/php-fpm,swoole）

時間 2019-11-17

標籤高性能分佈式框架行於多種環境 apache php fpm swoole 欄目系統架構简体版

原文原文鏈接

極簡 . 高性能 . 鬆耦合 . 分佈式 . 可運行於多種環境(cli,apache/php-fpm,swoole)

github:github.com/lizhichao/o…
碼雲:gitee.com/vicself/onephp

適用場景

常規web/app後端服務器
im即時通信服務器
tcp/udp物聯網服務器
綜合性項目，各類混合協議通信

背景

在用過laravel框架，發現它的路由和數據庫ORM確實很是好用，可是總體確實有點慢，執行到控制器大約須要耗時30ms左右。因而打算作一個擁有很是好用的路由和orm又很是簡單的框架。因此你會發現one框的路由和ORM有laravel的影子。但也有一些本身的特點，例如ORM支持自動化緩存(自動化讀、寫、刷新)保持與數據庫同步，對外使用無感知。one框架也支持在fpm下運行，在fpm下框架自身總體耗時在1ms左右。mysql

hello world

安裝laravel

composer create-project lizhichao/one-app app
cd app
php App/swoole.php 
複製代碼

測試git

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服務監聽github

[
	 // 主服務器
    '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

像調用本項目的方法同樣調用遠程服務器的方法。跨語言，跨機器。web

服務端

啓動rpc服務，框架已經內置了各個協議的rpc服務，添加到到上面配置文件的action便可。列如: 支持http調用，又支持tcp調用。redis

// 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，例若有個類Abcsql

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服務shell

// 添加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在框架裏。
你也能夠複製到任何其餘地方使用。