从零开始，徒手撸一个简单的 RPC 框架，轻松搞定！ |
您所在的位置：网站首页 › 从零开始写一个rpc框架 › 从零开始，徒手撸一个简单的 RPC 框架，轻松搞定！ |
从零开始，徒手撸一个简单的 RPC 框架，轻松搞定！
|
得知了RPC（远程过程调用）简单来说就是调用远程的服务就像调用本地方法一样，其中用到的知识有序列化和反序列化、动态代理、网络传输、动态加载、反射这些知识点。发现这些知识都了解一些。所以就想着试试自己实现一个简单的RPC框架，即巩固了基础的知识，也能更加深入的了解RPC原理。当然一个完整的RPC框架包含了许多的功能，例如服务的发现与治理，网关等等。本篇只是简单的实现了一个调用的过程。 传参出参分析一个简单请求可以抽象为两步 那么就根据这两步进行分析，在请求之前我们应该发送给服务端什么信息？而服务端处理完以后应该返回客户端什么信息？ 1、在请求之前我们应该发送给服务端什么信息？由于我们在客户端调用的是服务端提供的接口，所以我们需要将客户端调用的信息传输过去，那么我们可以将要传输的信息分为两类 第一类是服务端可以根据这个信息找到相应的接口实现类和方法 第二类是调用此方法传输的参数信息 那么我们就根据要传输的两类信息进行分析，什么信息能够找到相应的实现类的相应的方法？要找到方法必须要先找到类，这里我们可以简单的用Spring提供的Bean实例管理ApplicationContext进行类的寻找。所以要找到类的实例只需要知道此类的名字就行，找到了类的实例，那么如何找到方法呢？在反射中通过反射能够根据方法名和参数类型从而找到这个方法。那么此时第一类的信息我们就明了了，那么就建立相应的是实体类存储这些信息。 @Data public class Request implements Serializable { private static final long serialVersionUID = 3933918042687238629L; private String className; private String methodName; private Class [] parameTypes; private Object [] parameters; } 2、服务端处理完以后应该返回客户端什么信息？上面我们分析了客户端应该传输什么信息给服务端，那么服务端处理完以后应该传什么样的返回值呢？这里我们只考虑最简单的情况，客户端请求的线程也会一直在等着，不会有异步处理这一说，所以这么分析的话就简单了，直接将得到的处理结果返回就行了。 @Data public class Response implements Serializable { private static final long serialVersionUID = -2393333111247658778L; private Object result; }由于都涉及到了网络传输，所以都要实现序列化的接口 如何获得传参信息并执行？-客户端上面我们分析了客户端向服务端发送的信息都有哪些？那么我们如何获得这些信息呢？首先我们调用的是接口，所以我们需要写自定义注解然后在程序启动的时候将这些信息加载在Spring容器中。有了这些信息那么我们就需要传输了，调用接口但是实际上执行的确实网络传输的过程，所以我们需要动态代理。那么就可以分为以下两步 初始化信息阶段：将key为接口名，value为动态接口类注册进Spring容器中 执行阶段：通过动态代理，实际执行网络传输 1、初始化信息阶段由于我们使用Spring作为Bean的管理，所以要将接口和对应的代理类注册进Spring容器中。而我们如何找到我们想要调用的接口类呢？我们可以自定义注解进行扫描。将想要调用的接口全部注册进容器中。 创建一个注解类，用于标注哪些接口是可以进行Rpc的 @Target({ElementType.TYPE}) @Retention(RetentionPolicy.RUNTIME) public @interface RpcClient { }然后创建对于@RpcClient注解的扫描类RpcInitConfig，将其注册进Spring容器中 public class RpcInitConfig implements ImportBeanDefinitionRegistrar{ @Override public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) { ClassPathScanningCandidateComponentProvider provider = getScanner(); //设置扫描器 provider.addIncludeFilter(new AnnotationTypeFilter(RpcClient.class)); //扫描此包下的所有带有@RpcClient的注解的类 Set beanDefinitionSet = provider.findCandidateComponents("com.example.rpcclient.client"); for (BeanDefinition beanDefinition : beanDefinitionSet){ if (beanDefinition instanceof AnnotatedBeanDefinition){ //获得注解上的参数信息 AnnotatedBeanDefinition annotatedBeanDefinition = (AnnotatedBeanDefinition) beanDefinition; String beanClassAllName = beanDefinition.getBeanClassName(); Map paraMap = annotatedBeanDefinition.getMetadata() .getAnnotationAttributes(RpcClient.class.getCanonicalName()); //将RpcClient的工厂类注册进去 BeanDefinitionBuilder builder = BeanDefinitionBuilder .genericBeanDefinition(RpcClinetFactoryBean.class); //设置RpcClinetFactoryBean工厂类中的构造函数的值 builder.addConstructorArgValue(beanClassAllName); builder.getBeanDefinition().setAutowireMode(AbstractBeanDefinition.AUTOWIRE_BY_TYPE); //将其注册进容器中 registry.registerBeanDefinition( beanClassAllName , builder.getBeanDefinition()); } } } //允许Spring扫描接口上的注解 protected ClassPathScanningCandidateComponentProvider getScanner() { return new ClassPathScanningCandidateComponentProvider(false) { @Override protected boolean isCandidateComponent(AnnotatedBeanDefinition beanDefinition) { return beanDefinition.getMetadata().isInterface() && beanDefinition.getMetadata().isIndependent(); } }; } }由于上面注册的是工厂类，所以我们建立一个工厂类RpcClinetFactoryBean继承Spring中的FactoryBean类，由其统一创建@RpcClient注解的代理类 如果对FactoryBean类不了解的可以参见FactoryBean讲解 @Data public class RpcClinetFactoryBean implements FactoryBean { @Autowired private RpcDynamicPro rpcDynamicPro; private Class classType; public RpcClinetFactoryBean(Class classType) { this.classType = classType; } @Override public Object getObject(){ ClassLoader classLoader = classType.getClassLoader(); Object object = Proxy.newProxyInstance(classLoader,new Class[]{classType},rpcDynamicPro); return object; } @Override public Class getObjectType() { return this.classType; } @Override public boolean isSingleton() { return false; } }注意此处的getObjectType方法，在将工厂类注入到容器中的时候，这个方法返回的是什么Class类型那么注册进容器中就是什么Class类型。 然后看一下我们创建的代理类rpcDynamicPro @Component @Slf4j public class RpcDynamicPro implements InvocationHandler { @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { String requestJson = objectToJson(method,args); Socket client = new Socket("127.0.0.1", 20006); client.setSoTimeout(10000); //获取Socket的输出流，用来发送数据到服务端 PrintStream out = new PrintStream(client.getOutputStream()); //获取Socket的输入流，用来接收从服务端发送过来的数据 BufferedReader buf = new BufferedReader(new InputStreamReader(client.getInputStream())); //发送数据到服务端 out.println(requestJson); Response response = new Response(); Gson gson =new Gson(); try{ //从服务器端接收数据有个时间限制（系统自设，也可以自己设置），超过了这个时间，便会抛出该异常 String responsJson = buf.readLine(); response = gson.fromJson(responsJson, Response.class); }catch(SocketTimeoutException e){ log.info("Time out, No response"); } if(client != null){ //如果构造函数建立起了连接，则关闭套接字，如果没有建立起连接，自然不用关闭 client.close(); //只关闭socket，其关联的输入输出流也会被关闭 } return response.getResult(); } public String objectToJson(Method method,Object [] args){ Request request = new Request(); String methodName = method.getName(); Class[] parameterTypes = method.getParameterTypes(); String className = method.getDeclaringClass().getName(); request.setMethodName(methodName); request.setParameTypes(parameterTypes); request.setParameters(args); request.setClassName(getClassName(className)); GsonBuilder gsonBuilder = new GsonBuilder(); gsonBuilder.registerTypeAdapterFactory(new ClassTypeAdapterFactory()); Gson gson = gsonBuilder.create(); return gson.toJson(request); } private String getClassName(String beanClassName){ String className = beanClassName.substring(beanClassName.lastIndexOf(".")+1); className = className.substring(0,1).toLowerCase() + className.substring(1); return className; } }我们的客户端已经写完了，传给服务端的信息我们也已经拼装完毕了。剩下的工作就简单了，开始编写服务端的代码。 服务端处理完以后应该返回客户端什么信息？-服务端服务端的代码相比较客户端来说要简单一些。可以简单分为下面三步 拿到接口名以后，通过接口名找到实现类 通过反射进行对应方法的执行 返回执行完的信息 那么我们就根据这三步进行编写代码 1、拿到接口名以后，通过接口名找到实现类如何通过接口名拿到对应接口的实现类呢？这就需要我们在服务端启动的时候将其对应信息加载进去 @Component @Log4j public class InitRpcConfig implements CommandLineRunner { @Autowired private ApplicationContext applicationContext; public static Map rpcServiceMap = new HashMap(); @Override public void run(String... args) throws Exception { Map beansWithAnnotation = applicationContext.getBeansWithAnnotation(Service.class); for (Object bean: beansWithAnnotation.values()){ Class clazz = bean.getClass(); Class[] interfaces = clazz.getInterfaces(); for (Class inter : interfaces){ rpcServiceMap.put(getClassName(inter.getName()),bean); log.info("已经加载的服务:"+inter.getName()); } } } private String getClassName(String beanClassName){ String className = beanClassName.substring(beanClassName.lastIndexOf(".")+1); className = className.substring(0,1).toLowerCase() + className.substring(1); return className; } }此时rpcServiceMap存储的就是接口名和其对应的实现类的对应关系。 2、通过反射进行对应方法的执行此时拿到了对应关系以后就能根据客户端传过来的信息找到相应的实现类中的方法。然后进行执行并返回信息就行 public Response invokeMethod(Request request){ String className = request.getClassName(); String methodName = request.getMethodName(); Object[] parameters = request.getParameters(); Class[] parameTypes = request.getParameTypes(); Object o = InitRpcConfig.rpcServiceMap.get(className); Response response = new Response(); try { Method method = o.getClass().getDeclaredMethod(methodName, parameTypes); Object invokeMethod = method.invoke(o, parameters); response.setResult(invokeMethod); } catch (NoSuchMethodException e) { log.info("没有找到"+methodName); } catch (IllegalAccessException e) { log.info("执行错误"+parameters); } catch (InvocationTargetException e) { log.info("执行错误"+parameters); } return response; }现在我们两个服务都启动起来并且在客户端进行调用就发现只是调用接口就能调用过来了。 总结到现在一个简单的RPC就完成了，但是其中还有很多的功能需要完善，例如一个完整RPC框架肯定还需要服务注册与发现，而且双方通信肯定也不能是直接开启一个线程一直在等着，肯定需要是异步的等等的各种功能。后面随着学习的深入，这个框架也会慢慢增加一些东西。不仅是对所学知识的一个应用，更是一个总结。有时候学一个东西学起来觉得很简单，但是真正应用的时候就会发现各种各样的小问题。比如在写这个例子的时候碰到一个问题就是@Autowired的时候一直找不到SendMessage的类型，最后才发现是工厂类RpcClinetFactoryBean中的getObjectType中的返回类型写错了，我之前写的是 public Class getObjectType() { return this.getClass();; }这样的话注册进容器的就是RpcClinetFactoryBean类型的而不是SendMessage的类型。 作者：保洁阿姨 juejin.cn/post/6844903764445364232 往期精选 点击标题可跳转 Spring Boot 2.x 推荐缓存框架 Caffeine 高性能设计剖析 在 Java 项目中，如何使用 Error 日志更加方便排查问题，这才是正确姿势，非常实用！ 19 张思维导图带你梳理 Spring Cloud 体系中的重要知识点！ 程序员经常浏览的 60 个技术网站汇总，还不赶快收藏！ 还在手动部署 Spring Boot 项目？使用 Docker 真香！ 【Stackoverflow 问题】为什么资深的程序员都不用 “ ! = null " 做判空？ 你还在使用 BeanUtils 来做对象转换吗？快试试 MapStruct 吧！ Spring boot 集成阿里开源 Sentinel 限流神器，轻松搞定接口限流！ 关于分布式锁 Redis 与 Zookeeper 的原理，它们如何实现分布式锁？ IntelliJ IDEA 2020.2.3 版本永久破解激活详细教程，亲测有效！ 有了 HTTP 协议，为什么还要 RPC 协议，两者有什么区别？ 点个赞，就知道你“在看”！ |
【本文地址】
今日新闻 |
推荐新闻 |