From db99445878563c523fd22dfa6d415c03bef1a6b1 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Sat, 28 Apr 2018 21:36:46 +0800
Subject: [PATCH]

---
 src/org/redkale/net/ProtocolServer.java | 12 ++++--------
 src/org/redkale/net/Server.java         |  5 ++++-
 2 files changed, 8 insertions(+), 9 deletions(-)

diff --git a/src/org/redkale/net/ProtocolServer.java b/src/org/redkale/net/ProtocolServer.java
index b76beffd8..ceeb8b848 100644
--- a/src/org/redkale/net/ProtocolServer.java
+++ b/src/org/redkale/net/ProtocolServer.java
@@ -12,6 +12,7 @@ import java.nio.channels.*;
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicLong;
+import org.redkale.util.AnyValue;
 
 /**
  * 协议底层Server
@@ -53,7 +54,7 @@ public abstract class ProtocolServer {
     //最大连接数，小于1表示无限制
     protected int maxconns;
 
-    public abstract void open() throws IOException;
+    public abstract void open(AnyValue config) throws IOException;
 
     public abstract void bind(SocketAddress local, int backlog) throws IOException;
 
@@ -111,7 +112,7 @@ public abstract class ProtocolServer {
         }
 
         @Override
-        public void open() throws IOException {
+        public void open(AnyValue config) throws IOException {
             DatagramChannel ch = DatagramChannel.open();
             ch.configureBlocking(true);
             this.serverChannel = ch;
@@ -203,14 +204,9 @@ public abstract class ProtocolServer {
         }
 
         @Override
-        public void open() throws IOException {
+        public void open(AnyValue config) throws IOException {
             group = AsynchronousChannelGroup.withCachedThreadPool(context.executor, 1);
             this.serverChannel = AsynchronousServerSocketChannel.open(group);
-            try {
-                if (supportTcpNoDelay()) this.serverChannel.setOption(StandardSocketOptions.TCP_NODELAY, true);
-                if (supportTcpKeepAlive()) this.serverChannel.setOption(StandardSocketOptions.SO_KEEPALIVE, true);
-            } catch (IOException e) {
-            }
         }
 
         @Override
diff --git a/src/org/redkale/net/Server.java b/src/org/redkale/net/Server.java
index b835e8443..4d0d29c7e 100644
--- a/src/org/redkale/net/Server.java
+++ b/src/org/redkale/net/Server.java
@@ -225,10 +225,13 @@ public abstract class Server<K extends Serializable, C extends Context, R extend
         this.context = this.createContext();
         this.prepare.init(this.context, config);
         this.serverChannel = ProtocolServer.create(this.protocol, context);
-        this.serverChannel.open();
+        this.serverChannel.open(config);
         if (this.serverChannel.supportedOptions().contains(StandardSocketOptions.TCP_NODELAY)) {
             this.serverChannel.setOption(StandardSocketOptions.TCP_NODELAY, true);
         }
+        if (this.serverChannel.supportedOptions().contains(StandardSocketOptions.SO_KEEPALIVE)) {
+            this.serverChannel.setOption(StandardSocketOptions.SO_KEEPALIVE, true);
+        }
         serverChannel.bind(address, backlog);
         serverChannel.setMaxconns(this.maxconns);
         serverChannel.accept();