Categories: HproseHprose for PHPHprose for PHP 2.0PHPPHP 7.4PostmanPostman v6Web应用开发Web框架YiiYii 2开发工具程序开发程序调试工具编程语言网络工具包

基于 yiisoft/yii2-app-advanced，在 GitHub 上新建仓库 yii2-app-advanced，新建远程过程调用应用(实现基于 Hprose 2.0 for PHP 的 RPC 服务端)，在 rpc 目录中实现 页面 的相应 RPC 服务，且在 api 目录中的 API 实现 RPC 客户端 (八) (2)

图1

1、在 rpc 目录中实现 页面 的相应 RPC 服务，创建 远程过程调用 HTTP 服务器，新建 \rpc\controllers\ServerController.php

<?php
/**
 * Created by PhpStorm.
 * User: WangQiang
 * Date: 2018/08/01
 * Time: 18:02
 */
namespace rpc\controllers;

use Yii;
use yii\web\Controller;
use Hprose\Yii\Server;

/**
 * 远程过程调用 HTTP 服务器
 *
 * @author Qiang Wang <shuijingwanwq@163.com>
 * @since 1.0
 */class ServerController extends Controller
{
    public $enableCsrfValidation = false;

    public function beforeAction($action)
    {
        parent::beforeAction($action);
        $server = new Server();
        $server->addMethod($action->actionMethod, $this, $action->controller->id . '_' . $action->id);
        $server->start();
    }
}

2、新建页面模型 \rpc\models\Page.php

<?php

namespace rpc\models;


class Page extends \common\logics\Page
{

}

3、新建页面控制器，\rpc\controllers\PageController.php

<?php
/**
 * Created by PhpStorm.
 * User: WangQiang
 * Date: 2018/08/01
 * Time: 15:01
 */
namespace rpc\controllers;

use Yii;
use rpc\models\Page;

/**
 * Page Controller
 *
 * @author Qiang Wang <shuijingwanwq@163.com>
 * @since 1.0
 */class PageController extends ServerController
{
    /**
     * 创建页面
     *
     * @param array $data 数据
     *
     * @param string $version 版本号(次版本号与修订号)
     * 格式如下：
     * 2.3
     *
     * @param string $language 区域和语言
     * 格式如下：
     * en-US
     *
     * @return mixed
     */    public function actionCreate(array $data, string $version = '', string $language = '')
    {
        return $data;
        //echo 1;
        //exit;
        //$fileName = date('Y-m-d-H-i-s', time()) . '-' . microtime(true);
        //file_put_contents('./../runtime/' . $fileName . '.txt', '0');
        //return 1;
    }
}

4、然后在浏览器端打开网址：http://rpc.github-shuijingwan-yii2-app-advanced.localhost/page/create ，看到以下输出：Fa2{u#s11″page_create”}z，符合预期

5、通过工厂方法 create 创建客户端，编辑 \api\rests\page\CreateAction.php

<?php
/**
 * @link http://www.yiiframework.com/
 * @copyright Copyright (c) 2008 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */
namespace api\rests\page;

use Yii;
use yii\base\Model;
use yii\helpers\Url;
use yii\web\ServerErrorHttpException;
use Hprose\Http\Client;

/**
 * CreateAction implements the API endpoint for creating a new model from the given data.
 *
 * For more details and usage information on CreateAction, see the [guide article on rest controllers](guide:rest-controllers).
 *
 * @author Qiang Wang <shuijingwanwq@163.com>
 * @since 1.0
 */class CreateAction extends Action
{
    /**
     * @var string the scenario to be assigned to the new model before it is validated and saved.
     */    public $scenario = Model::SCENARIO_DEFAULT;
    /**
     * @var string the name of the view action. This property is need to create the URL when the model is successfully created.
     */    public $viewAction = 'view';


    /**
     * Creates a new model.
     * @return \yii\db\ActiveRecordInterface the model newly created
     * @throws ServerErrorHttpException if there is any error when creating the model
     */    public function run()
    {
        if ($this->checkAccess) {
            call_user_func($this->checkAccess, $this->id);
        }

        $client = Client::create('http://rpc.github-shuijingwan-yii2-app-advanced.localhost/page/create', false);
        $page = $client->page_create([
            'title' => 'title',
            'body' => 'body',
        ]);

        print_r($page);
        exit;

        /* @var $model \yii\db\ActiveRecord */        $model = new $this->modelClass([
            'scenario' => $this->scenario,
        ]);

        $model->load(Yii::$app->getRequest()->getBodyParams(), '');
        if ($model->save()) {
            $response = Yii::$app->getResponse();
            $response->setStatusCode(201);
            $id = implode(',', array_values($model->getPrimaryKey(true)));
            $response->getHeaders()->set('Location', Url::toRoute([$this->viewAction, 'id' => $id], true));
        } elseif ($model->hasErrors()) {
            $response = Yii::$app->getResponse();
            $response->setStatusCode(422, 'Data Validation Failed.');
            foreach ($model->getFirstErrors() as $message) {
                $firstErrors = $message;
                break;
            }
            return ['code' => 20004, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '20004'), ['firstErrors' => $firstErrors]))];
        } elseif (!$model->hasErrors()) {
            throw new ServerErrorHttpException('Failed to create the object for unknown reason.');
        }

        return ['code' => 10000, 'message' => Yii::t('success', '10805'), 'data' => $model];
    }
}

