org.springframework.data.redis.connection

Class RedisClusterConfiguration

java.lang.Object

org.springframework.data.redis.connection.RedisClusterConfiguration

All Implemented Interfaces:

RedisConfiguration, RedisConfiguration.ClusterConfiguration, RedisConfiguration.WithAuthentication, RedisConfiguration.WithPassword

public class RedisClusterConfiguration
extends Object
implements RedisConfiguration, RedisConfiguration.ClusterConfiguration

Configuration class used for setting up RedisConnection via RedisConnectionFactory using connecting to Redis Cluster. Useful when setting up a high availability Redis environment.

Since:

1.7

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.RedisConfiguration

RedisConfiguration.ClusterConfiguration, RedisConfiguration.DomainSocketConfiguration, RedisConfiguration.SentinelConfiguration, RedisConfiguration.StaticMasterReplicaConfiguration, RedisConfiguration.WithAuthentication, RedisConfiguration.WithDatabaseIndex, RedisConfiguration.WithDomainSocket, RedisConfiguration.WithHostAndPort, RedisConfiguration.WithPassword

Constructor Summary

Constructors

Constructor and Description
RedisClusterConfiguration() Creates new RedisClusterConfiguration.
RedisClusterConfiguration(Collection<String> clusterNodes) Creates RedisClusterConfiguration for given hostPort combinations.
RedisClusterConfiguration(PropertySource<?> propertySource) Creates RedisClusterConfiguration looking up values in given PropertySource.

Method Summary

Modifier and Type	Method and Description
void	addClusterNode(RedisNode node) Add a cluster node to configuration.
RedisClusterConfiguration	clusterNode(RedisNode node)
RedisClusterConfiguration	clusterNode(String host, Integer port)
Set<RedisNode>	getClusterNodes() Returns an Collections.unmodifiableSet(Set) of cluster nodes.
Integer	getMaxRedirects()
RedisPassword	getPassword() Get the RedisPassword to use when connecting.
String	getUsername() Get the username to use when connecting.
void	setClusterNodes(Iterable<RedisNode> nodes) Set cluster nodes to connect to.
void	setMaxRedirects(int maxRedirects)
void	setPassword(RedisPassword password) Create and set a RedisPassword for given String.
void	setUsername(String username) Create and set a username with the given String.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.RedisConfiguration

getDatabaseOrElse, getDatabaseOrElse, getHostOrElse, getPasswordOrElse, getPasswordOrElse, getPortOrElse, getUsernameOrElse, isAuthenticationAware, isClusterConfiguration, isDatabaseIndexAware, isDomainSocketConfiguration, isHostAndPortAware, isSentinelConfiguration, isStaticMasterReplicaConfiguration

Methods inherited from interface org.springframework.data.redis.connection.RedisConfiguration.WithAuthentication

setPassword, setPassword

Constructor Detail

RedisClusterConfiguration

public RedisClusterConfiguration()

Creates new RedisClusterConfiguration.

RedisClusterConfiguration

public RedisClusterConfiguration(Collection<String> clusterNodes)

Creates RedisClusterConfiguration for given hostPort combinations.

 
 clusterHostAndPorts[0] = 127.0.0.1:23679
 clusterHostAndPorts[1] = 127.0.0.1:23680 ...
 

 

Parameters:

clusterNodes - must not be null.

RedisClusterConfiguration

public RedisClusterConfiguration(PropertySource<?> propertySource)

Creates RedisClusterConfiguration looking up values in given PropertySource.

 
 spring.redis.cluster.nodes=127.0.0.1:23679,127.0.0.1:23680,127.0.0.1:23681
 spring.redis.cluster.max-redirects=3
 
 

Parameters:

propertySource - must not be null.

Method Detail

setClusterNodes

public void setClusterNodes(Iterable<RedisNode> nodes)

Set cluster nodes to connect to.

Parameters:

nodes - must not be null.

getClusterNodes

public Set<RedisNode> getClusterNodes()

Description copied from interface: RedisConfiguration.ClusterConfiguration

Returns an Collections.unmodifiableSet(Set) of cluster nodes.

Specified by:

getClusterNodes in interface RedisConfiguration.ClusterConfiguration

Returns:

Set of nodes. Never null.

addClusterNode

public void addClusterNode(RedisNode node)

Add a cluster node to configuration.

Parameters:

node - must not be null.

clusterNode

public RedisClusterConfiguration clusterNode(RedisNode node)

Returns:

this.

getMaxRedirects

public Integer getMaxRedirects()

Specified by:

getMaxRedirects in interface RedisConfiguration.ClusterConfiguration

Returns:

max number of redirects to follow or null if not set.

setMaxRedirects

public void setMaxRedirects(int maxRedirects)

Parameters:

maxRedirects - the max number of redirects to follow.

clusterNode

public RedisClusterConfiguration clusterNode(String host,
                                             Integer port)

Parameters:

host - Redis cluster node host name or ip address.

port - Redis cluster node port.

Returns:

this.

setUsername

public void setUsername(@Nullable
                        String username)

Description copied from interface: RedisConfiguration.WithAuthentication

Create and set a username with the given String. Requires Redis 6 or newer.

Specified by:

setUsername in interface RedisConfiguration.WithAuthentication

Parameters:

username - the username.

getUsername

@Nullable
public String getUsername()

Description copied from interface: RedisConfiguration.WithAuthentication

Get the username to use when connecting.

Specified by:

getUsername in interface RedisConfiguration.WithAuthentication

Returns:

null if none set.

getPassword

public RedisPassword getPassword()

Description copied from interface: RedisConfiguration.WithAuthentication

Get the RedisPassword to use when connecting.

Specified by:

getPassword in interface RedisConfiguration.WithAuthentication

Returns:

RedisPassword.none() if none set.

setPassword

public void setPassword(RedisPassword password)

Description copied from interface: RedisConfiguration.WithAuthentication

Create and set a RedisPassword for given String.

Specified by:

setPassword in interface RedisConfiguration.WithAuthentication

Parameters:

password - must not be null use RedisPassword.none() instead.