大数据训练营 -0718 课后作业

package com.gaoyong.bd.rpc;
import org.apache.hadoop.ipc.VersionedProtocol;
public interface StuService extends VersionedProtocol {    /**     * 定义版本号     */    long versionID=1l;
    /*    * 输入你的真实学号，返回真实姓名    */    public String finaName(long studentId);
}

package com.gaoyong.bd.rpc;
import org.apache.commons.lang.StringUtils;import org.apache.hadoop.ipc.ProtocolSignature;
import java.io.IOException;
public class StuServiceImpl implements StuService {    @Override    public String finaName(long studentId) {        String name =null;        if(studentId<=0L){            name ="请输入正确的学号";        }       else if (studentId == 20210123456789L){           name ="心心";       }       return name;

    }
    @Override    public long getProtocolVersion(String protocol, long clentVserion) throws IOException {        return StuService.versionID;    }
    @Override    public ProtocolSignature getProtocolSignature(String s, long l, int i) throws IOException {        return null;    }}

package com.gaoyong.bd.rpc.service;

import com.gaoyong.bd.rpc.StuService;import com.gaoyong.bd.rpc.StuServiceImpl;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.ipc.RPC;
import java.io.IOException;
//启动RPCpublic class StuRPCService {    public static void main(String[] args) {        RPC.Builder builder= new RPC.Builder(new Configuration());        //服务器IP地址        builder.setBindAddress("127.0.0.1");        //端口号        builder.setPort(8888);
        builder.setProtocol(StuService.class);        builder.setInstance(new StuServiceImpl());
        try {            RPC.Server server = builder.build();            server.start();            System.out.println("RPC SERVER STARTED");        } catch (IOException e) {            e.printStackTrace();        }
    }}

package com.gaoyong.bd.rpc.client;
import com.gaoyong.bd.rpc.StuService;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.ipc.RPC;
import java.io.IOException;import java.net.InetSocketAddress;
public class StuRPCClient {    public static void main(String[] args) {        try {            StuService proxy = RPC.getProxy(StuService.class,1L,new InetSocketAddress("127.0.0.1",8888),new Configuration());            String name1 = proxy.finaName(20210123456789L);            System.out.println("【Client】输入学号为：20210123456789L，学生姓名为："+name1);            String name2 = proxy.finaName(20210000000000L);            System.out.println("【Client】输入学号为：20210000000000L，学生姓名为："+name2);        } catch (IOException e) {            e.printStackTrace();        }    }}