轻量级高性能PHP框架ycroute

时间  2019-11-08 标签 轻量级 高性能 php 框架 ycroute

YCRoute

github: https://github.com/caohao-php...php

目录

  • 框架介绍
  • 运行环境
  • 代码结构
  • 路由配置
  • 过滤验签
  • 控制层
  • 加载器
  • 模型层
  • 数据交互dao层(可选)
  • Redis缓存操做
  • 数据库操做
  • 配置加载
  • 公共类加载
  • 公共函数
  • 日志模块
  • 视图层
  • RPC 介绍 - 像调用本地函数同样调用远程函数
  • RPC Server
  • RPC Client
  • RPC 并行调用
  • 附录 - Core_Model 中的辅助极速开发函数

框架介绍

框架由3层架构构成，Controller、Model、View 以及1个可选的Dao层，支持PHP7，优势以下：mysql

一、框架井井有条，灵活可扩展至4层架构、使用简洁（开箱即用）、功能强大。nginx

二、基于 yaf 路由和 ycdatabase 框架，二者都是C语言扩展，保证了性能。git

三、ycdatabase 是强大的数据库 ORM 框架，功能强大，安全可靠，支持便捷的主从配置，支持稳定、强大的数据库链接池。具体参考 https://blog.csdn.net/caohao0...github

四、支持Redis代理，简便的主从配置，支持稳定的redis链接池。具体参考：https://blog.csdn.net/caohao0...web

五、强大的日志模块、异常捕获模块，便捷高效的类库、共用函数加载模块redis

六、基于PHP7，代码缓存opcache。sql

运行环境

运行环境： PHP 7 shell

依赖扩展： yaf 、 ycdatabase 扩展 数据库

建立日志目录：/data/app/logs ，目录权限为 php 项目可写。

yaf 介绍以及安装： https://github.com/laruence/yaf

ycdatabase 介绍以及安装： https://github.com/caohao-php...

代码结构

———————————————— 
|--- system                   //框架系统代码
|--- conf                     //yaf配置路径 
|--- application              //业务代码 
         |----- config        //配置目录
         |----- controller    //控制器目录
                |------ User.php    //User控制器
         |----- core          //框架基类目录
     |----- daos          //DAO层目录(可选)
         |----- errors        //错误页目录
         |----- helpers       //公共函数目录
         |----- library       //公共类库目录
         |----- models        //模型层目录
         |----- plugins       //yaf路由插件目录，路由先后钩子，(接口验签在这里)
         |----- third         //第三方类库
         |----- views         //视图层

路由配置

路由配置位于： framework/conf/application.ini

示例： http://localhost/index.php?c=...

详细参考文档： http://php.net/manual/zh/book...

控制器由参数c决定，动做有 m 决定。
参数 方式 描述
c GET 控制器，路由到 /application/controller/User.php 文件
m GET 入口方法， User.php 里面的 getUserInfoAction 方法

程序将被路由到 framework/application/controllers/User.php文件的 UserController::getUserInfoAction方法，其它路由细节参考Yaf框架

class UserController extends Core_Controller  
{  
    public function getUserInfoAction()  
    {  
    }  
}

过滤验签

framework/application/plugins/Filter.php ， 在 _auth 中写入验签方法，全部接口都会在这里校验， 全部GET、POST等参数放在 $this->params 里。

class FilterPlugin extends Yaf_Plugin_Abstract {
    var $params;

    //路由以前调用
    public function routerStartUp ( Yaf_Request_Abstract $request , Yaf_Response_Abstract $response) {
        $this->params = & $request->getParams();
       
           $this->_auth();
    }
    
    
    //验签过程
    protected function _auth()
    {
        //在这里写你的验签逻辑
    }
    ...
}

控制层

全部控制器位于：framework/application/controllers 目录，全部控制器继承自Core_Controller方法，里面主要获取GET/POST参数，以及返回数据的处理，Core_Controller继承自 Yaf_Controller_Abstract， init方法会被自动调用，更多细节参考 Yaf 框架控制器。

class UserController extends Core_Controller {
    public function init() {
        parent::init(); //必须

        $this->user_model = Loader::model('UserinfoModel'); //模型层

        $this->util_log = Logger::get_instance('user_log'); //日志
        Loader::helper('common_helper'); //公共函数

        $this->sample = Loader::library('Sample'); //加载类库，加载的就是 framework/library/Sample.php 里的Sample类
    }

    //获取用户信息接口
    public function getUserInfoAction() {
        $userId = $this->params['userid'];
        $token = $this->params['token'];

        if (empty($userId)) {
            $this->response_error(10000017, "user_id is empty");
        }

        if (empty($token)) {
            $this->response_error(10000016, "token is empty");
        }

        $userInfo = $this->user_model->getUserinfoByUserid($userId);
        if (empty($userInfo)) {
            $this->response_error(10000023, "未找到该用户");
        }

        if (empty($token) || $token != $userInfo['token']) {
            $this->response_error(10000024, "token 校验失败");
        }
        
        $this->response_success($userInfo);
    }
}