6、在 Postman 中 POST http://api.github-shuijingwan-yii2-app-advanced.localhost/v1/pages ，响应失败

{
    "name": "Exception",
    "message": "28: Operation timed out after 30000 milliseconds with 0 bytes received",
    "code": 0,
    "type": "Exception",
    "file": "E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Http\\Client.php",
    "line": 276,
    "stack-trace": [
        "#0 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Http\\Client.php(295): Hprose\\Http\\Client->syncSendAndReceive('Cs11\"page_creat...', Object(stdClass))",
        "#1 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(539): Hprose\\Http\\Client->sendAndReceive('Cs11\"page_creat...', Object(stdClass))",
        "#2 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(109): Hprose\\Client->afterFilterHandler('Cs11\"page_creat...', Object(stdClass))",
        "#3 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(504): Hprose\\Client->Hprose\\{closure}('Cs11\"page_creat...', Object(stdClass))",
        "#4 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(518): Hprose\\Client->syncBeforeFilterHandler('Cs11\"page_creat...', Object(stdClass))",
        "#5 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(106): Hprose\\Client->beforeFilterHandler('Cs11\"page_creat...', Object(stdClass))",
        "#6 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(476): Hprose\\Client->Hprose\\{closure}('Cs11\"page_creat...', Object(stdClass))",
        "#7 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(489): Hprose\\Client->syncInvokeHandler('page_create', Array, Object(stdClass))",
        "#8 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(103): Hprose\\Client->invokeHandler('page_create', Array, Object(stdClass))",
        "#9 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(608): Hprose\\Client->Hprose\\{closure}('page_create', Array, Object(stdClass))",
        "#10 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\hprose\\hprose\\src\\Hprose\\Client.php(438): Hprose\\Client->invoke('page_create', Array)",
        "#11 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\api\\rests\\page\\CreateAction.php(49): Hprose\\Client->__call('page_create', Array)",
        "#12 [internal function]: api\\rests\\page\\CreateAction->run()",
        "#13 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\yiisoft\\yii2\\base\\Action.php(94): call_user_func_array(Array, Array)",
        "#14 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\yiisoft\\yii2\\base\\Controller.php(157): yii\\base\\Action->runWithParams(Array)",
        "#15 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\yiisoft\\yii2\\base\\Module.php(528): yii\\base\\Controller->runAction('create', Array)",
        "#16 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\yiisoft\\yii2\\web\\Application.php(103): yii\\base\\Module->runAction('v1/page/create', Array)",
        "#17 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\vendor\\yiisoft\\yii2\\base\\Application.php(386): yii\\web\\Application->handleRequest(Object(yii\\web\\Request))",
        "#18 E:\\wwwroot\\github-shuijingwan-yii2-app-advanced\\api\\web\\index.php(17): yii\\base\\Application->run()",
        "#19 {main}"
    ]
}

7、出现以上原因是因为 Windows 下 nginx php 环境，不支持并发的原因，当同时访问多个域名，并且同时指向你本地服务的时候，就不支持并发了。nginx.conf 里面 对不同 server 修改 fastcgi_pass 的端口号，启动多个 php-cgi。如图1

图1

