complete

wangkunTiny · Nov 4, 2020 · Nov 5, 2020 · Nov 5, 2020 · Nov 6, 2020 · Nov 6, 2020
commit d360a518ec3ddef629a5c7b23fb2490a72a6c2bb
diff --git a/07rpc/rpc01/rpcfx-api/pom.xml b/07rpc/rpc01/rpcfx-api/pom.xml
@@ -17,13 +17,4 @@
 		<java.version>1.8</java.version>
 	</properties>
 
-	<build>
-		<plugins>
-			<plugin>
-				<groupId>org.springframework.boot</groupId>
-				<artifactId>spring-boot-maven-plugin</artifactId>
-			</plugin>
-		</plugins>
-	</build>
-
 </project>
diff --git a/07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/RpcfxRequest.java b/07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/RpcfxRequest.java
@@ -0,0 +1,34 @@
+package io.kimmking.rpcfx.api;
+
+public class RpcfxRequest {
+
+  private String serviceClass;
+
+  private String method;
+
+  private Object[] params;
+
+    public String getServiceClass() {
+        return serviceClass;
+    }
+
+    public void setServiceClass(String serviceClass) {
+        this.serviceClass = serviceClass;
+    }
+
+    public String getMethod() {
+        return method;
+    }
+
+    public void setMethod(String method) {
+        this.method = method;
+    }
+
+    public Object[] getParams() {
+        return params;
+    }
+
+    public void setParams(Object[] params) {
+        this.params = params;
+    }
+}
diff --git a/07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/RpcfxResponse.java b/07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/RpcfxResponse.java
@@ -0,0 +1,32 @@
+package io.kimmking.rpcfx.api;
+
+public class RpcfxResponse {
+
+    private Object result;
+    private boolean status;
+    private Exception exception;
+
+    public Object getResult() {
+        return result;
+    }
+
+    public void setResult(Object result) {
+        this.result = result;
+    }
+
+    public boolean isStatus() {
+        return status;
+    }
+
+    public void setStatus(boolean status) {
+        this.status = status;
+    }
+
+    public Exception getException() {
+        return exception;
+    }
+
+    public void setException(Exception exception) {
+        this.exception = exception;
+    }
+}
diff --git a/07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/User.java b/07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/User.java
@@ -2,6 +2,13 @@
 
 public class User {
 
+    public User(){}
+
+    public User(int id, String name) {
+        this.id = id;
+        this.name = name;
+    }
+
     private int id;
     private String name;
 

diff --git a/07rpc/rpc01/rpcfx-client/pom.xml b/07rpc/rpc01/rpcfx-client/pom.xml
@@ -34,6 +34,18 @@
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>fastjson</artifactId>
+			<version>1.2.70</version>
+		</dependency>
+
+		<dependency>
+			<groupId>com.squareup.okhttp3</groupId>
+			<artifactId>okhttp</artifactId>
+			<version>3.12.2</version>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

diff --git a/07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java b/07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java
@@ -0,0 +1,58 @@
+package io.kimmking.rpcfx.client;
+
+
+import com.alibaba.fastjson.JSON;
+import io.kimmking.rpcfx.api.RpcfxRequest;
+import io.kimmking.rpcfx.api.RpcfxResponse;
+import okhttp3.MediaType;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.RequestBody;
+
+import java.io.IOException;
+import java.lang.reflect.InvocationHandler;
+import java.lang.reflect.Method;
+import java.lang.reflect.Proxy;
+
+public class Rpcfx {
+    public static <T> T create(final Class<T> serviceClass, final String url) {
+
+        return (T) Proxy.newProxyInstance(Rpcfx.class.getClassLoader(), new Class[]{serviceClass}, new RpcfxInvocationHandler(serviceClass, url));
+
+    }
+
+    public static class RpcfxInvocationHandler implements InvocationHandler {
+
+        public static final MediaType JSONTYPE = MediaType.get("application/json; charset=utf-8");
+
+
+        private final Class<?> serviceClass;
+        private final String url;
+        public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url) {
+            this.serviceClass = serviceClass;
+            this.url = url;
+        }
+
+        @Override
+        public Object invoke(Object proxy, Method method, Object[] params) throws Throwable {
+            RpcfxRequest request = new RpcfxRequest();
+            request.setServiceClass(this.serviceClass.getName());
+            request.setMethod(method.getName());
+            request.setParams(params);
+
+            RpcfxResponse response = post(request, url);
+            return JSON.parse(response.getResult().toString());
+        }
+
+        private RpcfxResponse post(RpcfxRequest req, String url) throws IOException {
+            String reqJson = JSON.toJSONString(req);
+            OkHttpClient client = new OkHttpClient();
+            final Request request = new Request.Builder()
+                    .url(url)
+                    .post(RequestBody.create(JSONTYPE, reqJson))
+                    .build();
+            String respJson = client.newCall(request).execute().body().string();
+            return JSON.parseObject(respJson, RpcfxResponse.class);
+        }
+    }
+}
diff --git a/07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/rpcfx/client/RpcfxClientApplication.java b/07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/rpcfx/client/RpcfxClientApplication.java
@@ -0,0 +1,24 @@
+package io.kimmking.rpcfx.client;
+
+import com.alibaba.fastjson.parser.ParserConfig;
+import io.kimmking.rpcfx.api.User;
+import io.kimmking.rpcfx.api.UserService;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class RpcfxClientApplication {
+
+	static {
+		ParserConfig.getGlobalInstance().addAccept("io.kimmking");
+	}
+
+	public static void main(String[] args) {
+
+		UserService service = Rpcfx.create(UserService.class, "http://localhost:8080/");
+		User user = service.findById(1);
+		System.out.println("find user id=1 from server: " + user.getName());
+
+//		SpringApplication.run(RpcfxClientApplication.class, args);
+	}
+
+}
diff --git a/07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/springboot01/Springboot01Application.java b/07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/springboot01/Springboot01Application.java
diff --git a/07rpc/rpc01/rpcfx-client/src/main/resources/application.yml b/07rpc/rpc01/rpcfx-client/src/main/resources/application.yml
@@ -1,2 +1,2 @@
-server:
-  port: 8080
+#server:
+#  port: 8080
diff --git a/...c01/rpcfx-client/src/test/java/io/kimmking/rpcfx/client/Springboot01ApplicationTests.java b/...c01/rpcfx-client/src/test/java/io/kimmking/rpcfx/client/Springboot01ApplicationTests.java
@@ -0,0 +1,13 @@
+//package io.kimmking.springboot01;
+//
+//import org.junit.Test;
+//import org.springframework.boot.test.context.SpringBootTest;
+//
+//@SpringBootTest
+//class Springboot01ApplicationTests {
+//
+//	@Test
+//	void contextLoads() {
+//	}
+//
+//}
diff --git a/...c01/rpcfx-client/src/test/java/io/kimmking/springboot01/Springboot01ApplicationTests.java b/...c01/rpcfx-client/src/test/java/io/kimmking/springboot01/Springboot01ApplicationTests.java
diff --git a/07rpc/rpc01/rpcfx-server/pom.xml b/07rpc/rpc01/rpcfx-server/pom.xml
@@ -34,6 +34,12 @@
 			<artifactId>spring-boot-starter-web</artifactId>
 		</dependency>
 
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>fastjson</artifactId>
+			<version>1.2.70</version>
+		</dependency>
+
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
 			<artifactId>spring-boot-starter-test</artifactId>