经过 $this->response_error(10000017, 'user_id is empty'); 返回错误结果 

{
    "errno":10000017,
    "errmsg":"user_id is empty"
}

经过 $this->response_success($result); 返回JSON格式成功结果，格式以下：

{
    "errno":0,
    "union":"",
    "amount":0,
    "session_key":"ZqwsC+Spy4C31ThvqkhOPg==",
    "open_id":"oXtwn4_mrS4zIxtSeV0yVT2sAuRo",
    "nickname":"凉之渡",
    "last_login_time":"2018-09-04 18:53:06",
    "regist_time":"2018-06-29 22:03:38",
    "user_id":6842811,
    "token":"c9bea5dee1f49488e2b4b4645ff3717e",
    "updatetime":"2018-09-04 18:53:06",
    "avatar_url":"https://wx.qlogo.cn/mmopen/vi_32/xfxHib91BictV8T4ibRQAibD10DfoNpzpB1LBqZvRrz0icPkN0gdibZg62EPJL3KE1Y5wkPDRAhibibymnQCFgBM2nuiavA/132",
    "city":"Guangzhou",
    "province":"Guangdong",
    "country":"China",
    "appid":"wx385863ba15f573b6",
    "gender":1,
    "form_id":""
}

加载器

经过 Loader 加载器能够加载模型层，公共类库，公共函数，数据库，缓存等对象， Logger 为日志类。

模型层

framework/application/models/Userinfo.php ，模型层，你能够继承自Core_Model， 也能够不用，Core_Model 中封装了许多经常使用SQL操做。最后一章会介绍各个函数用法。

经过 $this->user_model = Loader::model('UserinfoModel') 加载模型层，模型层与数据库打交道。

class UserinfoModel extends Core_Model {
    public function __construct() {
        $this->db = Loader::database('default');
        $this->util_log = Logger::get_instance('userinfo_log');
    }

    function register_user($appid, $userid, $open_id, $session_key) {
        $data = array();
        $data['appid'] = $appid;
        $data['user_id'] = $userid;
        $data['open_id'] = $open_id;
        $data['session_key'] = $session_key;
        $data['last_login_time'] = $data['regist_time'] = date('Y-m-d H:i:s', time());
        $data['token'] = md5(TOKEN_GENERATE_KEY . time() . $userid . $session_key);
        $ret = $this->db->insert("user_info", $data);
        if ($ret != -1) {
            return $data['token'];
        } else {
            $this->util_log->LogError("error to register_user, DATA=[".json_encode($data)."]");
            return false;
        }
    }
    
    ...
}

数据交互Dao层(可选)

若是你习惯了4层结构，你能够加载Dao层，做为与数据库交互的层，而model层做为业务层。这个时候 Model 最好不要继承 Core_Model，而由 Dao 层来继承。

framework/application/daos/UserinfoDao.php ，数据库交互层，你能够继承自Core_Model， 也能够不用，Core_Model 中封装了许多经常使用SQL操做。最后一章会介绍各个函数用法。

经过 $this->user_dao = Loader::dao('UserinfoDao') 加载dao层，咱们建议一个数据库对应一个Dao层。

redis 缓存操做

加载 redis 缓存： Loader::redis('default_master'); 参数为framework/application/config/redis.php 配置键值，以下：

$redis_conf['default_master']['host'] = '127.0.0.1';
$redis_conf['default_master']['port'] = 6379;
$redis_conf['default_slave']['host'] = '/tmp/redis_pool.sock';  //unix socket redis链接池，须要配置 openresty-pool/conf/nginx.conf，并开启代理，具体参考 https://blog.csdn.net/caohao0591/article/details/85679702

$redis_conf['userinfo']['host'] = '127.0.0.1';
$redis_conf['userinfo']['port'] = 6379;

return $redis_conf;

使用例子：

$redis = Loader::redis("default_master"); //主写
$redis->set("pre_redis_user_${userid}", serialize($result));
$redis->expire("pre_redis_user_${userid}", 3600);

$redis = Loader::redis("default_slave"); //从读
$data = $redis->get("pre_redis_user_${userid}");

链接池配置 openresty-pool/conf/nginx.conf ：

worker_processes  1;        #nginx worker 数量

error_log logs/error.log;   #指定错误日志文件路径

events {
    worker_connections 1024;
}

