1、引入依賴

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

2、配置

# Redis集群服務器地址
redis.nodes=aliyun:6900,aliyun:6901,aliyun:6902,aliyun:6930,aliyun:6931,aliyun:6932
#在集群中執行命令時要遵循的最大重定向數目
redis.cluster.max-redirects=5
# Redis服務器連接密碼（默認為空）
redis.password=null
redis.timeout=30000
# 連接池最大連接數（使用負值表示沒有限制）
redis.maxTotal=30
# 連接池中的最大空閑連接
redis.maxIdle=10
redis.numTestsPerEvictionRun=1024
redis.timeBetweenEvictionRunsMillis=30000
redis.minEvictableIdleTimeMillis=1800000
redis.softMinEvictableIdleTimeMillis=10000
# 連接池最大阻塞等待時間（使用負值表示沒有限制）
redis.maxWaitMillis=1500
redis.testOnBorrow=true
redis.testWhileIdle=true
redis.blockWhenExhausted=false
redis.JmxEnabled=true

3、獲取api對象

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisSentinelPool;import java.util.HashSet;
import java.util.Set;@Configuration
@PropertySource("classpath:application.properties")
public class RedisClusterConfig {@Value("${redis.nodes}")private String hosts;@Value("${redis.cluster.max-redirects}")private int maxRedirects;@Value("${redis.timeout}")private int timeout;@Value("${redis.maxIdle}")private int maxIdle;@Value("${redis.maxWaitMillis}")private int maxWaitMillis;@Value("${redis.blockWhenExhausted}")private Boolean blockWhenExhausted;@Value("${redis.JmxEnabled}")private Boolean JmxEnabled;@Beanpublic JedisPoolConfig  jedisPoolConfigFactory() {JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();jedisPoolConfig.setMaxIdle(maxIdle);jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);// 連接耗盡時是否阻塞, false報異常,true阻塞直到超時, 默認truejedisPoolConfig.setBlockWhenExhausted(blockWhenExhausted);// 是否啟用pool的jmx管理功能, 默認truejedisPoolConfig.setJmxEnabled(JmxEnabled);jedisPoolConfig.setTestOnBorrow(true);jedisPoolConfig.setTestOnReturn(true);return jedisPoolConfig;}@Beanpublic JedisCluster getJedisCluster(JedisPoolConfig jedisPoolConfig) {Set<HostAndPort> nodes = new HashSet<>();String[] hostsArray = hosts.split(",");for (String ipPort : hostsArray) {String[] ipPortPair = ipPort.split(":");nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));}return new JedisCluster(nodes,timeout,1000,1,jedisPoolConfig);}}

4、操作String類型示例

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisSentinelPool;/*** 操作字符串類型*/
@Component
public class RedisString {public final static String RS_STR_NS = "rs:";@Autowiredprivate JedisCluster jedisCluster;/*** 向Redis中存值，永久有效*/public String set(String key, String value) {try {return jedisCluster.set(RS_STR_NS +key, value);} catch (Exception e) {throw new RuntimeException("向Redis中存值失敗！");} finally {}}/*** 根據傳入Key獲取指定Value*/public String get(String key) {try {return jedisCluster.get(RS_STR_NS +key);} catch (Exception e) {throw new RuntimeException("獲取Redis值失敗！");} finally {}}}

5、測試

import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;@SpringBootTest
public class TestRedisString {@Autowiredprivate RedisString redisString;@Testvoid testSet(){System.out.println(redisString.set("test","Hello Java"));}@Testvoid testGet(){System.out.println(redisString.get("test"));}
}