格式化

src/main/java/org/redkale/net/Cryptor.java

@@ -25,8 +25,7 @@ public interface Cryptor {
      * @param consumer ByteBuffer回收器
      * @return 加密后数据
      */
-    public ByteBuffer[] encrypt(
-            ByteBuffer[] buffers, final Supplier<ByteBuffer> supplier, final Consumer<ByteBuffer> consumer);
+    public ByteBuffer[] encrypt(ByteBuffer[] buffers, Supplier<ByteBuffer> supplier, Consumer<ByteBuffer> consumer);
 
     /**
      * 解密
@@ -36,6 +35,5 @@ public interface Cryptor {
      * @param consumer ByteBuffer回收器
      * @return 解密后数据
      */
-    public ByteBuffer[] decrypt(
-            ByteBuffer[] buffers, final Supplier<ByteBuffer> supplier, final Consumer<ByteBuffer> consumer);
+    public ByteBuffer[] decrypt(ByteBuffer[] buffers, Supplier<ByteBuffer> supplier, Consumer<ByteBuffer> consumer);
 }

src/main/java/org/redkale/net/Filter.java

@@ -26,11 +26,14 @@ import org.redkale.util.AnyValue;
  */
 public abstract class Filter<C extends Context, R extends Request<C>, P extends Response<C, R>> implements Comparable {
 
-    AnyValue _conf; // 当前Filter的配置
+    // 当前Filter的配置
+    AnyValue _conf;
 
-    final boolean _nonBlocking; // 当前Filter.doFilter方法是否为阻塞模式
+    // 当前Filter.doFilter方法是否为阻塞模式
+    final boolean _nonBlocking;
 
-    Filter<C, R, P> _next; // 下一个Filter
+    // 下一个Filter
+    Filter<C, R, P> _next;
 
     protected Filter() {
         NonBlocking a = getClass().getAnnotation(NonBlocking.class);

src/main/java/org/redkale/net/ProtocolServer.java

@@ -26,7 +26,8 @@ public abstract class ProtocolServer {
     // 最大连接数，小于1表示无限制
     protected int maxConns;
 
-    @Resource(required = false) // 独立创建HttpServer时没有Application
+    // 独立创建HttpServer时没有Application
+    @Resource(required = false)
     protected Application application;
 
     public abstract void open(AnyValue config) throws IOException;

src/main/java/org/redkale/net/Server.java

@@ -5,17 +5,26 @@
  */
 package org.redkale.net;
 
-import java.io.*;
-import java.net.*;
+import java.io.File;
+import java.io.IOException;
+import java.io.Serializable;
+import java.net.InetSocketAddress;
+import java.net.SocketAddress;
+import java.net.URI;
 import java.nio.charset.Charset;
-import java.util.*;
-import java.util.concurrent.*;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Objects;
+import java.util.Set;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.atomic.LongAdder;
-import java.util.logging.*;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 import javax.net.ssl.SSLContext;
 import org.redkale.boot.Application;
 import org.redkale.inject.ResourceFactory;
-import org.redkale.net.Filter;
 import org.redkale.util.*;
 
 /**
@@ -159,7 +168,7 @@ public abstract class Server<
         AnyValue sslConf = config.getAnyValue("ssl");
         if (sslConf != null) {
             String builderClass = sslConf.getValue("builder", SSLBuilder.class.getName());
-            SSLBuilder builder = null;
+            SSLBuilder builder;
             if (SSLBuilder.class.getName().equals(builderClass) || builderClass.isEmpty()) {
                 builder = new SSLBuilder();
             } else {