客户端整合spring

rpc-framework-spring/README.md

+# 整合spring
+基于spring 5.2.6.RELEASE 
+
+- 通过一个注解就可以实现远程接口的调用 
+  @RpcServiceScan("github.javaguide.spring.service")
\ No newline at end of file

rpc-framework-spring/pom.xml

@@ -13,10 +13,12 @@
 
 
     <dependencies>
+
         <dependency>
             <groupId>org.springframework</groupId>
             <artifactId>spring-context</artifactId>
             <version>5.2.6.RELEASE</version>
+            <scope>provided</scope>
         </dependency>
 
         <dependency>

rpc-framework-spring/src/main/java/github/javaguide/ClientProxy.java

@@ -5,7 +5,7 @@ import github.javaguide.remoting.transport.ClientTransport;
 import github.javaguide.remoting.transport.netty.client.NettyClientTransport;
 
 /**
- * @description:
+ * @description: 简单写一个方法获取代理对象，其实应该在simple框架里面提供一个接口获取代理对象
  * @author:lvxuhong
  * @date:2020/6/18
  */

rpc-framework-spring/src/main/java/github/javaguide/Config.java

-package github.javaguide;
-
-import github.javaguide.spring.annotation.RpcServiceScan;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * @description:
- * @author:lvxuhong
- * @date:2020/6/18
- */
-
-@Configuration
-@RpcServiceScan("github.javaguide.spring.service")
-//@Import(RpcServiceScannerRegistrar.class)
-public class Config {
-
-}

rpc-framework-spring/src/main/java/github/javaguide/spring/annotation/RpcServiceScannerRegistrar.java

 package github.javaguide.spring.annotation;
 
-import github.javaguide.spring.rpcservice.Scanner;
+import github.javaguide.spring.rpcservice.RpcServiceScanner;
 import org.springframework.beans.factory.support.BeanDefinitionRegistry;
 import org.springframework.context.ResourceLoaderAware;
 import org.springframework.context.annotation.ImportBeanDefinitionRegistrar;
@@ -26,7 +26,7 @@ public class RpcServiceScannerRegistrar implements ImportBeanDefinitionRegistrar
     public void registerBeanDefinitions(AnnotationMetadata importingClassMetadata, BeanDefinitionRegistry registry) {
         AnnotationAttributes annoAttrs = AnnotationAttributes.fromMap(
                 importingClassMetadata.getAnnotationAttributes(RpcServiceScan.class.getName()));
-        Scanner scanner = new Scanner(registry);
+        RpcServiceScanner scanner = new RpcServiceScanner(registry);
         String value = annoAttrs.getString("value");
         if (resourceLoader != null) {
             scanner.setResourceLoader(resourceLoader);

rpc-framework-spring/src/main/java/github/javaguide/spring/rpcservice/Scanner.java → rpc-framework-spring/src/main/java/github/javaguide/spring/rpcservice/RpcServiceScanner.java

@@ -16,11 +16,11 @@ import java.util.Set;
  * @author:lvxuhong
  * @date:2020/6/18
  */
-public class Scanner extends ClassPathBeanDefinitionScanner {
+public class RpcServiceScanner extends ClassPathBeanDefinitionScanner {
 
     private RpcServiceFactoryBean<Object> rpcServiceFactoryBean = new RpcServiceFactoryBean<>();
 
-    public Scanner(BeanDefinitionRegistry registry) {
+    public RpcServiceScanner(BeanDefinitionRegistry registry) {
         super(registry);
     }
 

rpc-framework-spring/src/test/java/ClientTest.java

-import github.javaguide.Config;
-import org.springframework.context.ApplicationContext;
-import org.springframework.context.annotation.AnnotationConfigApplicationContext;
-import org.springframework.context.support.GenericApplicationContext;
-
-/**
- * @description:
- * @author:lvxuhong
- * @date:2020/6/18
- */
-public class ClientTest {
-
-    public static void main(String[] args) {
-        AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
-        applicationContext.register(Config.class);
-        applicationContext.refresh();
-        applicationContext.start();
-        String[] beanDefinitionNames = applicationContext.getBeanDefinitionNames();
-        for (String s : beanDefinitionNames) {
-            System.out.println(s);
-        }
-
-        applicationContext.getBean("Service1");
-    }
-}

rpc-framework-spring/src/main/java/github/javaguide/ClientTest.java → rpc-framework-spring/src/test/java/github/javaguide/spring/ClientTest.java

-package github.javaguide;
+package github.javaguide.spring;
 
+import github.javaguide.spring.annotation.RpcServiceScan;
+import org.junit.Test;
 import org.springframework.context.annotation.AnnotationConfigApplicationContext;
+import org.springframework.context.annotation.Configuration;
 
 /**
  * @description:
  * @author:lvxuhong
- * @date:2020/6/18
+ * @date:2020/6/19
  */
 public class ClientTest {
 
-    public static void main(String[] args) {
+    @Test
+    public void test() {
         AnnotationConfigApplicationContext applicationContext = new AnnotationConfigApplicationContext();
-        applicationContext.register(Config.class);
+        applicationContext.register(TestConfig.class);
         applicationContext.refresh();
         applicationContext.start();
 
 
 
+    }
+
+    @Configuration
+    @RpcServiceScan("github.javaguide.spring.service")
+    public static class TestConfig {
+
     }
 }