概述

在工作中, 可能会在非Spring项目(如Spark,Flink作业)中去操作Redis, 重复造轮子去写工具类没有太大的意义, 使用RedisTemplate已经足够丰富和完善了,使用New的方式进行创建即可, 不同的spring-data-redis的版本会略有不同, 下面以2.3.0和1.8.9做为示例.

2.3.0

maven

<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
    <version>2.3.0.RELEASE</version>
</dependency>
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.3.0</version>
</dependency>

代码

import org.springframework.data.redis.connection.RedisClusterConfiguration;
import org.springframework.data.redis.connection.RedisNode;
import org.springframework.data.redis.connection.RedisStandaloneConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;

import java.util.Collections;
import java.util.List;
import java.util.Objects;
public class RedisTest {
    public static void main(String[] args) {
        //单机模式
        RedisStandaloneConfiguration rsc = new RedisStandaloneConfiguration();
        rsc.setPort(6379);
        rsc.setPassword("123456");
        rsc.setHostName("192.168.1.1");

        //集群模式
        RedisClusterConfiguration rcc = new RedisClusterConfiguration();
        rcc.setPassword("123456");
        List<RedisNode> nodes = Collections.singletonList(new RedisNode("192.168.1.1", 6379));
        rcc.setClusterNodes(nodes);

        RedisTemplate<String, String> template = new RedisTemplate<>();
        //单机模式
        JedisConnectionFactory fac = new JedisConnectionFactory(rsc);
        //集群模式
        //JedisConnectionFactory fac = new JedisConnectionFactory(rcc);
        fac.afterPropertiesSet();
        template.setConnectionFactory(fac);
        template.setDefaultSerializer(new StringRedisSerializer());
        template.afterPropertiesSet();
        ValueOperations<String, String> op = template.opsForValue();
        final String key = "123_tmp";
        final String value = "abc";
        template.delete(key);
        op.set(key, value);
        assert Objects.equals(op.get(key), value);
    }
}

集群方式运行报错

Exception in thread "main" redis.clients.jedis.exceptions.JedisDataException: ERR This instance has cluster support disabled

解决

在redis.conf下将cluster-enabled改为yes
如果只有一个节点, 改为单机模式

1.8.9

maven

<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
    <version>1.8.9.RELEASE</version>
</dependency>
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.9.0</version>
</dependency>

代码

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.ValueOperations;
import redis.clients.jedis.JedisPoolConfig;
import redis.clients.jedis.JedisShardInfo;

import java.util.Objects;
public class RedisTest {
    public static void main(String[] args) {
        RedisTemplate<String, String> template = new RedisTemplate<>();
        JedisConnectionFactory fac = new JedisConnectionFactory(new JedisPoolConfig());
        JedisShardInfo shardInfo = new JedisShardInfo("192.168.1.1", 6379);
        shardInfo.setPassword("123456");
        fac.setShardInfo(shardInfo);
        template.setConnectionFactory(fac);
        template.setDefaultSerializer(new StringRedisSerializer());
        template.afterPropertiesSet();
        ValueOperations<String, String> op = template.opsForValue();
        final String key = "123_tmp";
        final String value = "abc";
        template.delete(key);
        op.set(key, value);
        assert Objects.equals(op.get(key), value);
    }
}

这里有个小细节, 如果不调用setShardInfo()方法, 那么需要执行下面的代码, afterPropertiesSet()用来初始化

JedisConnectionFactory fac = new JedisConnectionFactory(new JedisPoolConfig());
        fac.setPort(6379);
        fac.setPassword("123456");
        fac.setHostName("192.168.1.1");
        fac.afterPropertiesSet();