系统架构

image.png
image.png

一些问题

程序入口：
image.png
@RpcScan给开发者用的，对于server侧，开发者在主启动类上标注这个，指定一个路径，框架就会去扫描这个路径及其子路径下的所有被@RpcService标注的类（即暴露的RPC实现类），将其加载到spring容器中：
image.png
那👆🏻代码为何不都直接都用@Component呢：1.开发者便于识别，看到@RpcService就知道这个bean与普通的@Component不一样，它是对外提供的RPC服务！；2.在spring初始化操作的过程中容易对该bean有一些特殊的操作，可将其发布到zookeeper中：
image.png

发布到zookeeper中的结果都存放在my-rpc根节点下面，格式为全类名+group+version：
rpc-guide - 图6

client调用远程服务时、server注册的时候，都需指定version和group，version区分迭代版本，group区分该接口的多个实现类。
image.png
image.png

再来看看这段代码，重点放在第一个方法的分析上：

  1. /**
  2.  * call this method before creating the bean to see if the class is annotated
  3.  *
  4.  * @author shuang.kou
  5.  * @createTime 2020年07月14日 16:42:00
  6.  */
  7. @Slf4j
  8. @Component
  9. public class SpringBeanPostProcessor implements BeanPostProcessor {
  11.     private final ServiceProvider serviceProvider;
  12.     private final RpcRequestTransport rpcClient;
  14.     public SpringBeanPostProcessor() {
  15.         this.serviceProvider = SingletonFactory.getInstance(ZkServiceProviderImpl.class);
  16.         this.rpcClient = ExtensionLoader.getExtensionLoader(RpcRequestTransport.class).getExtension("netty");
  17.     }
  19.     @SneakyThrows
  20.     @Override
  21.     public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
  22.         if (bean.getClass().isAnnotationPresent(RpcService.class)) {
  23.             log.info("[{}] is annotated with  [{}]", bean.getClass().getName(), RpcService.class.getCanonicalName());
  24.             // get RpcService annotation
  25.             RpcService rpcService = bean.getClass().getAnnotation(RpcService.class);
  26.             // build RpcServiceProperties
  27.             RpcServiceConfig rpcServiceConfig = RpcServiceConfig.builder()
  28.                     .group(rpcService.group())
  29.                     .version(rpcService.version())
  30.                     .service(bean).build();
  31.             serviceProvider.publishService(rpcServiceConfig);
  32.         }
  33.         return bean;
  34.     }
  36.     @Override
  37.     public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
  38.         Class<?> targetClass = bean.getClass();
  39.         Field[] declaredFields = targetClass.getDeclaredFields();
  40.         for (Field declaredField : declaredFields) {
  41.             RpcReference rpcReference = declaredField.getAnnotation(RpcReference.class);
  42.             if (rpcReference != null) {
  43.                 RpcServiceConfig rpcServiceConfig = RpcServiceConfig.builder()
  44.                         .group(rpcReference.group())
  45.                         .version(rpcReference.version()).build();
  46.                 RpcClientProxy rpcClientProxy = new RpcClientProxy(rpcClient, rpcServiceConfig);
  47.                 Object clientProxy = rpcClientProxy.getProxy(declaredField.getType());
  48.                 declaredField.setAccessible(true);
  49.                 try {
  50.                     declaredField.set(bean, clientProxy);
  51.                 } catch (IllegalAccessException e) {
  52.                     e.printStackTrace();
  53.                 }
  54.             }
  56.         }
  57.         return bean;
  58.     }
  59. }

在分析第一个方法之前，可以先分析一下项目结构：此类属于rpc-framework-simple这个模块，也就是