## FRONTEND ##
server {
    charset utf-8;
    client_max_body_size 128M;

    listen 80; ## listen for ipv4
    #listen [::]:80 default_server ipv6only=on; ## listen for ipv6

    server_name www.github-shuijingwan-yii2-app-advanced.localhost;
    root        E:/wwwroot/github-shuijingwan-yii2-app-advanced/frontend/web;
    index       index.php;

    access_log  logs/www.github-shuijingwan-yii2-app-advanced.localhost.access.log;
    error_log   logs/www.github-shuijingwan-yii2-app-advanced.localhost.error.log;

 location / {
  # Redirect everything that isn't a real file to index.php
  try_files $uri $uri/ /index.php$is_args$args;
 }

 # uncomment to avoid processing of calls to non-existing static files by Yii
 #location ~ \.(js|css|png|jpg|gif|swf|ico|pdf|mov|fla|zip|rar)$ {
 #    try_files $uri =404;
 #}
 #error_page 404 /404.html;

 # deny accessing php files for the /assets directory
 location ~ ^/assets/.*\.php$ {
  deny all;
 }

 location ~ \.php$ {
  include fastcgi_params;
  fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;
  fastcgi_pass 127.0.0.1:9000;
  #fastcgi_pass unix:/var/run/php5-fpm.sock;
  try_files $uri =404;
 }

 location ~* /\. {
  deny all;
 }
}

## BACKEND ##
server {
    charset utf-8;
    client_max_body_size 128M;

    listen 80; ## listen for ipv4
    #listen [::]:80 default_server ipv6only=on; ## listen for ipv6

    server_name backend.github-shuijingwan-yii2-app-advanced.localhost;
    root        E:/wwwroot/github-shuijingwan-yii2-app-advanced/backend/web;
    index       index.php;

    access_log  logs/backend.github-shuijingwan-yii2-app-advanced.localhost.access.log;
    error_log   logs/backend.github-shuijingwan-yii2-app-advanced.localhost.error.log;

 location / {
  # Redirect everything that isn't a real file to index.php
  try_files $uri $uri/ /index.php$is_args$args;
 }

 # uncomment to avoid processing of calls to non-existing static files by Yii
 #location ~ \.(js|css|png|jpg|gif|swf|ico|pdf|mov|fla|zip|rar)$ {
 #    try_files $uri =404;
 #}
 #error_page 404 /404.html;

 # deny accessing php files for the /assets directory
 location ~ ^/assets/.*\.php$ {
  deny all;
 }

 location ~ \.php$ {
  include fastcgi_params;
  fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;
  fastcgi_pass 127.0.0.1:9000;
  #fastcgi_pass unix:/var/run/php5-fpm.sock;
  try_files $uri =404;
 }

 location ~* /\. {
  deny all;
 }
}

## API ##
server {
    charset utf-8;
    client_max_body_size 128M;

    listen 80; ## listen for ipv4
    #listen [::]:80 default_server ipv6only=on; ## listen for ipv6

    server_name api.github-shuijingwan-yii2-app-advanced.localhost;
    root        E:/wwwroot/github-shuijingwan-yii2-app-advanced/api/web;
    index       index.php;

    access_log  logs/api.github-shuijingwan-yii2-app-advanced.localhost.access.log;
    error_log   logs/api.github-shuijingwan-yii2-app-advanced.localhost.error.log;

 location / {
  # Redirect everything that isn't a real file to index.php
  try_files $uri $uri/ /index.php$is_args$args;
 }

 # uncomment to avoid processing of calls to non-existing static files by Yii
 #location ~ \.(js|css|png|jpg|gif|swf|ico|pdf|mov|fla|zip|rar)$ {
 #    try_files $uri =404;
 #}
 #error_page 404 /404.html;

 # deny accessing php files for the /assets directory
 location ~ ^/assets/.*\.php$ {
  deny all;
 }

 location ~ \.php$ {
  include fastcgi_params;
  fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;
  fastcgi_pass 127.0.0.1:9001;
  #fastcgi_pass unix:/var/run/php5-fpm.sock;
  try_files $uri =404;
 }

 location ~* /\. {
  deny all;
 }
}

