Oe-一个极简的基于swoole常驻内存框架。helloworld
安装
composer create-project lizhichao/oe-app appcd appphp App/swoole.php测试
curl https://127.0.0.1:8081/主要功能RESTful路由
中间件
websocket/tcp/http……任意协议路由
ORM模型
统一的sessio处理
mysql连接池
redis连接池
tcp连接池
HTTP/TCP/WEBOSCKET/UDP服务器
缓存
进程间内存共享
RPC(http,tcp,udp)
日志
RequestId跟踪
路由Router::get('/', \App\Cotrollers\IdexCotroller::class . '@idex');// 带参数路由Router::get('/user/{id}', \App\Cotrollers\IdexCotroller::class . '@user');// 路由分组 Router::group(['amespace'=>'App\\Test\\WebSocket'],fuctio (){ // websocket 路由 Router::set('ws','/a','TestCotroller@abc'); Router::set('ws','/b','TestCotroller@bbb'); });// 中间件Router::group([ 'middle' => [ \App\Test\MixPro\TestMiddle::class . '@checkSessio' ]], fuctio () { Router::get('/mix/ws', HttpCotroller::class . '@ws'); Router::get('/mix/http', HttpCotroller::class . '@http'); Router::post('/mix/http/loop', HttpCotroller::class . '@httpLoop'); Router::post('/mix/http/sed', HttpCotroller::class . '@httpSed');});orm模型定义模型amespace App\Model;use Oe\Database\Mysql\Model;// 模型里面不需要指定主键，框架会缓存数据库结构// 自动匹配主键，自动过滤非表结构里的字段class User exteds Model{ // 定义模型对应的表名 CONST TABLE = 'users'; // 定义关系 public fuctio articles() { retur $this->hasMay('id',Article::class,'user_id'); } // 定义事件 // 是否开启自动化缓存 // ……}使用模型在fpm下数据库连接为单列,在swoole模式下数据库连接自动切换为连接池
// 查询一条记录$user = User::fid(1);// 关联查询$user_list = User::whereI('id',[1,2,3])->with('articles')->fidAll()->toArray();// 更新$r = $user->update(['ame' => 'aaa']);// 或者$r = user::where('id',1)->update(['ame' => 'aaa']);// $r 为影响记录数量缓存// 设置缓存Cache::set('ccc',1);// 获取Cache::get('ccc');// 或者 缓存ccc 过期10s 在tag1下面Cache::get('ccc',fuctio (){ retur '缓存的信息';},10,['tag1']);// 刷新tag1下的所有缓存Cache::flush('tag1');HTTP/TCP/WEBOSCKET/UDP服务器启动一个websocket服务器，添加http服务监听，添加tcp服务监听
[ // 主服务器 'server' => [ 'server_type' => \Oe\Swoole\OeServer::SWOOLE_WEBSOCKET_SERVER, 'port' => 8082, // 事件回调 'actio' => \Oe\Swoole\Server\WsServer::class, 'mode' => SWOOLE_PROCESS, 'sock_type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', // swoole 服务器设置参数 'set' => [ 'worker_um' => 5 ] ], // 添加监听 'add_listeer' => [ [ 'port' => 8081, // 事件回调 'actio' => \App\Server\AppHttpPort::class, 'type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', // 给监听设置参数 'set' => [ 'ope_http_protocol' => true, 'ope_websocket_protocol' => false ] ], [ 'port' => 8083, // 打包 解包协议 'pack_protocol' => \Oe\Protocol\Text::class, // 事件回调 'actio' => \App\Test\MixPro\TcpPort::class, 'type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', // 给监听设置参数 'set' => [ 'ope_http_protocol' => false, 'ope_websocket_protocol' => false ] ] ]];RPC像调用本项目的方法一样调用远程服务器的方法。跨语言，跨机器。
服务端启动rpc服务，框架已经内置了各个协议的rpc服务，添加到到上面配置文件的actio即可。列如:支持http调用，又支持tpc调用。
// http 协议 rpc服务[ 'port' => 8082, 'actio' => \App\Server\RpcHttpPort::class, 'type' => SWOOLE_SOCK_TCP, 'ip' => '0.0.0.0', 'set' => [ 'ope_http_protocol' => true, 'ope_websocket_protocol' => false ]],// tpc 协议 rpc服务[ 'port' => 8083, 'actio' => \App\Server\RpcTcpPort::class, 'type' => SWOOLE_SOCK_TCP, 'pack_protocol' => \Oe\Protocol\Frame::class, // tcp 打包 解包协议 'ip' => '0.0.0.0', 'set' => [ 'ope_http_protocol' => false, 'ope_websocket_protocol' => false, 'ope_legth_check' => 1, 'package_legth_fuc' => '\Oe\Protocol\Frame::legth', 'package_body_offset' => \Oe\Protocol\Frame::HEAD_LEN, ]]添加具体服务到rpc，例如有个类Abc
class Abc{ private $a; // 初始值 public fuctio __costruct($a = 0) { $this->a = $a; } // 加法 public fuctio add($a, $b) { retur $this->a + $a + $b; } public fuctio time() { retur date('Y-m-d H:i:s'); } // 重新设初始值 public fuctio setA($a) { $this->a = $a; retur $this; }}把Abc添加到rpc服务
// 添加Abc到rpc服务RpcServer::add(Abc::class);// 如果你不希望把Abc下的所有方法都添加到rpc服务，也可以指定添加。// 未指定的方法客户端无法调用.//RpcServer::add(Abc::class,'add');// 分组添加//RpcServer::group([// // 中间件 在这里可以做 权限验证 数据加解密 等等// 'middle' => [// TestMiddle::class . '@aa'// ],// // 缓存 如果设置了 当以同样的参数调用时 会返回缓存信息 不会真正调用 单位:秒// 'cache' => 10//], fuctio () {// RpcServer::add(Abc::class);// RpcServer::add(User::class);//});客户端调用为了方便调用我们建立一个映射类（oe框架可自动生成）
class ClietAbc exteds RpcClietHttp { // rpc服务器地址 protected $_rpc_server = 'https://127.0.0.1:8082/'; // 远程的类 不设置 默认为当前类名 protected $_remote_class_ame = 'Abc';}调用rpc服务的远程方法，和调用本项目的方法一样的。你可以想象这个方法就在你的项目里面。
$abc = ew ClietAbc(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::whereI('id',[1,2,3])->with('articles')->fidAll()->toArray();上面是通过http协议调用的。你也可以通过其他协议调用。例如Tpc协议
class ClietAbc exteds RpcClietTcp { // rpc服务器地址 protected $_rpc_server = 'tcp://127.0.0.1:8083/'; // 远程的类 不设置 默认为当前类名 protected $_remote_class_ame = 'Abc';}其中类 RpcClietHttp,RpcClietTcp在框架里。你也可以复制到任何其他地方使用。
更多请看文档详细文档地址
使用列子-DEMO
评论