README.md 8.0 KB
Newer Older
lzc828's avatar
readme  
lzc828 已提交
1 2
# One - 一个极简的基于swoole常驻内存框架

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

lzc828's avatar
lzc828 已提交
6 7 8 9

## hello world

安装
lzc828's avatar
readme  
lzc828 已提交
10 11 12 13 14 15 16

```shell
composer create-project lizhichao/one-app app
cd app
php App/swoole.php 
```

lzc828's avatar
lzc828 已提交
17 18 19 20 21 22
测试

```shell
curl http://127.0.0.1:8081/
```

lzc828's avatar
lzc828 已提交
23 24 25 26
## 主要功能

- RESTful路由
- 中间件
lzc828's avatar
lzc828 已提交
27
- websocket/tcp/http……任意协议路由
lzc828's avatar
lzc828 已提交
28
- ORM模型
lzc828's avatar
lzc828 已提交
29 30 31 32
- 统一的session处理
- mysql连接池
- redis连接池
- tcp连接池
lzc828's avatar
lzc828 已提交
33 34 35
- HTTP/TCP/WEBOSCKET/UDP服务器
- 缓存
- 进程间内存共享
lzc828's avatar
lzc828 已提交
36
- RPC(http,tcp,udp)
lzc828's avatar
lzc828 已提交
37
- 日志
lzc828's avatar
lzc828 已提交
38
- RequestId跟踪
lzc828's avatar
lzc828 已提交
39 40


lzc828's avatar
readme  
lzc828 已提交
41 42 43
## 路由

```php
lzc828's avatar
lzc828 已提交
44

lzc828's avatar
readme  
lzc828 已提交
45 46 47 48 49
Router::get('/', \App\Controllers\IndexController::class . '@index');

// 带参数路由
Router::get('/user/{id}', \App\Controllers\IndexController::class . '@user');

lzc828's avatar
readme  
lzc828 已提交
50 51
// 路由分组 
Router::group(['namespace'=>'App\\Test\\WebSocket'],function (){
lzc828's avatar
lzc828 已提交
52 53 54 55 56 57 58 59 60 61 62 63 64 65 66
	// 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');
lzc828's avatar
readme  
lzc828 已提交
67 68
});

lzc828's avatar
readme  
lzc828 已提交
69 70 71 72 73 74 75 76 77 78
```

## orm 模型

### 定义模型
```php
namespace App\Model;

use One\Database\Mysql\Model;

lzc828's avatar
lzc828 已提交
79 80
// 模型里面不需要指定主键,框架会缓存数据库结构
// 自动匹配主键,自动过滤非表结构里的字段
lzc828's avatar
readme  
lzc828 已提交
81 82
class User extends Model
{
lzc828's avatar
lzc828 已提交
83
	// 定义模型对应的表名
lzc828's avatar
readme  
lzc828 已提交
84 85
    CONST TABLE = 'users';

lzc828's avatar
lzc828 已提交
86
	// 定义关系
lzc828's avatar
readme  
lzc828 已提交
87 88 89 90
    public function articles()
    {
        return $this->hasMany('id',Article::class,'user_id');
    }
lzc828's avatar
lzc828 已提交
91 92 93 94
    
    // 定义事件 
    // 是否开启自动化缓存 
    // ……
lzc828's avatar
readme  
lzc828 已提交
95 96 97
}
```

lzc828's avatar
lzc828 已提交
98
### 使用模型
lzc828's avatar
readme  
lzc828 已提交
99

lzc828's avatar
lzc828 已提交
100 101
`fpm`下数据库连接为单列,
`swoole`模式下数据库连接自动切换为连接池
lzc828's avatar
readme  
lzc828 已提交
102 103 104

```php
// 查询一条记录
lzc828's avatar
lzc828 已提交
105
$user = User::find(1);
lzc828's avatar
readme  
lzc828 已提交
106 107

// 关联查询
lzc828's avatar
lzc828 已提交
108
$user_list = User::whereIn('id',[1,2,3])->with('articles')->findAll()->toArray();
lzc828's avatar
readme  
lzc828 已提交
109 110

// 更新
lzc828's avatar
lzc828 已提交
111 112 113 114
$r = $user->update(['name' => 'aaa']);
// 或者
$r = user::where('id',1)->update(['name' => 'aaa']);
// $r 为影响记录数量
lzc828's avatar
readme  
lzc828 已提交
115 116 117 118 119

```

## 缓存
```php
lzc828's avatar
lzc828 已提交
120 121
// 设置缓存
Cache::set('ccc',1);
lzc828's avatar
readme  
lzc828 已提交
122

lzc828's avatar
lzc828 已提交
123 124
// 获取
Cache::get('ccc');
lzc828's avatar
readme  
lzc828 已提交
125

lzc828's avatar
lzc828 已提交
126 127 128 129
// 或者 缓存ccc 过期10s 在tag1下面
Cache::get('ccc',function (){
    return '缓存的信息';
},10,['tag1']);
lzc828's avatar
readme  
lzc828 已提交
130

lzc828's avatar
lzc828 已提交
131 132
// 刷新tag1下的所有缓存
Cache::flush('tag1');
lzc828's avatar
readme  
lzc828 已提交
133 134 135

```
        
lzc828's avatar
lzc828 已提交
136
## HTTP/TCP/WEBOSCKET/UDP服务器
lzc828's avatar
readme  
lzc828 已提交
137

