服務治理深刻淺出（2）- 遠程方法調用的實現

需求

在瞭解了前面咱們關於服務治理出現的必要性以後。咱們知道服務治理是創建在衆多「服務」基礎之上的，那麼，第一步，打通這些服務是基礎，也就是咱們常說的 RPC 遠程調用。要像調用本地方法同樣調用遠程服務器上的方法。

如今簡單粗暴口語化的方式來介紹一個需求：

A 服務器上部署的項目中，有一個UserService裏面有一個getUserInfo的方法。
B 服務器上想"直接"調用該方法，怎麼辦?

分析

咱們以 PHP 爲例來進行分析。
咱們但願在 B 服務器上實現相似於 A 服務器上直接調用方式

$userService = new UserService();
$userService->getUserInfo($uid);

咱們常常會使用 SDK 來調用第三方提供的 api 服務，咱們的作法確定相似於

$client  = new \SDK\Client();
$request = new \SDK\UserService\Request\GetStudentInfoRequest();
$request->setUid($uid);
$request->setMethod("GET");
$response = $client->doAction($request);

sdk 裏面的 GetStudentInfoRequest 經過http映射 A 服務器上的UserService::getUserInfo。

sdk 的改造

咱們只須要在原來的基礎上稍做修改便可，下面的代碼僅作簡單的演示

服務端

該服務部署在localhost:8081

class UserService
{
    public static function getUserInfo($uid)
    {
        // 假設如下內容從數據庫取出
        return [
            'id'       => $uid,
            'username' => 'mengkang',
        ];
    }
}

$service = $_GET['service'];
$action = $_GET['action'];
$argv = file_get_contents("php://input");

if (!$service || !$action) {
    die();
}

if ($argv) {
    $argv = json_decode($argv, true);
}


$res = call_user_func_array([$service, $action], $argv);

echo json_encode($res);

客戶端

class Client
{
    private $url;
    private $service;

    private $rpcConfig = [
        "UserService" => "http://127.0.0.1:8081",
    ];

    /**
     * Client constructor.
     * @param $service
     */
    public function __construct($service)
    {
        if (array_key_exists($service, $this->rpcConfig)) {
            $this->url = $this->rpcConfig[$service];
            $this->service = $service;
        }
    }

    public function __call($action, $arguments)
    {


        $content = json_encode($arguments);
        $options['http'] = [
            'timeout' => 5,
            'method'  => 'POST',
            'header'  => 'Content-type:application/x-www-form-urlencoded',
            'content' => $content,
        ];

        $context = stream_context_create($options);

        $get = [
            'service' => $this->service,
            'action'  => $action,
        ];

        $url = $this->url . "?" . http_build_query($get);

        $res = file_get_contents($url, false, $context);

        return json_decode($res, true);
    }

}

$userService = new Client('UserService');
var_export($userService->getUserInfo(103));

這樣是否是就很是方便的在客戶端實現了像在本地同樣調用遠程的方法呢？這也是鳥哥 @Laruence yar 的操做原理。下面對比下 Yar 的 demo：

Yar 演示

yar https://github.com/laruence/yar
yar 的 java 客戶端 https://github.com/zhoumengka...

客戶端代碼，假設該服務設在局域網10.211.55.4上

class RpcClient {
    // RPC 服務地址映射表
    public static $rpcConfig = array(
        "RewardScoreService"    => "http://10.211.55.4/yar/server/RewardScoreService.class.php",
    );
 
    public static function init($server){
        if (array_key_exists($server, self::$rpcConfig)) {
            $uri = self::$rpcConfig[$server];
            return new Yar_Client($uri);
        }
    }
}
 
$RewardScoreService = RpcClient::init("RewardScoreService");
var_dump($RewardScoreService->support(1, 2));

服務器端代碼

class RewardScoreService {
    /**
     * $uid 給 $feedId 點贊
     * @param $feedId  interge
     * @param $uid  interge
     * @return void
     */
    public function support($uid,$feedId){
        return "uid = ".$uid.", feedId = ".$feedId;
    }
}
 
$yar_server = new Yar_server(new RewardScoreService());
$yar_server->handle();

yar 背後的故事就是我前面那段 sdk 改造的代碼演示。想必看到這裏，rpc 框架再也不那麼神祕了吧。
固然這只是實現了 rpc 的一小部分，簡單的遠程調用。畢竟 php 是世界上最好的語言。
java 上面執行遠程調用也相似。

java 遠程調用

若是換成 java 可稍微麻煩點，java 實現起來以後會讓你以爲更加的本地化，因此 java 也是最強大的語言。
因爲 java 是靜態編譯的，不存在相似於 php 裏的__call方法的方式來實現遠程調用，通常經過動態代理來實現

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
 
/**
 * Created by zhoumengkang on 5/12/15.
 */
 
/**
 * 點讚的積分服務接口
 */
interface RewardScoreService{
    String support(int uid,int feedId);
}
 
public class SupportService {
 
    public static void main(String[] args) {
        add(1,2);
    }
 
    /**
     * uid 給 feedId 點贊
     * @param uid
     * @param feedId
     * @return
     */
    public static String add(int uid, int feedId){
        YarClient yarClient = new YarClient();
        RewardScoreService rewardScoreService = (RewardScoreService) yarClient.proxy(RewardScoreService.class);
        return rewardScoreService.support(uid, feedId);
    }
 
}
 
class YarClient {
 
    public final Object proxy(Class type) {
        YarClientInvocationHandler handler = new YarClientInvocationHandler();
        return Proxy.newProxyInstance(type.getClassLoader(), new Class[]{type}, handler);
    }
}
 
final class YarClientInvocationHandler implements InvocationHandler {
 
    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        System.out.println("這裏的動態調用實現了 php 的 __call 方法");
 
        System.out.println("method : " + method.getName());
        for (int i = 0; i < args.length; i++) {
            System.out.println("args["+ i +"] : " + args[i]);
        }
         
        return null;
    }
}

瞭解更多

看完本篇，是否是頓時以爲 rpc 框架再也不那麼神祕，有一點點感受了呢？

老鐵週末的直播：揭開她的神祕面紗 - 零基礎構建本身的服務治理框架 趕快上車
https://segmentfault.com/l/15...