Merge pull request #315 from wafflestudio/develop

Release

Author: Hank-Choi

core/src/main/kotlin/config/ApiWebClientConfig.kt

@@ -1,5 +1,8 @@
 package com.wafflestudio.snu4t.config
 
+import io.netty.channel.ChannelOption
+import io.netty.handler.timeout.ReadTimeoutHandler
+import io.netty.handler.timeout.WriteTimeoutHandler
 import org.springframework.boot.context.properties.ConfigurationProperties
 import org.springframework.boot.context.properties.EnableConfigurationProperties
 import org.springframework.context.annotation.Bean
@@ -8,8 +11,11 @@ import org.springframework.context.annotation.Profile
 import org.springframework.http.client.reactive.ReactorClientHttpConnector
 import org.springframework.stereotype.Component
 import org.springframework.web.reactive.function.client.WebClient
+import reactor.netty.Connection
 import reactor.netty.http.client.HttpClient
+import reactor.netty.resources.ConnectionProvider
 import java.time.Duration
+import java.util.concurrent.TimeUnit
 
 @Configuration
 @EnableConfigurationProperties(ApiConfigs::class)
@@ -23,8 +29,25 @@ class ApiWebClientConfig(
     }
 
     private fun create(apiConfig: ApiConfig): WebClient {
-        val httpClient = HttpClient.create().responseTimeout(Duration.ofMillis(apiConfig.responseTimeout))
-        val connector = ReactorClientHttpConnector(httpClient)
+        val connector =
+            ReactorClientHttpConnector(
+                HttpClient.create(
+                    ConnectionProvider.builder("snuttev-provider")
+                        .maxConnections(100)
+                        .pendingAcquireTimeout(Duration.ofMillis(300))
+                        .maxLifeTime(Duration.ofSeconds(3600))
+                        .maxIdleTime(Duration.ofSeconds(240))
+                        .lifo()
+                        .build(),
+                )
+                    .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, apiConfig.connectTimeout)
+                    .doOnConnected { conn: Connection ->
+                        conn
+                            .addHandlerLast(ReadTimeoutHandler(apiConfig.readTimeout, TimeUnit.MILLISECONDS))
+                            .addHandlerLast(WriteTimeoutHandler(apiConfig.readTimeout, TimeUnit.MILLISECONDS))
+                    },
+            )
+
         return WebClient.builder().clientConnector(connector).baseUrl(apiConfig.baseUrl).build()
     }
 }
@@ -36,7 +59,8 @@ class ApiConfigs {
 }
 
 class ApiConfig {
-    var responseTimeout: Long = 2000
+    var readTimeout = 3000L
+    var connectTimeout = 3000
     lateinit var baseUrl: String
 }