src/com/wentch/redkale/net/Transport.java

@@ -33,10 +33,13 @@ public final class Transport {
 
     protected final AsynchronousChannelGroup group;
 
+    protected BlockingQueue<AsyncConnection> queue;
+
     public Transport(String name, String protocol, int clients, int bufferPoolSize, WatchFactory watch, SocketAddress... addresses) {
         this.name = name;
         this.protocol = protocol;
         this.udp = "UDP".equalsIgnoreCase(protocol);
+        this.queue = this.udp ? null : new ArrayBlockingQueue<>(clients);
         AsynchronousChannelGroup g = null;
         try {
             final AtomicInteger counter = new AtomicInteger();
@@ -80,6 +83,12 @@ public final class Transport {
     }
 
     public AsyncConnection pollConnection() {
+        if (udp) return createConnection();
+        AsyncConnection conn = queue.poll();
+        return (conn != null && conn.isOpen()) ? conn : createConnection();
+    }
+
+    private AsyncConnection createConnection() {
         SocketAddress addr = remoteAddres[0];
         try {
             if (udp) {
@@ -97,10 +106,19 @@ public final class Transport {
     }
 
     public void offerConnection(AsyncConnection conn) {
+        if (udp) {
             try {
                 conn.close();
             } catch (IOException io) {
             }
+        } else if (conn.isOpen()) {
+            if (!queue.offer(conn)) {
+                try {
+                    conn.close();
+                } catch (IOException io) {
+                }
+            }
+        }
     }
 
     public <A> void async(final ByteBuffer buffer, A att, final CompletionHandler<Integer, A> handler) {