stream {
    lua_code_cache on;

    lua_check_client_abort on;

    server {
        listen unix:/tmp/redis_pool.sock;
        content_by_lua_block {
            local redis_pool = require "redis_pool"
            pool = redis_pool:new({ip = "127.0.0.1", port = 6380, auth = "password"})
            pool:run()
        }
    }
    
    server {

        listen unix:/var/run/mysql_sock/mysql_user_pool.sock;
        
        content_by_lua_block {
            local mysql_pool = require "mysql_pool"
            
            local config = {host = "127.0.0.1", 
                    user = "root", 
                    password = "test123123",
                    database = "userinfo", 
                    timeout = 2000, 
                    max_idle_timeout = 10000, 
                    pool_size = 200}
                           
            pool = mysql_pool:new(config)
            
            pool:run()
        }
    }
}

数据库操做

数据库加载： Loader::database("default"); 参数为 framework/application/config/database.php 里配置键值，以下：

$db['default']['unix_socket'] = '/var/run/mysql_sock/mysql_user_pool.sock';  //unix socket 数据库链接池，具体使用参考 https://blog.csdn.net/caohao0591/article/details/85255704
$db['default']['pconnect'] = FALSE;
$db['default']['db_debug'] = TRUE;
$db['default']['char_set'] = 'utf8';
$db['default']['dbcollat'] = 'utf8_general_ci';
$db['default']['autoinit'] = FALSE;

$db['payinfo_master']['host']     = '127.0.0.1';   //地址
$db['payinfo_master']['username'] = 'root';        //用户名
$db['payinfo_master']['password'] = 'test123123';  //密码
$db['payinfo_master']['dbname']   = 'payinfo';     //数据库名
$db['payinfo_master']['pconnect'] = FALSE;         //是否链接池
$db['payinfo_master']['db_debug'] = TRUE;          //debug标志，线上关闭，打开后，异常SQL会显示到页面，不安全，仅在测试时打开，（注意，上线必定得将 db_debug 置为 FALSE，不然必定几率可能暴露数据库配置）
$db['payinfo_master']['char_set'] = 'utf8';
$db['payinfo_master']['dbcollat'] = 'utf8_general_ci';
$db['payinfo_master']['autoinit'] = FALSE;         //自动初始化，Loader的时候就链接，建议关闭
$db['payinfo_master']['port'] = 3306;

$db['payinfo_slave']['host']     = '192.168.0.7';
$db['payinfo_slave']['username'] = 'root';
$db['payinfo_slave']['password'] = 'test123123';
$db['payinfo_slave']['dbname']   = 'payinfo';
$db['payinfo_slave']['pconnect'] = FALSE;
$db['payinfo_slave']['db_debug'] = TRUE;
$db['payinfo_slave']['char_set'] = 'utf8';
$db['payinfo_slave']['dbcollat'] = 'utf8_general_ci';
$db['payinfo_slave']['autoinit'] = FALSE;
$db['payinfo_slave']['port'] = 3306;

原生SQL：

$data = $this->db->query("select * from user_info where country='China' limit 3");

查询多条记录：

$data = $this->db->get("user_info", ['regist_time[<]' => '2018-06-30 15:48:39', 
                                    'gender' => 1,
                                    'country' => 'China',
                    'city[!]' => null,
                                    'ORDER' => [
                                        "user_id",
                                        "regist_time" => "DESC",
                                        "amount" => "ASC"
                                        ],
                                    'LIMIT' => 10], "user_id,nickname,city");
echo json_encode($data);exit;
[
    {
        "nickname":"芒果",
        "user_id":6818810,
        "city":"Yichun"
    },
    {
        "nickname":"Smile、格调",
        "user_id":6860814,
        "city":"Guangzhou"
    },
    {
        "nickname":"Yang",
        "user_id":6870818,
        "city":"Hengyang"
    },
    {
        "nickname":"凉之渡",
        "user_id":7481824,
        "city":"Guangzhou"
    }
]

查询单列

$data = $this->db->get("user_info", ['regist_time[<]' => '2018-06-30 15:48:39', 
                                    'gender' => 1,
                                    'country' => 'China',
                    'city[!]' => null,
                                    'ORDER' => [
                                        "user_id",
                                        "regist_time" => "DESC",
                                        "amount" => "ASC"
                                        ],
                                    'LIMIT' => 10], "nickname");
echo json_encode($data);exit;
[
    "芒果",
    "Smile、格调",
    "Yang",
    "凉之渡"
]

查询单条记录

