Skip to content

Latest commit

 

History

History
115 lines (91 loc) · 3.49 KB

jphp.md

File metadata and controls

115 lines (91 loc) · 3.49 KB

概述

jksoa-rpc-client 整合jphp技术, 支持同构异语言(java/php), 以便支持更多的动态性, 如直接用php来调用rpc

实现

1. WrapJavaReferer

包装java服务的java引用对象, 以便在php中进行rpc调用

php调用如下：

<?php
use php\jksoa\rpc\JavaReferer;

// 打印rpc的调用+结果
function print_rpc($ref, $ret){
   if(is_array($ret))
      $ret = print_r($ret, true);
   echo "----------- php rpc call [{$ref->getLastCall()}], result: $ret\n";
}

// 创建java引用对象: 工程中必须存在类 net.jkcode.jksoa.rpc.example.ISimpleService
$ref = new JavaReferer('net.jkcode.jksoa.rpc.example.ISimpleService');

// rpc: php代理调用java对象
$ret = $ref->hostname();
print_rpc($ref, $ret);

等价于java/kotlin的调用，实际上WrapJavaReferer意义就是php代理调用java对象

// 获得服务引用者(stub)
val service = Referer.getRefer<ISimpleService>()
// 调用服务引用者, 实际调用的是远程方法, 但跟调用本地方法一样简单
val ret = service.hostname()

2. WrapPhpReferer

包装java服务的php引用对象(PhpReferer), 以便在php中进行rpc调用, 借助php的动态性, 我们可以动态的升级rpc服务接口, 不用再重新将java服务接口打包到应用里并重新发布, 大大的减少应用的发布与重启的频率。

  • 1 根据java服务接口来生成php映射类

我们安装并使用idea插件jk-yapix 来生成php映射类

  • 2 java服务类 vs 生成的php映射类

  • 3 php调用

<?php
use php\jksoa\rpc\PhpReferer;

// 打印rpc的调用+结果
function print_rpc($ref, $ret){
   if(is_array($ret))
      $ret = print_r($ret, true);
   echo "----------- php rpc call [{$ref->getLastCall()}], result: $ret\n";
}

// php引用对象
include 'src/test/resources/IPhpGuardService.php'; // 引用生成的php映射类文件
$ref = new PhpReferer('net\jkcode\jksoa\rpc\example\IPhpGuardService');
// rpc: 内部调用 RpcInvocationHandler.guardInvoke(method, this, params, env) 来发送rpc请求
$ret = $ref->getUserByIdAsync(1)->get();
print_rpc($ref, $ret);

3. WrapP2pReferer

包装php服务的php引用对象, 以便在php中调用远端php方法

其实现是通过java远端接口来代理调用远端php方法

  • 1 server端 1.1 java远端服务接口 -- 直接继承net.jkcode.jksoa.rpc.client.jphp.IP2pService, 代理调用 callFunc.php
package net.jkcode.jksoa.rpc.example

import net.jkcode.jksoa.common.annotation.RemoteService
import net.jkcode.jksoa.rpc.client.jphp.IP2pService

@RemoteService
interface IP2pTestService:IP2pService{
}

1.2 java远端服务实现 -- 实现上面1.1的接口类

package net.jkcode.jksoa.rpc.example

class P2pTestService:IP2pTestService{
}

1.3 复制php入口文件 复制 callFunc.php 到server项目的resources/jphp/目录下

1.4 编写server端的php代码 在server项目的resources/jphp/目录下新建php文件Test.php

class Test
{
    public static function sayHi($name) {
        return "Hello, $name";
    }
}
  • 2 client端 php调用如下：
// p2p引用对象
$ref = new P2pReferer('net.jkcode.jksoa.rpc.example.IP2pTestService');
$ret = $ref->callPhpFunc('Test::sayHi', ['shi']);
print_rpc($ref, $ret);