php 分布式环境 启动,极简.高性能.分布式框架，可运行于多种环境（apache/php-fpm,swoole）...
常規(guī)web/app后端服務(wù)器
im即時(shí)通訊服務(wù)器
tcp/udp物聯(lián)網(wǎng)服務(wù)器
綜合性項(xiàng)目，各種混合協(xié)議通訊
背景
在用過(guò) laravel
框架，發(fā)現(xiàn)它的 路由
和 數(shù)據(jù)庫(kù)ORM
確實(shí)非常好用，但是整體確實(shí)有點(diǎn)慢，執(zhí)行到控制器大約需要耗時(shí)30ms左右。于是打算做一個(gè)擁有非常好用的路由和orm又非常簡(jiǎn)單的框架。所以你會(huì)發(fā)現(xiàn)one框的 路由
和 ORM
有l(wèi)aravel的影子。但也有一些自己的特色，例如 ORM
支持自動(dòng)化緩存(自動(dòng)化讀、寫(xiě)、刷新)保持與 數(shù)據(jù)庫(kù) 同步，對(duì)外使用無(wú)感知。one框架也支持在fpm下運(yùn)行，在 fpm
下框架自身整體耗時(shí)在1ms左右。
hello world
安裝
composer create-project lizhichao/one-app app
cd app
php App/swoole.php
復(fù)制代碼
測(cè)試
curl http://127.0.0.1:8081/
復(fù)制代碼
主要功能
RESTful路由
中間件
websocket/tcp/http……任意協(xié)議路由
ORM模型
統(tǒng)一的session處理
mysql連接池
redis連接池
協(xié)程 tcp-client 連接池
HTTP/TCP/WEBOSCKET/UDP服務(wù)器
緩存
進(jìn)程間內(nèi)存共享
RPC(http,tcp,udp)
日志
RequestId跟蹤
分布式(長(zhǎng)連接,事務(wù)……)
路由
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');
});
復(fù)制代碼
orm 模型
定義模型
namespace App\Model;
use One\Database\Mysql\Model;
// 模型里面不需要指定主鍵，框架會(huì)緩存數(shù)據(jù)庫(kù)結(jié)構(gòu)
// 自動(dòng)匹配主鍵，自動(dòng)過(guò)濾非表結(jié)構(gòu)里的字段
class User extends Model
{
// 定義模型對(duì)應(yīng)的表名
CONST TABLE = 'users';
// 定義關(guān)系
public function articles()
{
return $this->hasMany('id',Article::class,'user_id');
}
// 定義事件
// 是否開(kāi)啟自動(dòng)化緩存
// ……
}
復(fù)制代碼
使用模型
fpm
swoole
// 查詢一條記錄
$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ù)量
復(fù)制代碼
緩存
// 設(shè)置緩存 無(wú)過(guò)期時(shí)間
Cache::set('ccc',1);
// 設(shè)置緩存 1分鐘過(guò)期
Cache::set('ccc',1,60);
// 獲取
Cache::get('ccc');
// 或者 緩存ccc 過(guò)期10s 在tag1下面
Cache::get('ccc',function (){
return '緩存的信息';
},10,['tag1']);
// 刷新tag1下的所有緩存
Cache::flush('tag1');
復(fù)制代碼
HTTP/TCP/WEBSOCKET/UDP服務(wù)器
啟動(dòng)一個(gè)websocket服務(wù)器，
添加http服務(wù)監(jiān)聽(tīng)，
添加tcp服務(wù)監(jiān)聽(tīng)
[
// 主服務(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)聽(tīng)
'add_listener' => [
[
'port' => 8081,
// 事件回調(diào)
'action' => \App\Server\AppHttpPort::class,
'type' => SWOOLE_SOCK_TCP,
'ip' => '0.0.0.0',
// 給監(jiān)聽(tīng)設(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)聽(tīng)設(shè)置參數(shù)
'set' => [
'open_http_protocol' => false,
'open_websocket_protocol' => false
]
]
]
];
復(fù)制代碼
RPC
像調(diào)用本項(xiàng)目的方法一樣調(diào)用遠(yuǎn)程 服務(wù)器 的方法。跨語(yǔ)言，跨機(jī)器。
服務(wù)端
啟動(dòng)rpc服務(wù)，框架已經(jīng)內(nèi)置了各個(gè)協(xié)議的rpc服務(wù)，添加到到上面配置文件的 action
即可。列如: 支持 http
調(diào)用，又支持 tcp
調(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
]
],
// tcp 協(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,
]
]
復(fù)制代碼
添加具體服務(wù)到rpc，
例如有個(gè)類 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;
}
}
復(fù)制代碼
把 Abc
添加到rpc服務(wù)
// 添加Abc到rpc服務(wù)
RpcServer::add(Abc::class);
// 如果你不希望把Abc下的所有方法都添加到rpc服務(wù)，也可以指定添加。
// 未指定的方法客戶端無(wú)法調(diào)用.
//RpcServer::add(Abc::class,'add');
// 分組添加
//RpcServer::group([
// // 中間件 在這里可以做 權(quán)限驗(yàn)證 數(shù)據(jù)加解密 等等
// 'middle' => [
// TestMiddle::class . '@aa'
// ],
// // 緩存 如果設(shè)置了 當(dāng)以同樣的參數(shù)調(diào)用時(shí) 會(huì)返回緩存信息 不會(huì)真正調(diào)用 單位:秒
// 'cache' => 10
//], function () {
// RpcServer::add(Abc::class);
// RpcServer::add(User::class);
//});
復(fù)制代碼
客戶端調(diào)用
為了方便調(diào)用我們建立一個(gè)映射類(one框架可自動(dòng)生成)
class ClientAbc extends RpcClientHttp {
// rpc服務(wù)器地址
protected $_rpc_server = 'http://127.0.0.1:8082/';
// 遠(yuǎn)程的類 不設(shè)置 默認(rèn)為當(dāng)前類名
protected $_remote_class_name = 'Abc';
}
復(fù)制代碼
調(diào)用rpc服務(wù)的遠(yuǎn)程方法， 和調(diào)用本項(xiàng)目的方法一樣的。你可以想象這個(gè)方法就在你的項(xiàng)目里面。
$abc = new ClientAbc(5);
// $res === 10
$res = $abc->add(2,3);
// 鏈?zhǔn)秸{(diào)用 $res === 105
$res = $abc->setA(100)->add(2,3);
// 如果把上面的模型的User添加到rpc
// RpcServer::add(User::class);
// 下面運(yùn)行結(jié)果和上面一樣
// $user_list = User::whereIn('id',[1,2,3])->with('articles')->findAll()->toArray();
復(fù)制代碼
上面是通過(guò)http協(xié)議調(diào)用的。你也可以通過(guò)其他協(xié)議調(diào)用。例如Tcp協(xié)議
class ClientAbc extends RpcClientTcp {
// rpc服務(wù)器地址
protected $_rpc_server = 'tcp://127.0.0.1:8083/';
// 遠(yuǎn)程的類 不設(shè)置 默認(rèn)為當(dāng)前類名
protected $_remote_class_name = 'Abc';
}
復(fù)制代碼
其中類 RpcClientHttp
, RpcClientTcp
在框架里。
你也可以復(fù)制到任何其他地方使用。
總結(jié)
以上是生活随笔為你收集整理的php 分布式环境 启动,极简.高性能.分布式框架，可运行于多种环境（apache/php-fpm,swoole）...的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： window 事件
- 下一篇： php 仿高德,仿高德路线规划滑动效果