$data = $this->db->get_one("user_info", ['user_id' => 6818810]);
{
    "union":null,
    "amount":0,
    "session_key":"Et1yjxbEfRqVmCVsYf5qzA==",
    "open_id":"oXtwn4wkPO4FhHmkan097DpFobvA",
    "nickname":"芒果",
    "last_login_time":"2018-10-04 16:01:27",
    "regist_time":"2018-06-29 21:24:45",
    "user_id":6818810,
    "token":"5a350bc05bbbd9556f719a0b8cf2a5ed",
    "updatetime":"2018-10-04 16:01:27",
    "avatar_url":"https://wx.qlogo.cn/mmopen/vi_32/DYAIOgq83epqg7FwyBUGd5xMXxLQXgW2TDEBhnNjPVla8GmKiccP0pFiaLK1BGpAJDMiaoyGHR9Nib2icIX9Na4Or0g/132",
    "city":"Yichun",
    "province":"Jiangxi",
    "country":"China",
    "appid":"wx385863ba15f573b6",
    "gender":1,
    "form_id":"" 
}

插入数据

function register_user($appid, $userid, $open_id, $session_key) {
    $data = array();
        $data['appid'] = $appid;
        $data['user_id'] = $userid;
        $data['open_id'] = $open_id;
        $data['session_key'] = $session_key;
        $data['last_login_time'] = $data['regist_time'] = date('Y-m-d H:i:s', time());
        $data['token'] = md5(TOKEN_GENERATE_KEY . time() . $userid . $session_key);
        $ret = $this->db->insert("user_info", $data);
        if ($ret != -1) {
            return $data['token'];
        } else {
            $this->util_log->LogError("error to register_user, DATA=[".json_encode($data)."]");
            return false;
        }
}

更新数据

function update_user($userid, $update_data) {
        $redis = Loader::redis("userinfo");
        $redis->del("pre_redis_user_info_" . $userid);

        $ret = $this->db->update("user_info", ["user_id" => $userid], $update_data);
        if ($ret != -1) {
            return true;
        } else {
            $this->util_log->LogError("error to update_user, DATA=[".json_encode($update_data)."]");
            return false;
        }
}

删除操做

$ret = $this->db->delete("user_info", ["user_id" => 7339820]);

更多操做参考

经过 $this->db->get_ycdb(); 能够获取ycdb句柄进行更多数据库操做， ycdb 的使用教程以下：
英文： https://github.com/caohao-php...

中文： https://blog.csdn.net/caohao0...

配置加载

经过 Loader::config('xxxxx'); 加载 /application/config/xxxxx.php 的配置。例如：

$config = Loader::config('config');
var_dump($config);

公共类加载

全部的公共类库位于superci/application/library目录，可是注意的是， 若是你的类位于library子目录下面，你的类必须用下划线"_"分隔；

$this->sample = Loader::library('Sample');

加载的就是 framework/application/library/Sample.php 中的 Sample类。

$this->ip_location = Loader::library('Ip_Location');

加载的是 framework/application/library/Ip/Location.php 中的Ip_Location类

公共函数

全部的公共类库位于superci/application/helpers目录，经过 Loader::helper('common_helper'); 方法包含进来。

日志

日志使用方法以下：

$this->util_log = Logger::get_instance('userinfo');
$this->util_log->LogInfo("register success");
$this->util_log->LogError("not find userinfo");

日志级别：

const DEBUG  = 'DEBUG';   /* 级别为 1 ,  调试日志,   当 DEBUG = 1 的时候才会打印调试 */
const INFO   = 'INFO';    /* 级别为 2 ,  应用信息记录,  与业务相关, 这里能够添加统计信息 */
const NOTICE = 'NOTICE';  /* 级别为 3 ,  提示日志,  用户不当操做，或者恶意刷频等行为，比INFO级别高，可是不须要报告*/
const WARN  = 'WARN';    /* 级别为 4 ,  警告,   应该在这个时候进行一些修复性的工做，系统能够继续运行下去 */
const ERROR   = 'ERROR';   /* 级别为 5 ,  错误,     能够进行一些修复性的工做，但没法肯定系统会正常的工做下去，系统在之后的某个阶段， 极可能由于当前的这个问题，致使一个没法修复的错误(例如宕机),但也可能一直工做到中止有不出现严重问题 */
const FATAL  = 'FATAL';   /* 级别为 6 ,  严重错误,  这种错误已经没法修复，而且若是系统继续运行下去的话，能够确定必然会愈来愈乱, 这时候采起的最好的措施不是试图将系统状态恢复到正常，而是尽量的保留有效数据并中止运行 */

FATAL和ERROR级别日志文件以 .wf 结尾， DEBUG级别日志文件以.debug结尾，日志目录存放于 /data/app/localhost 下面，localhost为你的项目域名，好比：

[root@gzapi: /data/app/logs/localhost]# ls
userinfo.20190211.log  userinfo.20190211.log.wf

日志格式: [日志级别] [时间] [错误代码] [文件|行数] [ip] [uri] [referer] [cookie] [统计信息] "内容"

