周六第3题:改成泛型和反射，增加全局异常类，处理异常

曾林辉 · 曾林辉 · commit 393dd9ed49aa · 2020-12-16T18:12:34.000+08:00
diff --git a/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java
@@ -19,11 +19,7 @@
 public final class Rpcfx {
 
     static {
-        ParserConfig config = ParserConfig.getGlobalInstance();
-        config.addAccept("io.kimmking");
-        config.setAutoTypeSupport(true);
-
-        //ParserConfig.getGlobalInstance().addAccept("io.kimmking");
+        ParserConfig.getGlobalInstance().addAccept("io.kimmking");
     }
 
     public static <T> T create(final Class<T> serviceClass, final String url) {
@@ -39,6 +35,7 @@ public static class RpcfxInvocationHandler implements InvocationHandler {
 
         private final Class<?> serviceClass;
         private final String url;
+
         public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url) {
             this.serviceClass = serviceClass;
             this.url = url;
@@ -56,19 +53,17 @@ public Object invoke(Object proxy, Method method, Object[] params) throws Throwa
             request.setParams(params);
 
             RpcfxResponse response = post(request, url);
-            if (response.isStatus()) {
-                return response.getResult();
-            } else {
-                RpcfxException e = (RpcfxException) response.getException();
-                return null;
-            }
             // 这里判断response.status，处理异常
             // 考虑封装一个全局的RpcfxException
+            if (!response.isStatus()) {
+                throw new RpcfxException("invoke error", response.getException());
+            }
+            return JSON.parse(response.getResult().toString());
         }
 
         private RpcfxResponse post(RpcfxRequest req, String url) throws IOException {
             String reqJson = JSON.toJSONString(req);
-            System.out.println("req json: "+reqJson);
+            System.out.println("req json: " + reqJson);
 
             // 1.可以复用client
             // 2.尝试使用httpclient或者netty client
@@ -78,7 +73,7 @@ private RpcfxResponse post(RpcfxRequest req, String url) throws IOException {
                     .post(RequestBody.create(JSONTYPE, reqJson))
                     .build();
             String respJson = client.newCall(request).execute().body().string();
-            System.out.println("resp json: "+respJson);
+            System.out.println("resp json: " + respJson);
             return JSON.parseObject(respJson, RpcfxResponse.class);
         }
     }
diff --git a/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/exception/RpcfxException.java b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/exception/RpcfxException.java
@@ -10,8 +10,12 @@ public RpcfxException(Throwable throwable) {
         super(throwable);
     }
 
-    public RpcfxException(String exception) {
-        super(exception);
+    public RpcfxException(String message) {
+        super(message);
+    }
+
+    public RpcfxException(String message, Throwable throwable) {
+        super(message, throwable);
     }
 
 }
diff --git a/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/server/RpcfxInvoker.java b/07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/server/RpcfxInvoker.java
@@ -14,24 +14,24 @@
 
 public class RpcfxInvoker {
 
-    private RpcfxResolver resolver;
+//    private RpcfxResolver resolver;
+//
+//    public RpcfxInvoker(RpcfxResolver resolver){
+//        this.resolver = resolver;
+//    }
+    private RpcfxReflectionResolver reflectionResolver;
 
-    public RpcfxInvoker(RpcfxResolver resolver){
-        this.resolver = resolver;
+    public RpcfxInvoker(RpcfxReflectionResolver reflectionResolver) {
+        this.reflectionResolver = reflectionResolver;
     }
-    //private RpcfxReflectionResolver reflectionResolver;
-
-//    public RpcfxInvoker(RpcfxReflectionResolver reflectionResolver) {
-//        this.reflectionResolver = reflectionResolver;
-//    }
 
     public RpcfxResponse invoke(RpcfxRequest request) {
         RpcfxResponse response = new RpcfxResponse();
         String serviceClass = request.getServiceClass();
 
         // 作业1：改成泛型和反射
-        Object service = resolver.resolve(serviceClass);//this.applicationContext.getBean(serviceClass);
-        //Object service = reflectionResolver.resolve(serviceClass);
+        //Object service = resolver.resolve(serviceClass);//this.applicationContext.getBean(serviceClass);
+        Object service = reflectionResolver.resolve(serviceClass);
 
         try {
             Method method = resolveMethodFromClass(service.getClass(), request.getMethod());
diff --git a/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/ReflectionResolver.java b/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/ReflectionResolver.java
@@ -1,28 +1,30 @@
 package io.kimmking.rpcfx.demo.provider;
 
 import io.kimmking.rpcfx.api.RpcfxReflectionResolver;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
 
 import java.lang.reflect.InvocationTargetException;
 
-public class ReflectionResolver<T> implements RpcfxReflectionResolver<T> {
+public class ReflectionResolver<T> implements RpcfxReflectionResolver<T>, ApplicationContextAware {
+
+    private ApplicationContext applicationContext;
+
     @Override
     public T resolve(String serviceClass) {
         T t = null;
         try {
             Class<?> klass = Class.forName(serviceClass);
-            t = (T) klass.getConstructor().newInstance();
+            t = (T) applicationContext.getBean(klass);
         } catch (ClassNotFoundException e) {
             e.printStackTrace();
-        } catch (IllegalAccessException e) {
-            e.printStackTrace();
-        } catch (InstantiationException e) {
-            e.printStackTrace();
-        } catch (NoSuchMethodException e) {
-            e.printStackTrace();
-        } catch (InvocationTargetException e) {
-            e.printStackTrace();
         }
-
         return t;
     }
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        this.applicationContext = applicationContext;
+    }
 }
diff --git a/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java b/07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java
@@ -32,20 +32,20 @@ public RpcfxResponse invoke(@RequestBody RpcfxRequest request) {
 	}
 
 	@Bean
-	public RpcfxInvoker createInvoker(@Autowired RpcfxResolver resolver){
+	public RpcfxInvoker createInvoker(@Autowired RpcfxReflectionResolver resolver){
 		return new RpcfxInvoker(resolver);
 	}
 
-//	@Bean
-//	public RpcfxReflectionResolver createReflectionResolver() {
-//		return new ReflectionResolver();
-//	}
-
 	@Bean
-	public RpcfxResolver createResolver(){
-		return new DemoResolver();
+	public RpcfxReflectionResolver createReflectionResolver() {
+		return new ReflectionResolver();
 	}
 
+//	@Bean
+//	public RpcfxResolver createResolver(){
+//		return new DemoResolver();
+//	}
+
 	// 能否去掉name
 	//
 	@Bean(name = "io.kimmking.rpcfx.demo.api.UserService")

Original file line number	Diff line number	Diff line change
`@@ -10,8 +10,12 @@ public RpcfxException(Throwable throwable) {`
`10`	`10`	`super(throwable);`
`11`	`11`	`}`
`12`	`12`
`13`		`- public RpcfxException(String exception) {`
`14`		`- super(exception);`
	`13`	`+ public RpcfxException(String message) {`
	`14`	`+ super(message);`
	`15`	`+ }`
	`16`	`+`
	`17`	`+ public RpcfxException(String message, Throwable throwable) {`
	`18`	`+ super(message, throwable);`
`15`	`19`	`}`
`16`	`20`
`17`	`21`	`}`