本文主要向大家介绍了【云计算】RPC协议解析，通过具体的内容向大家展现，希望对大家学习云计算有所帮助。

package rpc.client;

import java.io.IOException;
import java.net.InetSocketAddress;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import rpc.server.MyInterface;

public class RPCClient {

    public static void main(String[] args) throws Exception {
        //得到的是服务器端的一个代理对象
        MyInterface proxy = RPC.getProxy(MyInterface.class,  //调用服务器端的接口
                                         MyInterface.versionID,      // 版本号
                                         new InetSocketAddress("localhost", 7788), //指定RPC Server的地址
                                         new Configuration());

        String result = proxy.sayHello("Tom");
        System.out.println("结果是："+ result);
    }

}

服务器端

package rpc.server;

import java.io.IOException;

import org.apache.hadoop.HadoopIllegalArgumentException;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Server;
public class RPCServer {
    public static void main(String[] args) throws Exception {
        //定义一个RPC Builder
        RPC.Builder builder = new RPC.Builder(new Configuration());     
        //指定RPC Server的参数
        builder.setBindAddress("localhost");
        builder.setPort(7788);      
        //将自己的程序部署到Server上
        builder.setProtocol(MyInterface.class);
        builder.setInstance(new MyInterfaceImpl());     
        //创建Server
        Server server = builder.build();        
        //启动
        server.start();
    }
}

package rpc.server;

import org.apache.hadoop.ipc.VersionedProtocol;
public interface MyInterface extends VersionedProtocol {
    //定义一个版本号
    public static long versionID=1; 
    //定义客户端可以调用的方法
    public String sayHello(String name);
}

package rpc.server;

import java.io.IOException;
import org.apache.hadoop.ipc.ProtocolSignature;
public class MyInterfaceImpl implements MyInterface {

    @Override
    public ProtocolSignature getProtocolSignature(String arg0, long arg1, int arg2) throws IOException {
        // 指定签名（版本号）
        return new ProtocolSignature(MyInterface.versionID, null);
    }

    @Override
    public long getProtocolVersion(String arg0, long arg1) throws IOException {
        // 返回的该实现类的版本号
        return MyInterface.versionID;
    }

    @Override
    public String sayHello(String name) {
        System.out.println("********* 调用到了Server端*********");
        return "Hello " + name;
    }
}

本文由职坐标整理并发布，希望对同学们有所帮助。了解更多详情请关注职坐标大数据云计算大数据安全频道！