From dcdaa1bc2d8e3e12ab5af433c5e7b01602ebe385 Mon Sep 17 00:00:00 2001 From: tursom Date: Fri, 14 May 2021 11:24:55 +0800 Subject: [PATCH] NettyHttpServer add SSL support --- .../cn/tursom/web/netty/NettyHttpServer.kt | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/ts-web/ts-web-netty/src/main/kotlin/cn/tursom/web/netty/NettyHttpServer.kt b/ts-web/ts-web-netty/src/main/kotlin/cn/tursom/web/netty/NettyHttpServer.kt index 0db1360..9b46af2 100644 --- a/ts-web/ts-web-netty/src/main/kotlin/cn/tursom/web/netty/NettyHttpServer.kt +++ b/ts-web/ts-web-netty/src/main/kotlin/cn/tursom/web/netty/NettyHttpServer.kt @@ -30,8 +30,8 @@ class NettyHttpServer( var bodySize: Int = 512 * 1024, autoRun: Boolean = false, var webSocketPath: Iterable>> = listOf(), - var readTimeout: Int? = 60, - var writeTimeout: Int? = null, + var readTimeout: Int = 60, + var writeTimeout: Int = 0, decodeType: NettyHttpDecodeType = if (webSocketPath.iterator() .hasNext() ) NettyHttpDecodeType.FULL_HTTP else NettyHttpDecodeType.MULTI_PART, @@ -44,8 +44,8 @@ class NettyHttpServer( bodySize: Int = 512 * 1024, autoRun: Boolean = false, webSocketPath: Iterable>> = listOf(), - readTimeout: Int? = 60, - writeTimeout: Int? = null, + readTimeout: Int = 60, + writeTimeout: Int = 0, decodeType: NettyHttpDecodeType = if (webSocketPath.iterator() .hasNext() ) NettyHttpDecodeType.FULL_HTTP else NettyHttpDecodeType.MULTI_PART, @@ -95,11 +95,11 @@ class NettyHttpServer( pipeline.addLast(sslHandler) } - readTimeout?.let { - pipeline.addLast(ReadTimeoutHandler(it)) + if (readTimeout > 0) { + pipeline.addLast(ReadTimeoutHandler(readTimeout)) } - writeTimeout?.let { - pipeline.addLast(WriteTimeoutHandler(it)) + if (writeTimeout > 0) { + pipeline.addLast(WriteTimeoutHandler(writeTimeout)) } pipeline.addLast("codec", HttpServerCodec()) if (this@NettyHttpServer.decodeType == NettyHttpDecodeType.FULL_HTTP) {