美文网首页
根据RPC框架原理,手写一个mini版RPC

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

作者: swaiter | 来源:发表于2018-09-30 17:19 被阅读0次

    我的个人博客地址:http://swaiter.github.io
    根据RPC框架原理,手写一个mini版RPC

    在实际后台服务开发中,RPC框架具有很大的优势,其中当前dubbo已经受到大家的关注和认可,现在开始进行手动码一个简单的RPC框架。

    项目背景

    假如项目背景为:

    订单服务(开发者A负责)需要调用商品服务(开发者B负责),那么开发者B会和A约定调用API,以接口的形式提供给A。通常都是B把API上传到Maven私服,然后B开始写API的实现,A只需要引入API依赖进行开发即可。

    screenshot home

    动手实现RPC

    首先项目框架如下图

    screenshot home

    订单查询(service模块)

    直接调用rpc方法,获取productService实现对象,这个对象通过动态代理的方式获取,如果想了解动态代理和反射知识点,可以参考我的另外两个开源的源码地址

    我的git地址 https://github.com/SWaiter/proxy.git
    我的git地址 https://github.com/SWaiter/reflect.git

    rpc的实现在api模块中

    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模块)

    1、首先是bean

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

    2、定义查询接口

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

    3、接口实现

    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;
        }
    }
    

    4、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;
                }
            });
    
        }
    
    

    5、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();
                }
            }
    

    启动

    1、首先启动api中的service中的Main.main方法
    2、然后启动service中的Main.main方法
    3、就可以获取服务对象

    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)

    相关文章

      网友评论

          本文标题:根据RPC框架原理,手写一个mini版RPC

          本文链接:https://www.haomeiwen.com/subject/zbwwoftx.html