update nonblocking

Author: Jang4360

server/src/main/java/dev/interview/server/ai/config/WebClientConfig.java

@@ -1,17 +1,42 @@
 package dev.interview.server.ai.config;
 
+import io.netty.channel.ChannelOption;
+import io.netty.handler.timeout.ReadTimeoutHandler;
+import io.netty.handler.timeout.WriteTimeoutHandler;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.http.MediaType;
+import org.springframework.http.client.reactive.ReactorClientHttpConnector;
 import org.springframework.web.reactive.function.client.WebClient;
 import org.springframework.http.HttpHeaders;
+import reactor.netty.http.client.HttpClient;
+import reactor.netty.resources.ConnectionProvider;
+
+import java.time.Duration;
 
 @Configuration
 public class WebClientConfig {
     @Bean
     public WebClient webClient(WebClient.Builder builder) {
+        int maxConnections = 50;
+        int maxIdleTime = 30;  // 초
+
+        ConnectionProvider provider = ConnectionProvider.builder("fixed")
+                .maxConnections(maxConnections)
+                .maxIdleTime(Duration.ofSeconds(maxIdleTime))  // 유휴 커넥션 시간
+                .build();
+
+        HttpClient httpClient = HttpClient.create()
+                .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000)
+                .responseTimeout(Duration.ofSeconds(5))
+                .doOnConnected(conn ->
+                        conn.addHandlerLast(new ReadTimeoutHandler(5))
+                                .addHandlerLast(new WriteTimeoutHandler(5))
+                );
+
         return builder
                 .baseUrl("http://localhost:6333")
+                .clientConnector(new ReactorClientHttpConnector(httpClient))
                 .defaultHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON_VALUE)  // 수정된 부분
                 .build();
     }

server/src/main/java/dev/interview/server/ai/service/RedisLockService.java

@@ -1,7 +1,10 @@
 package dev.interview.server.ai.service;
 
 import lombok.RequiredArgsConstructor;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.connection.RedisStringCommands;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.types.Expiration;
 import org.springframework.stereotype.Service;
 
 import java.time.Duration;
@@ -12,7 +15,16 @@ public class RedisLockService {
     private final RedisTemplate<String, String> redisTemplate;
 
     public boolean tryLock(String key, Duration timeout) {
-        Boolean success = redisTemplate.opsForValue().setIfAbsent(key, "locked", timeout);
+        // 밀리초 단위로 변환
+        long timeoutMillis = timeout.toMillis();
+        // Redis 명령어를 직접 실행하여 NX와 PX 옵션 설정
+        Boolean success = redisTemplate.execute((RedisConnection connection) ->
+                connection.set(
+                        key.getBytes(),
+                        "locked".getBytes(),
+                        Expiration.milliseconds(timeoutMillis),
+                        RedisStringCommands.SetOption.SET_IF_ABSENT)
+        );
         return Boolean.TRUE.equals(success);
     }