Feature derby raft

.gitignore

@@ -11,5 +11,7 @@ target
 *.iml
 node_modules
 test/derby.log
+test/log
+test/work
 derby.log
 work

CHANGELOG.md

@@ -177,7 +177,7 @@
 * Fully integrate with and seamlessly support Spring framework, Spring Boot and Spring Cloud
 * Separate nacos-api from nacos client implementation
 * Support high available cluster mode
-* Fix cluster node health check abnormality
+* Fix cluster member health check abnormality
 * Fix stand-alone mode gets the change history list exception
 * Fix Pulling does not exist configuration print io exception
 * Optimized log framework
@@ -190,7 +190,7 @@
 #### FEATURES:
 
 * separate nacos-api from nacos client implementation
-* Cluster node health check abnormality
+* Cluster member health check abnormality
 * Stand-alone mode gets the change history list exception
 * Pulling does not exist configuration print io exception
 * Optimized log framework

NEW_FEATURE_USE.md

@@ -0,0 +1,91 @@
+#### 命令行参数
+
+```shell script
+-Dnacos.serializer-type=kryo
+# -Dnacos.serializer-type=protostuff
+```
+
+#### application.properties
+
+```properties
+#*************** Core Related Configurations ***************#
+
+### Whether to turn on inter-member discovery, If this configuration is enabled, the cluster.conf configuration
+### of the newly added member requires that a member of the known cluster be added to build the discovery channel
+nacos.core.member.self-discovery=true
+
+### Which nacos embedded distributed ID is turned on,
+### If an external implementation is provided, the external implementation is automatically selected
+nacos.core.idGenerator.type=default
+### The step size for each fetch of the embedded distributed ID
+nacos.core.idGenerator.default.acquire.step=100
+
+### If nacos.core.idGenerator.type=snakeflower, You need to set the dataCenterID manually
+#nacos.core.snowflake.data-center=
+### If nacos.core.idGenerator.type=snakeflower, You need to set the WorkerID manually
+#nacos.core.snowflake.worker-id=
+
+#*************** Embed Storage Related Configurations ***************#
+
+### Whether to open embedded distributed storage in nacos cluster mode
+embeddedDistributedStorage=true
+
+#*************** Consistency Related Configurations ***************#
+
+# About Raft
+
+### Sets the Raft cluster election timeout, default value is 5 second
+nacos.core.protocol.raft.data.election_timeout_ms=5000
+### Sets the amount of time the Raft snapshot will execute periodically, default is 30 minute
+nacos.core.protocol.raft.data.snapshot_interval_secs=30
+### Requested retries, default value is 1
+nacos.core.protocol.raft.data.request_failoverRetries=1
+### raft internal worker threads
+nacos.core.protocol.raft.data.core_thread_num=8
+### Number of threads required for raft business request processing
+nacos.core.protocol.raft.data.cli_service_thread_num=4
+### raft linear read strategy, defaults to index
+nacos.core.protocol.raft.data.read_index_type=ReadOnlySafe
+### rpc request timeout, default 5 seconds
+nacos.core.protocol.raft.data.rpc_request_timeout_ms=5000
+### Maximum size of each file RPC (snapshot copy) request between members, default is 128 K
+nacos.core.protocol.raft.data.max_byte_count_per_rpc=131072
+### Maximum number of logs sent from leader to follower, default is 1024
+nacos.core.protocol.raft.data.max_entries_size=1024
+### Maximum body size for sending logs from leader to follower, default is 512K
+nacos.core.protocol.raft.data.max_body_size=524288
+### Maximum log storage buffer size, default 256K
+nacos.core.protocol.raft.data.max_append_buffer_size=262144
+### Election timer interval will be a random maximum outside the specified time, default is 1 second
+nacos.core.protocol.raft.data.max_election_delay_ms=1000
+### Specify the ratio between election timeout and heartbeat interval. Heartbeat interval is equal to
+### electionTimeoutMs/electionHeartbeatFactor，One tenth by default.
+nacos.core.protocol.raft.data.election_heartbeat_factor=10
+### The tasks submitted to the leader accumulate the maximum batch size of a batch flush log storage. The default is 32 tasks.
+nacos.core.protocol.raft.data.apply_batch=32
+### Call fsync when necessary when writing logs and meta information, usually should be true
+nacos.core.protocol.raft.data.sync=true
+### Whether to write snapshot / raft meta-information to call fsync. The default is false. When sync is true, it is preferred to respect sync.
+nacos.core.protocol.raft.data.sync_meta=false
+### Internal disruptor buffer size. For applications with high write throughput, you need to increase this value. The default value is 16384.
+nacos.core.protocol.raft.data.disruptor_buffer_size=16384
+### Whether to enable replication of pipeline request optimization, which is enabled by default
+nacos.core.protocol.raft.data.replicator_pipeline=true
+### Maximum number of in-flight requests with pipeline requests enabled, default is 256
+nacos.core.protocol.raft.data.max_replicator_inflight_msgs=256
+### Whether to enable LogEntry checksum
+nacos.core.protocol.raft.data.enable_log_entry_checksum=false
+
+# About Distro
+
+### Maximum interval between two data transmissions
+nacos.core.protocol.distro.data.task_dispatch_period_ms=2000
+### Number of keys per batch of tasks
+nacos.core.protocol.distro.data.batch_sync_key_count=1000
+### Task retry delay time
+nacos.core.protocol.distro.data.sync_retry_delay_ms=5000
+### Whether to enable the authoritative server mechanism
+nacos.core.protocol.distro.data.distro_enabled=true
+### Data synchronization retry strategy
+nacos.core.protocol.distro.data.retry_policy=simple
+```