## RPC ##
server {
    charset utf-8;
    client_max_body_size 128M;

    listen 80; ## listen for ipv4
    #listen [::]:80 default_server ipv6only=on; ## listen for ipv6

    server_name rpc.github-shuijingwan-yii2-app-advanced.localhost;
    root        E:/wwwroot/github-shuijingwan-yii2-app-advanced/rpc/web;
    index       index.php;

    access_log  logs/rpc.github-shuijingwan-yii2-app-advanced.localhost.access.log;
    error_log   logs/rpc.github-shuijingwan-yii2-app-advanced.localhost.error.log;

 location / {
  # Redirect everything that isn't a real file to index.php
  try_files $uri $uri/ /index.php$is_args$args;
 }

 # uncomment to avoid processing of calls to non-existing static files by Yii
 #location ~ \.(js|css|png|jpg|gif|swf|ico|pdf|mov|fla|zip|rar)$ {
 #    try_files $uri =404;
 #}
 #error_page 404 /404.html;

 # deny accessing php files for the /assets directory
 location ~ ^/assets/.*\.php$ {
  deny all;
 }

 location ~ \.php$ {
  include fastcgi_params;
  fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;
  fastcgi_pass 127.0.0.1:9000;
  #fastcgi_pass unix:/var/run/php5-fpm.sock;
  try_files $uri =404;
 }

 location ~* /\. {
  deny all;
 }
}

## MISC ##

### WWW Redirect ###
server {
    listen       80;
    server_name  github-shuijingwan-yii2-app-advanced.localhost;
    return       301 http://www.github-shuijingwan-yii2-app-advanced.localhost$request_uri;
}

8、在 Postman 中 POST http://api.github-shuijingwan-yii2-app-a-client.localhost/v1/pages ，响应成功

Array
(
    [title] => title
    [body] => body
)

9、新建模块 v1，基于模块实现版本控制，打开：http://www.github-shuijingwan-yii2-app-advanced.localhost/gii/module ，生成模块 v1，如图2

图2

10、重命名 \rpc\modules\v1\controllers\DefaultController.php 为 \rpc\modules\v1\controllers\PageController.php

<?php

namespace rpc\modules\v1\controllers;

/**
 * Page controller for the `v1` module
 */class PageController extends \rpc\controllers\PageController
{
    public $modelClass = 'rpc\modules\v1\models\Page';
}

11、删除 \rpc\modules\v1\views

12、复制 \api\models\Page.php、\api\models\PageQuery.php、\api\models\PageSearch.php 为 \rpc\models\Page.php、\rpc\models\PageQuery.php、\rpc\models\PageSearch.php，调整命名空间

13、复制 \api\modules\v1\models\Page.php、\api\modules\v1\models\PageQuery.php、\api\modules\v1\models\PageSearch.php 为 \rpc\modules\v1\models\Page.php、\rpc\modules\v1\models\PageQuery.php、\rpc\modules\v1\models\PageSearch.php，调整命名空间

14、编辑 \rpc\config\main.php，将模块加入到应用主体配置的 modules 属性的列表中

    'modules' => [
        'v1' => [
            'class' => rpc\modules\v1\Module::class,
        ],
    ],

15、在浏览器端打开网址：http://rpc.github-shuijingwan-yii2-app-advanced.localhost/v1/page/create ，看到以下输出：Fa2{u#s11″page_create”}z，符合预期

16、通过工厂方法 create 创建客户端，编辑 \api\rests\page\CreateAction.php，调整 HTTP 服务地址

        $client = Client::create('http://rpc.github-shuijingwan-yii2-app-advanced.localhost/v1/page/create', false);
        $page = $client->page_create([
            'title' => 'title',
            'body' => 'body',
        ]);

        print_r($page);
        exit;

17、在 Postman 中 POST http://api.github-shuijingwan-yii2-app-advanced.localhost/v1/pages ，响应正常

Array
(
    [title] => title
    [body] => body
)

18、编辑 \environments\dev\common\config\params-local.php、\environments\prod\common\config\params-local.php

<?php
return [
    // RPC HTTP 服务地址
    'rpc' => [
        'hostInfo' => 'http://rpc.github-shuijingwan-yii2-app-advanced.localhost', // HOME URL
        'baseUrl' => '/v1', // BASE URL
    ],
];

19、新建 RPC 客户端的基础类，\common\logics\rpc\Model.php

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2018/08/02
 * Time: 13:12
 */
namespace common\logics\rpc;

use Yii;
use Hprose\Http\Client;