lzc828's avatar
lzc828 已提交
138 139 140
启动一个websocket服务器,
添加http服务监听,
添加tcp服务监听
lzc828's avatar
readme  
lzc828 已提交
141 142 143 144

```php

[
lzc828's avatar
lzc828 已提交
145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186
	 // 主服务器
    '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
            ]
        ]
lzc828's avatar
readme  
lzc828 已提交
187
    ]
lzc828's avatar
lzc828 已提交
188 189 190 191 192 193 194
];


```

## RPC

lzc828's avatar
lzc828 已提交
195
像调用本项目的方法一样调用远程服务器的方法。跨语言,跨机器。
lzc828's avatar
lzc828 已提交
196

lzc828's avatar
lzc828 已提交
197
### 服务端
lzc828's avatar
lzc828 已提交
198
启动rpc服务,框架已经内置了各个协议的rpc服务,添加到到上面配置文件的`action`即可。列如: 支持`http`调用,又支持`tpc`调用。
lzc828's avatar
lzc828 已提交
199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228

```php
// 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
    ]
],
// tpc 协议 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,
lzc828's avatar
lzc828 已提交
229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260
例如有个类`Abc`

```php 

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;
    }
}
lzc828's avatar
readme  
lzc828 已提交
261 262

```
lzc828's avatar
lzc828 已提交
263
`Abc`添加到rpc服务
lzc828's avatar
readme  
lzc828 已提交
264

lzc828's avatar
lzc828 已提交
265
```php
lzc828's avatar
readme  
lzc828 已提交
266

lzc828's avatar
lzc828 已提交
267 268 269
// 添加Abc到rpc服务
RpcServer::add(Abc::class);

lzc828's avatar
lzc828 已提交
270 271
// 如果你不希望把Abc下的所有方法都添加到rpc服务,也可以指定添加。
// 未指定的方法客户端无法调用.
lzc828's avatar
lzc828 已提交
272 273 274 275 276 277 278 279
//RpcServer::add(Abc::class,'add');

// 分组添加
//RpcServer::group([
//    // 中间件 在这里可以做 权限验证 数据加解密 等等
//    'middle' => [
//        TestMiddle::class . '@aa'
//    ],
lzc828's avatar
lzc828 已提交
280
//    // 缓存 如果设置了 当以同样的参数调用时 会返回缓存信息 不会真正调用 单位:秒
lzc828's avatar
lzc828 已提交
281 282 283 284 285 286 287 288 289 290
//    'cache'  => 10
//], function () {
//    RpcServer::add(Abc::class);
//    RpcServer::add(User::class);
//});
```

### 客户端调用

为了方便调用我们建立一个映射类(one框架可自动生成)
lzc828's avatar
readme  
lzc828 已提交
291 292

```php
lzc828's avatar
lzc828 已提交
293
class ClientAbc extends RpcClientHttp {
lzc828's avatar
readme  
lzc828 已提交
294

lzc828's avatar
lzc828 已提交
295
    // rpc服务器地址
lzc828's avatar
lzc828 已提交
296
    protected $_rpc_server = 'http://127.0.0.1:8082/';
lzc828's avatar
readme  
lzc828 已提交
297

lzc828's avatar
lzc828 已提交
298
    // 远程的类 不设置 默认为当前类名
lzc828's avatar
lzc828 已提交
299 300
    protected $_remote_class_name = 'Abc';
}
lzc828's avatar
readme  
lzc828 已提交
301
```
lzc828's avatar
lzc828 已提交
302
调用rpc服务的远程方法, 和调用本项目的方法一样的。你可以想象这个方法就在你的项目里面。
lzc828's avatar
readme  
lzc828 已提交
303

lzc828's avatar
lzc828 已提交
304 305
```php
$abc = new ClientAbc(5);
lzc828's avatar
readme  
lzc828 已提交
306

lzc828's avatar
lzc828 已提交
307 308
// $res === 10
$res = $abc->add(2,3);
lzc828's avatar
readme  
lzc828 已提交
309

lzc828's avatar
lzc828 已提交
310
// 链式调用 $res === 105
lzc828's avatar
lzc828 已提交
311
$res = $abc->setA(100)->add(2,3);
lzc828's avatar
lzc828 已提交
312 313 314 315 316 317

// 如果把上面的模型的User添加到rpc
// RpcServer::add(User::class);
// 下面运行结果和上面一样
// $user_list = User::whereIn('id',[1,2,3])->with('articles')->findAll()->toArray();

lzc828's avatar
lzc828 已提交
318 319 320 321 322 323 324 325
```

上面是通过http协议调用的。你也可以通过其他协议调用。例如Tpc协议

```php
class ClientAbc extends RpcClientTcp {

    // rpc服务器地址
lzc828's avatar
lzc828 已提交
326
    protected $_rpc_server = 'tcp://127.0.0.1:8083/';
lzc828's avatar
lzc828 已提交
327

lzc828's avatar
lzc828 已提交
328
    // 远程的类 不设置 默认为当前类名
lzc828's avatar
lzc828 已提交
329 330 331 332 333
    protected $_remote_class_name = 'Abc';
}
```

其中类 `RpcClientHttp`,`RpcClientTcp`在框架里。   
lzc828's avatar
lzc828 已提交
334 335 336 337 338 339 340 341 342
你也可以复制到任何其他地方使用。

## 更多请看文档

[详细文档地址](https://www.kancloud.cn/vic-one/php-one/826876)

[使用列子-DEMO](https://github.com/lizhichao/one-demo)

QQ交流群: 731475644