session disconnect delay configurable (#141)

Author: nocvalight

server/server/data/src/main/java/com/alipay/sofa/registry/server/data/bootstrap/DataServerConfig.java

@@ -123,6 +123,8 @@ public class DataServerConfig {
 
     private int                dataSyncNotifyRetry                          = 3;
 
+    private int                sessionDisconnectDelayMs                     = 30000;
+
     /**
      * constructor
      * @param commonConfig
@@ -848,6 +850,24 @@ public void setDataSyncNotifyRetry(int dataSyncNotifyRetry) {
         this.dataSyncNotifyRetry = dataSyncNotifyRetry;
     }
 
+    /**
+     * Getter method for property <tt>sessionDisconnectDelayMs</tt>.
+     *
+     * @return property value of sessionDisconnectDelayMs
+     */
+    public int getSessionDisconnectDelayMs() {
+        return sessionDisconnectDelayMs;
+    }
+
+    /**
+     * Setter method for property <tt>sessionDisconnectDelayMs</tt>.
+     *
+     * @param sessionDisconnectDelayMs value to be assigned to property sessionDisconnectDelayMs
+     */
+    public void setSessionDisconnectDelayMs(int sessionDisconnectDelayMs) {
+        this.sessionDisconnectDelayMs = sessionDisconnectDelayMs;
+    }
+
     @Override
     public String toString() {
         return ToStringBuilder.reflectionToString(this, ToStringStyle.MULTI_LINE_STYLE);

server/server/data/src/main/java/com/alipay/sofa/registry/server/data/remoting/sessionserver/SessionServerConnectionFactory.java

@@ -25,6 +25,7 @@
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicInteger;
 
+import com.alipay.sofa.registry.server.data.bootstrap.DataServerConfig;
 import org.springframework.beans.factory.annotation.Autowired;
 
 import com.alipay.remoting.Connection;
@@ -45,7 +46,6 @@ public class SessionServerConnectionFactory {
     private static final Logger            LOGGER                      = LoggerFactory
                                                                            .getLogger(SessionServerConnectionFactory.class);
 
-    private static final int               DELAY                       = 30 * 1000;
     private static final Map               EMPTY_MAP                   = new HashMap(0);
 
     /**
@@ -69,6 +69,9 @@ public class SessionServerConnectionFactory {
     @Autowired
     private DisconnectEventHandler         disconnectEventHandler;
 
+    @Autowired
+    private DataServerConfig               dataServerConfig;
+
     /**
      * register connection
      *
@@ -125,7 +128,7 @@ public void sessionDisconnected(String sessionConnAddress) {
             // The SessionServerDisconnectEvent is triggered only when the last connection is broken
             if (pair == null || pair.getConnections().isEmpty()) {
                 disconnectEventHandler.receive(new SessionServerDisconnectEvent(processId,
-                    sessionConnAddress, DELAY));
+                    sessionConnAddress, dataServerConfig.getSessionDisconnectDelayMs()));
             }
         }
     }

server/server/data/src/main/resources/application.properties

@@ -17,4 +17,5 @@ data.server.metaServerPort=9611
 data.server.storeNodes=3
 data.server.numberOfReplicas=1000
 data.server.datumTimeToLiveSec=900
+data.server.sessionDisconnectDelayMs=30000