&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<pre style="background-color:#2b2b2b;color:#a9b7c6;font-family:'D2Coding',monospace;font-size:11.3pt;">import io.lettuce.core.ReadFrom; import io.lettuce.core.cluster.ClusterClientOptions; import io.lettuce.core.cluster.ClusterTopologyRefreshOptions; import kr.promotion.builder.pipeline.RedisSubscriber; import lombok.RequiredArgsConstructor; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.data.redis.connection.RedisClusterConfiguration; import org.springframework.data.redis.connection.RedisConnectionFactory; import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration; import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.listener.ChannelTopic; import org.springframework.data.redis.listener.RedisMessageListenerContainer; import org.springframework.data.redis.listener.adapter.MessageListenerAdapter; import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer; import org.springframework.data.redis.serializer.StringRedisSerializer; import java.util.Collections; import java.util.List; @RequiredArgsConstructor @Configuration public class RedisConfig { @Value("${spring.redis.host}") private String host; @Value("${spring.redis.port}") private int port; @Value("${spring.redis.topic}") private String topic; @Bean public RedisConnectionFactory redisConnectionFactory() { // 클러스터 접속시 노드 리스트를 생성해 주어야 함 List&lt;String&gt; nodes = Collections.singletonList(String.format("%s:%s", host, port)); RedisClusterConfiguration clusterConfiguration = new RedisClusterConfiguration(nodes); ClusterTopologyRefreshOptions topologyRefreshOptions = ClusterTopologyRefreshOptions.builder().closeStaleConnections(true) .enableAllAdaptiveRefreshTriggers().build(); ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder().autoReconnect(true) .topologyRefreshOptions(topologyRefreshOptions).validateClusterNodeMembership(false) .build(); LettuceClientConfiguration lettuceClientConfiguration = LettuceClientConfiguration.builder() .readFrom(ReadFrom.REPLICA_PREFERRED).clientOptions(clusterClientOptions).build(); LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(clusterConfiguration, lettuceClientConfiguration); lettuceConnectionFactory.afterPropertiesSet(); return lettuceConnectionFactory; } @Bean public RedisTemplate&lt;?, ?&gt; redisTemplate() { RedisTemplate&lt;?, ?&gt; redisTemplate = new RedisTemplate&lt;&gt;(); redisTemplate.setConnectionFactory(redisConnectionFactory()); redisTemplate.setKeySerializer(new StringRedisSerializer()); redisTemplate.setValueSerializer(new Jackson2JsonRedisSerializer&lt;&gt;(String.class)); return redisTemplate; } }</pre>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;

redis cluster 인 경우 접속하는 방법