Yaf Yar使用

发表于 2020-05-10 阅读次数：本文字数： 1.2k 阅读时长 ≈ 4 分钟

Yar (Yet Another RPC Framework) 一个rpc框架

Yar 是一个轻量级, 高效的RPC框架, 它提供了一种简单方法来让PHP项目之间可以互相远程调用对方的本地方法. 并且Yar也提供了并行调用的能力. 可以支持同时调用多个远程服务的方法.

范例



//服务端
<?php

/* 假设这个页面的访问路径是: http://example.com/operator.php */

class Operator {

    /**
     * Add two operands
     * @param interge 
     * @return interge
     */
    public function add($a, $b) {
        return $this->_add($a, $b);
    }

    /**
     * Sub 
     */
    public function sub($a, $b) {
        return $a - $b;
    }

    /**
     * Mul
     */
    public function mul($a, $b) {
        return $a * $b;
    }

    /**
     * Protected methods will not be exposed
     * @param interge 
     * @return interge
     */
    protected function _add($a, $b) {
        return $a + $b;
    }
}

$server = new Yar_Server(new Operator());
$server->handle();
?>


// 客户端

<?php
$client = new yar_client("http://example.com/operator.php");

/* call directly */
var_dump($client->add(1, 2));

/* call via call */
var_dump($client->call("add", array(3, 2)));


/* __add can not be called */
var_dump($client->_add(1, 2));
?>

多个客户端异步调用


<?php
function callback($ret, $callinfo) {
    echo $callinfo['method'] , " result: ", $ret , "\n";
}

/* 注册一个异步调用 */
Yar_Concurrent_Client::call("http://example.com/operator.php", "add", array(1, 2), "callback");
Yar_Concurrent_Client::call("http://example.com/operator.php", "sub", array(2, 1), "callback");
Yar_Concurrent_Client::call("http://example.com/operator.php", "mul", array(2, 2), "callback");

/* 发送所有注册的调用, 等待返回, 返回后Yar会调用callback回掉函数 */
Yar_Concurrent_Client::loop();





function callback($ret, $callinfo) {
    echo $callinfo['method'] , " result: ", $ret , "\n";
}

/* 注册一个异步调用 */
Yar_Concurrent_Client::call("http://example.com/operator.php", "add", array(1, 2), "callback");
/* 发送所有注册的调用, 等待返回, 返回后Yar会调用callback回掉函数 */
Yar_Concurrent_Client::loop();
/* 重置call ,否则上面的call会调用*/
Yar_Concurrent_Client::reset();
Yar_Concurrent_Client::call("http://example.com/operator.php", "sub", array(2, 1), "callback");
Yar_Concurrent_Client::loop();


?>

Yaf官方文档

php net yaf官网
 中文文档

Yaf的优点

用C语言开发的PHP框架, 相比原生的PHP, 几乎不会带来额外的性能开销.
所有的框架类, 不需要编译, 在PHP启动的时候加载, 并常驻内存.
更短的内存周转周期, 提高内存利用率, 降低内存占用率.
灵巧的自动加载. 支持全局和局部两种加载规则, 方便类库共享.
高性能的视图引擎.
高度灵活可扩展的框架, 支持自定义视图引擎, 支持插件, 支持自定义路由等等.
内建多种路由, 可以兼容目前常见的各种路由协议.
强大而又高度灵活的配置文件支持. 并支持缓存配置文件, 避免复杂的配置结构带来的性能损失.
在框架本身,对危险的操作习惯做了禁止.
更快的执行速度, 更少的内存占用.

安装


Yaf can be installed from source code by:

cd /path/to/yaf-src/
phpize
./configure
make
sudo make install

路由改写，伪静态


http://dev-all.ekeguan.com/test/1/1.html

在 Bootstrap.php 中 _initRoute 增加：
//http://dev-all.ekeguan.com/product/list/1/2
 $router = $dispatcher->getRouter();
$route  = new Yaf_Route_Rewrite(
        "/product/list/:id/:name",
        array(
            "controller" => "index",
            "action"     => "index",
        )
    ); 
    
    $router->addRoute('dummy', $route);
