Skip to content

Commit

Permalink
Redis 타임아웃 설정 #120
Browse files Browse the repository at this point in the history
Merge pull request #120 from team-crews/infra/set-redis-connection-timeoutRedis 타임아웃 설정
  • Loading branch information
jongmee authored Nov 12, 2024
2 parents 18d995e + 8cc54dd commit 4695a5b
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -5,12 +5,8 @@
import com.server.crews.auth.dto.response.TokenResponse;
import com.server.crews.global.CustomLogger;
import com.server.crews.global.exception.InternalErrorOccurredEvent;
import io.lettuce.core.RedisCommandTimeoutException;
import io.lettuce.core.RedisException;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.data.redis.RedisConnectionFailureException;
import org.springframework.data.redis.RedisSystemException;
import org.springframework.stereotype.Service;

/*
Expand All @@ -34,7 +30,7 @@ public RefreshTokenStorageFailureHandler(
public RefreshToken createRefreshToken(Role role, String username) {
try {
return refreshTokenService.createRefreshToken(role, username);
} catch (RedisConnectionFailureException | RedisSystemException | RedisException e) {
} catch (Exception e) {
customLogger.error(e);
eventPublisher.publishEvent(new InternalErrorOccurredEvent(e, null));
return new RefreshToken("", 0l, "");
Expand All @@ -53,7 +49,7 @@ public TokenResponse renew(String refreshToken) {
public void delete(String username) {
try {
refreshTokenService.delete(username);
} catch (RedisConnectionFailureException | RedisCommandTimeoutException | RedisSystemException e) {
} catch (Exception e) {
customLogger.error(e);
eventPublisher.publishEvent(new InternalErrorOccurredEvent(e, null));
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,8 @@
import com.redis.lettucemod.RedisModulesClient;
import com.redis.lettucemod.api.StatefulRedisModulesConnection;
import com.redis.lettucemod.spring.RedisModulesAutoConfiguration;
import io.lettuce.core.RedisURI;
import java.time.Duration;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.Bean;
Expand All @@ -21,11 +23,17 @@ public RedisStackConfig(@Value("${redis-stack.host}") String host, @Value("${red

@Bean
public RedisModulesClient redisModulesClient() {
return RedisModulesClient.create("redis://" + host + ":" + port);
RedisURI redisURI = RedisURI.builder()
.withHost(host)
.withPort(Integer.parseInt(port))
.withTimeout(Duration.ofSeconds(10))
.build();
return RedisModulesClient.create(redisURI);
}

@Bean
public StatefulRedisModulesConnection<String, String> redisModulesConnection(RedisModulesClient redisModulesClient) {
public StatefulRedisModulesConnection<String, String> redisModulesConnection(
RedisModulesClient redisModulesClient) {
return redisModulesClient.connect();
}
}
2 changes: 1 addition & 1 deletion src/main/resources/config

0 comments on commit 4695a5b

Please sign in to comment.