update homeworks

Author: kimmking

07rpc/rpc01/.DS_Store

@@ -16,9 +16,10 @@
 	<description>RPC demo project for Spring Boot</description>
 
 	<modules>
-		<module>rpcfx-api</module>
+		<module>rpcfx-core</module>
 		<module>rpcfx-server</module>
 		<module>rpcfx-client</module>
+		<module>rpcfx-demo-api</module>
 	</modules>
 
 	<properties>

07rpc/rpc01/pom.xml

@@ -20,7 +20,12 @@
 	<dependencies>
 		<dependency>
 			<groupId>io.kimmking</groupId>
-			<artifactId>rpcfx-api</artifactId>
+			<artifactId>rpcfx-core</artifactId>
+			<version>${project.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>io.kimmking</groupId>
+			<artifactId>rpcfx-demo-api</artifactId>
 			<version>${project.version}</version>
 		</dependency>
 

07rpc/rpc01/rpcfx-client/pom.xml

@@ -17,6 +17,7 @@
 public class Rpcfx {
     public static <T> T create(final Class<T> serviceClass, final String url) {
 
+        // 0. 替换动态代理 -> AOP
         return (T) Proxy.newProxyInstance(Rpcfx.class.getClassLoader(), new Class[]{serviceClass}, new RpcfxInvocationHandler(serviceClass, url));
 
     }
@@ -25,14 +26,17 @@ 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;
         }
 
+        // 可以尝试，自己去写对象序列化，二进制还是文本的，，，rpcfx是xml自定义序列化、反序列化，json: code.google.com/p/rpcfx
+        // int byte char float double long bool
+        // [], data class
+
         @Override
         public Object invoke(Object proxy, Method method, Object[] params) throws Throwable {
             RpcfxRequest request = new RpcfxRequest();
@@ -41,17 +45,26 @@ public Object invoke(Object proxy, Method method, Object[] params) throws Throwa
             request.setParams(params);
 
             RpcfxResponse response = post(request, url);
+
+            // 这里判断response.status，处理异常
+            // 考虑封装一个全局的RpcfxException
+
             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);
+
+            // 1.可以复用client
+            // 2.尝试使用httpclient或者netty client
             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();
+            System.out.println("resp json: "+respJson);
             return JSON.parseObject(respJson, RpcfxResponse.class);
         }
     }

07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/rpcfx/client/Rpcfx.java

@@ -1,6 +1,8 @@
 package io.kimmking.rpcfx.client;
 
 import com.alibaba.fastjson.parser.ParserConfig;
+import io.kimmking.rpcfx.api.Order;
+import io.kimmking.rpcfx.api.OrderService;
 import io.kimmking.rpcfx.api.User;
 import io.kimmking.rpcfx.api.UserService;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
@@ -12,12 +14,26 @@ public class RpcfxClientApplication {
 		ParserConfig.getGlobalInstance().addAccept("io.kimmking");
 	}
 
+	// 二方库
+	// 三方库 lib
+	// nexus, userserivce -> userdao -> user
+	//
+
 	public static void main(String[] args) {
 
-		UserService service = Rpcfx.create(UserService.class, "http://localhost:8080/");
-		User user = service.findById(1);
+		// UserService service = new xxx();
+		// service.findById
+
+		UserService userService = Rpcfx.create(UserService.class, "http://localhost:8080/");
+		User user = userService.findById(1);
 		System.out.println("find user id=1 from server: " + user.getName());
 
+		OrderService orderService = Rpcfx.create(OrderService.class, "http://localhost:8080/");
+		Order order = orderService.findOrderById(1992129);
+		System.out.println(String.format("find order name=%s, amount=%f",order.getName(),order.getAmount()));
+
+		// 新加一个OrderService
+
 //		SpringApplication.run(RpcfxClientApplication.class, args);
 	}
 

07rpc/rpc01/rpcfx-client/src/main/java/io/kimmking/rpcfx/client/RpcfxClientApplication.java

@@ -9,9 +9,9 @@
 <!--		<relativePath/> &lt;!&ndash; lookup parent from repository &ndash;&gt;-->
 	</parent>
 	<groupId>io.kimmking</groupId>
-	<artifactId>rpcfx-api</artifactId>
+	<artifactId>rpcfx-core</artifactId>
 	<version>0.0.1-SNAPSHOT</version>
-	<name>rpcfx-api</name>
+	<name>rpcfx-core</name>
 
 	<properties>
 		<java.version>1.8</java.version>

07rpc/rpc01/rpcfx-api/pom.xml renamed to 07rpc/rpc01/rpcfx-core/pom.xml

@@ -3,7 +3,9 @@
 public class RpcfxResponse {
 
     private Object result;
+
     private boolean status;
+
     private Exception exception;
 
     public Object getResult() {

07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/RpcfxRequest.java renamed to 07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/RpcfxRequest.java

@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+	<parent>
+		<groupId>io.kimmking</groupId>
+		<artifactId>rpcfx</artifactId>
+		<version>0.0.1-SNAPSHOT</version>
+<!--		<relativePath/> &lt;!&ndash; lookup parent from repository &ndash;&gt;-->
+	</parent>
+	<groupId>io.kimmking</groupId>
+	<artifactId>rpcfx-demo-api</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<name>rpcfx-demo-api</name>
+
+	<properties>
+		<java.version>1.8</java.version>
+	</properties>
+
+</project>

07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/RpcfxResponse.java renamed to 07rpc/rpc01/rpcfx-core/src/main/java/io/kimmking/rpcfx/api/RpcfxResponse.java

@@ -0,0 +1,40 @@
+package io.kimmking.rpcfx.demo.api;
+
+public class Order {
+
+    private int id;
+
+    private String name;
+
+    private float amount;
+
+    public Order(int id, String name, float amount) {
+        this.id = id;
+        this.name = name;
+        this.amount = amount;
+    }
+
+    public int getId() {
+        return id;
+    }
+
+    public void setId(int id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public float getAmount() {
+        return amount;
+    }
+
+    public void setAmount(float amount) {
+        this.amount = amount;
+    }
+}