SpringBoot 整合 Redis

素颜马尾好姑娘i 2021-09-19 09:24 375阅读 0赞

# SpringBoot 整合 Redis 无其他数据库。 #

代码地址： [geithub SpringbootRedis][]

# POM #

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>bsea</groupId>
        <artifactId>SpringBootRedis</artifactId>
        <version>1.0-SNAPSHOT</version>
        <packaging>jar</packaging>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>1.5.9.RELEASE</version>
            <relativePath/> 
        </parent>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <java.version>1.8</java.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-redis</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>fastjson</artifactId>
                <version>1.2.38</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
    
        </dependencies>
        <repositories>
            <repository>
                <id>alimaven</id>
                <name>aliyun maven</name>
                <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
            </repository>
        </repositories>
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>

## RedisTemplateService ##

package com.zz.service;
    
    /**
     * @Description: java类作用描述
     * @Author: Bsea
     * @CreateDate: 2019/9/15$ 20:28$
     */
    import com.alibaba.fastjson.JSON;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.stereotype.Service;
    
    @Service
    public class RedisTemplateService {
    
        @Autowired
        StringRedisTemplate stringRedisTemplate;
    
        public <T> boolean set(String key ,T value){
    
            try {
    
                //任意类型转换成String
                String val = beanToString(value);
    
                if(val==null||val.length()<=0){
                    return false;
                }
    
                stringRedisTemplate.opsForValue().set(key,val);
                return true;
            }catch (Exception e){
                return false;
            }
        }
        public <T> T get(String key,Class<T> clazz){
            try {
                String value = stringRedisTemplate.opsForValue().get(key);
    
                return stringToBean(value,clazz);
            }catch (Exception e){
                return null ;
            }
        }
    
        @SuppressWarnings("unchecked")
        private <T> T stringToBean(String value, Class<T> clazz) {
            if(value==null||value.length()<=0||clazz==null){
                return null;
            }
    
            if(clazz ==int.class ||clazz==Integer.class){
                return (T)Integer.valueOf(value);
            }
            else if(clazz==long.class||clazz==Long.class){
                return (T)Long.valueOf(value);
            }
            else if(clazz==String.class){
                return (T)value;
            }else {
                return JSON.toJavaObject(JSON.parseObject(value),clazz);
            }
        }
    
        /**
         *
         * @return String
         */
        private <T> String beanToString(T value) {
    
            if(value==null){
                return null;
            }
            Class <?> clazz = value.getClass();
            if(clazz==int.class||clazz==Integer.class){
                return ""+value;
            }
            else if(clazz==long.class||clazz==Long.class){
                return ""+value;
            }
            else if(clazz==String.class){
                return (String)value;
            }else {
                return JSON.toJSONString(value);
            }
        }
    
    }

# resources/application.properties #

#Redis
    #spring.redis.host=127.0.0.1
    redis.host=127.0.0.1
    ## Redis服务器连接端口
    redis.port=6379
    ## 连接超时时间（毫秒）
    redis.timeout=3
    ## Redis服务器连接密码（默认为空）
    #redis.password=135246
    ## 连接池中的最大连接数
    redis.poolMaxTotal=10
    ## 连接池中的最大空闲连接
    redis.poolMaxIdle=10
    ## 连接池最大阻塞等待时间（使用负值表示没有限制）
    redis.poolMaxWait=3

# 测试类 #

import com.zz.Application;
    import com.zz.entity.User;
    import com.zz.service.RedisTemplateService;
    import org.junit.Test;
    import org.junit.runner.RunWith;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.boot.test.context.SpringBootTest;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
    
    @RunWith(SpringJUnit4ClassRunner.class)
    @SpringBootTest(classes = Application.class)
    public class RedisTest {
    
        @Autowired
        StringRedisTemplate stringRedisTemplate;
    
        @Autowired
        RedisTemplateService redisTemplateService;
        @Test
        public void test()  {
            // 保存字符串
            stringRedisTemplate.opsForValue().set("aaa", "111");
        }
    
        @Test
        public void test1()  {
            // 取字符串
            String val=stringRedisTemplate.opsForValue().get("tt");
            System.out.println(val);
        }
        @Test
        public void redisTestObject(){
    
            User user = new User();
            user.setId(11);
            user.setUsername("test");
            user.setPassword("hello redis");
            redisTemplateService.set("key1",user);
    
            User us = redisTemplateService.get("key1",User.class);
            System.out.println(us.getUsername()+":  "+us.getPassword());
        }
    }

运行结果：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gzNTYzNjM_size_16_color_FFFFFF_t_70]  
test: hello redis

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gzNTYzNjM_size_16_color_FFFFFF_t_70 1]

[geithub SpringbootRedis]: https://github.com/bseayin/springdemos/tree/master/SpringBootRedis
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gzNTYzNjM_size_16_color_FFFFFF_t_70]: /images/20210726/f5a795c8307c4fb19206e21f5818a156.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2gzNTYzNjM_size_16_color_FFFFFF_t_70 1]: /images/20210726/64e48f6cf5734e20b75592af01a0f8b5.png