/**
 * RPC 客户端的基础类
 *
 * @author Qiang Wang <shuijingwanwq@163.com>
 * @since 1.0
 */class Model extends \yii\base\Model
{
    /**
     * 创建一个同步的 HTTP 客户端
     *
     * @param string $controllerId 控制器ID
     * 格式如下：
     * page
     *
     * @param string $actionId 方法ID
     * 格式如下：
     * create
     *
     * @return object $client 同步的 HTTP 客户端
     */    public static function client($controllerId, $actionId)
    {
        $url = Yii::$app->params['rpc']['hostInfo'] . Yii::$app->params['rpc']['baseUrl'];
        $client = Client::create($url . '/' . $controllerId . '/' . $actionId, false);
        return $client->$controllerId;
    }
}

20、新建页面模型的公共逻辑类，\common\logics\rpc\Page.php，定义模型属性、场景(块赋值)、验证规则(初步验证请求数据，以避免明显不符合规则的数据，穿透至 RPC 服务端)

<?php

namespace common\logics\rpc;

use Yii;

/**
 * 页面模型
 */class Page extends Model
{
    const STATUS_DELETED = -1; //状态：删除
    const STATUS_DISABLED = 0; //状态：禁用
    const STATUS_DRAFT = 1; //状态：草稿
    const STATUS_PUBLISHED = 2; //状态：发布

    const CONTROLLER_ID = 'page'; //控制器ID

    const SCENARIO_CREATE = 'create';

    public $slug;
    public $title;
    public $body;
    public $view;
    public $status;

    /**
     * {@inheritdoc}
     */    public function scenarios()
    {
        $scenarios = parent::scenarios();
        $scenarios[self::SCENARIO_CREATE] = ['slug', 'title', 'body', 'view', 'status'];

        return $scenarios;
    }

    /**
     * {@inheritdoc}
     */    public function rules()
    {
        return [
            [['title', 'body'], 'required'],
            [['body'], 'string'],
            [['view', 'status'], 'integer'],
            [['slug', 'title'], 'string', 'max' => 255],
        ];
    }

    /**
     * {@inheritdoc}
     */    public function attributeLabels()
    {
        return [
            'slug' => Yii::t('model/rpc/page', 'Slug'),
            'title' => Yii::t('model/rpc/page', 'Title'),
            'body' => Yii::t('model/rpc/page', 'Body'),
            'view' => Yii::t('model/rpc/page', 'View'),
            'status' => Yii::t('model/rpc/page', 'Status'),
        ];
    }

    /**
     * 创建页面
     *
     * @param array $data 数据
     *
     * @param string $version 版本号(次版本号与修订号)
     * 格式如下：
     * 2.3
     *
     * @param string $language 区域和语言
     * 格式如下：
     * en-US
     *
     * @return array
     */    public function create(array $data, string $version, string $language)
    {
        $actionId = 'create';
        return self::client(self::CONTROLLER_ID, $actionId)->$actionId($data, $version, $language);
    }

}

21、新建 \api\models\rpc\Page.php

<?php

namespace api\models\rpc;

class Page extends \common\logics\rpc\Page
{

}

22、新建 \api\modules\v1\models\rpc\Page.php

<?php
/**
 * Created by PhpStorm.
 * User: WangQiang
 * Date: 2018/08/02
 * Time: 13:04
 */
namespace api\modules\v1\models\rpc;


class Page extends \api\models\rpc\Page
{

}

23、编辑 \api\modules\v1\controllers\PageController.php，指定模型类

<?php

namespace api\modules\v1\controllers;

/**
 * Page controller for the `v1` module
 */class PageController extends \api\controllers\PageController
{
    public $modelClass = 'api\modules\v1\models\rpc\Page';
}

23、编辑 \common\logics\Page.php，定义场景

<?php

namespace common\logics;

use Yii;
use yii\behaviors\SluggableBehavior;
use yii\behaviors\TimestampBehavior;
use yii2tech\ar\softdelete\SoftDeleteBehavior;
use yii\helpers\ArrayHelper;

class Page extends \common\models\Page
{
    const STATUS_DELETED = -1; //状态：删除
    const STATUS_DISABLED = 0; //状态：禁用
    const STATUS_DRAFT = 1; //状态：草稿
    const STATUS_PUBLISHED = 2; //状态：发布

    const SCENARIO_CREATE = 'create';

