lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

日志优化

Browse Source
This commit is contained in:
redkale
2023-04-03 14:48:01 +08:00
parent 849d628a75
commit dc6d53e6be
1 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/org/redkale/net/Server.java
View File

@@ -9,6 +9,7 @@ import java.io.*;
import java.net.*; import java.net.*;
import java.nio.charset.Charset; import java.nio.charset.Charset;
import java.util.*; import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.atomic.LongAdder; import java.util.concurrent.atomic.LongAdder;
import java.util.logging.*; import java.util.logging.*;
import javax.net.ssl.SSLContext; import javax.net.ssl.SSLContext;
@@ -313,8 +314,18 @@ public abstract class Server<K extends Serializable, C extends Context, R extend
} }
serverChannel.accept(application, this); serverChannel.accept(application, this);
postStart(); postStart();
ExecutorService workExecutor = context.workExecutor;
int workThreads = 0;
if (workExecutor instanceof ThreadPoolExecutor) {
workThreads = ((ThreadPoolExecutor) workExecutor).getCorePoolSize();
} else if (workExecutor instanceof ThreadHashExecutor) {
workThreads = ((ThreadHashExecutor) workExecutor).getCorePoolSize();
} else if (workExecutor != null) { //virtual thread pool
workThreads = -1;
}
logger.info(this.getClass().getSimpleName() + ("TCP".equalsIgnoreCase(netprotocol) ? "" : ("." + netprotocol)) + " listen: " + (address.getHostString() + ":" + address.getPort()) logger.info(this.getClass().getSimpleName() + ("TCP".equalsIgnoreCase(netprotocol) ? "" : ("." + netprotocol)) + " listen: " + (address.getHostString() + ":" + address.getPort())
+ ", cpu: " + Utility.cpus() + ", responsePoolSize: " + responsePoolSize + ", bufferPoolSize: " + bufferPoolSize + ", cpu: " + Utility.cpus() + ", workThreads: " + (workThreads >= 0 ? workThreads : "[virtual]")
+ ", responsePoolSize: " + responsePoolSize + ", bufferPoolSize: " + bufferPoolSize
+ ", bufferCapacity: " + formatLenth(bufferCapacity) + ", maxbody: " + formatLenth(context.maxBody) + startExtLog() + ", bufferCapacity: " + formatLenth(bufferCapacity) + ", maxbody: " + formatLenth(context.maxBody) + startExtLog()
+ ", started in " + (System.currentTimeMillis() - context.getServerStartTime()) + " ms\r\n"); + ", started in " + (System.currentTimeMillis() - context.getServerStartTime()) + " ms\r\n");
} }