complete

Author: kimmking

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>

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

@@ -0,0 +1,34 @@
+packageio.kimmking.rpcfx.api;
+
+publicclassRpcfxRequest{
+
+privateStringserviceClass;
+
+privateStringmethod;
+
+privateObject[] params;
+
+publicStringgetServiceClass(){
+returnserviceClass;
+ }
+
+publicvoidsetServiceClass(StringserviceClass){
+this.serviceClass = serviceClass;
+ }
+
+publicStringgetMethod(){
+returnmethod;
+ }
+
+publicvoidsetMethod(Stringmethod){
+this.method = method;
+ }
+
+publicObject[] getParams(){
+returnparams;
+ }
+
+publicvoidsetParams(Object[] params){
+this.params = params;
+ }
+}

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

@@ -0,0 +1,32 @@
+packageio.kimmking.rpcfx.api;
+
+publicclassRpcfxResponse{
+
+privateObjectresult;
+privatebooleanstatus;
+privateExceptionexception;
+
+publicObjectgetResult(){
+returnresult;
+ }
+
+publicvoidsetResult(Objectresult){
+this.result = result;
+ }
+
+publicbooleanisStatus(){
+returnstatus;
+ }
+
+publicvoidsetStatus(booleanstatus){
+this.status = status;
+ }
+
+publicExceptiongetException(){
+returnexception;
+ }
+
+publicvoidsetException(Exceptionexception){
+this.exception = exception;
+ }
+}

07rpc/rpc01/rpcfx-api/src/main/java/io/kimmking/rpcfx/api/User.java

@@ -2,6 +2,13 @@
 
 publicclassUser{
 
+publicUser(){}
+
+publicUser(intid, Stringname){
+this.id = id;
+this.name = name;
+ }
+
 privateintid;
 privateStringname;
 

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>

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

@@ -0,0 +1,58 @@
+packageio.kimmking.rpcfx.client;
+
+
+importcom.alibaba.fastjson.JSON;
+importio.kimmking.rpcfx.api.RpcfxRequest;
+importio.kimmking.rpcfx.api.RpcfxResponse;
+importokhttp3.MediaType;
+importokhttp3.OkHttpClient;
+importokhttp3.Request;
+importokhttp3.RequestBody;
+
+importjava.io.IOException;
+importjava.lang.reflect.InvocationHandler;
+importjava.lang.reflect.Method;
+importjava.lang.reflect.Proxy;
+
+publicclassRpcfx{
+publicstatic <T> Tcreate(finalClass<T> serviceClass, finalStringurl){
+
+return (T) Proxy.newProxyInstance(Rpcfx.class.getClassLoader(), newClass[]{serviceClass}, newRpcfxInvocationHandler(serviceClass, url));
+
+ }
+
+publicstaticclassRpcfxInvocationHandlerimplementsInvocationHandler{
+
+publicstaticfinalMediaTypeJSONTYPE = MediaType.get("application/json; charset=utf-8");
+
+
+privatefinalClass<?> serviceClass;
+privatefinalStringurl;
+public <T> RpcfxInvocationHandler(Class<T> serviceClass, Stringurl){
+this.serviceClass = serviceClass;
+this.url = url;
+ }
+
+@Override
+publicObjectinvoke(Objectproxy, Methodmethod, Object[] params) throwsThrowable{
+RpcfxRequestrequest = newRpcfxRequest();
+request.setServiceClass(this.serviceClass.getName());
+request.setMethod(method.getName());
+request.setParams(params);
+
+RpcfxResponseresponse = post(request, url);
+returnJSON.parse(response.getResult().toString());
+ }
+
+privateRpcfxResponsepost(RpcfxRequestreq, Stringurl) throwsIOException{
+StringreqJson = JSON.toJSONString(req);
+OkHttpClientclient = newOkHttpClient();
+finalRequestrequest = newRequest.Builder()
+ .url(url)
+ .post(RequestBody.create(JSONTYPE, reqJson))
+ .build();
+StringrespJson = client.newCall(request).execute().body().string();
+returnJSON.parseObject(respJson, RpcfxResponse.class);
+ }
+ }
+}

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

@@ -0,0 +1,24 @@
+packageio.kimmking.rpcfx.client;
+
+importcom.alibaba.fastjson.parser.ParserConfig;
+importio.kimmking.rpcfx.api.User;
+importio.kimmking.rpcfx.api.UserService;
+importorg.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+publicclassRpcfxClientApplication{
+
+static{
+ParserConfig.getGlobalInstance().addAccept("io.kimmking");
+ }
+
+publicstaticvoidmain(String[] args){
+
+UserServiceservice = Rpcfx.create(UserService.class, "http://localhost:8080/");
+Useruser = service.findById(1);
+System.out.println("find user id=1 from server: " + user.getName());
+
+// SpringApplication.run(RpcfxClientApplication.class, args);
+ }
+
+}

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

@@ -1,2 +1,2 @@
-server:
-port: 8080
+#server:
+# port: 8080

07rpc/rpc01/rpcfx-client/src/main/resources/application.yml

@@ -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(){
+// }
+//
+//}