    /**
     * @inheritdoc
     */    public function behaviors()
    {
        return [
            'timestampBehavior' => [
                'class' => TimestampBehavior::className(),
                'attributes' => [
                    self::EVENT_BEFORE_INSERT => ['created_at', 'updated_at'],
                    self::EVENT_BEFORE_UPDATE => 'updated_at',
                    SoftDeleteBehavior::EVENT_BEFORE_SOFT_DELETE => 'updated_at',
                ]
            ],
            'slug' => [
                'class' => SluggableBehavior::className(),
                'attribute' => 'title',
                'ensureUnique' => true,
                'immutable' => true
            ],
            'softDeleteBehavior' => [
                'class' => SoftDeleteBehavior::className(),
                'softDeleteAttributeValues' => [
                    'status' => self::STATUS_DELETED
                ],
            ],
        ];
    }

    /**
     * {@inheritdoc}
     */    public function scenarios()
    {
        $scenarios = parent::scenarios();
        $scenarios[self::SCENARIO_CREATE] = ['slug', 'title', 'body', 'view', 'status'];

        return $scenarios;
    }

    /**
     * @inheritdoc
     */    public function rules()
    {
        $rules = [
            [['title', 'body'], 'required'],
            [['slug'], 'unique'],
            ['view', 'default', 'value' => 0],
            ['status', 'default', 'value' => self::STATUS_DRAFT],
        ];
        $parentRules = parent::rules();

        unset($parentRules[0]);

        return ArrayHelper::merge($rules, $parentRules);
    }

    /**
     * {@inheritdoc}
     * @return PageQuery the active query used by this AR class.
     */    public static function find()
    {
        return new PageQuery(get_called_class());
    }

}

24、编辑 \rpc\config\main.php，以支持国际化

        'i18n' => [
            'translations' => [
                'model/*'=> [
                    'class' => 'yii\i18n\PhpMessageSource',
                    'forceTranslation' => true,
                    'basePath'=>'@common/messages',
                    'fileMap'=>[
                    ],
                ],
                '*'=> [
                    'class' => 'yii\i18n\PhpMessageSource',
                    'forceTranslation' => true,
                    'basePath'=>'@rpc/messages',
                    'fileMap'=>[
                    ],
                ],
            ],
        ],
    ],

25、编辑 \api\rests\page\CreateAction.php

<?php
/**
 * @link http://www.yiiframework.com/
 * @copyright Copyright (c) 2008 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */
namespace api\rests\page;

use Yii;
use yii\base\Model;
use yii\helpers\Url;
use yii\web\ServerErrorHttpException;

/**
 * CreateAction implements the API endpoint for creating a new model from the given data.
 *
 * For more details and usage information on CreateAction, see the [guide article on rest controllers](guide:rest-controllers).
 *
 * @author Qiang Wang <shuijingwanwq@163.com>
 * @since 1.0
 */class CreateAction extends Action
{
    /**
     * @var string the scenario to be assigned to the new model before it is validated and saved.
     */    public $scenario = Model::SCENARIO_DEFAULT;
    /**
     * @var string the name of the view action. This property is need to create the URL when the model is successfully created.
     */    public $viewAction = 'view';

    public $createScenario = 'create';


    /**
     * Creates a new model.
     * @return \yii\db\ActiveRecordInterface the model newly created
     * @throws ServerErrorHttpException if there is any error when creating the model
     */    public function run()
    {
        if ($this->checkAccess) {
            call_user_func($this->checkAccess, $this->id);
        }

        /* @var $model \yii\db\ActiveRecord */        $model = new $this->modelClass([
            'scenario' => $this->createScenario,
        ]);

        $model->load(Yii::$app->getRequest()->getBodyParams(), '');

        // 模型转换成数组
        $data = $model->attributes;

        // 内容协商
        $response = Yii::$app->response;
        $acceptParams = $response->acceptParams;
        if (isset($acceptParams['version'])) {
            $version = $acceptParams['version'];
        } else {
            $version = '';
        }

        if ($model->validate()) {
            $data = $model->create($data, $version, Yii::$app->language);
            if ($data['code'] === 10000) {
                $response = Yii::$app->getResponse();
                $response->setStatusCode(201);
                $id = $data['data']['id'];
                $response->getHeaders()->set('Location', Url::toRoute([$this->viewAction, 'id' => $id], true));
            }
            return $data;
        } elseif ($model->hasErrors()) {
            $response = Yii::$app->getResponse();
            $response->setStatusCode(422, 'Data Validation Failed.');
            foreach ($model->getFirstErrors() as $message) {
                $firstErrors = $message;
                break;
            }
            return ['code' => 20004, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '20004'), ['firstErrors' => $firstErrors]))];
        } elseif (!$model->hasErrors()) {
            throw new ServerErrorHttpException('Failed to create the object for unknown reason.');
        }
    }
}

