热点数据服务发现的实现

core-swift/src/main/java/com/ware/swift/core/CoreSwiftManagerDelegate.java

@@ -0,0 +1,70 @@
+package com.ware.swift.core;
+
+import com.ware.swift.core.inter.ICoreSwiftManager;
+
+import java.util.Set;
+
+/**
+ * delegate the core swift manager
+ */
+public final class CoreSwiftManagerDelegate implements ICoreSwiftManager {
+
+    private static ICoreSwiftManager coreSwiftManager;
+
+    static {
+        try {
+            Set<ICoreSwiftManager> wareSwiftManagers = WareCoreSwiftPluginLoader.load(ICoreSwiftManager.class,
+                    CoreSwiftManagerImpl.class.getClassLoader());
+
+            boolean isLoad = false;
+            if (wareSwiftManagers != null && wareSwiftManagers.size() > 0) {
+                coreSwiftManager = wareSwiftManagers.iterator().next();
+                isLoad = true;
+            }
+
+            if (!isLoad) {
+                coreSwiftManager = new CoreSwiftManagerImpl();
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    private final static CoreSwiftManagerDelegate CORE_SWIFT_MANAGER = new CoreSwiftManagerDelegate();
+
+    private CoreSwiftManagerDelegate() {
+    }
+
+    public static CoreSwiftManagerDelegate getInstance() {
+        return CORE_SWIFT_MANAGER;
+    }
+
+    public void init(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+
+        coreSwiftManager.init(wareSwiftGlobalContext);
+    }
+
+    public void startBefore(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+        coreSwiftManager.startBefore(wareSwiftGlobalContext);
+    }
+
+    public void start(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+        coreSwiftManager.start(wareSwiftGlobalContext);
+    }
+
+    public void startAfter(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+        coreSwiftManager.startAfter(wareSwiftGlobalContext);
+    }
+
+    public void shutdown(NodeInformation nodeInformation) {
+        coreSwiftManager.shutdown(nodeInformation);
+    }
+
+    public void getAllNodeInformation() {
+        coreSwiftManager.getAllNodeInformation();
+    }
+
+    public void getClusterNodeInformation(String clusterName) {
+        coreSwiftManager.getClusterNodeInformation(clusterName);
+    }
+}

core-swift/src/main/java/com/ware/swift/core/CoreSwiftManagerImpl.java

@@ -0,0 +1,79 @@
+package com.ware.swift.core;
+
+import com.ware.swift.core.inter.ICoreSwiftManager;
+import com.ware.swift.core.remoting.RemotingManager;
+import io.netty.util.internal.logging.InternalLogger;
+import io.netty.util.internal.logging.InternalLoggerFactory;
+import io.netty.util.internal.logging.JdkLoggerFactory;
+
+import static com.ware.swift.core.WareCoreSwiftGlobalContext.RAFT_CONTEXT_ATTR_KEY_CONFIG;
+import static com.ware.swift.core.WareCoreSwiftGlobalContext.RAFT_CONTEXT_ATTR_KEY_CONFIG_PATH;
+
+/**
+ *
+ */
+public class CoreSwiftManagerImpl implements ICoreSwiftManager {
+
+    private InternalLogger logger = InternalLoggerFactory
+            .getInstance(CoreSwiftManagerImpl.class);
+
+    public void init(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+        startBefore(wareSwiftGlobalContext);
+        start(wareSwiftGlobalContext);
+        startAfter(wareSwiftGlobalContext);
+    }
+
+    /**
+     * @param wareSwiftGlobalContext
+     */
+    public void startBefore(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+        InternalLoggerFactory.setDefaultFactory(JdkLoggerFactory.INSTANCE);
+        String configPath = wareSwiftGlobalContext.getAttribute(
+                RAFT_CONTEXT_ATTR_KEY_CONFIG_PATH, "ware-swift.properties");
+        try {
+            WareCoreSwiftConfig wareSwiftConfig = WareCoreSwiftConfigManager.initRaftConfig(configPath,
+                    this.getClass().getClassLoader());
+            RemotingManager.getRemotingManager().init(wareSwiftConfig);
+            wareSwiftGlobalContext.putAttribute(RAFT_CONTEXT_ATTR_KEY_CONFIG, wareSwiftConfig);
+        } catch (Exception e) {
+            logger.error(WareCoreSwiftExceptionCode.getConfigInitializerErrorMessage(
+                    " init wareSwift cause an exception with " + configPath), e);
+        }
+    }
+
+    /**
+     * @param wareSwiftGlobalContext
+     */
+    public void start(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+
+        RemotingManager.getRemotingManager().startLeaderElection(wareSwiftGlobalContext);
+    }
+
+    /**
+     * @param wareSwiftGlobalContext
+     */
+    public void startAfter(WareCoreSwiftGlobalContext wareSwiftGlobalContext) {
+
+    }
+
+    /**
+     * @param nodeInformation
+     */
+    public void shutdown(NodeInformation nodeInformation) {
+
+    }
+
+    /**
+     *
+     */
+    public void getAllNodeInformation() {
+
+    }
+
+    /**
+     * @param clusterName
+     */
+    public void getClusterNodeInformation(String clusterName) {
+
+    }
+}

core-swift/src/main/java/com/ware/swift/core/IPluginAble.java

@@ -0,0 +1,12 @@
+package com.ware.swift.core;
+
+/**
+ *
+ */
+public interface IPluginAble {
+
+    /**
+     * @return
+     */
+    String getPluginName();
+}