1、Spring配置Bean

@Bean
public JedisCluster jedisCluster(JedisPoolConfig jedisPoolConfig) {
    Set<HostAndPort> nodeSet = new HashSet<>();
    nodeSet.add(new HostAndPort("172.16.122.101", 6379));
    nodeSet.add(new HostAndPort("172.16.122.101", 6380));
    nodeSet.add(new HostAndPort("172.16.122.102", 6379));
    nodeSet.add(new HostAndPort("172.16.122.102", 6380));
    nodeSet.add(new HostAndPort("172.16.122.103", 6379));
    nodeSet.add(new HostAndPort("172.16.122.103", 6380));
    JedisCluster jedisCluster = new JedisCluster(nodeSet, 2000, jedisPoolConfig);

    log.info("=====创建JedisCluster=====");

    return jedisCluster;
}

2、代码测试示例

@Autowired
private JedisCluster jedisCluster; // 集群操作

@Test
public void TestJedisCluster() {
    // jedisCluster
    jedisCluster.set("name", "zxb");
    jedisCluster.set("age", "28");

    // get
    log.info(jedisCluster.get("name"));

    // exists
    log.info(jedisCluster.exists("age") + "");

    // expire
    jedisCluster.expire("name", 1);

    // ttl
    log.info(jedisCluster.ttl("name") + "");

    // ++ --
    log.info(jedisCluster.incr("age") + "");
    log.info(jedisCluster.decr("age") + "");

    // del
    jedisCluster.del("age");

}

SpringBoot集成Jedis(一)