摘要：前言昨天看了一篇關(guān)于用幾行代碼實(shí)現(xiàn)框架的博客，收獲很大，于是我想在這篇博客的基礎(chǔ)上理一理思路，盡可能的多加一點(diǎn)注釋，進(jìn)一步降低學(xué)習(xí)框架原理的門檻。

昨天看了一篇關(guān)于用幾行代碼實(shí)現(xiàn)RPC框架的博客[http://javatar.iteye.com/blog...]()，收獲很大，于是我想在這篇博客的基礎(chǔ)上理一理思路，盡可能的多加一點(diǎn)注釋，進(jìn)一步降低學(xué)習(xí)RPC框架原理的門檻。

先上一個(gè)原理圖，讀者可根據(jù)此圖來幫助理解后續(xù)的代碼。

RpcFramework核心類

import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.net.ServerSocket;
import java.net.Socket;


public class RpcFramework {

    /**
     * 暴露服務(wù)
     *
     * @param service 服務(wù)實(shí)現(xiàn)
     * @param port 服務(wù)端口
     * @throws Exception
     */
    public static void export(final Object service, int port) throws Exception {

        System.out.println("Export service " + service.getClass().getName() + " on port " + port);

        ServerSocket server = new ServerSocket(port);
        //一直輪詢，相比while(true)，這種方式性能更佳
        for(;;) {
            try {
                //此處阻塞一直等到有consumer請(qǐng)求過來
                final Socket socket = server.accept();
                //每來一個(gè)消費(fèi)請(qǐng)求就開啟一個(gè)新的線程
                new Thread(() -> {
                    try {
                        try {
                            ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
                            try {
                                //consumer會(huì)分三次發(fā)送所需要的方法信息，這里的readUTF(),readObject()都會(huì)發(fā)生阻塞
                                String methodName = input.readUTF();
                                Class[] parameterTypes = (Class[])input.readObject();
                                Object[] arguments = (Object[])input.readObject();
                                ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
                                try {
                                    //獲取到目標(biāo)方法
                                    Method method = service.getClass().getMethod(methodName, parameterTypes);
                                    //通過反射執(zhí)行目標(biāo)方法并返回結(jié)果
                                    Object result = method.invoke(service, arguments);
                                    //將執(zhí)行結(jié)果返回給consumer
                                    output.writeObject(result);
                                } catch (Throwable t) {
                                    output.writeObject(t);
                                } finally {
                                    output.close();
                                }
                            } finally {
                                input.close();
                            }
                        } finally {
                            socket.close();
                        }
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }).start();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

    /**
     * 引用服務(wù)
     *
     * @param  接口泛型
     * @param interfaceClass 接口類型
     * @param host 服務(wù)器主機(jī)名
     * @param port 服務(wù)器端口
     * @return 遠(yuǎn)程服務(wù)
     * @throws Exception
     */
    @SuppressWarnings("unchecked")
    public static  T refer(final Class interfaceClass, final String host, final int port) throws Exception {

        System.out.println("Get remote service " + interfaceClass.getName() + " from server " + host + ":" + port);
        //通過JDK動(dòng)態(tài)代理的方式直接返回給調(diào)用refer方法的調(diào)用者一個(gè)被動(dòng)態(tài)代理處理過的 對(duì)象
        return (T) Proxy.newProxyInstance(interfaceClass.getClassLoader(), new Class[] {interfaceClass}, new InvocationHandler() {
            @Override
            //調(diào)用該對(duì)象的每個(gè)方法都會(huì)先去調(diào)用下面的邏輯
            public Object invoke(Object proxy, Method method, Object[] arguments) throws Throwable {
                //當(dāng)方法真實(shí)被調(diào)用的時(shí)候才會(huì)發(fā)起RPC遠(yuǎn)程請(qǐng)求provider執(zhí)行服務(wù)
                Socket socket = new Socket(host, port);
                try {
                    ObjectOutputStream output = new ObjectOutputStream(socket.getOutputStream());
                    try {
                        //分三次發(fā)送方法所需要的信息
                        output.writeUTF(method.getName());
                        output.writeObject(method.getParameterTypes());
                        output.writeObject(arguments);
                        ObjectInputStream input = new ObjectInputStream(socket.getInputStream());
                        try {
                            //得到服務(wù)執(zhí)行的最終結(jié)果
                            Object result = input.readObject();
                            if (result instanceof Throwable) {
                                throw (Throwable) result;
                            }
                            return result;
                        } finally {
                            input.close();
                        }
                    } finally {
                        output.close();
                    }
                } finally {
                    socket.close();
                }
            }
        });
    }

}

服務(wù)接口

public interface HelloService {

    String hello(String name);

}

服務(wù)接口實(shí)現(xiàn)

public class HelloServiceImpl implements HelloService {

    @Override
    public String hello(String name) {
        System.out.println("被調(diào)用了");
        return "Hello" + name;
    }

}

provider引導(dǎo)類

public class RpcProvider {
    public static void main(String[] args) throws Exception {
        HelloService service = new HelloServiceImpl();
        RpcFramework.export(service, 1234);
    }
}

consumer引導(dǎo)類

public class RpcConsumer {
        public static void main(String[] args) throws Exception {
            //此時(shí)獲取到的service是被JDK動(dòng)態(tài)代理包裝后的service，在調(diào)用方法的時(shí)候會(huì)進(jìn)行遠(yuǎn)程調(diào)用
            HelloService service = RpcFramework.refer(HelloService.class, "127.0.0.1", 1234);
            for (int i = 0; i < Integer.MAX_VALUE; i ++) {
                String hello = service.hello("World" + i);
                System.out.println(hello);
                Thread.sleep(1000);
            }
        }
}

下圖是provider項(xiàng)目的類結(jié)構(gòu)圖

下圖是consumer項(xiàng)目的類結(jié)構(gòu)圖

簡單總結(jié)了一下簡易R(shí)PC框架，題主最近正在學(xué)習(xí)dubbo原理，故并沒有延展講太多分布式內(nèi)容，希望隨著學(xué)習(xí)的深入以后能寫一篇關(guān)于分布式的文章，共勉！