One-Frame基于 swoole 的常駐內(nèi)存框架
One - 一個極簡的基于swoole常駐內(nèi)存框架。
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……任意協(xié)議路由
-
ORM模型
-
統(tǒng)一的session處理
-
mysql連接池
-
redis連接池
-
tcp連接池
-
HTTP/TCP/WEBOSCKET/UDP服務(wù)器
-
緩存
-
進程間內(nèi)存共享
-
RPC(http,tcp,udp)
-
日志
-
RequestId跟蹤
路由
Router::get('/', \App\Controllers\IndexController::class . '@index');
// 帶參數(shù)路由
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;// 模型里面不需要指定主鍵，框架會緩存數(shù)據(jù)庫結(jié)構(gòu)// 自動匹配主鍵，自動過濾非表結(jié)構(gòu)里的字段class User extends Model{
// 定義模型對應(yīng)的表名
CONST TABLE = 'users'; // 定義關(guān)系
public function articles()
{
return $this->hasMany('id',Article::class,'user_id');
}
// 定義事件
// 是否開啟自動化緩存
// ……
}
使用模型
在fpm下數(shù)據(jù)庫連接為單列, 在swoole模式下數(shù)據(jù)庫連接自動切換為連接池
// 查詢一條記錄$user = User::find(1);// 關(guān)聯(lián)查詢$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 為影響記錄數(shù)量
緩存
// 設(shè)置緩存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服務(wù)器
啟動一個websocket服務(wù)器， 添加http服務(wù)監(jiān)聽， 添加tcp服務(wù)監(jiān)聽
[ // 主服務(wù)器 'server' => [ 'server_type' => \One\Swoole\OneServer::SWOOLE_WEBSOCKET_SERVER, 'port' => 8082, // 事件回調(diào) 'action' => \One\Swoole\Server\WsServer::class, 'mode' => SWOOLE_PROCESS, 'sock_type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', // swoole 服務(wù)器設(shè)置參數(shù) 'set' => [ 'worker_num' => 5 ] ], // 添加監(jiān)聽 'add_listener' => [ [ 'port' => 8081, // 事件回調(diào) 'action' => \App\Server\AppHttpPort::class, 'type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', // 給監(jiān)聽設(shè)置參數(shù) 'set' => [ 'open_http_protocol' => true, 'open_websocket_protocol' => false ] ], [ 'port' => 8083, // 打包 解包協(xié)議 'pack_protocol' => \One\Protocol\Text::class, // 事件回調(diào) 'action' => \App\Test\MixPro\TcpPort::class, 'type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', // 給監(jiān)聽設(shè)置參數(shù) 'set' => [ 'open_http_protocol' => false, 'open_websocket_protocol' => false ] ] ] ];
RPC
像調(diào)用本項目的方法一樣調(diào)用遠程服務(wù)器的方法?？缯Z言，跨機器。
服務(wù)端
啟動rpc服務(wù)，框架已經(jīng)內(nèi)置了各個協(xié)議的rpc服務(wù)，添加到到上面配置文件的action即可。列如: 支持http調(diào)用，又支持tpc調(diào)用。
// http 協(xié)議 rpc服務(wù) [ '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 協(xié)議 rpc服務(wù) [ 'port' => 8083, 'action' => \App\Server\RpcTcpPort::class, 'type' => SWOOLE_SOCK_TCP, 'pack_protocol' => \One\Protocol\Frame::class, // tcp 打包 解包協(xié)議 '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, ] ]
添加具體服務(wù)到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');
} // 重新設(shè)初始值
public function setA($a)
{
$this->a = $a; return $this;
}
}
把Abc添加到rpc服務(wù)
// 添加Abc到rpc服務(wù)
RpcServer::add(Abc::class);
// 如果你不希望把Abc下的所有方法都添加到rpc服務(wù)，也可以指定添加。
// 未指定的方法客戶端無法調(diào)用.
//RpcServer::add(Abc::class,'add');
// 分組添加
//RpcServer::group([
// // 中間件 在這里可以做 權(quán)限驗證 數(shù)據(jù)加解密 等等
// 'middle' => [
// TestMiddle::class . '@aa'
// ],
// // 緩存 如果設(shè)置了 當(dāng)以同樣的參數(shù)調(diào)用時 會返回緩存信息 不會真正調(diào)用 單位:秒
// 'cache' => 10
//], function () {
// RpcServer::add(Abc::class);
// RpcServer::add(User::class);
//});
客戶端調(diào)用
為了方便調(diào)用我們建立一個映射類（one框架可自動生成）
class ClientAbc extends RpcClientHttp {
// rpc服務(wù)器地址
protected $_rpc_server = 'http://127.0.0.1:8082/'; // 遠程的類 不設(shè)置 默認為當(dāng)前類名
protected $_remote_class_name = 'Abc';
}
調(diào)用rpc服務(wù)的遠程方法， 和調(diào)用本項目的方法一樣的。你可以想象這個方法就在你的項目里面。
$abc = new ClientAbc(5);// $res === 10$res = $abc->add(2,3);// 鏈式調(diào)用 $res === 105$res = $abc->setA(100)->add(2,3);// 如果把上面的模型的User添加到rpc// RpcServer::add(User::class);// 下面運行結(jié)果和上面一樣// $user_list = User::whereIn('id',[1,2,3])->with('articles')->findAll()->toArray();
上面是通過http協(xié)議調(diào)用的。你也可以通過其他協(xié)議調(diào)用。例如Tpc協(xié)議
class ClientAbc extends RpcClientTcp {
// rpc服務(wù)器地址
protected $_rpc_server = 'tcp://127.0.0.1:8083/'; // 遠程的類 不設(shè)置 默認為當(dāng)前類名
protected $_remote_class_name = 'Abc';
}
其中類 RpcClientHttp,RpcClientTcp在框架里。
你也可以復(fù)制到任何其他地方使用。
更多請看文檔
評論
圖片
表情