リモートプロシージャコール (RPC) の使用方法-php手册-php.cn

リモートプロシージャコール (RPC) の使用方法

坏嘻嘻

リリース： 2018-09-14 11:44:18

オリジナル

4252 人が閲覧しました

HTTP リクエストスタイルでソケットプログラミングを行ったことがある人は、通信プロトコルを設計するときに、「メッセージヘッダーとメッセージ本文」の分離方法が非常に一般的に使用されることを知っています。メッセージヘッダーはメッセージの内容を相手に伝えます。とメッセージ本文相手に何をすべきかを伝えます。

HTTP プロトコルに基づく RPC と TCP プロトコルに基づく RPC の比較:

HTTP プロトコルに基づくシステム間の RPC は柔軟で実装が簡単です (さまざまなオープンソース Web サーバーのサポート)、オープン (国際標準)、そして本質的に異種プラットフォーム間の呼び出しをサポートしているため、広く使用されています。これに対応するのが TCP プロトコルの実装バージョンです。これはより効率的ですが実装がより複雑で、プロトコルや標準が異なるため、クロスプラットフォームおよび企業間の通信を促進することが困難です。

HTTP プロトコルの実装には欠点があります。これは、同じ内容を含む情報を送信する上位層プロトコルであるため、HTTP プロトコルの送信によって占有されるバイト数は、TCP プロトコルによって占有されるバイト数よりも確実に大きくなります。送信。そのため、同じネットワーク環境下では、HTTPプロトコルで同じコンテンツを送信する場合は、TCPプロトコルでデータを送信するよりも効率が低く、情報の送信に時間がかかります。もちろん、コードの実装を最適化し、gzip データ圧縮を使用することで、このギャップを減らすことができます。長所と短所を比較検討し、実際の環境でのパフォーマンスがユーザーエクスペリエンスに与える影響を考慮すると、HTTP プロトコルに基づく RPC には依然として大きな利点があります。

1. TCP プロトコルに基づいて RPC を実装します。

サービスインターフェイス:

public interface SayHelloService{
     public String sayHello(String helloArg);
}

ログイン後にコピー

サービス実装:

public class SayHelloServiceImpl implements SayHelloService {
    
    @Override
    public String sayHello(String helloArg) {
        if(helloArg.equals("Hello")) {
            return "hello";
        }else{
            return "bye bye";
        }
    }          
}

ログイン後にコピー

サービスコンシューマコンシューマキーコード:

// 接口名称
String interfacename = SayHelloService.class.getName();
// 需要远程执行的方法
Method method = SayHelloService.class.getMethod("sayHello", java.lang.String.class);
// 需要传递到远端的参数
Object[] arguments = {"hello"};
Socket socket = new Socket("127.0.0.1", 1234);
// 将方法名称和参数传递到远端
ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
output.writeUTF(interfacename); // 接口名称
output.writeUTF(method.getName()); // 方法名称
output.writeObject(method.getParameterTypes());
output.writeObject(arguments);

// 从远端读取方法的执行结果
ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
Object result = input.readObject();

ログイン後にコピー

サービスプロバイダープロバイダーキーコード:

ServiceSocket server = new ServerSocket(1234);
while(true){
    Socket socket = server.accept();

    //读取服务信息
    ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
    String interfacename = input.readUTF();    //接口名称
    String methodName = input.readUTF();    // 方法名称
    Class<?>[] parameterTypes = (Class<?>[])input.readObject(); //参数类型
    Object[] arguments = (Object[]) input.readObject(); //参数对象
    
    // 执行调用
    Class serviceinterfaceclass = Class.forName(interfacename);
    Object service = service.get(interfacename);
    Method method = serviceinterfaceclass.getMethod(methodName, parameterTypes);
    Object result = method.invoke(service, arguments);

    ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
    output.writeObject(result);
}

ログイン後にコピー

2. HTTP プロトコルに基づく RPC

プロトコルリクエスト定義:

public class Request{
    
    /**
    * 协议编码
    */
    private byte encode;

    /**
    * 命令
    */
    private String command;

    /**
    * 命令长度
    */
    private int commandLength;
}

ログイン後にコピー

プロトコルレスポンス定義:

public class Response {

    /**
    * 编码
    */
    private byte encode;

    /**
    * 响应长度
    */
    private int responseLength;

    /**
    * 响应
    */
    private String response;
}

ログイン後にコピー

クライアント実装のキーコード:

// 请求
Request request = new Request();
request.setCommand("HELLO");
request.setCommandLength(request.getCommand().length());
request.setEncode(Encode.UTF8.getValue());

Socket client = new Socket("127.0.0.1", 4567);
OutputStream output = client.getOutputStream();

// 发送请求
ProtocolUtil.writeRequest(output, request);
InputStream input = client.getInputStream();
Response = response = ProtocolUtil.readResponse(input);

ログイン後にコピー

サーバー実装のキーコード:

ServerSocket server = new ServerSocket(4567);
while(true){
    Socket client  = server.accept();
   
    //读取响应数据
    InputStream input = client.getInputStream();
    Request request = ProtocolUtil.readRequest(input);
    OutputStream output = client.getOutputStream();
    
    // 组装响应
    Response response = new Response();
    response.setEncode(Encode.UTF8.getValue());
    if(request.getCommand().equals("HELLO")){
       response.setResponse("hello!"); 
    }else {
        response.setResponse("bye bye");    
    }
    
    resposne.setResponseLength(response.getResponse().length());
    ProtocolUtil.writeResponse(output, response);
}

ログイン後にコピー

ProtocolUtil コード

public class ProtocolUtil {

    public static Request readRequest(InputStream input) throws IOException {
        //读取编码
        byte[] encodeByte = new byte[1];
        input.read(encodeByte);
        byte encode = encodeByte[0];
        
        //读取命令长度
        byte[] commandLengthBytes = new byte[4];
        input.read(commandLengthBytes);
        int commandLength = ByteUtil.bytes2Int(commandLengthBytes);

        //读取命令
        byte[] commandBytes = new byte[commandLength];
        input.read(commandBytes);
        String command = "";
        if(Encode.GBK.getValue() == encode){
            command = new String(commandBytes, "GBK");
        }else{
            command = new String(commandBytes, "UTF8");
        }

        // 组装请求返回
        Request request = new Request();
        request.setCommand(command);
        request.setEncode(encode);
        request.setCommandLength(commandLength);

        return request;
    }

    public static void writeResponse(OutputStream output, Response response) throws IOExceptiono{
        //将response响应返回给客户端
        output.write(response.getEncode());
       // output.write(response.getResponseLength()); 
        //直接write一个int类型会截取低8位传输，丢失高8位
        output.write(ByteUtil.int2ByteArray(response.getResponseLength()));
        if(Encode.GBK.getValue() == resposne.getEncode()){
            output.write(response.getResponse().getBytes("GBK"));
        }else{
            output.write(response.getResponse().getBytes("UTF8"));
        }

        output.flush();
    }
}

ログイン後にコピー

public static int bytes2Int(byte[] bytes){
    int num = bytes[3] & 0xFF;
    num |= ((bytes[2] << 8) & 0xFF00;
    num |= ((bytes[1] << 16) & 0xFF0000;
    num |= ((bytes[0] << 24) & oxFF000000;

    return num;
}

ログイン後にコピー

リモート プロシージャ コール (RPC) の使用方法

リモートプロシージャコール (RPC) の使用方法