三百行代碼完成一個(gè)簡(jiǎn)單的rpc框架-創(chuàng)新互聯(lián)

花了半天的時(shí)間寫了個(gè)簡(jiǎn)單的rpc框架，是因?yàn)槲易畛蹩磀ubbo源碼的時(shí)候發(fā)現(xiàn)dubbo雖然看起來(lái)很龐大，但是隱隱約約總感覺(jué)，其實(shí)其絕大多數(shù)功能，都是基于可擴(kuò)張性和服務(wù)治理的需要而編寫的。我看過(guò)dubbo和grpc的源碼，這兩個(gè)都是非常優(yōu)秀的rpc框架，但是為了讓初學(xué)rpc的同學(xué)能夠快速抓住rpc的核心，所以寫了這篇文章，希望看過(guò)的同學(xué)，再次去看dubbo的源碼的時(shí)候，能夠抓住這個(gè)核心去看。
一：rpc協(xié)議的接口
RpcProtocol.java

創(chuàng)新互聯(lián)是一家集網(wǎng)站建設(shè),金秀企業(yè)網(wǎng)站建設(shè),金秀品牌網(wǎng)站建設(shè),網(wǎng)站定制,金秀網(wǎng)站建設(shè)報(bào)價(jià),網(wǎng)絡(luò)營(yíng)銷,網(wǎng)絡(luò)優(yōu)化,金秀網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強(qiáng)企業(yè)競(jìng)爭(zhēng)力?？沙浞譂M足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時(shí)我們時(shí)刻保持專業(yè)、時(shí)尚、前沿，時(shí)刻以成就客戶成長(zhǎng)自我，堅(jiān)持不斷學(xué)習(xí)、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實(shí)用型網(wǎng)站。

public interface RpcProtocol  {
 void export(int port);
 Object refer(Class inrerfaceClass,String host, int port);

}

這個(gè)接口類只提供兩個(gè)接口，那是因?yàn)閷?duì)于一個(gè)rpc框架來(lái)說(shuō)，本質(zhì)上就只需要兩個(gè)接口，一個(gè)是consumer引用provider的服務(wù)，一個(gè)是provider接收到consumer的請(qǐng)求之后對(duì)外暴露服務(wù)。
下面是具體的實(shí)現(xiàn)。代碼不復(fù)雜，可以直接復(fù)制到idea，慢慢調(diào)試

二：rpc協(xié)議的具體實(shí)現(xiàn)

RpcCore.java

public class RpcCore implements RpcProtocol{

private Socket socket;
private ObjectOutputStream objectOutputStream;
private ObjectInputStream objectInputStream;

private ServerSocket serverSocket;
private Map> services=new ConcurrentHashMap>();
private Map> interfaceAtrributes=new ConcurrentHashMap<>();

@Override
public void export(int port){
    start(port);
}

@Override
public Object refer(final Class interfaceClass,String host, int port){
    connect(host,port);
    return Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[]{interfaceClass},
            new InvocationHandler() {
                @Override
                public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                    String interfaceName=interfaceClass.getName();
                    String fullName= (String) interfaceAtrributes.get(interfaceName).get("fullName");
                    return get(fullName,method,args);
                }
            });
}

public Object get(String interfaceFullName,Method method,Object[] parames){
    Object result=null;
    try {
        objectOutputStream.writeUTF(interfaceFullName);
        objectOutputStream.writeUTF(method.getName());
        objectOutputStream.writeObject(method.getParameterTypes());
        objectOutputStream.writeObject(parames);
        objectOutputStream.flush();
        result=objectInputStream.readObject();
    } catch (IOException e) {
        e.printStackTrace();
    } catch (ClassNotFoundException e) {
        e.printStackTrace();
    } finally {
        try {
            if (objectOutputStream!=null) {
                objectOutputStream.close();
            }
            if (objectInputStream!=null) {
                objectInputStream.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    return result;

}

private void start(int port) {
    try {
        serverSocket = new ServerSocket();
        serverSocket.bind(new InetSocketAddress("localhost", port));
        init();
    } catch (IOException e) {
        e.printStackTrace();
    }
    while (true) {
        System.out.println("server has started success port is --->"+port);
        Socket socket = null;
        try {
            socket = serverSocket.accept();
            new Thread(new Processsor(socket,services)).start();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}

public  void init(){
    RpcDemo rpcDemo=new RpcDemoImplProvider();
    String group="rpcDemo";
    String version="1.0.0";
    String fullName=RpcDemo.class.getName()+"&"+group+"&"+version;
    List