Java連接Redis集群

導入maven依賴

<dependency>
  <groupId>redis.clients</groupId>
  <artifactId>jedis</artifactId>
</dependency>

測試類

package com.boot.business;

import java.io.IOException;
import java.util.LinkedHashSet;
import java.util.Set;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

public class AppTest {
  public static void main(String[] args) {
    JedisPoolConfig poolConfig = new JedisPoolConfig();
    // 最大連接數
    poolConfig.setMaxTotal(1);
    // 最大空閑數
    poolConfig.setMaxIdle(1);
    // 最大允許等待時間，如果超過這個時間還未獲取到連接，則會報JedisException異常：
    // Could not get a resource from the pool
    poolConfig.setMaxWaitMillis(1000);
    Set<HostAndPort> nodes = new LinkedHashSet<HostAndPort>();
    nodes.add(new HostAndPort("192.168.33.159", 7001));
    nodes.add(new HostAndPort("192.168.33.159", 7002));
    nodes.add(new HostAndPort("192.168.33.159", 7003));
    nodes.add(new HostAndPort("192.168.33.159", 7004));
    nodes.add(new HostAndPort("192.168.33.159", 7005));
    nodes.add(new HostAndPort("192.168.33.159", 7006));
    JedisCluster cluster = new JedisCluster(nodes, poolConfig);
    String name = cluster.get("name");
    System.out.println(name);
    cluster.set("age", "18");
    System.out.println(cluster.get("age"));
    try {
      cluster.close();
    } catch (IOException e) {
      e.printStackTrace();
    }
  }
}