From 5c6f3c371226e6169ef368b621f38dc06307989a Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Mon, 28 May 2018 17:27:10 +0800
Subject: [PATCH]

---
 src/org/redkale/net/ProtocolServer.java | 22 ++++++++++------------
 1 file changed, 10 insertions(+), 12 deletions(-)

diff --git a/src/org/redkale/net/ProtocolServer.java b/src/org/redkale/net/ProtocolServer.java
index 4178378e3..f7166abc5 100644
--- a/src/org/redkale/net/ProtocolServer.java
+++ b/src/org/redkale/net/ProtocolServer.java
@@ -52,6 +52,8 @@ public abstract class ProtocolServer {
     //在线数
     protected final AtomicLong livingCounter = new AtomicLong();
 
+    protected final Context context;
+
     //最大连接数，小于1表示无限制
     protected int maxconns;
 
@@ -67,6 +69,11 @@ public abstract class ProtocolServer {
 
     public abstract void close() throws IOException;
 
+    protected ProtocolServer(Context context) {
+        this.context = context;
+        this.maxconns = context.getMaxconns();
+    }
+
     public long getCreateCount() {
         return createCounter.longValue();
     }
@@ -98,13 +105,10 @@ public abstract class ProtocolServer {
 
         private boolean running;
 
-        private final Context context;
-
         private DatagramChannel serverChannel;
 
         public ProtocolBIOUDPServer(Context context) {
-            this.context = context;
-            this.maxconns = context.getMaxconns();
+            super(context);
         }
 
         @Override
@@ -200,15 +204,12 @@ public abstract class ProtocolServer {
 
     static final class ProtocolAIOTCPServer extends ProtocolServer {
 
-        private final Context context;
-
         private AsynchronousChannelGroup group;
 
         private AsynchronousServerSocketChannel serverChannel;
 
         public ProtocolAIOTCPServer(Context context) {
-            this.context = context;
-            this.maxconns = context.getMaxconns();
+            super(context);
         }
 
         @Override
@@ -323,8 +324,6 @@ public abstract class ProtocolServer {
 
     static final class ProtocolNIOTCPServer extends ProtocolServer {
 
-        private final Context context;
-
         private Selector acceptSelector;
 
         private ServerSocketChannel serverChannel;
@@ -336,8 +335,7 @@ public abstract class ProtocolServer {
         private boolean running;
 
         public ProtocolNIOTCPServer(Context context) {
-            this.context = context;
-            this.maxconns = context.getMaxconns();
+            super(context);
         }
 
         @Override