add one (#5920)

* add one

* readme

* add php.ini

* git

* set header

* del toarr

* Get properties from object

* Update IndexController.php

* op db

* add connects

* change connects

.travis.yml

@@ -67,7 +67,7 @@ env:
     - 'TESTDIR="PHP/comet PHP/kumbiaphp PHP/workerman PHP/webman"'
     - 'TESTDIR="PHP/cakephp PHP/codeigniter PHP/fat-free PHP/fuel PHP/phpixie PHP/slim PHP/symfony PHP/yii2 PHP/zend PHP/spiral"'
     - 'TESTDIR="PHP/amp PHP/hhvm PHP/peachpie PHP/php-ngx PHP/phalcon"'
-    - 'TESTDIR="PHP/hamlet PHP/laravel PHP/lumen PHP/swoole PHP/ubiquity PHP/hyperf PHP/sw-fw-less PHP/imi PHP/simps"'
+    - 'TESTDIR="PHP/hamlet PHP/laravel PHP/lumen PHP/swoole PHP/ubiquity PHP/hyperf PHP/sw-fw-less PHP/imi PHP/simps PHP/one"'
     - 'TESTDIR="Python/aiohttp Python/api_hour Python/apidaora Python/blacksheep Python/bottle Python/cherrypy Python/django Python/emmett Python/eve Python/falcon Python/fastapi Python/flask"'
     - 'TESTDIR="Python/hug Python/japronto Python/klein Python/morepath Python/pyramid Python/quart Python/responder Python/sanic Python/spyne Python/starlette"'
     - 'TESTDIR="Python/tornado Python/turbogears Python/uvicorn Python/uwsgi Python/vibora Python/web2py Python/webware Python/weppy Python/wsgi"'

frameworks/PHP/one/.gitignore

@@ -0,0 +1,8 @@
+/vendor
+/App/RunCache
+.idea
+.vscode
+.svn
+.DS_Store
+composer.lock
+ideHelper

frameworks/PHP/one/App/Config/cache.php

@@ -0,0 +1,10 @@
+<?php
+return [
+    'drive' => 'file', // [file | redis] 调用Cache:: 相关方法使用的缓存驱动
+
+    'file' => [
+        'path' => _APP_PATH_ . '/RunCache/cache', //文件缓存位置
+        'prefix' => 'one_' //文件前缀
+    ],
+];
+

frameworks/PHP/one/App/Config/exception.php

@@ -0,0 +1,13 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: admin
+ * Date: 2019/7/30
+ * Time: 11:24
+ */
+
+return [
+//    'render' => function(\One\Exceptions\HttpException $e){
+//        return 'err!';
+//    }
+];

frameworks/PHP/one/App/Config/mysql.php

@@ -0,0 +1,16 @@
+<?php
+
+return [
+    'debug_log' => false, // 是否打印sql日志
+    'default'      => [
+        'max_connect_count' => 30,
+        'dns'               => env('mysql.default.dns', 'mysql:host=127.0.0.1;dbname=test'),
+        'username'          => env('mysql.default.username', 'root'),
+        'password'          => env('mysql.default.password', '123456'),
+        'ops'               => [
+            PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES utf8mb4',
+            PDO::ATTR_EMULATE_PREPARES   => false,
+            PDO::ATTR_PERSISTENT         => false
+        ]
+    ]
+];

frameworks/PHP/one/App/Config/protocol.php

@@ -0,0 +1,23 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: tanszhe
+ * Date: 2018/8/24
+ * Time: 下午5:23
+ * http,websocket,tcp 服务器配置
+ */
+
+return [
+    'server' => [
+        'server_type' => \One\Swoole\OneServer::SWOOLE_HTTP_SERVER,
+        'port'        => 8080,
+        'action'      => \App\Server\AppHttpServer::class,
+        'mode'        => SWOOLE_PROCESS,
+        'sock_type'   => SWOOLE_SOCK_TCP,
+        'ip'          => '0.0.0.0',
+        'set'         => [
+            'worker_num' => swoole_cpu_num() * 2,
+            'pid_file'   => _APP_PATH_ . '/RunCache/swoole.pid'
+        ],
+    ]
+];

frameworks/PHP/one/App/Config/router.php

@@ -0,0 +1,24 @@
+<?php
+
+/**
+ * 路由设置
+ */
+
+use One\Http\Router;
+use \App\Controllers\IndexController;
+
+Router::get('/json', IndexController::class.'@toJson');
+Router::get('/plaintext', IndexController::class.'@plaintext');
+Router::get('/db', IndexController::class.'@db');
+Router::get('/fortunes', IndexController::class.'@fortunes');
+Router::get('/queries', IndexController::class.'@queries');
+Router::get('/updates', IndexController::class.'@updates');
+
+
+
+//"json_url": "/json",
+//"plaintext_url": "/plaintext",
+//"db_url": "/db",
+//"fortune_url": "/fortunes",
+//"update_url": "/updates/",
+//"query_url": "/queries/",

frameworks/PHP/one/App/Controllers/IndexController.php

@@ -0,0 +1,78 @@
+<?php
+
+namespace App\Controllers;
+
+use App\Model\Fortune;
+use App\Model\World;
+use One\Http\Controller;
+
+class IndexController extends Controller
+{
+
+    protected function json($data)
+    {
+        $this->response->header('Content-type', 'application/json; charset=UTF-8');
+        return json_encode($data);
+    }
+
+    public function toJson()
+    {
+        return $this->json(['message' => 'Hello, World!']);
+    }
+
+    public function plaintext()
+    {
+        $this->response->header('Content-Type', 'text/plain');
+        return 'Hello, World!';
+    }
+
+    public function db()
+    {
+        return $this->json(World::repeatStatement()->find(mt_rand(1, 10000)));
+    }
+
+    public function fortunes()
+    {
+        $data   = Fortune::findAll()->jsonSerialize();
+        $data[] = (object) ['id' => 0,'message' => 'Additional fortune added at request time.'];
+        usort($data, function ($a,$b){
+            return $a->message <=> $b->message;
+        });
+
+        $html = '';
+        foreach ($data as $f) {
+            $f->message = htmlspecialchars($f->message, ENT_QUOTES, 'UTF-8');
+            $html    .= "<tr><td>{$f->id}</td><td>{$f->message}</td></tr>";
+        }
+
+        $this->response->header('Content-type', 'text/html; charset=UTF-8');
+        return "<!DOCTYPE html><html><head><title>Fortunes</title></head><body><table><tr><th>id</th><th>message</th></tr>{$html}</table></body></html>";
+    }
+
+    public function updates($count = 1)
+    {
+        $count = max(min(intval($count), 500), 1);
+        $list  = [];
+        while ($count--) {
+            $row    = World::repeatStatement()->find(mt_rand(1, 10000));
+            $list[] = $row;
+            $row->repeatStatement()->update(['randomNumber' => mt_rand(1, 10000)]);
+        }
+        return $this->json($list);
+    }
+
+    public function queries($count = 1)
+    {
+        $count = max(min(intval($count), 500), 1);
+        $list  = [];
+        while ($count--) {
+            $list[] = World::repeatStatement()->find(mt_rand(1, 10000));
+        }
+        return $this->json($list);
+
+    }
+}
+
+
+
+

frameworks/PHP/one/App/Model/Fortune.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\Model;
+
+use One\Database\Mysql\Model;
+
+class Fortune extends Model
+{
+    const TABLE = 'fortune';
+
+    protected $_pri_key = 'id';
+
+    protected $_cache_time = 0;
+}

frameworks/PHP/one/App/Model/World.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\Model;
+
+use One\Database\Mysql\Model;
+
+class World extends Model
+{
+    const TABLE = 'world';
+
+    protected $_pri_key = 'id';
+
+    protected $_cache_time = 0;
+}

frameworks/PHP/one/App/Server/AppHttpServer.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Server;
+
+use App\GlobalData\Client;
+use One\Http\Router;
+use One\Swoole\Server\HttpServer;
+
+class AppHttpServer extends HttpServer
+{
+    public function onRequest(\swoole_http_request $request, \swoole_http_response $response)
+    {
+        $this->httpRouter($request, $response);
+    }
+}

frameworks/PHP/one/App/View/error.php

@@ -0,0 +1 @@
+<?=$msg;?>

frameworks/PHP/one/App/View/exceptions/4000.php

@@ -0,0 +1,2 @@
+<?php
+print_r($e);

frameworks/PHP/one/App/View/exceptions/404.php

@@ -0,0 +1,3 @@
+<?php
+// print_r($e);
+echo '404';

frameworks/PHP/one/App/app.ini

@@ -0,0 +1,13 @@
+; 基于swoole运行时 配置文件名。
+; 加载配置文件 Config/protocol.php
+server = protocol
+
+[mysql]
+;default[dns] = "mysql:host=192.168.31.123;dbname=test"
+;default[username] = admin
+;default[password] = 123456
+
+default[dns] = "mysql:host=tfb-database;dbname=hello_world"
+default[username] = benchmarkdbuser
+default[password] = benchmarkdbpass
+

frameworks/PHP/one/App/config.php

@@ -0,0 +1,13 @@
+<?php
+\One\Database\Mysql\Connect::setConfig(config('mysql', true));
+\One\Http\Router::setConfig(['path' => _APP_PATH_ . '/Config/router.php']);
+\One\Exceptions\Handler::setConfig(config('exception', true));
+\One\Swoole\OneServer::setConfig(config(env('server', 'protocol'), true));
+
+\One\Cache\File::setConfig(config('cache.file', true));
+
+\One\Http\Router::loadRouter();
+
+
+
+

frameworks/PHP/one/App/swoole.php

@@ -0,0 +1,24 @@
+<?php
+/**
+ * swoole 运行这个文件
+ * php swoole.php
+ */
+define('_APP_PATH_', __DIR__);
+
+define('_APP_PATH_VIEW_', __DIR__ . '/View');
+
+//define('_DEBUG_',true);
+
+require __DIR__ . '/../vendor/autoload.php';
+require __DIR__ . '/../vendor/lizhichao/one/src/run.php';
+require __DIR__ . '/config.php';
+
+
+\One\Swoole\OneServer::parseArgv();
+
+\Swoole\Runtime::enableCoroutine();
+
+\One\Swoole\OneServer::runAll();
+
+
+

frameworks/PHP/one/README.md

@@ -0,0 +1,367 @@
+## One - 一个极简高性能php框架，支持[swoole | php-fpm ]环境
+One - is a minimalist, high-performance PHP framework that supports the [swoole | php-fpm] environment
+
+简单、灵活、高效，让你在fpm下也能在`1ms`内响应请求。不需要改一行代码就可以在`swoole`和`php-fpm`之间来回切换，甚至可以共存。
+
+QQ交流群: 731475644
+
+珍爱生命，抵制996
+<a href="https://github.com/996icu/996.ICU/blob/master/LICENSE"><img src="https://camo.githubusercontent.com/41215df7ff78cefe41536bf897fe1c7e55b10bd2/68747470733a2f2f696d672e736869656c64732e696f2f62616467652f6c6963656e73652d416e74692532303939362d626c75652e737667" alt="LICENSE" data-canonical-src="https://img.shields.io/badge/license-Anti%20996-blue.svg" style="max-width:100%;"></a>
+
+
+## hello world
+
+安装
+
+```shell
+composer create-project lizhichao/one-app app
+cd app
+php App/swoole.php 
+```
+
+测试
+
+```shell
+curl http://127.0.0.1:8081/
+```
+
+
+## 主要特点
+
+- 高性能路由，支持贪婪匹配和优先级，支持websocket/tcp/http……任意协议，即使你添加几万条路由也不会降低解析性能
+- 可以无限嵌套的路由分组
+- 灵活的中间件
+- ORM模型，高效的关系处理一对一，一对多，多态……
+- 自动化sql模板日志
+- 统一的session处理，可在fpm和swoole之间互通
+- 自动化mysql连接池
+- 自动化redis连接池
+- 自动化协程 tcp-client 连接池
+- HTTP/TCP/WEBOSCKET/UDP服务器
+- 缓存
+- 进程间数据共享
+- 高性能RPC(http,tcp,udp)
+- 自动化traceId跟踪
+- 原生支持分布式长连接,分布式事务……
+- 极简的Actor并发模型 ，Actor之间 可跨进程，跨机器通讯
+
+## 路由
+
+```php
+
+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('/user/{id}', \App\Controllers\IndexController::class . '@user');
+    Router::post('/mix/http/send', HttpController::class . '@httpSend');
+});
+
+```
+
+## orm 模型
+
+### 定义模型
+```php
+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`模式下所有数据库操作自动切换为连接池
+
+```php
+// 查询一条记录
+$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 为影响记录数量
+
+```
+
+## 缓存
+```php
+// 设置缓存 无过期时间
+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服务监听
+
+```php
+
+[
+	 // 主服务器
+    '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
+
+像调用本项目的方法一样调用远程服务器的方法。跨语言，跨机器。
+
+### 服务端
+启动rpc服务，框架已经内置了各个协议的rpc服务，添加到到上面配置文件的`action`即可。列如: 支持`http`调用，又支持`tcp`调用。
+
+```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
+    ]
+],
+// 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，
+例如有个类`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;
+    }
+}
+
+```
+把`Abc`添加到rpc服务
+
+```php
+
+// 添加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框架可自动生成）
+
+```php
+class ClientAbc extends RpcClientHttp {
+
+    // rpc服务器地址
+    protected $_rpc_server = 'http://127.0.0.1:8082/';
+
+    // 远程的类 不设置 默认为当前类名
+    protected $_remote_class_name = 'Abc';
+}
+```
+调用rpc服务的远程方法， 和调用本项目的方法一样的。你可以想象这个方法就在你的项目里面。
+
+```php
+$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协议
+
+```php
+class ClientAbc extends RpcClientTcp {
+
+    // rpc服务器地址
+    protected $_rpc_server = 'tcp://127.0.0.1:8083/';
+
+    // 远程的类 不设置 默认为当前类名
+    protected $_remote_class_name = 'Abc';
+}
+```
+
+其中类 `RpcClientHttp`,`RpcClientTcp`在框架里。   
+你也可以复制到任何其他地方使用。
+
+    
+## 更多
+
+* [各种协议通讯列子](https://github.com/lizhichao/one-demo)
+* [rpc使用例子](https://github.com/lizhichao/one-app/tree/test_rpc)
+* [分布式长连接（tcp）例子](https://github.com/lizhichao/one-app/tree/cloud_demo)
+* [Actor例子](https://github.com/lizhichao/one-app/tree/actor_demo)
+
+## 文档
+
+* [文档地址](https://github.com/lizhichao/one-doc/blob/master/SUMMARY.md)
+* [参数验证器](https://segmentfault.com/a/1190000018434298)
+
+
+## TODO
+
+* orm支持[postgresql](https://www.postgresql.org/)
+
+QQ交流群: 731475644
+
+## 我的其他开源项目
+[纯php的分词](https://github.com/lizhichao/VicWord)
+

frameworks/PHP/one/benchmark_config.json

@@ -0,0 +1,30 @@
+{
+  "framework": "one",
+  "tests": [
+    {
+      "default": {
+        "json_url": "/json",
+        "plaintext_url": "/plaintext",
+        "db_url": "/db",
+        "fortune_url": "/fortunes",
+        "update_url": "/updates/",
+        "query_url": "/queries/",
+        "port": 8080,
+        "approach": "Realistic",
+        "classification": "Fullstack",
+        "database": "MySQL",
+        "framework": "one",
+        "language": "PHP",
+        "flavor": "None",
+        "orm": "Full",
+        "platform": "swoole",
+        "webserver": "None",
+        "os": "Linux",
+        "database_os": "Linux",
+        "display_name": "one",
+        "notes": "",
+        "versus": "swoole"
+      }
+    }
+  ]
+}

frameworks/PHP/one/composer.json

@@ -0,0 +1,28 @@
+{
+  "name": "lizhichao/one-app",
+  "type": "library",
+  "description": "一个极简的php框架，可运行在fpm或者swoole协程模式下",
+  "keywords": [
+    "swoole",
+    "framework",
+    "async",
+    "one"
+  ],
+  "license": "Apache-2.0",
+  "authors": [
+    {
+      "name": "tanszhe",
+      "email": "[email protected]"
+    }
+  ],
+  "require": {
+    "php": ">=7.1.0",
+    "lizhichao/one": ">=2.0.1",
+    "ext-json": "*"
+  },
+  "autoload": {
+    "psr-4": {
+      "App\\": "App/"
+    }
+  }
+}

frameworks/PHP/one/one.dockerfile

@@ -0,0 +1,23 @@
+FROM php:7.4
+
+RUN pecl install swoole > /dev/null && \
+    docker-php-ext-enable swoole
+
+RUN docker-php-ext-install pdo_mysql > /dev/null
+
+RUN apt -yqq update > /dev/null && \
+    apt -yqq install git unzip > /dev/null
+
+COPY . /one
+COPY php.ini /usr/local/etc/php/
+
+WORKDIR /one
+
+RUN curl -sSL https://getcomposer.org/installer | php -- --install-dir=/usr/local/bin --filename=composer
+RUN composer install --no-dev --classmap-authoritative --quiet > /dev/null
+RUN composer dumpautoload -o
+
+RUN mkdir -p /one/App/RunCache
+RUN chmod -R 777 /one/App/RunCache
+
+CMD php App/swoole.php

frameworks/PHP/one/php.ini

@@ -0,0 +1,2 @@
+opcache.enable_cli=1
+opcache.validate_timestamps=0