[INFO] [2019-02-11 18:57:01] - - [218.30.116.8] - - - [] "register success"
[ERROR] [2019-02-11 18:57:01] [0] [index.php|23 => | => User.php|35 => Userinfo.php|93] [218.30.116.8] [/index.php?c=user&m=getUserInfo&userid=6842811&token=c9bea5dee1f49488e2b4b4645ff3717e] [] [] - "not find userinfo"

VIEW层

视图层参考yaf视图渲染那部分， 我没有写案例。

RPC 介绍 - 像调用本地函数同样调用远程函数

传统web应用弊端

传统的Web应用, 一个应用随着业务快速增加, 开发人员的流转, 就会慢慢的进入一个恶性循环, 代码量上只有加法没有了减法. 由于随着系统变复杂, 牵一发就会动全局, 而新来的维护者, 对原有的体系并无那么多时间给他让他全面掌握. 即便有这么多时间, 要想掌握之前那么多的维护者的思惟的结合, 也不是一件容易的事情…

那么, 长次以往, 这个系统将会愈来愈不可维护…. 到一个大型应用进入这个恶性循环, 那么等待他的只有重构了.

那么, 能不能对这个系统作解耦呢？ 咱们已经作了不少解耦了, 数据, 中间件, 业务, 逻辑, 等等, 各类分层. 但到Web应用这块, 还能怎么分呢, MVC咱们已经作过了….

解决利器---微服务

目前比较流行的解决方案是微服务，它可让咱们的系统尽量快地响应变化，微服务是指开发一个单个小型的但有业务功能的服务，每一个服务都有本身的处理和轻量通信机制，能够部署在单个或多个服务器上。微服务也指一种种松耦合的、有必定的有界上下文的面向服务架构。也就是说，若是每一个服务都要同时修改，那么它们就不是微服务，由于它们紧耦合在一块儿；若是你须要掌握一个服务太多的上下文场景使用条件，那么它就是一个有上下文边界的服务，这个定义来自DDD领域驱动设计。

相对于单体架构和SOA，它的主要特色是组件化、松耦合、自治、去中心化，体如今如下几个方面：

  • 一组小的服务

服务粒度要小，而每一个服务是针对一个单一职责的业务能力的封装，专一作好一件事情。

  • 独立部署运行和扩展

每一个服务可以独立被部署并运行在一个进程内。这种运行和部署方式可以赋予系统灵活的代码组织方式和发布节奏，使得快速交付和应对变化成为可能。

  • 独立开发和演化

技术选型灵活，不受遗留系统技术约束。合适的业务问题选择合适的技术能够独立演化。服务与服务之间采起与语言无关的API进行集成。相对单体架构，微服务架构是更面向业务创新的一种架构模式。

  • 独立团队和自治

团队对服务的整个生命周期负责，工做在独立的上下文中，本身决策本身治理，而不须要统一的指挥中心。团队和团队之间经过松散的社区部落进行衔接。

咱们能够看到整个微服务的思想就如咱们如今面对信息爆炸、知识爆炸是同样的：经过解耦咱们所作的事情，分而治之以减小没必要要的损耗，使得整个复杂的系统和组织可以快速的应对变化。

微服务的基石---RPC服务框架

微服务包含的东西很是多，这里咱们只讨论RPC服务框架，ycroute框架基于Yar扩展为咱们提供了RPC跨网络的服务调用基础，Yar是一个很是轻量级的RPC框架, 使用很是简单, 对于Server端和Soap使用方法很像，而对于客户端，你能够像调用本地对象的函数同样，调用远程的函数。

RPC Server

安装环境 (客户端服务端都须要安装)

扩展： yar.so

扩展： msgpack.so 可选，一个高效的二进制打包协议，用于客户端和服务端之间包传输，还能够选php、json, 若是要使用Msgpack作为打包协议, 就须要安装这个扩展。

服务加载

咱们在 framework/application/controllers/Rpcserver.php 中将 Model 层做为服务，提供给远程的其它程序调用，RPC Client 即可以像调用本地函数同样，调用远程的服务，以下咱们将 UserinfoModel 和 TradeModel 两个模型层提供给远程程序调用。

class RpcserverController extends Core_Controller {
    public function init() {
        parent::init(); //必须
    }

    //用户信息服务
    public function userinfoModelAction() {
        $user_model = Loader::model('UserinfoModel'); //模型层
        $yar_server = new Yar_server($user_model);
        $yar_server->handle();
        exit;
    }
    
    //支付服务
    public function tradeModelAction() {
        $trade_model = Loader::model('TradeModel'); //模型层
        $yar_server = new Yar_server($trade_model);
        $yar_server->handle();
        exit;
    }
}

上面一共提供了2个服务，UserinfoModel 和 TradeModel 分别经过http://localhost/index.php?c=... 和 http://localhost/index.php?c=... 来访问，咱们来看看 UserinfoModel 一共有哪些服务：