26、编辑 \rpc\controllers\PageController.php

<?php
/**
 * Created by PhpStorm.
 * User: WangQiang
 * Date: 2018/08/01
 * Time: 15:01
 */
namespace rpc\controllers;

use Yii;
use yii\web\ServerErrorHttpException;

/**
 * Page Controller
 *
 * @author Qiang Wang <shuijingwanwq@163.com>
 * @since 1.0
 */class PageController extends ServerController
{
    public $createScenario = 'create';

    /**
     * 创建页面
     *
     * @param array $data 数据
     *
     * @param string $version 版本号(次版本号与修订号)
     * 格式如下：
     * 2.3
     *
     * @param string $language 区域和语言
     * 格式如下：
     * en-US
     *
     * @return mixed
     */    public function actionCreate(array $data, string $version = '', string $language = '')
    {
        if (!empty($language)) {
            Yii::$app->language = $language;
        }

        /* @var $model \yii\db\ActiveRecord */        $model = new $this->modelClass([
            'scenario' => $this->createScenario,
        ]);

        if ($model->load($data, '') && $model->save()) {
            $data = $model->attributes;
        } elseif ($model->hasErrors()) {
            foreach ($model->getFirstErrors() as $message) {
                $firstErrors = $message;
                break;
            }
            return ['code' => 25004, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '25004'), ['firstErrors' => $firstErrors]))];
        } elseif (!$model->hasErrors()) {
            throw new ServerErrorHttpException('Failed to create the object for unknown reason1.');
        }

        return ['code' => 10000, 'message' => Yii::t('success', '15805'), 'data' => $data];
    }
}

27、在 Postman 中 POST http://api.github-shuijingwan-yii2-app-advanced.localhost/v1/pages ，响应失败

{
 "title":"title-20180731-5"
}

注：接口模型验证失败

{
    "code": 20004,
    "message": "数据验证失败：内容不能为空。"
}

28、在 Postman 中 POST http://api.github-shuijingwan-yii2-app-advanced.localhost/v1/pages ，响应失败

{
 "title":"title-20180731-5",
 "body":"title-20180731-5",
 "slug":"title-20180731-5"
}

注：RPC 模型验证失败

{
    "code": 25004,
    "message": "数据验证失败：别名的值\"title-20180731-5\"已经被占用了。"
}

29、在 Postman 中 POST http://api.github-shuijingwan-yii2-app-advanced.localhost/v1/pages ，响应成功

{
 "title":"title-20180731-5",
 "body":"title-20180731-5"
}

{
    "code": 10000,
    "message": "创建页面成功",
    "data": {
        "id": 12,
        "slug": "title-20180731-5-7",
        "title": "title-20180731-5",
        "body": "title-20180731-5",
        "view": 0,
        "status": 1,
        "created_at": 1533205467,
        "updated_at": 1533205467
    }
}

 

 

 

永夜

Leave a Comment
Share
Published by
永夜
Tags: HproseHprose for PHPHprose for PHP 2.0hprose-yiiRPCRPC 客户端yiisoft/yii2-app-advanced客户端服务
4 年 ago

Recent Posts

在 Laravel 9 中 job 运行报错：has been attempted too many times or run too long. The job may have previously timed out.

1、在 Laravel 9 中…

1 小时 ago

Laravel 9 中的 Redis 门面 hset 不允许传递多个字段/值

1、尝试基于 Redis 门面…

2 天 ago

在 Google Chrome 中由于网站升级，打开空白，仅在无痕模式中可正常打开的解决

1、在 Google Chro…

6 天 ago

在 https://tinys.pl/cn/swap 上用 SOL 购买得到 NUTS，在 欧易 Web3 钱包 中显示数量为 0 的排查分析

1、在 https://tin…

1 周 ago

在 Laravel 9 中，基于 Spatie\QueryBuilder\QueryBuilder 来生成查询 SQL，同一字段可支持：partial、exact

1、参考：在 Laravel …

1 周 ago

基于 PHP-Xlswriter 导出 Excel 文件时，设置日期列的格式

1、现在导出的 Excel 文…

2 周 ago