// http://dev-all.ekeguan.com/user-list/1

// http://dev-all.ekeguan.com/test/1/1.html

    $config = array(
     "user-list" => array(
        "type"  => "rewrite",        //Yaf_Route_Rewrite route
        "match" => "/user-list/:id", //match only /user/list/?/
        "route" => array(
            'controller' => "index",  //route to user controller,
            'action'     => "index",  //route to list action
        ),
     ),
     "test" => array(
        "type"  => "regex",          //Yaf_Route_Regex route
        "match" => "#^/test/([^/]+)/([^/])(.*)\.html+#",         //match arbitrary request uri
        "route" => array(
            'controller' => "index",  //route to product controller,
            'action'     => "index",    //route to dummy action
        ),
        "map" => array(
           1 => "uri",   // now you can call $request->getParam("uri")
        ),
     ),
 );

 $router->addConfig(new Yaf_Config_Simple($config));
 
 
 //分页
 $router = $dispatcher->getRouter();
$config = array(
   "detail" => array(
      "type"  => "regex",          //Yaf_Route_Regex route
      "match" => "#^/details/(\d+)\/?(\d?)(\.html)?#",         //match arbitrary request uri
      "route" => array(
          'controller' => "index",  //route to product controller,
          'action'     => "index",    //route to dummy action
      ),
      "map" => array(
         1 => "id",   // now you can call $request->getParam("uri")
         2 => "page",   // now you can call $request->getParam("uri")
      ),
   ),
);

$router->addConfig(new Yaf_Config_Simple($config));

CLI模式

第一种方式

在public目录下新建cli.php文件


if(php_sapi_name()!='cli'){
    echo 'No authority';exit();
}

$application = new Yaf_Application(GLOBAL_CONFIG_PATH.'application.ini');
$application->execute("main1");

function main1() {
    echo "hello\n";
}

运行 php cli.php 直接执行，运行函数

第二种方式

在public目录下新建cli.php文件

<?php
/*
 * cli命令行
 * 此文件不允许http方式访问
 */
if (php_sapi_name() != 'cli') {
    echo 'No authority';exit();
}
define('ENVIRONMENT', 'develop'); //生成环境请修改为product
define('ROOT_PATH', dirname(__FILE__));
define('APP_PATH', realpath(ROOT_PATH . '/../')); //指向上一级

define('GLOBAL_CONFIG_PATH', '/home/www/config/');
defined('REFERER') ? REFERER : define('REFERER', isset($_SERVER['HTTP_REFERER']) ? $_SERVER['HTTP_REFERER'] : '/'); //上一页

switch (ENVIRONMENT) {
    case 'develop':
        error_reporting(E_ALL & ~E_NOTICE); //报告所有的错误，但除了E_NOTICE这一种
        ini_set('display_errors', 1);
        ini_set('yaf.environ', 'develop');
        break;
    case 'product':
        ini_set('display_errors', 0);
        break;
    default:
        header('HTTP/1.1 503 Service Unavailable.', true, 503);
        echo 'The application environment is not set correctly.';
        exit(1); // EXIT_ERROR
}

$application = new Yaf_Application(GLOBAL_CONFIG_PATH . 'application.ini');
//加载cli的bootstrap配置内容
$application->bootstrap();

//获取argv参数
$uri_r = explode('/', $argv[1]);
$count = count($uri_r);

if ($count > 3 && $count <= 1) {
    echo 'uri error!';
    exit;
} elseif ($count == 2) {
    // 默认模块为空
    array_unshift($uri_r, '');
}

list($module, $controller, $action) = $uri_r;

$params = [];
if (isset($argv[2]) && !empty($argv[2])) {
    parse_str($argv[2], $params);
}

$request = new Yaf_Request_Simple('CLI', $module, $controller, $action, $params);
$application->getDispatcher()->returnResponse(true)->dispatch($request);

使用方法运行php cli2.php account/account/login "name=Bill&age=60",分别为模块，控制器，方法参数一定加上引号 , 其中参数在 controller 中使用 $this->getRequest()->getParams() 控制器里使用这个方法接受参数。