Image

从上图能够看到，UserinfoModel 类的全部 public 方法都会被当作服务提供，包括他继承的父类 public 方法。

服务校验

为了安全，咱们最好对客户端发起的RPC服务请求作校验。在 framework/application/plugins/Filter.php 中作校验：

class FilterPlugin extends Yaf_Plugin_Abstract {
    var $params;

    //路由以前调用
    public function routerStartUp ( Yaf_Request_Abstract $request , Yaf_Response_Abstract $response) {
        $this->params = & $request->getParams();

        $this->_auth();
        
        if(!empty($this->params['rpc'])) {
            $this->_rpc_auth(); //rpc 调用校验
        }
    }
    
    //rpc调用校验
    protected function _rpc_auth()
    {
           $signature = $this->get_rpc_signature($this->params);
           if($signature != $this->params['signature']) {
               $this->response_error(1, 'check failed');
           }
    }
    
    //rpc签名计算，不要改函数名，在RPC客户端中 system/YarClientProxy.php 咱们也会用到这个函数，作签名。
    public function get_rpc_signature($params) 
    {
        $secret = 'MJCISDYFYHHNKBCOVIUHFUIHCQWE';
        unset($params['signature']);
        ksort($params);
    reset($params);
    unset($auth_params['callback']);
    unset($auth_params['_']);
    $str = $secret;
    foreach ($params as $value) {
        $str = $str . trim($value);
    }
            
    return md5($str);
    }
    
    ...
    
}

切记不要修改签名生成函数 get_rpc_signature 的名字和参数，由于在 RPC Client 咱们也会利用这个函数作签名，若是须要修改，请在 system/YarClientProxy.php 中作相应修改，以保证客户端和服务器之间的调用正常。

RPC Client

yar 除了支持 http 以外，还支持tcp， unix domain socket传输协议，不过ycroute中只用了 http ，固然 http 也能够开启 keepalive 以得到更高的传输性能，只不过相比 socket， http 协议仍是多了很多的协议头部的开销。

安装环境

扩展： yar.so

扩展： msgpack.so 可选，一个高效的二进制打包协议，用于客户端和服务端之间包传输，还能够选php、json, 若是要使用Msgpack作为打包协议, 就须要安装这个扩展。

调用逻辑

例子：

class UserController extends Core_Controller {

    ...
    
    //获取用户信息(从远程)
    public function getUserInfoByRemoteAction() {
        $userId = $this->params['userid'];
        
        if (empty($userId)) {
            $this->response_error(10000017, "user_id is empty");
        }
        
        $model = Loader::remote_model('UserinfoModel');
        $userInfo = $model->getUserinfoByUserid($userId);
        $this->response_success($userInfo);
    }
    
    ...
}

经过 $model = Loader::remote_model('UserinfoModel'); 能够获取远程 UserinfoModel，参数是framework/application/config/rpc.php配置里的键值：

$remote_config['UserinfoModel']['url'] = "http://localhost/index.php?c=rpcserver&m=userinfoModel&rpc=true";  //服务地址
$remote_config['UserinfoModel']['packager'] = FALSE;         //RPC包类型，FALSE则选择默认，能够为 "json", "msgpack", "php", msgpack 须要安装扩展
$remote_config['UserinfoModel']['persitent'] = FALSE;        //是否长连接，须要服务端支持keepalive
$remote_config['UserinfoModel']['connect_timeout'] = 1000;   //链接超时(毫秒)，默认 1秒 
$remote_config['UserinfoModel']['timeout'] = 5000;           //调用超时(毫秒)， 默认 5 秒
$remote_config['UserinfoModel']['debug'] = TRUE;             //DEBUG模式，调用异常是否会打印到屏幕，线上关闭

$remote_config['TradeModel']['url'] = "http://localhost/index.php?c=rpcserver&m=tradeModel&rpc=true";
$remote_config['TradeModel']['packager'] = FALSE;
$remote_config['TradeModel']['persitent'] = FALSE;
$remote_config['TradeModel']['connect_timeout'] = 1000; 
$remote_config['TradeModel']['timeout'] = 5000;       
$remote_config['TradeModel']['debug'] = TRUE;

这样，咱们就能够把 model 当成本地对象同样调用远程 UserinfoModel 的成员方法。

url签名

调用远程服务的时候，system/YarClientProxy.php 会从配置中获取服务的 url， 而后调用 FilterPlugin::get_rpc_signature 方法对 URL 作签名，并将签名参数拼接到 url 结尾，发起调用。

class YarClientProxy {
    
    ...
    
