V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
onanying
V2EX  ›  PHP

使用 mix/vega + mix/db 进行现代化的原生 PHP 开发

  •  1
     
  •   onanying · 2021-07-07 17:14:23 +08:00 · 1497 次点击
    这是一个创建于 1240 天前的主题,其中的信息可能已经有所发展或是发生改变。

    最近几年在 javascript 、golang 生态中游走,发现很多 npm 、go mod 的优点。最近回过头开发 MixPHP V3,发现 composer 其实一直都是一个非常优秀的工具,但是 phper 们对 composer 的用法很多都不是很深入,今天我就采用 composer 手撸一个原生项目,帮助大家理解现代化的原生 PHP 开发流程。

    PHP 的开发者可能是所有语言里被惯坏的最厉害的,因为几乎每个框架都提供了脚手架,像这样:

    composer create-project
    

    这个在 npm 、go mod 是没有这个功能的,需要自己创建程序骨架,当然 npm 和 go 生态产生了自己的解决方案,就是 vue-cli 和 mixcli 这样的脚手架工具来负责创建。

    创建一个项目

    和 npm init 、go mod init 一样,我们使用 composer init 创建一个项目

    mkdir hello
    cd hello
    composer init 
    

    交互式填写一些内容后,生成了 composer.json 文件

    {
        "name": "liujian/hello",
        "type": "project",
        "autoload": {
            "psr-4": {
                "Liujian\\Hello\\": "src/"
            }
        },
        "require": {}
    }
    

    这个文件是以 composer 库的标准创建的,必须要两级名称,这让我很蛋疼,所以我修改一下

    {
        "name": "project/app",
        "type": "project",
        "autoload": {
            "psr-4": {
                "App\\": "src/"
            }
        },
        "require": {}
    }
    

    选择我需要使用的库

    和 node.js 、go 生态一样,第二步就是寻找我们需要的库,通常我们的需求是写一个 API 服务,就需要一个 http server 库,一个 db 库就可以开始工作了。

    由于是现代化的 PHP 开发,因此我选择了 PHP CLI 模式的常驻高性能库,这里我选择的是:

    • mix/vega Vega 是一个用 PHP 编写的 CLI 模式 HTTP 网络框架,支持 Swoole 、WorkerMan
    • mix/database 可在各种环境中使用的轻量数据库,支持 FPM 、Swoole 、WorkerMan,可选的连接池 (协程)

    这两个都是 MixPHP V3+ 的核心组件。

    Mix Vega & Mix Database 安装

    Vega 同时支持 Swoole 、WorkerMan,以后还会支持 Swow,最简单原则,因为 WorkerMan 可以不需要安装扩展即可执行,开发先采用 WorkerMan 来驱动 Vega,上线可根据自己的需要切换。

    安装 Workerman

    composer require workerman/workerman
    

    安装 Mix Vega

    composer require mix/vega
    

    安装 Mix Database

    composer require mix/database
    

    创建一个入口文件

    vue 的入口通常是 src/main.js 因为 js 通常是单入口项目,我们还是按二进制的惯例,创建一个 bin/start.php 入口文件

    <?php
    require __DIR__ . '/../vendor/autoload.php';
    
    $vega = new Mix\Vega\Engine();
    $vega->handleF('/hello', function (Mix\Vega\Context $ctx) {
        $ctx->string(200, 'hello, world!');
    })->methods('GET');
    
    $http_worker = new Workerman\Worker("http://0.0.0.0:2345");
    $http_worker->onMessage = $vega->handler();
    $http_worker->count = 4;
    Workerman\Worker::runAll();
    

    然后我们模仿 npm 的搞法,在 composer.json 增加:

    "scripts": {
          "server": "php bin/start.php start"
    },
    

    这里我非常困惑 composer 的搞法,npm 的入口文件中可不需要 require __DIR__ . '/../vendor/autoload.php'; 直接 npm run server 执行的脚本是自己可以找到对应依赖的,但是 composer 即便使用 composer run server 执行对应的脚本,依然要在代码里处理 autoload,给差评。

    现在我们 composer run server 启动服务试试:

    % composer run server
    > php8 bin/start.php start
    Workerman[bin/start.php] start in DEBUG mode
    ----------------------------------------- WORKERMAN -----------------------------------------
    Workerman version:4.0.19          PHP version:8.0.7
    ------------------------------------------ WORKERS ------------------------------------------
    proto   user            worker          listen                 processes    status           
    tcp     liujian         none            http://0.0.0.0:2345    4             [OK]            
    ---------------------------------------------------------------------------------------------
    Press Ctrl+C to stop. Start success.
    

    写一个 API 接口

    我们将上面的入口文件改造一下,写一个用户查询接口,Vega 的使用非常简单。

    <?php
    
    require __DIR__ . '/../vendor/autoload.php';
    
    const DSN = 'mysql:host=127.0.0.1;port=3306;charset=utf8;dbname=test';
    const USERNAME = 'root';
    const PASSWORD = '123456';
    
    $db = new \Mix\Database\Database(DSN, USERNAME, PASSWORD);
    
    $vega = new Mix\Vega\Engine();
    $vega->handleF('/users/{id}', function (Mix\Vega\Context $ctx) use ($db) {
        $row = $db->table('users')->where('id = ?', $ctx->param('id'))->first();
        if (!$row) {
            throw new \Exception('User not found');
        }
        $ctx->JSON(200, [
            'code' => 0,
            'message' => 'ok',
            'data' => $row
        ]);
    })->methods('GET');
    
    $http_worker = new Workerman\Worker("http://0.0.0.0:2345");
    $http_worker->onMessage = $vega->handler();
    $http_worker->count = 4;
    Workerman\Worker::runAll();
    

    curl 测试一下:

    % curl http://127.0.0.1:2345/users/1
    {"code":0,"message":"ok","data":{"id":"1","name":"foo2","balance":"102","add_time":"2021-07-06 08:40:20"}}
    

    使用 PSR 调整一下目录结构

    前面我们定义了 PSR

    "autoload": {
        "psr-4": {
            "App\\": "src/"
        }
    },
    

    接下来我们采用自动加载来合理拆分上面入口文件的代码,拆分后目录结构如下:

    ├── bin
    │   └── start.php
    ├── composer.json
    ├── composer.lock
    ├── src
    │   ├── Controller
    │   │   └── Users.php
    │   ├── Database
    │   │   └── DB.php
    │   └── Router
    │       └── Vega.php
    └── vendor
    
    • bin/start.php
    <?php
    
    require __DIR__ . '/../vendor/autoload.php';
    
    $vega = \App\Router\Vega::new();
    
    $http_worker = new Workerman\Worker("http://0.0.0.0:2345");
    $http_worker->onMessage = $vega->handler();
    $http_worker->count = 8;
    Workerman\Worker::runAll();
    
    • src/Router/Vega.php
    <?php
    
    namespace App\Router;
    
    use App\Controller\Users;
    use Mix\Vega\Engine;
    
    class Vega
    {
    
        /**
         * @return Engine
         */
        public static function new()
        {
            $vega = new Engine();
    
            $vega->handleC('/users/{id}', [new Users(), 'index'])->methods('GET');
    
            return $vega;
        }
    
    }
    
    • src/Controller/Users.php
    <?php
    
    namespace App\Controller;
    
    use App\Database\DB;
    use Mix\Vega\Context;
    
    class Users
    {
    
        public function index(Context $ctx)
        {
            $row = DB::instance()->table('users')->where('id = ?', $ctx->param('id'))->first();
            if (!$row) {
                throw new \Exception('User not found');
            }
            $ctx->JSON(200, [
                'code' => 0,
                'message' => 'ok',
                'data' => $row
            ]);
        }
    
    }
    
    • src/Database/DB.php
    <?php
    
    namespace App\Database;
    
    use Mix\Database\Database;
    
    const DSN = 'mysql:host=127.0.0.1;port=3306;charset=utf8;dbname=test';
    const USERNAME = 'root';
    const PASSWORD = '123456';
    
    class DB extends Database
    {
    
        static private $instance;
    
        public static function instance()
        {
            if (!isset(self::$instance)) {
                self::$instance = new self(DSN, USERNAME, PASSWORD);
            }
            return self::$instance;
        }
    
    }
    

    调整完基本就完成了一个正式项目的雏形了,接下来大家可以自由发挥。

    压测一下

    mysql: docker mysql8 本机
    cpu: macOS M1 8 核
    mem: 16G
    wokerman (未安装 libevent): 8 进程,相当于 8 个 mysql 连接

    % wrk -c 1000 -d 1m http://127.0.0.1:2345/users/1
    Running 1m test @ http://127.0.0.1:2345/users/1
      2 threads and 1000 connections
      Thread Stats   Avg      Stdev     Max   +/- Stdev
        Latency    36.08ms    8.11ms 428.09ms   95.38%
        Req/Sec     3.49k   211.80     4.00k    71.00%
      416817 requests in 1.00m, 109.31MB read
      Socket errors: connect 749, read 295, write 1, timeout 0
    Requests/sec:   6943.38
    Transfer/sec:      1.82MB
    
    目前尚无回复
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   5302 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 23ms · UTC 03:40 · PVG 11:40 · LAX 19:40 · JFK 22:40
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.