cluster

src/main/java/module-info.java

@@ -20,6 +20,7 @@ module org.redkale {
     exports org.redkale.cache;
     exports org.redkale.cache.spi;
     exports org.redkale.cluster;
+    exports org.redkale.cluster.spi;
     exports org.redkale.convert;
     exports org.redkale.convert.bson;
     exports org.redkale.convert.ext;
@@ -44,7 +45,7 @@ module org.redkale {
     
     uses org.redkale.boot.PropertiesAgentProvider;
     uses org.redkale.cache.spi.CacheManagerProvider;
-    uses org.redkale.cluster.ClusterAgentProvider;
+    uses org.redkale.cluster.spi.ClusterAgentProvider;
     uses org.redkale.convert.ConvertProvider;
     uses org.redkale.inject.ResourceAnnotationProvider;
     uses org.redkale.mq.spi.MessageAgentProvider;

src/main/java/org/redkale/boot/Application.java

@@ -25,6 +25,10 @@ import org.redkale.asm.AsmMethodBoost;
 import org.redkale.boot.ClassFilter.FilterEntry;
 import org.redkale.cache.spi.CacheModuleEngine;
 import org.redkale.cluster.*;
+import org.redkale.cluster.spi.ClusterAgent;
+import org.redkale.cluster.spi.ClusterModuleEngine;
+import org.redkale.cluster.spi.HttpClusterRpcClient;
+import org.redkale.cluster.spi.HttpLocalRpcClient;
 import org.redkale.convert.Convert;
 import org.redkale.convert.bson.BsonFactory;
 import org.redkale.convert.json.*;

src/main/java/org/redkale/boot/NodeHttpServer.java

@@ -17,7 +17,7 @@ import org.redkale.annotation.*;
 import org.redkale.asm.AsmMethodBoost;
 import static org.redkale.boot.Application.RESNAME_SNCP_ADDRESS;
 import org.redkale.boot.ClassFilter.FilterEntry;
-import org.redkale.cluster.ClusterAgent;
+import org.redkale.cluster.spi.ClusterAgent;
 import org.redkale.inject.ResourceFactory;
 import org.redkale.inject.ResourceTypeLoader;
 import org.redkale.mq.spi.MessageAgent;

src/main/java/org/redkale/boot/NodeServer.java

@@ -21,7 +21,7 @@ import org.redkale.annotation.Command;
 import org.redkale.asm.AsmMethodBoost;
 import static org.redkale.boot.Application.*;
 import org.redkale.boot.ClassFilter.FilterEntry;
-import org.redkale.cluster.ClusterAgent;
+import org.redkale.cluster.spi.ClusterAgent;
 import org.redkale.inject.ResourceFactory;
 import org.redkale.inject.ResourceTypeLoader;
 import org.redkale.mq.spi.MessageAgent;

src/main/java/org/redkale/cluster/spi/CacheClusterAgent.java

@@ -3,7 +3,7 @@
  * To change this template file, choose Tools | Templates
  * and open the template in the editor.
  */
-package org.redkale.cluster;
+package org.redkale.cluster.spi;
 
 import java.net.InetSocketAddress;
 import java.util.*;
@@ -18,7 +18,6 @@ import org.redkale.inject.ResourceEvent;
 import org.redkale.service.Service;
 import org.redkale.source.CacheSource;
 import org.redkale.util.*;
-import org.redkale.annotation.ResourceChanged;
 
 /**
  * 使用CacheSource实现的第三方服务发现管理接口cluster

src/main/java/org/redkale/cluster/spi/ClusterAgent.java

@@ -3,7 +3,7 @@
  * To change this template file, choose Tools | Templates
  * and open the template in the editor.
  */
-package org.redkale.cluster;
+package org.redkale.cluster.spi;
 
 import java.lang.ref.WeakReference;
 import java.net.*;
@@ -23,7 +23,6 @@ import org.redkale.net.http.*;
 import org.redkale.net.sncp.*;
 import org.redkale.service.*;
 import org.redkale.util.*;
-import org.redkale.annotation.ResourceChanged;
 
 /**
  * 服务注册中心管理类cluster

src/main/java/org/redkale/cluster/spi/ClusterAgentProvider.java

@@ -3,7 +3,7 @@
  * To change this template file, choose Tools | Templates
  * and open the template in the editor.
  */
-package org.redkale.cluster;
+package org.redkale.cluster.spi;
 
 import org.redkale.util.*;
 

src/main/java/org/redkale/cluster/spi/ClusterModuleEngine.java

@@ -1,7 +1,7 @@
 /*
  *
  */
-package org.redkale.cluster;
+package org.redkale.cluster.spi;
 
 import java.util.ArrayList;
 import java.util.HashSet;

src/main/java/org/redkale/cluster/spi/HttpClusterRpcClient.java

@@ -1,4 +1,4 @@
-package org.redkale.cluster;
+package org.redkale.cluster.spi;
 
 import java.io.Serializable;
 import java.net.*;
@@ -10,6 +10,7 @@ import java.util.logging.Level;
 import java.util.logging.Logger;
 import org.redkale.annotation.Resource;
 import org.redkale.boot.Application;
+import org.redkale.cluster.HttpRpcClient;
 import org.redkale.net.http.*;
 import org.redkale.util.Traces;
 import org.redkale.util.Utility;

src/main/java/org/redkale/cluster/spi/HttpLocalRpcClient.java

@@ -3,7 +3,7 @@
  * To change this template file, choose Tools | Templates
  * and open the template in the editor.
  */
-package org.redkale.cluster;
+package org.redkale.cluster.spi;
 
 import java.io.Serializable;
 import java.lang.reflect.Type;
@@ -13,6 +13,7 @@ import java.util.concurrent.CompletableFuture;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 import org.redkale.boot.*;
+import org.redkale.cluster.HttpRpcClient;
 import org.redkale.convert.Convert;
 import org.redkale.convert.json.JsonConvert;
 import org.redkale.net.http.*;

src/main/java/org/redkale/mq/MessageMultiConsumer.java

@@ -1,63 +0,0 @@
-///*
-// * To change this license header, choose License Headers in Project Properties.
-// * To change this template file, choose Tools | Templates
-// * and open the template in the editor.
-// */
-//package org.redkale.mq;
-//
-//import static java.lang.annotation.RetentionPolicy.RUNTIME;
-//import java.lang.annotation.*;
-//import static java.lang.annotation.ElementType.*;
-//
-///**
-// * 多消费组，需要同 @RestService 一起使用
-// * <p>
-// * 通常一个topic只会被一个RestService消费， 当一个topic需要被其他RestService消费时，就需要使用&#64;MessageMultiConsumer
-// *
-// * <blockquote><pre>
-// * &#64;RestService(name = "user", comment = "用户服务")
-// * public class UserService implements Service{
-// *
-// *      &#64;RestMapping(comment = "用户登录")
-// *      public RetResult login(LoginBean bean){
-// *          //do something
-// *      }
-// * }
-// * </pre></blockquote>
-// *
-// * 需求：统计用户登录次数， 可以创建一个MessageMultiConsumer 的 RestService：
-// * <blockquote><pre>
-// * <b>&#64;MessageMultiConsumer(module = "user") </b>
-// * &#64;RestService(name = "loginstat", comment = "用户统计服务")
-// * public class LoginStatService implements Service{
-// *
-// *      private LongAdder counter = new LongAdder();
-// *
-// *      &#64;RestMapping(name = "login", comment = "用户登录统计")
-// *      public void stat(LoginBean bean){     //参数必须和UserService.login方法一致
-// *          counter.increment();
-// *      }
-// * }
-// * </pre></blockquote>
-// *
-// * <p>
-// * 注： 标记 &#64;MessageMultiConsumer 的Service的&#64;RestMapping方法都只能是void返回类型  <br>
-// * 由 MessageConsumer 代替
-// * <p>
-// * 详情见: https://redkale.org
-// *
-// *
-// * @author zhangjx
-// * @deprecated
-// *
-// * @since 2.1.0
-// */
-//@Inherited
-//@Documented
-//@Target({TYPE})
-//@Retention(RUNTIME)
-//@Deprecated(since = "2.8.0")
-//public @interface MessageMultiConsumer {
-//
-//    String module();
-//}

src/main/java/org/redkale/mq/MessageProducer.java

@@ -8,7 +8,7 @@ import java.util.concurrent.CompletableFuture;
 import org.redkale.convert.Convert;
 
 /**
- * MQ消息发送器
+ * MQ消息发送器 {@link org.redkale.mq.ResourceProducer}
  *
  * <p>
  * 详情见: https://redkale.org

src/main/java/org/redkale/mq/ResourceProducer.java

@@ -9,7 +9,7 @@ import static java.lang.annotation.RetentionPolicy.RUNTIME;
 import org.redkale.convert.ConvertType;
 
 /**
- * MQ资源注解, 只能标记在MessageProducer类型字段上
+ * MQ资源注解, 只能标记在{@link org.redkale.mq.MessageProducer}类型字段上
  *
  * <p>
  * 详情见: https://redkale.org

src/main/java/org/redkale/util/RedkaleClassLoader.java

@@ -50,6 +50,7 @@ public class RedkaleClassLoader extends URLClassLoader {
         "org.redkale.cache",
         "org.redkale.cache.spi",
         "org.redkale.cluster",
+        "org.redkale.cluster.spi",
         "org.redkale.convert",
         "org.redkale.convert.bson",
         "org.redkale.convert.ext",