    public static function get_signatured_url($url) {
        $get = array();
        $t = parse_url($url, PHP_URL_QUERY);
        parse_str($t, $get);
        $get['timestamp'] = time();
        $get['auth'] = rand(11111111, 9999999999);
        $signature = FilterPlugin::get_rpc_signature($get);
        return $url . "&timestamp=" . $get['timestamp'] . "&auth=" . $get['auth'] . "&signature=" . $signature;
    }
    
    ...
}

调用异常日志

日志位于 /data/app/logs/localhost 下，localhost 为项目域名。

[root@gzapi: /data/app/logs/localhost]# ls
yar_client_proxy.20190214.log.wf

[ERROR] [2019-02-14 18:57:13] [0] [index.php|23 => | => User.php|61 => YarClientProxy.php|46] [218.30.116.3] [/index.php?c=user&m=getUserInfoByRemote&userid=6818810&token=c9bea5dee1f49488e2b4b4645ff3717e1] [] [] - "yar_client_call_error URL=[http://tr.gaoqu.site/index.ph...] , Remote_model=[UserinfoModel] Func=[getUserinfoByUserid] Exception=[server responsed non-200 code '500']"

RPC 并行调用

yar框架支持并行调用，能够同时调用多个服务，这样能够充分利用CPU性能，避免IO等待，提高系统性能，按照yar的流程，你首先得一个个注册服务，而后发送注册的调用，而后reset 重置调用。在ycroute 中，一个函数就能够了。

用 Loader::concurrent_call($call_params); 来并行调用RPC服务， 其中 call_params是调用参数数组。

以下数组包含4个元素，每一个调用都包含 model, method 两个必输参数，以及 parameters, callback , error_callback 三个可选参数。

  • model : 服务名，是framework/application/config/rpc.php配置里的键值。
  • method : 调用函数
  • parameters : 函数的参数，是一个数组，数组的个数为参数的个数
  • callback : 回调函数，调用成功以后回调，针对的是各自的回调。
  • error_callback : 调用失败以后会回调这个函数，其中调用超时不会回调该方法， 针对的也是各自的回调。
class UserController extends Core_Controller {
    //获取用户信息(并行远程调用)
    public function multipleGetUsersInfoByRemoteAction() {
        $userId = $this->params['userid'];
        
        $call_params = array();
        $call_params[] = ['model' => 'UserinfoModel', 
                          'method' => 'getUserinfoByUserid', 
                          'parameters' => array($userId), 
                          "callback" => array($this, 'callback1')];
                          
        $call_params[] = ['model' => 'UserinfoModel', 
                          'method' => 'getUserInUserids', 
                          'parameters' => array(array(6860814, 6870818)), 
                          "callback" => array($this, 'callback2'),
                          "error_callback" => array($this, 'error_callback')];
                          
        $call_params[] = ['model' => 'UserinfoModel', 
                          'method' => 'getUserByName', 
                          'parameters' => array('CH.smallhow')];
              
        //不存在的方法
        $call_params[] = ['model' => 'UserinfoModel', 
                          'method' => 'unknownMethod', 
                          'parameters' => array(),
                          "error_callback" => array($this, 'error_callback')];
                          
        Loader::concurrent_call($call_params);
        echo json_encode($this->retval);
        exit;
    }
    
    //回调函数1
    public function callback1($retval, $callinfo) {
        $this->retval['callback1']['retval'] = $retval;
        $this->retval['callback1']['callinfo'] = $callinfo;
    }
    
    //回调函数2
    public function callback2($retval, $callinfo) {
        $this->retval['callback2']['retval'] = $retval;
        $this->retval['callback2']['callinfo'] = $callinfo;
    }
    
    //错误回调
    public function error_callback($type, $error, $callinfo) {
        $tmp['type'] = $type;
        $tmp['error'] = $error;
        $tmp['callinfo'] = $callinfo;
        $this->retval['error_callback'][] = $tmp;
    }
}

我特地将第4个调用的method设置一个不存在的函数，你们能够看下上面的并行调用的结果：

