Springboot整合二之Springboot整合redis教程

小灰灰 2022-05-23 01:22 315阅读 0赞

## 前言 ##

springboot整合系列之Springboot整合redis教程，这是继  **[Springboot整合RabbitMQ][Springboot_RabbitMQ]**

后的第二篇springboot整合案例。

###简单的springboot 整合 redis ，有以下几个方法(基本可以满足小型后台应用)： ##### 1.保存字符串 ##### 2.根据key获取字符串 ##### 3.保存对象 ##### 4.根据key获取对象 ##### 5.从redis中删除 ##### 6.从redis中批量删除

## 1.新建一个springboot过程 ##

此处不做多说。。。

![70][]

*注：RedisCacheObject 和 RedisObjectSerializer 在本次讲解中用不到，此处也不做说明。*

## 2.加入Redis依赖 ##

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

## 3.配置application.yml ##

spring:
      devtools:
        restart:
          enabled: false
      redis:
        database: 1
        host: 127.0.0.1
        port: 6379
        timeout: 6000  # 连接超时时长（毫秒）
        pool:
          max-active: 1000  # 连接池最大连接数（使用负值表示没有限制）
          max-wait: -1      # 连接池最大阻塞等待时间（使用负值表示没有限制）
          max-idle: 10      # 连接池中的最大空闲连接
          min-idle: 5       # 连接池中的最小空闲连接
        password:
    server:
      port: 90

## 4.配置RedisConfig     ##

package com.example.redis.config;
    
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
    
    /**
     * @author zhuzhe
     * @date 2018/5/20 16:12
     * @email 1529949535@qq.com
     */
    @Configuration
    public class RedisConfig {
    
        @Bean
        JedisConnectionFactory jedisConnectionFactory() {
            return new JedisConnectionFactory();
        }
    }

## 5.RedisUtils ##

package com.example.redis.util;
    
    import com.fasterxml.jackson.core.JsonProcessingException;
    import com.fasterxml.jackson.databind.ObjectMapper;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Component;
    
    import java.io.IOException;
    import java.util.Collection;
    
    /**
     * @author zhuzhe
     * @date 2018/5/20 16:22
     * @email 1529949535@qq.com
     */
    @Component
    public class RedisUtils {
    
        @Autowired
        private StringRedisTemplate stringRedisTemplate;
    
        private static final ObjectMapper mapper = new ObjectMapper();
    
        /**
         * 保存字符串
         * @param key
         * @param value
         */
        public void saveString(String key,String value){
            stringRedisTemplate.opsForValue().set(key, value);
        }
    
        /**
         * 根据key获取字符串
         * @param key
         */
        public String getString(String key){
            return stringRedisTemplate.opsForValue().get(key);
        }
    
        /**
         * 保存对象
         * @param key
         * @param obj
         * @throws JsonProcessingException
         */
        public void saveBean(String key,Object obj) throws JsonProcessingException {
            saveString(key,mapper.writeValueAsString(obj));
        }
    
        /**
         * 根据key获取对象
         * @param key
         * @return RedisCacheObject
         */
        public <T>T getBean(String key,Class<T> clazz) throws IOException {
            String value = getString(key);
            if (value == null) {
                return null;
            }
            return mapper.readValue(value, clazz);
        }
    
        /**
         * 从redis中删除
         * @param key
         */
        public void delete(String key){
            stringRedisTemplate.delete(key);
        }
    
        /**
         * 从redis中批量删除
         * @param keys
         */
        public void delete(Collection<String> keys){
            stringRedisTemplate.delete(keys);
        }
    }

## 6.测试 ##

package com.example.redis.domain;
    
    import lombok.Data;
    
    import java.io.Serializable;
    
    /**
     * @author zhuzhe
     * @date 2018/5/20 17:13
     * @email 1529949535@qq.com
     */
    @Data
    public class User implements Serializable {
    
        private static final long serialVersionUID = -1L;
    
        private String username;
        private Integer age;
    
        public User(String username, Integer age) {
            this.username = username;
            this.age = age;
        }
        public User() {}
    }

package com.example.redis.test;
    
    import com.example.redis.common.RedisCacheObject;
    import com.example.redis.domain.User;
    import com.example.redis.util.RedisUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    import java.io.IOException;
    
    /**
     * @author zhuzhe
     * @date 2018/5/20 18:16
     * @email 1529949535@qq.com
     */
    @RestController
    public class ApplicationTests {
    
        @Autowired
        private RedisUtils redisUtils;
    
        @RequestMapping("/test")
        public String test() throws IOException {
    
            User user = new User("zzz",12);
            redisUtils.saveString("zhuzhe","zhuzhe123");
    
            redisUtils.saveBean("aaa",user);
    
            String zhuzhe = redisUtils.getString("zhuzhe");
    
            User aaa = redisUtils.getBean("aaa", User.class);
    
            System.out.println(aaa);
    
            return zhuzhe;
        }
    }

git 地址： [https://github.com/zhuzhegithub/springboot-redis][https_github.com_zhuzhegithub_springboot-redis]

转载请务必保留此出处（原作者）：[https://blog.csdn.net/zhuzhezhuzhe1][https_blog.csdn.net_zhuzhezhuzhe1]

[https://blog.csdn.net/zhuzhezhuzhe1][https_blog.csdn.net_zhuzhezhuzhe1]

[Springboot_RabbitMQ]: https://blog.csdn.net/zhuzhezhuzhe1/article/details/80454956
[70]: /images/20220523/1099da38d37d43eeae94c657fa5e9cda.png
[https_github.com_zhuzhegithub_springboot-redis]: https://github.com/zhuzhegithub/springboot-redis
[https_blog.csdn.net_zhuzhezhuzhe1]: https://blog.csdn.net/zhuzhezhuzhe1