diff --git a/07rpc/rpc01/rpcfx-server/src/main/java/io/kimmking/rpcfx/server/RpcfxServerApplication.java b/07rpc/rpc01/rpcfx-server/src/main/java/io/kimmking/rpcfx/server/RpcfxServerApplication.java
@@ -0,0 +1,51 @@
+package io.kimmking.rpcfx.server;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import io.kimmking.rpcfx.api.RpcfxRequest;
+import io.kimmking.rpcfx.api.RpcfxResponse;
+import io.kimmking.rpcfx.api.User;
+import io.kimmking.rpcfx.api.UserService;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.context.annotation.Bean;
+import org.springframework.util.ReflectionUtils;
+import org.springframework.web.bind.annotation.*;
+
+@SpringBootApplication
+@RestController
+public class RpcfxServerApplication implements ApplicationContextAware {
+
+	private ApplicationContext applicationContext;
+
+	@Override
+	public void setApplicationContext(ApplicationContext applicationContext) {
+		this.applicationContext = applicationContext;
+	}
+
+	public static void main(String[] args) {
+		SpringApplication.run(RpcfxServerApplication.class, args);
+	}
+
+	@PostMapping("/")
+	public RpcfxResponse call(@RequestBody RpcfxRequest request) {
+
+		String serviceClass = request.getServiceClass();
+		// 作业1：改成泛型和反射
+		UserService service = (UserService) this.applicationContext.getBean(serviceClass);
+		int id = Integer.parseInt(request.getParams()[0].toString());
+		Object result = service.findById(id);
+		RpcfxResponse response = new RpcfxResponse();
+		response.setResult(JSON.toJSONString(result, SerializerFeature.WriteClassName));
+		response.setStatus(true);
+		return response;
+	}
+
+	@Bean(name = "io.kimmking.rpcfx.api.UserService")
+	public UserService create(){
+		return new UserServiceImpl();
+	}
+
+}
diff --git a/07rpc/rpc01/rpcfx-server/src/main/java/io/kimmking/rpcfx/server/UserServiceImpl.java b/07rpc/rpc01/rpcfx-server/src/main/java/io/kimmking/rpcfx/server/UserServiceImpl.java
@@ -0,0 +1,12 @@
+package io.kimmking.rpcfx.server;
+
+import io.kimmking.rpcfx.api.User;
+import io.kimmking.rpcfx.api.UserService;
+
+public class UserServiceImpl implements UserService {
+
+    @Override
+    public User findById(int id) {
+        return new User(id, "KK" + System.currentTimeMillis());
+    }
+}
diff --git a/07rpc/rpc01/rpcfx-server/src/main/java/io/kimmking/springboot01/Springboot01Application.java b/07rpc/rpc01/rpcfx-server/src/main/java/io/kimmking/springboot01/Springboot01Application.java