根据RPC框架原理，手写一个mini版RPC

在实际后台服务开发中，RPC框架具备很大的优点，其中当前dubbo已经受到你们的关注和承认，如今开始进行手动码一个简单的RPC框架。

项目背景

假如项目背景为：

订单服务（开发者A负责）须要调用商品服务（开发者B负责），那么开发者B会和A约定调用API，以接口的形式提供给A。一般都是B把API上传到Maven私服，而后B开始写API的实现，A只须要引入API依赖进行开发便可。

 

在实际后台服务开发中，RPC框架具备很大的优点，其中当前dubbo已经受到你们的关注和承认，如今开始进行手动码一个简单的RPC框架。

动手实现RPC

首先项目框架以下图

 

 

订单查询（service模块）

直接调用rpc方法，获取productService实现对象，这个对象经过动态代理的方式获取，若是想了解动态代理和反射知识点，能够参考个人另外两个开源的源码地址
 

https://github.com/SWaiter/proxy.git
https://github.com/SWaiter/reflect.git
 

public class Main {
    public static void main(String[] args) {
        IProductService productService = (IProductService) com.yoozoo.api.Main.rpc(IProductService.class);
        Product product = productService.queryById(1025);
        System.out.println(product);
    }
}

 

商品服务（api模块）

一、首先是bean
 

   public class Product implements Serializable{
       private long id;
       private String name;
       private double price;
       //省去set、get 、tostring 方法
       }

二、定义查询接口
 

public interface IProductService {
    public Product queryById(long id);
}

三、接口实现

 

public class ProductService implements IProductService{
    @Override
    public Product queryById(long id) {
        Product product = new Product();
        product.setId(id);
        product.setName("wangshan");
        product.setPrice(12211.2125);
        return product;
    }
}

四、rpc方法实现
 

public static Object rpc(final Class iProductServiceClass) {
        return Proxy.newProxyInstance(iProductServiceClass.getClassLoader(), new Class[]{iProductServiceClass}, new InvocationHandler() {
            @Override
            public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                Socket socket = new Socket("127.0.0.1", 19088);

                String apiClassName = iProductServiceClass.getName();
                String methodName = method.getName();
                Class[] parameterTypes = method.getParameterTypes();

                ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                objectOutputStream.writeUTF(apiClassName);
                objectOutputStream.writeUTF(methodName);
                objectOutputStream.writeObject(parameterTypes);
                objectOutputStream.writeObject(args);
                objectOutputStream.flush();

                ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
                Object o = objectInputStream.readObject();
                objectInputStream.close();
                objectOutputStream.close();

                socket.close();
                return o;
            }
        });

    }

五、rpc启动

 

public static void main(String[] args) {
            try {
                ServerSocket serverSocket = new ServerSocket(19088);
                while (true) {
                    Socket socket = serverSocket.accept();
                    ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
    
                    String apiClassName = objectInputStream.readUTF();
                    String methodName = objectInputStream.readUTF();
                    Class[] parameterTypes = (Class[]) objectInputStream.readObject();
                    Object[] args4method = (Object[]) objectInputStream.readObject();
    
                    Class clazz = null;
    
                    if (apiClassName.equals(IProductService.class.getName())) {
                        clazz = ProductService.class;
                    }
                    Method method = clazz.getMethod(methodName, parameterTypes);
                    Object invoke = method.invoke(clazz.newInstance(), args4method);
    
                    ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
                    objectOutputStream.writeObject(invoke);
                    objectOutputStream.flush();
    
                    objectInputStream.close();
                    objectOutputStream.close();
                    socket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

 

启动

一、首先启动api中的service中的Main.main方法  
二、而后启动service中的Main.main方法  
三、就能够获取服务对象

com.intellij.rt.execution.application.AppMain com.yoozoo.service.Main
Product{id=1025, name='wangshan', price=12211.2125}
Process finished with exit code 0

总结

 

就这一个简单的rpc框架就完成了。有什么问题能够QQ联系交流。（787324413）