Jedis & spring-data-redis

发表于 | 分类于

当我们了解了redis的五大数据类型,手动去敲一敲每个数据类型对应的命令,无论是再来看jedis,还是spring-data-redis都是很轻松的,他们提供的API都是基于原生的redis命令,可读性很强

jedis操作五大数据类型

其实关于怎么使用jedis的对应的五大数据类型的api,就不说太多了,因为可读性真的是太强了,只要了解那么底层的命令,开箱即用,忘记了,点一下,全出来了

demo:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
/**
 * @Author: Changwu
 * @Date: 2019/3/28 11:45
 */
public class TextAPI {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.43.150", 6379);
        jedis.hset("user","userName","25");
        jedis.hset("user","id","1");
        System.out.println(jedis.hget("user","userName"));
        HashMap<String, String> map = new HashMap<>();
        map.put("role1","admin");
        map.put("role2","user");
        jedis.hmset("role",map);
        System.out.println(jedis.hmget("role","role1"));
    }
}

jedis的事务demo

1
2
3
4
5
Transaction multi = jedis.multi();
//放弃提交事务
multi.discard();
// 提交事务
//  multi.exec();

因为他对事务是部分支持,所以一般都要加上watch

RedisPool

一般在多线程下并发访问redis,为了提高性能,会使用redis连接池(单例)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

/**
* 工具方法,获取jedispool的单例
* @Author: Changwu
* @Date: 2019/3/28 14:10
*/
public class jedisPoolUtil {
private static volatile JedisPool jedisPool = null;
// 私有化构造方法
private jedisPoolUtil(){}

//提供工厂方法
public static JedisPool getJedisPoolInstance(){
 if (jedisPool==null){
    synchronized (jedisPoolUtil.class){
     if (jedisPool==null){
         // jedispool 的相关配置
         JedisPoolConfig poolConfig = new JedisPoolConfig();
         poolConfig.setMaxIdle(32);  // 最多有这么多尅空闲
         poolConfig.setMaxTotal(500);
         poolConfig.setMaxWaitMillis(100*1000); //最长等待的时间
         poolConfig.setTestOnBorrow(true); // 获取redis连接时,是否检验redis的连接可用性
         return new JedisPool(poolConfig,"192.168.43.150",6379);
     }
 }
 }
     return jedisPool;
}

/**
 *  关闭具体某个池子的某个实例
 * @param jedis
 */
public static void release(Jedis jedis){
    if (jedis!=null){
        jedis.close();
    }
}

spring-data-redis

spring整个redis后提供了如下两个模板,供我们去操作redis

1
2
3
4
5
6
7
8
9
@RunWith(SpringRunner.class)
@SpringBootTest
public class BootRedisApplicationTests {

    @Autowired
    RedisTemplate redisTemplate;

    @Autowired
    StringRedisTemplate stringRedisTemplate;
  • 前者的kv 全是object
  • 后者的kv 全是string

大多数情况下,我们都是把string字符串往redis里面存储,所以更倾向于StringRedisTemplate

两套模板针对五大数据类型对应如下api,同样可读性依然超级好

header 1 header 2
操作字符串 redisTemplate.opsForValue()
操作hash redisTemplate.opsForHash()
操作list redisTemplate.opsForList()
操作set redisTemplate.opsForSet()
操作zset redisTemplate.opsForZSet()

注意点:

RedisTemplate 前者针对对象操作,要求我们的bean要是实现可序列化接口Serializable

  • 默认会使用jdk默认的序列化机制,把序列化后的数据保存到redis,当我们直接去redis上查看存进去的对象时,看到的无异于一堆乱码(当然并没错,依旧可以通过反序列化得到对象)

如何解决?

  1. 我们可以先把对象手动转化成json,再存储到redis
  2. 定制RedisTemplate

在redis的自动配置类中我们可以看到它的自动配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@Configuration
@ConditionalOnClass(RedisOperations.class)
@EnableConfigurationProperties(RedisProperties.class)
@Import({ LettuceConnectionConfiguration.class, JedisConnectionConfiguration.class })
public class RedisAutoConfiguration {

	@Bean
	@ConditionalOnMissingBean(name = "redisTemplate")
	public RedisTemplate<Object, Object> redisTemplate(
			RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
		RedisTemplate<Object, Object> template = new RedisTemplate<>();
		template.setConnectionFactory(redisConnectionFactory);
		return template;
	}

跟进 RedisTemplate 可以找到他默认使用的序列化器是 jdk的

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
@Override
public void afterPropertiesSet() {

	super.afterPropertiesSet();

	boolean defaultUsed = false;

	if (defaultSerializer == null) {

		defaultSerializer = new JdkSerializationRedisSerializer(
				classLoader != null ? classLoader : this.getClass().getClassLoader());
	}

``` 

**我们要做的就是定制一个自己的关于redis的配置类,让他覆盖掉自动配置**

新建类,加`@Configuration` 注解 , 拷贝原自动配置类的代码段,替换掉 它指定序列化器的部分

```java
@Configuration
public class redisConfig {
    @Bean
    public RedisTemplate<Object, 将被序列化的类名> redisTemplate(
            RedisConnectionFactory redisConnectionFactory) throws UnknownHostException {
        RedisTemplate<Object, 将被序列化的类名> template = new RedisTemplate<Object, 将被序列化的类名>();
        template.setConectionFactory(redisConnectionFactory);

        // 更换默认的序列化器
        RedisSerializer ser= new Jackson2JsonRedisSerializer<将被序列化的类名>(将被序列化的类名.Class);
        template.setDefaultSerializer(ser);
        return template;
    }
}

自动注入我们指定的redisTemplate

1
2
@Autowired
 RedisTemplate<Object,将要序列化的类名> redisTemplate;