diff --git a/src/main/java/org/redkale/net/Cryptor.java b/src/main/java/org/redkale/net/Cryptor.java index 2ce85aea2..5fbcb4814 100644 --- a/src/main/java/org/redkale/net/Cryptor.java +++ b/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 supplier, final Consumer consumer); + public ByteBuffer[] encrypt(ByteBuffer[] buffers, Supplier supplier, Consumer consumer); /** * 解密 @@ -36,6 +35,5 @@ public interface Cryptor { * @param consumer ByteBuffer回收器 * @return 解密后数据 */ - public ByteBuffer[] decrypt( - ByteBuffer[] buffers, final Supplier supplier, final Consumer consumer); + public ByteBuffer[] decrypt(ByteBuffer[] buffers, Supplier supplier, Consumer consumer); } diff --git a/src/main/java/org/redkale/net/Filter.java b/src/main/java/org/redkale/net/Filter.java index 45d4b408e..bc51e5e88 100644 --- a/src/main/java/org/redkale/net/Filter.java +++ b/src/main/java/org/redkale/net/Filter.java @@ -26,11 +26,14 @@ import org.redkale.util.AnyValue; */ public abstract class Filter, P extends Response> implements Comparable { - AnyValue _conf; // 当前Filter的配置 + // 当前Filter的配置 + AnyValue _conf; - final boolean _nonBlocking; // 当前Filter.doFilter方法是否为阻塞模式 + // 当前Filter.doFilter方法是否为阻塞模式 + final boolean _nonBlocking; - Filter _next; // 下一个Filter + // 下一个Filter + Filter _next; protected Filter() { NonBlocking a = getClass().getAnnotation(NonBlocking.class); diff --git a/src/main/java/org/redkale/net/ProtocolServer.java b/src/main/java/org/redkale/net/ProtocolServer.java index 84c2fc64a..c597cd459 100644 --- a/src/main/java/org/redkale/net/ProtocolServer.java +++ b/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; diff --git a/src/main/java/org/redkale/net/Server.java b/src/main/java/org/redkale/net/Server.java index 1a3e919bd..db0405174 100644 --- a/src/main/java/org/redkale/net/Server.java +++ b/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 {