Package 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	Description
RedisClusterConfiguration()	Creates new RedisClusterConfiguration.
RedisClusterConfiguration(Collection<String> clusterNodes)	Creates RedisClusterConfiguration for given hostPort combinations.
RedisClusterConfiguration(org.springframework.core.env.PropertySource<?> propertySource)	Creates RedisClusterConfiguration looking up values in given PropertySource.

Method Summary

Modifier and Type	Method	Description
void	addClusterNode(RedisNode node)	Add a cluster node to configuration.
RedisClusterConfiguration	clusterNode(String host, Integer port)
RedisClusterConfiguration	clusterNode(RedisNode node)
boolean	equals(Object o)
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.
int	hashCode()
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, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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

getDatabaseOrElse, getPasswordOrElse

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

setPassword, setPassword

Constructor Details

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(org.springframework.core.env.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 Details

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.

equals

public boolean equals(@Nullable
 Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object