添加异常类

zenglinhui · zenglinhui · commit 56cca62679f4 · 2020-12-16T12:48:20.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
@@ -3,6 +3,7 @@
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.parser.ParserConfig;
+import io.kimmking.rpcfx.exception.RpcfxException;
 import io.kimmking.rpcfx.param.RpcfxRequest;
 import io.kimmking.rpcfx.param.RpcfxResponse;
 import okhttp3.MediaType;
@@ -18,7 +19,11 @@
 public final class Rpcfx {
 
     static {
-        ParserConfig.getGlobalInstance().addAccept("io.kimmking");
+        ParserConfig config = ParserConfig.getGlobalInstance();
+        config.addAccept("io.kimmking");
+        config.setAutoTypeSupport(true);
+
+        //ParserConfig.getGlobalInstance().addAccept("io.kimmking");
     }
 
     public static <T> T create(final Class<T> serviceClass, final String url) {
@@ -51,11 +56,14 @@ 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
-
-            return JSON.parse(response.getResult().toString());
         }
 
         private RpcfxResponse post(RpcfxRequest req, String url) throws IOException {
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
@@ -0,0 +1,17 @@
+package io.kimmking.rpcfx.exception;
+
+public class RpcfxException extends Exception {
+
+    public RpcfxException() {
+        super();
+    }
+
+    public RpcfxException(Throwable throwable) {
+        super(throwable);
+    }
+
+    public RpcfxException(String exception) {
+        super(exception);
+    }
+
+}
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
@@ -3,6 +3,7 @@
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.serializer.SerializerFeature;
 import io.kimmking.rpcfx.api.RpcfxReflectionResolver;
+import io.kimmking.rpcfx.exception.RpcfxException;
 import io.kimmking.rpcfx.param.RpcfxRequest;
 import io.kimmking.rpcfx.api.RpcfxResolver;
 import io.kimmking.rpcfx.param.RpcfxResponse;
@@ -13,24 +14,24 @@
 
 public class RpcfxInvoker {
 
-/*    private RpcfxResolver resolver;
+    private RpcfxResolver resolver;
 
     public RpcfxInvoker(RpcfxResolver resolver){
         this.resolver = resolver;
-    }*/
-    private RpcfxReflectionResolver reflectionResolver;
-
-    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());
@@ -46,7 +47,7 @@ public RpcfxResponse invoke(RpcfxRequest request) {
             // 2.封装一个统一的RpcfxException
             // 客户端也需要判断异常
             e.printStackTrace();
-            response.setException(e);
+            response.setException(new RpcfxException(e));
             response.setStatus(false);
             return response;
         }
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 RpcfxReflectionResolver resolver){
+	public RpcfxInvoker createInvoker(@Autowired RpcfxResolver 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")
