import org.springframework.data.redis.connection.RedisNode; //导入依赖的package包/类
private List<RedisNode> createSentinels(Sentinel sentinel) {
	List<RedisNode> nodes = new ArrayList<RedisNode>();
	for (String node : StringUtils
			.commaDelimitedListToStringArray(sentinel.getNodes())) {
		try {
			String[] parts = StringUtils.split(node, ":");
			Assert.state(parts.length == 2, "Must be defined as 'host:port'");
			nodes.add(new RedisNode(parts[0], Integer.valueOf(parts[1])));
		}
		catch (RuntimeException ex) {
			throw new IllegalStateException(
					"Invalid redis sentinel " + "property '" + node + "'", ex);
		}
	}
	return nodes;
}
 

import org.springframework.data.redis.connection.RedisNode; //导入依赖的package包/类
private List<RedisNode> createSentinels(Sentinel sentinel) {
	List<RedisNode> sentinels = new ArrayList<RedisNode>();
	String nodes = sentinel.getNodes();
	for (String node : StringUtils.commaDelimitedListToStringArray(nodes)) {
		try {
			String[] parts = StringUtils.split(node, ":");
			Assert.state(parts.length == 2, "Must be defined as 'host:port'");
			sentinels.add(new RedisNode(parts[0], Integer.valueOf(parts[1])));
		}
		catch (RuntimeException ex) {
			throw new IllegalStateException(
					"Invalid redis sentinel " + "property '" + node + "'", ex);
		}
	}
	return sentinels;
}
 

import org.springframework.data.redis.connection.RedisNode; //导入依赖的package包/类
@Bean
public JedisConnectionFactory getJedisConnectionFactory(){
    RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
    HashSet<RedisNode> nodes = new HashSet<>();
    String[] serverArray = redisProperties.getClusterNodes().split(",");
    for(String server:serverArray){
        String[] ipPortPair = server.split(":");
        RedisNode redisNode = new RedisNode(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim()));
        nodes.add(redisNode);
    }
    redisClusterConfiguration.setClusterNodes(nodes);
    JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(redisClusterConfiguration, getJedisPoolConfig());
    return jedisConnectionFactory;
}
 

import org.springframework.data.redis.connection.RedisNode; //导入依赖的package包/类
private void verify(SentinelsAvailable verificationMode) {

		int failed = 0;
		for (RedisNode node : sentinelConfig.getSentinels()) {
			if (!isAvailable(node)) {
				failed++;
			}
		}

		if (failed > 0) {
			if (SentinelsAvailable.ALL_ACTIVE.equals(verificationMode)) {
				throw new AssumptionViolatedException(String.format(
						"Expected all Redis Sentinels to respone but %s of %s did not responde", failed, sentinelConfig
								.getSentinels().size()));
			}

			if (SentinelsAvailable.ONE_ACTIVE.equals(verificationMode) && sentinelConfig.getSentinels().size() - 1 < failed) {
				throw new AssumptionViolatedException(
						"Expected at least one sentinel to respond but it seems all are offline - Game Over!");
			}
		}

		if (SentinelsAvailable.NONE_ACTIVE.equals(verificationMode) && failed != sentinelConfig.getSentinels().size()) {
			throw new AssumptionViolatedException(String.format(
					"Expected to have no sentinels online but found that %s are still alive.", (sentinelConfig.getSentinels()
							.size() - failed)));
		}
	}
 

import org.springframework.data.redis.connection.RedisNode; //导入依赖的package包/类
private List<RedisNode> createSentinels() {
	List<RedisNode> sentinels = new ArrayList<RedisNode>();
	for (String node : StringUtils.commaDelimitedListToStringArray(sentinelNodes)) {
		try {
			String[] parts = StringUtils.split(node, ":");
			Assert.state(parts.length == 2, "Must be defined as 'host:port'");
			sentinels.add(new RedisNode(parts[0], Integer.valueOf(parts[1])));
		}
		catch (RuntimeException ex) {
			throw new IllegalStateException("Invalid redis sentinel "
					+ "property '" + node + "'", ex);
		}
	}
	return sentinels;
}