{
    "error_callback":[
        {
            "type":4,
            "error":"call to undefined api ::unknownMethod()",
            "callinfo":{
                "sequence":4,
                "uri":"http://tr.gaoqu.site/index.php?c=rpcserver&m=userinfoModel&rpc=true×tamp=1550142590&auth=5930400101&signature=fc0ed911c624d9176523544421a0248d",
                "method":"unknownMethod"
            }
        }
    ],
    "callback1":{
        "retval":{
            "user_id":"6818810",
            "appid":"wx385863ba15f573b6",
            "open_id":"oXtwn4wkPO4FhHmkan097DpFobvA",
            "union":null,
            "session_key":"Et1yjxbEfRqVmCVsYf5qzA==",
            "nickname":"芒果",
            "city":"Yichun",
            "province":"Jiangxi",
            "country":"China",
            "avatar_url":"https://wx.qlogo.cn/mmopen/vi_32/DYAIOgq83epqg7FwyBUGd5xMXxLQXgW2TDEBhnNjPVla8GmKiccP0pFiaLK1BGpAJDMiaoyGHR9Nib2icIX9Na4Or0g/132",
            "gender":"1",
            "form_id":"",
            "token":"5a350bc05bbbd9556f719a0b8cf2a5ed",
            "amount":"0",
            "last_login_time":"2018-10-04 16:01:27",
            "regist_time":"2018-06-29 21:24:45",
            "updatetime":"2018-10-04 16:01:27"
        },
        "callinfo":{
            "sequence":1,
            "uri":"http://tr.gaoqu.site/index.php?c=rpcserver&m=userinfoModel&rpc=true×tamp=1550142590&auth=8384256613&signature=c0f9c944ae070d2eb38c8e9638723a2e",
            "method":"getUserinfoByUserid"
        }
    },
    "callback2":{
        "retval":{
            "6860814":{
                "user_id":"6860814",
                "nickname":"Smile、格调",
                "avatar_url":"https://wx.qlogo.cn/mmopen/vi_32/Q0j4TwGTfTKNE5mFLk33q690Xl1N6mrehQr0ggasgk8Y4cuaUJt4CNHORwq8rVjwET7H06F3aDjU5UiczjpD4nw/132",
                "city":"Guangzhou"
            },
            "6870818":{
                "user_id":"6870818",
                "nickname":"Yang",
                "avatar_url":"https://wx.qlogo.cn/mmopen/vi_32/Q0j4TwGTfTLTKBoU1tdRicImnUHyr43FdMulSHRhAlsQwuYgAyOlrwQaLGRoFEHbgfVuyEV1K1VU2NMmm0slS4w/132",
                "city":"Hengyang"
            }
        },
        "callinfo":{
            "sequence":2,
            "uri":"http://tr.gaoqu.site/index.php?c=rpcserver&m=userinfoModel&rpc=true×tamp=1550142590&auth=7249482640&signature=26c419450bb4747ac166fbaa4a242b77",
            "method":"getUserInUserids"
        }
    }
}

附录 - Core_Model 中的辅助极速开发函数（不关心能够跳过）

$this->redis_conf_path = 'default_master'; //用到快速缓存时，须要在 __construct 构造函数中加上 redis 缓存配置

/**
 * 插入表记录
 * @param string table 表名
 * @param array data 表数据
 * @param string redis_key redis 缓存键值, 可空， 非空时清理键值缓存
 */
public function insert_table($table, $data, $redis_key = "");
/**
 * 更新表记录
 * @param string table 表名
 * @param array where 查询条件
 * @param array data 更新数据
 * @param string redis_key redis 缓存键值, 可空， 非空时清理键值缓存
 */
public function update_table($table, $where, $data, $redis_key = "");
/**
 * 替换表记录
 * @param string table 表名
 * @param array data 替换数据
 * @param string redis_key redis 缓存键值, 可空， 非空时清理键值缓存
 */
public function replace_table($table, $data, $redis_key = "");
/**
 * 删除表记录
 * @param string table 表名
 * @param array where 查询条件
 * @param string redis_key redis缓存键值, 可空， 非空时清理键值缓存
 */
public function delete_table($table, $where, $redis_key = "");
/**
 * 获取表数据
 * @param string table 表名
 * @param array where 查询条件
 * @param string redis_key redis 缓存键值, 可空， 非空时清理键值缓存
 * @param int redis_expire redis 缓存到期时长(秒)
 * @param boolean set_empty_flag 是否标注空值，若是标注空值，在表记录更新以后，必定记得清理空值标记缓存
 */
public function get_table_data($table, $where = array(), $redis_key = "", $redis_expire = 600, $set_empty_flag = true);
/**
 * 根据key获取表记录
 * @param string table 表名
 * @param string key 键名
 * @param string value 键值
 * @param string redis_key redis 缓存键值, 可空， 非空时清理键值缓存
 * @param int redis_expire redis 缓存到期时长(秒)
 * @param boolean set_empty_flag 是否标注空值，若是标注空值，在表记录更新以后，必定记得清理空值标记缓存
 */
public function get_table_data_by_key($table, $key, $value, $redis_key = "", $redis_expire = 300, $set_empty_flag = true);

/**
 * 获取一条表数据
 * @param string table 表名
 * @param array where 查询条件
 * @param string redis_key redis 缓存键值, 可空， 非空时清理键值缓存
 * @param int redis_expire redis 缓存到期时长(秒)
 * @param boolean set_empty_flag 是否标注空值，若是标注空值，在表记录更新以后，必定记得清理空值标记缓存
 */
public function get_one_table_data($table, $where, $redis_key = "", $redis_expire = 600, $set_empty_flag = true);
联系我们 沪ICP备2021010478号-7