update

Author: kimmking

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

@@ -0,0 +1,9 @@
+package io.kimmking.rpcfx.api;
+
+public interface Filter {
+
+    boolean filter(RpcfxRequest request);
+
+    Filter next();
+
+}

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

@@ -0,0 +1,9 @@
+package io.kimmking.rpcfx.api;
+
+import java.util.List;
+
+public interface LoadBalancer {
+
+    String select(List<String> urls);
+
+}

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

@@ -0,0 +1,8 @@
+package io.kimmking.rpcfx.api;
+
+import java.util.List;
+
+public interface Router {
+
+    List<String> route(List<String> urls);
+}

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

@@ -3,8 +3,7 @@
 
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.parser.ParserConfig;
-import io.kimmking.rpcfx.api.RpcfxRequest;
-import io.kimmking.rpcfx.api.RpcfxResponse;
+import io.kimmking.rpcfx.api.*;
 import okhttp3.MediaType;
 import okhttp3.OkHttpClient;
 import okhttp3.Request;
@@ -14,17 +13,34 @@
 import java.lang.reflect.InvocationHandler;
 import java.lang.reflect.Method;
 import java.lang.reflect.Proxy;
+import java.util.ArrayList;
+import java.util.List;
 
 public final class Rpcfx {
 
     static {
         ParserConfig.getGlobalInstance().addAccept("io.kimmking");
     }
 
-    public static <T> T create(final Class<T> serviceClass, final String url) {
+    public static <T, filters> T createFromRegistry(final Class<T> serviceClass, final String zkUrl, Router router, LoadBalancer loadBalance, Filter filter) {
+
+        // 加filte之一
+
+        // curator Provider list from zk
+        List<String> invokers = new ArrayList<>(); // 监听zk的临时节点，根据事件更新这个list
+
+        List<String> urls = router.route(invokers);
+
+        String url = loadBalance.select(urls); // router, loadbalance
+
+        return (T) create(serviceClass, url, filter);
+
+    }
+
+    public static <T> T create(final Class<T> serviceClass, final String url, Filter filter) {
 
         // 0. 替换动态代理 -> AOP
-        return (T) Proxy.newProxyInstance(Rpcfx.class.getClassLoader(), new Class[]{serviceClass}, new RpcfxInvocationHandler(serviceClass, url));
+        return (T) Proxy.newProxyInstance(Rpcfx.class.getClassLoader(), new Class[]{serviceClass}, new RpcfxInvocationHandler(serviceClass, url, filter));
 
     }
 
@@ -34,9 +50,12 @@ public static class RpcfxInvocationHandler implements InvocationHandler {
 
         private final Class<?> serviceClass;
         private final String url;
-        public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url) {
+        private final Filter[] filters;
+
+        public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url, Filter... filters) {
             this.serviceClass = serviceClass;
             this.url = url;
+            this.filters = filters;
         }
 
         // 可以尝试，自己去写对象序列化，二进制还是文本的，，，rpcfx是xml自定义序列化、反序列化，json: code.google.com/p/rpcfx
@@ -45,13 +64,26 @@ public <T> RpcfxInvocationHandler(Class<T> serviceClass, String url) {
 
         @Override
         public Object invoke(Object proxy, Method method, Object[] params) throws Throwable {
+
+            // 加filter地方之二
+            // mock == true, new Student("hubao");
+
             RpcfxRequest request = new RpcfxRequest();
             request.setServiceClass(this.serviceClass.getName());
             request.setMethod(method.getName());
             request.setParams(params);
 
+            for (Filter filter : filters) {
+                if(!filter.filter(request)) {
+                    return null;
+                }
+            }
+
             RpcfxResponse response = post(request, url);
 
+            // 加filter地方之三
+            // Student.setTeacher("cuijing");
+
             // 这里判断response.status，处理异常
             // 考虑封装一个全局的RpcfxException
 

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

@@ -7,6 +7,8 @@
 import io.kimmking.rpcfx.demo.api.UserService;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 
+import java.util.Random;
+
 @SpringBootApplication
 public class RpcfxClientApplication {
 
@@ -28,9 +30,13 @@ public static void main(String[] args) {
 		Order order = orderService.findOrderById(1992129);
 		System.out.println(String.format("find order name=%s, amount=%f",order.getName(),order.getAmount()));
 
-		// 新加一个OrderService
+		//
+		UserService userService2 = Rpcfx.createFromRegistry(UserService.class, "localhost:2181", new TagRouter(), new RandomLoadBalancer(), new CuicuiFilter());
 
 //		SpringApplication.run(RpcfxClientApplication.class, args);
 	}
 
 }
+
+
+

07rpc/rpc01/rpcfx-demo-provider/pom.xml

@@ -38,6 +38,12 @@
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.curator</groupId>
+            <artifactId>curator-client</artifactId>
+            <version>5.1.0</version>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>

07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/RpcfxServerApplication.java

@@ -14,11 +14,25 @@
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import java.net.InetAddress;
+import java.net.InterfaceAddress;
+import java.net.UnknownHostException;
+
 @SpringBootApplication
 @RestController
 public class RpcfxServerApplication {
 
-	public static void main(String[] args) {
+	public static void main(String[] args) throws Exception {
+
+		// xxx "io.kimmking.rpcfx.demo.api.UserService"
+
+		ServiceProviderDesc desc = new ServiceProviderDesc();
+		desc.setHost(InetAddress.getLocalHost().getHostAddress());
+		desc.setPort(8080);
+		desc.setServiceClass("io.kimmking.rpcfx.demo.api.UserService");
+
+		// Curator.
+
 		SpringApplication.run(RpcfxServerApplication.class, args);
 	}
 
@@ -42,6 +56,10 @@ public RpcfxResolver createResolver(){
 
 	// 能否去掉name
 	//
+
+	// annotation
+
+
 	@Bean(name = "io.kimmking.rpcfx.demo.api.UserService")
 	public UserService createUserService(){
 		return new UserServiceImpl();

07rpc/rpc01/rpcfx-demo-provider/src/main/java/io/kimmking/rpcfx/demo/provider/ServiceProviderDesc.java

@@ -0,0 +1,35 @@
+package io.kimmking.rpcfx.demo.provider;
+
+public class ServiceProviderDesc {
+
+    private String host;
+    private Integer port;
+    private String serviceClass;
+
+    // group
+    // version
+
+    public String getHost() {
+        return host;
+    }
+
+    public void setHost(String host) {
+        this.host = host;
+    }
+
+    public Integer getPort() {
+        return port;
+    }
+
+    public void setPort(Integer port) {
+        this.port = port;
+    }
+
+    public String getServiceClass() {
+        return serviceClass;
+    }
+
+    public void setServiceClass(String serviceClass) {
+        this.serviceClass = serviceClass;
+    }
+}

07rpc/rpc02/dubbo-demo-consumer/src/main/java/io/kimmking/dubbo/demo/consumer/DubboClientApplication.java

@@ -13,10 +13,10 @@
 @SpringBootApplication
 public class DubboClientApplication {
 
-	@DubboReference(version = "1.0.0", url = "dubbo://127.0.0.1:12345")
+	@DubboReference(version = "1.0.0") //, url = "dubbo://127.0.0.1:12345")
 	private UserService userService;
 
-	@DubboReference(version = "1.0.0", url = "dubbo://127.0.0.1:12345")
+	@DubboReference(version = "1.0.0") //, url = "dubbo://127.0.0.1:12345")
 	private OrderService orderService;
 
 	public static void main(String[] args) {

07rpc/rpc02/dubbo-demo-provider/src/main/java/io/kimmking/dubbo/demo/provider/OrderServiceImpl.java

@@ -5,7 +5,7 @@
 import org.apache.dubbo.config.annotation.DubboService;
 
 
-@DubboService(version = "1.0.0")
+@DubboService(version = "1.0.0", tag = "red", weight = 100)
 public class OrderServiceImpl implements OrderService {
 
     @Override