SpringBoot整合Redis的示例

redis是最常用的缓存数据库,常用于存储用户登录token、临时数据、定时相关数据等。

redis是单线程的,所以redis的操作是原子性的,这样可以保证不会出现并发问题。

redis基于内存,速度非常快,据测试,redis读的速度是110000次/s,写的速度是81000次/s

本节介绍SpringBoot引入redis,以及使用RedisTemplate来操作redis数据。

采用SpringBoot 2.1.9.RELEASE,对应示例代码在:https://github.com/laolunsi/spring-boot-examples/tree/master/07-spring-boot-redis-demo

一、A Simple Demo-使用SpringBoot连接redis

maven:

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

yml:

server:
 port: 8867
spring:
 redis:
  host: localhost
  port: 6379
  #password: ''
  database: 6

测试类:

@SpringBootTest
@RunWith(SpringRunner.class)
public class RedisTest {

  @Autowired
  private RedisTemplate redisTemplate;

  @Test
  public void testRedis() {
    String key = "hello";
    redisTemplate.opsForValue().set("hello", "你好");

    String res = (String) redisTemplate.opsForValue().get(key);
    System.out.println(res);
  }
}

执行结果:

看一下redis:

这里存在一个问题:默认的存储方式导致key在redis-manager里面显示出来是乱码的,并且存储结果是二进制了。这样不利用我们查看redis里面的数据。

我们需要自定义redis存储的序列化规则。

二、解决RedisTemplate默认序列化的问题

完善一下maven:

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter</artifactId>
</dependency>

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-test</artifactId>
  <scope>test</scope>
</dependency>

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

定义RedisConfig类:

/**
 * redis配置
 * 主要是配置Redis的序列化规则,替换默认的jdkSerializer
 * key的序列化规则用StringRedisSerializer
 * value的序列化规则用Jackson2JsonRedisSerializer
 */
@Configuration
public class RedisConfig {

  @Bean
  public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory connectionFactory) {
    RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(connectionFactory);

    // 使用Jackson2JsonRedisSerialize替换默认序列化
    Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

    ObjectMapper objectMapper = new ObjectMapper();
    objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

    jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

    // 设置key和value的序列化规则
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);

    redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);

    redisTemplate.afterPropertiesSet();
    return redisTemplate;
  }
}

删除之前的key,重新执行一下test方法:

下面来演示一下SpringBoot使用RedisTemplate进行redis数据的操作

三、基于SpringBoot的redis操作——key/list/hash

RedisTemplate内置redis操作如下:

这里主要展示value/hash/list三种用法:

3.1 RedisTemplate.opsForValue

 @Test
  public void testKeyOps() {
    // 测试redis操作key-value形式
    Set<String> keySet = new HashSet<>();

    String key1 = "name";
    keySet.add(key1);
    // 存储简单的key-value,并设置过期时间
    redisTemplate.opsForValue().set(key1, "eknown", 1, TimeUnit.MINUTES);

    String key2 = "token:user1";
    String key3 = "token:user2";
    keySet.add(key2);
    keySet.add(key3);
    //
    redisTemplate.opsForValue().set(key2, "{\"name\":\"eknown\"}, \"role\":\"admin\"");
    redisTemplate.opsForValue().set(key3, "{\"name\":\"test\"}, \"role\":\"test\"");

    // 根据key的集合获取多个value
    List<String> valueList = redisTemplate.opsForValue().multiGet(keySet);
    for (String value : valueList) {
      System.out.println(value);
    }
  }

执行结果:

redis中的数据:

redis中的key显示出了一个层级关系,这个小技巧对于实际项目有个非常好的作用:通过prefix:suffix这样的形式,可以将redis中存储的数据分出层级。

3.2 RedisTemplate.opsForHash

清空该database下的数据,测试redisTemplate.opsForHash:

  @Test
  public void testHashOps() {
    String key = "hash";
    // 单次往hash中存放一个数据
    redisTemplate.opsForHash().put(key, "1", "你好");

    Map<String, Object> map = new HashMap<>();
    map.put("2", "hello");
    map.put("3a", "china1=2");

    // 一次性向hash中存放一个map
    redisTemplate.opsForHash().putAll(key, map);

    // 获取hash下的所有key和value
    Map<String, Object> resultMap = redisTemplate.opsForHash().entries(key);
    for (String hashKey : resultMap.keySet()) {
      System.out.println(hashKey + ": " + resultMap.get(hashKey));
    }
  }

执行结果:

redis:

3.3 RedisTemplate.opsForList

  @Test
  public void testListOps() {
    String listKey = "list";
    redisTemplate.opsForList().leftPush(listKey, "first value"); // 从list最左边插入数据
    redisTemplate.opsForList().leftPush(listKey, "second value but left");
    redisTemplate.opsForList().rightPush(listKey, 3); // 从list最右边插入数据

    List<Object> list = new ArrayList<>();
    list.add("hello");
    list.add("http://www.eknown.cn");
    list.add(23344);
    list.add(false);
    redisTemplate.opsForList().rightPushAll(listKey, list); // 从list右边批量插入数据

    long size = redisTemplate.opsForList().size(listKey);
    if (size > 0) {
      for (int i = 0; i < size -1 ; i++) {
        // 从list最左边开始读取list中的数据,注意pop会导致出栈,也就是数据被取出来了(redis中就没有这个值了)
        // 此处我们读取size-1条数据,仅留下最后一条数据
        System.out.println(i + ":" + redisTemplate.opsForList().leftPop(listKey).toString());
      }
    }
  }

