|
|
@@ -21,10 +21,10 @@ public class Bootstrap {
|
|
|
static byte[] body = "Hello, World!".getBytes();
|
|
|
|
|
|
public static void main(String[] args) {
|
|
|
- System.setProperty("smart-socket.server.pageSize", (512 * 1024) + "");
|
|
|
- System.setProperty("smart-socket.bufferPool.pageNum", 512 + "");
|
|
|
+ System.setProperty("smart-socket.server.pageSize", (8 * 1024 * 1024) + "");
|
|
|
+// System.setProperty("smart-socket.bufferPool.pageNum", 512 + "");
|
|
|
System.setProperty("smart-socket.session.writeChunkSize", (1024 * 4) + "");
|
|
|
-// System.setProperty("sun.nio.ch.maxCompletionHandlersOnStack","2");
|
|
|
+// System.setProperty("sun.nio.ch.maxCompletionHandlersOnStack","24");
|
|
|
HttpMessageProcessor processor = new HttpMessageProcessor(System.getProperty("webapps.dir", "./"));
|
|
|
processor.route("/plaintext", new HttpHandle() {
|
|
|
|
|
|
@@ -53,8 +53,8 @@ public class Bootstrap {
|
|
|
public static void http(MessageProcessor<Http11Request> processor) {
|
|
|
// 定义服务器接受的消息类型以及各类消息对应的处理器
|
|
|
AioQuickServer<Http11Request> server = new AioQuickServer<>(8080, new HttpRequestProtocol(), processor);
|
|
|
- server.setReadBufferSize(1024 * 2);
|
|
|
- server.setThreadNum((int)(Runtime.getRuntime().availableProcessors() * 1.2));
|
|
|
+ server.setReadBufferSize(1024 * 4);
|
|
|
+ server.setThreadNum((int) (Runtime.getRuntime().availableProcessors() * 1.2));
|
|
|
try {
|
|
|
server.start();
|
|
|
} catch (IOException e) {
|
三刀