api/src/main/java/com/alibaba/nacos/api/config/ConfigService.java

@@ -17,13 +17,14 @@
 
 import com.alibaba.nacos.api.config.listener.Listener;
 import com.alibaba.nacos.api.exception.NacosException;
+import com.alibaba.nacos.api.life.LifeCycle;
 
 /**
  * Config Service Interface
  *
  * @author Nacos
  */
-public interface ConfigService {
+public interface ConfigService extends LifeCycle {
 
     /**
      * Get config

api/src/main/java/com/alibaba/nacos/api/life/LifeCycle.java

@@ -0,0 +1,35 @@
+/*
+ * Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.nacos.api.life;
+
+/**
+ * @author <a href="mailto:liaochuntao@live.com">liaochuntao</a>
+ */
+public interface LifeCycle {
+
+	/**
+	 * Correlation initialization
+	 * @throws Exception
+	 */
+	void init() throws Exception;
+
+	/**
+	 * Destruction of the callback
+	 * @throws Exception
+	 */
+	void destroy() throws Exception;
+
+}

api/src/main/java/com/alibaba/nacos/api/life/LifeCycleUtils.java

@@ -0,0 +1,50 @@
+/*
+ * Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.nacos.api.life;
+
+/**
+ * @author <a href="mailto:liaochuntao@live.com">liaochuntao</a>
+ */
+public final class LifeCycleUtils {
+
+	public static void invokeInit(LifeCycle lifeCycle) throws Exception {
+		if (lifeCycle != null) {
+			lifeCycle.init();
+		}
+	}
+
+	public static void invokeDestroy(LifeCycle lifeCycle) throws Exception {
+		if (lifeCycle != null) {
+			lifeCycle.destroy();
+		}
+	}
+
+	public static void registerShutdownHook(final LifeCycle lifeCycle) {
+		if (lifeCycle != null) {
+			Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
+				@Override
+				public void run() {
+					try {
+						invokeDestroy(lifeCycle);
+					} catch (Exception e) {
+						e.printStackTrace();
+					}
+				}
+			}));
+		}
+	}
+
+}

api/src/main/java/com/alibaba/nacos/api/naming/NamingMaintainService.java

@@ -17,6 +17,7 @@
 package com.alibaba.nacos.api.naming;
 
 import com.alibaba.nacos.api.exception.NacosException;
+import com.alibaba.nacos.api.life.LifeCycle;
 import com.alibaba.nacos.api.naming.pojo.Instance;
 import com.alibaba.nacos.api.naming.pojo.Service;
 import com.alibaba.nacos.api.selector.AbstractSelector;
@@ -29,7 +30,7 @@
  * @author liaochuntao
  * @since 1.0.1
  */
-public interface NamingMaintainService {
+public interface NamingMaintainService extends LifeCycle {
 
     /**
      * update instance info

api/src/main/java/com/alibaba/nacos/api/naming/NamingService.java

@@ -16,6 +16,7 @@
 package com.alibaba.nacos.api.naming;
 
 import com.alibaba.nacos.api.exception.NacosException;
+import com.alibaba.nacos.api.life.LifeCycle;
 import com.alibaba.nacos.api.naming.listener.EventListener;
 import com.alibaba.nacos.api.naming.pojo.Instance;
 import com.alibaba.nacos.api.naming.pojo.ListView;
@@ -29,7 +30,7 @@
  *
  * @author nkorange
  */
-public interface NamingService {
+public interface NamingService extends LifeCycle {
 
     /**
      * register a instance to service

api/src/main/java/com/alibaba/nacos/api/naming/listener/NamingBaseEvent.java

@@ -0,0 +1,78 @@
+/*
+ * Copyright 1999-2018 Alibaba Group Holding Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.nacos.api.naming.listener;
+
+import com.alibaba.nacos.api.naming.pojo.Instance;
+
+import java.util.List;
+
+/**
+ * @author zhixiang.yuan
+ */
+public class NamingBaseEvent implements Event {
+
+    private String serviceName;
+
+    private String groupName;
+
+    private String clusters;
+
+    private List<Instance> instances;
+
+    public NamingBaseEvent(String serviceName, List<Instance> instances) {
+        this.serviceName = serviceName;
+        this.instances = instances;
+    }
+
+    public NamingBaseEvent(String serviceName, String groupName, String clusters, List<Instance> instances) {
+        this.serviceName = serviceName;
+        this.groupName = groupName;
+        this.clusters = clusters;
+        this.instances = instances;
+    }
+
+    public String getServiceName() {
+        return serviceName;
+    }
+
+    public void setServiceName(String serviceName) {
+        this.serviceName = serviceName;
+    }
+
+    public List<Instance> getInstances() {
+        return instances;
+    }
+
+    public void setInstances(List<Instance> instances) {
+        this.instances = instances;
+    }
+
+    public String getGroupName() {
+        return groupName;
+    }
+
+    public void setGroupName(String groupName) {
+        this.groupName = groupName;
+    }
+
+    public String getClusters() {
+        return clusters;
+    }
+
+    public void setClusters(String clusters) {
+        this.clusters = clusters;
+    }
+}