执行上面的脚本,注意在最后的读取list数据代码前面加一个断点,此时redis中是这样的:

放开断点,程序继续执行,控制台如下:

注意,此时redis中仅剩余最后一条数据,这是由于pop的问题,list中的数据被读取并删除了:

好了,这一节主要讲了SpringBoot引入redis,以及使用redis的一些基本操作和相关技巧,在此基础上,我们可以让我们的项目变得更加快速、灵活!

以上就是SpringBoot整合Redis的示例的详细内容,更多关于SpringBoot整合Redis的资料请关注我们其它相关文章!

(0)

相关推荐

  • springboot整合redis集群过程解析

    简介 在springboot使用搭建好的redis集群 添加redis和连接池依赖 <!--redis连接池 start--> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-pool2</artifactId> </dependency> <!--redis连接池 end--> <!--redis start-

  • SpringBoot 整合Redis 数据库的方法

    Redis简介 Redis(官网: https://redis.io )是一个基于内存的日志型可持久化的缓存数据库,保存形式为key-value格式,Redis完全免费开源,它使用ANSI C语言编写.与其他的key - value缓存产品一样,Redis具有以下三个特点. • Redis支持数据的持久化,可以将内存中的数据保存在磁盘中,重启的时候可以再次加载进行使用: • Redis不仅支持简单的key-value类型数据,同时还提供字符串.链表.集合.有序集合和哈希等数据结构的存储: • R

  • Springboot整合Redis最简单例子分享

    1. 编写目的 最简单的例子,Springboot整合Redis. 2. 详细过程 pom 文件添加依赖 <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-data-redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spr

  • SpringBoot2整合Redis多数据源步骤详解

    redis是一个基于内存的高性能key-value数据库,具有极高的读写速度.本文介绍 SpringBoot 和 Redis 的整合,以及如何在项目中具体应用 配置文件属性 spring: redis: database: 1 host: 192.168.50.144 port: 6379 password: timeout: 600 #Springboot2.0 不能设置为0 lettuce: pool: max-active: 50 max-wait: -1 max-idle: 8 min-

  • SpringBoot如何整合redis实现过期key监听事件

    可以用于简单的过期订单取消支付.7天自动收货场景中 1.Spring Boot整合redis 参考 https://www.jb51.net/article/170687.htm 2.打开redis服务的配置文件添加notify-keyspace-events Ex 如果是注释了,就取消注释 Linux安装redis:https://www.jb51.net/article/193265.htm Windows安装redis:https://www.jb51.net/article/176040

  • SpringBoot2整合Redis缓存三步骤代码详解

    遵循SpringBoot三板斧 第一步加依赖 <!-- Redis --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <!-- redis依赖commons-pool 这个依赖一定要添加 --> <

  • springboot整合redis进行数据操作(推荐)

    redis是一种常见的nosql,日常开发中,我们使用它的频率比较高,因为它的多种数据接口,很多场景中我们都可以用到,并且redis对分布式这块做的非常好. springboot整合redis比较简单,并且使用redistemplate可以让我们更加方便的对数据进行操作. 1.添加依赖 <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starte

  • springboot与redis的简单整合实例

    前言 Redis是一个缓存.消息代理和功能丰富的键值存储.StringBoot提供了基本的自动配置.本文记录一下springboot与redis的简单整合实例 官方文档:https://docs.spring.io/spring-boot/docs/2.1.0.RELEASE/reference/htmlsingle/ 前期准备 首先我们要有一个Redis服务,由于我没有Linux环境,为了方便搭建项目,直接在Windows下安装,参考这篇博客:Windows下安装Redis服务 安装步骤:一直

  • SpringBoot2.3整合redis缓存自定义序列化的实现

    1.引言 我们使用redis作为缓存中间件时,当我们第一次查询数据的时候,是去数据库查询,然后查到的数据封装到实体类中,实体类会被序列化存入缓存中,当第二次查数据时,会直接去缓存中查找被序列化的数据,然后反序列化被我们获取.我们在缓存中看到的序列化数据不直观,如果想看到类似json的数据格式,就需要自定义序列化规则. 2.整合redis pom.xml: <!--引入redis--> <dependency> <groupId>org.springframework.d

  • SpringBoot整合Redis正确的实现分布式锁的示例代码

    前言 最近在做分块上传的业务,使用到了Redis来维护上传过程中的分块编号. 每上传完成一个分块就获取一下文件的分块集合,加入新上传的编号,手动接口测试下是没有问题的,前端通过并发上传调用就出现问题了,并发的get再set,就会存在覆盖写现象,导致最后的分块数据不对,不能触发分块合并请求. 遇到并发二话不说先上锁,针对执行代码块加了一个JVM锁之后问题就解决了. 仔细一想还是不太对,项目是分布式部署的,做了负载均衡,一个节点的代码被锁住了,请求轮询到其他节点还是可以进行覆盖写,并没有解决到问题啊

随机推荐