SpringBoot整合Redis

清疚 2024-04-23 20:03 3阅读 0赞

在SpringBoot整合Redis之前，先来简单认识下Redis。

### 1. Redis 简介 ###

Redis 是完全开源免费的，遵守BSD协议，是一个**高性能的key-value数据库**。  
Redis 与其他 key - value 缓存产品有以下**三个特点**：

*  Redis**支持数据的持久化**，可以将内存中的数据保持在磁盘中，重启的时候可以再次加载进行使用。
 *  Redis不仅仅支持简单的key-value类型的数据，同时还提供strings（字符串），list（列表），set（集合），zset（有序集合），hash（哈希）等数据结构的存储（**支持多种数据结构**）。
 *  Redis**支持数据的备份**，即master-slave模式的数据备份。
 *  Redis 典型的应用场景：缓存、计数器、排行榜、消息队列、社交网络等。

### 2. Redis 优势 ###

*  **性能极高** – Redis能读的速度是110000次/s,写的速度是81000次/s 。
 *  **丰富的数据类型** – Redis支持二进制案例的 Strings, Lists, Hashes, Sets 及 Ordered Sets 数据类型操作。
 *  **原子** – **Redis的所有操作都是原子性的**，同时Redis还支持对几个操作全并后的原子性执行。
 *  **丰富的特性** – Redis还支持 publish/subscribe, 通知, key 过期等等特性。

### 3. Redis与其他key-value存储有什么不同？ ###

*  **Redis有着更为复杂的数据结构并且提供对他们的原子性操作**，这是一个不同于其他数据库的进化路径。Redis的数据类型都是基于基本数据结构的同时对程序员透明，无需进行额外的抽象。
 *  **Redis运行在内存中但是可以持久化到磁盘**，所以在对不同数据集进行高速读写时需要权衡内存，因为数据量不能大于硬件内存。在内存数据库方面的另一个优点是， 相比在磁盘上相同的复杂的数据结构，在内存中操作起来非常简单，这样Redis可以做很多内部复杂性很强的事情。 同时，在磁盘格式方面他们是紧凑的以追加的方式产生的，因为他们并不需要进行随机访问。

### 4. 使用SpringBoot整合Redis ###

#### 4.1 导入依赖：在 pom.xml 文件中导入对应的依赖 ####

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

#### 4.2 配置Redis ####

在 application.properties 或 application.yml 中配置：

# RedisProperties
    # 这个是redis所在主机的ip地址，安装在本机直接写 localhost 或者127.0.0.0,安装在云服务器写对应的云服务器的ip地址
    spring.redis.host= 59.xxx.xxx.xxx
    # redis 的端口号
    spring.redis.port=6379
    # redis 的密码
    spring.redis.password= xxx
    spring.redis.database=0
    # 连接超时时间
    spring.redis.timeout=1800000
    # 连接池最大连接数（使用负值表示没有限制）
    spring.redis.lettuce.pool.max-active=20
    # 连接池最大阻塞等待时间（使用负值表示没有限制）
    spring.redis.lettuce.pool.max-wait=-1
    # 连接池中的最大空闲连接
    spring.redis.lettuce.pool.max-idle=5
    # 连接池中的最小空闲连接
    spring.redis.lettuce.pool.min-idle=0

编写 RedisConfig 配置类，构造 RedisTemplate

import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.redis.connection.RedisConnectionFactory;
    import org.springframework.data.redis.core.RedisTemplate;
    import org.springframework.data.redis.serializer.RedisSerializer;
    
    @Configuration
    public class RedisConfig {
        
        @Bean
        public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory) {
        
            // 当你在定义一个 bean 的时候，方法中声明的 factory 参数，spring会自动把这个 bean 注入进来
            RedisTemplate<String,Object> template = new RedisTemplate<>();
            //配置了连接工厂，具备了访问数据库的能力
            template.setConnectionFactory(factory);
            //配置Template主要配置序列化的方式
    
            //设置Key的序列化方式
            template.setKeySerializer(RedisSerializer.string());
            //设置普通value的序列化方式
            template.setValueSerializer(RedisSerializer.json());
            //设置hash的key的序列化方式
            template.setHashKeySerializer(RedisSerializer.string());
            //设置hash的value的序列化方式
            template.setHashValueSerializer(RedisSerializer.json());
    
            template.afterPropertiesSet();
            return template;
        }
    }

#### 4.3 测试： ####

@RunWith(SpringRunner.class)
    @ContextConfiguration(classes = CommunityApplication.class)
    @SpringBootTest
    public class RedisTests {
        
        
        // 注入 RedisTemplate
        @Autowired
        private RedisTemplate redisTemplate;
    
        @Test
        public void testStrings(){
        
            String redisKey = "test:count";
            redisTemplate.opsForValue().set(redisKey,1);
            System.out.println(redisTemplate.opsForValue().get(redisKey));
            System.out.println(redisTemplate.opsForValue().increment(redisKey));
            System.out.println(redisTemplate.opsForValue().decrement(redisKey));
        }
    
        @Test
        public void testHash(){
        
            String redisKey = "test:user";
            redisTemplate.opsForHash().put(redisKey,"id",1);
            redisTemplate.opsForHash().put(redisKey,"name","张三");
            System.out.println(redisTemplate.opsForHash().get(redisKey,"id"));
            System.out.println(redisTemplate.opsForHash().get(redisKey,"name"));
        }
    
        @Test
        public void testLists(){
        
            String redisKey = "test:ids";
            redisTemplate.opsForList().leftPush(redisKey,101);
            redisTemplate.opsForList().leftPush(redisKey,102);
            redisTemplate.opsForList().leftPush(redisKey,103);
            System.out.println(redisTemplate.opsForList().size(redisKey));
            System.out.println(redisTemplate.opsForList().index(redisKey,0));
            System.out.println(redisTemplate.opsForList().range(redisKey,0,2));
            System.out.println(redisTemplate.opsForList().leftPop(redisKey));
            System.out.println(redisTemplate.opsForList().leftPop(redisKey));
            System.out.println(redisTemplate.opsForList().leftPop(redisKey));
        }
    
        @Test
        public void testSet(){
        
            String redisKey = "test:teachers";
            redisTemplate.opsForSet().add(redisKey,"liubei","guanyu","zhangfei","zhaoyun","zhugeliang");
            System.out.println(redisTemplate.opsForSet().size(redisKey));
            System.out.println(redisTemplate.opsForSet().pop(redisKey));
            System.out.println(redisTemplate.opsForSet().members(redisKey));
        }
    
        @Test
        public void testSortedSet(){
        
            String redisKey = "test:students";
            redisTemplate.opsForZSet().add(redisKey,"唐僧",80);
            redisTemplate.opsForZSet().add(redisKey,"悟空",100);
            redisTemplate.opsForZSet().add(redisKey,"猪八戒",50);
            redisTemplate.opsForZSet().add(redisKey,"沙僧",20);
            redisTemplate.opsForZSet().add(redisKey,"白龙马",10);
    
            System.out.println(redisTemplate.opsForZSet().zCard(redisKey));
            System.out.println(redisTemplate.opsForZSet().score(redisKey,"猪八戒"));
            System.out.println(redisTemplate.opsForZSet().reverseRank(redisKey,"猪八戒"));
            System.out.println(redisTemplate.opsForZSet().range(redisKey,0,2));
        }
    
        @Test
        public void testKeys(){
        
            redisTemplate.delete("test:student");
            System.out.println(redisTemplate.hasKey("test:student"));
            redisTemplate.expire("test:teachers",10, TimeUnit.SECONDS);
        }
    
        //多次访问redisKey,可以绑定
        @Test
        public void testBoundOperations(){
        
            String redisKey = "test:count";
            BoundValueOperations operations = redisTemplate.boundValueOps(redisKey);
            operations.increment();
            operations.increment();
            operations.increment();
            operations.increment();
            operations.increment();
            System.out.println(operations.get());
        }
    
        //编程式事务管理
        @Test
        public void testTransactional(){
        
            Object obj = redisTemplate.execute(new SessionCallback() {
        
                @Override
                public Object execute(RedisOperations operations) throws DataAccessException {
        
                    String redisKey = "test:tx";
                    operations.multi();
    
                    operations.opsForSet().add(redisKey,"zhangsan");
                    operations.opsForSet().add(redisKey,"lisi");
                    operations.opsForSet().add(redisKey,"wangwu");
    
                    //在事务中进行查询是无效的
                    System.out.println(operations.opsForSet().members(redisKey));
    
                    return operations.exec();
                }
            });
            System.out.println(obj);
        }
    
    }

#### 4.4 小结： ####

1、当项目报以下错误：Caused by: redis.clients.jedis.exceptions.JedisDataException: ERR Client sent AUTH, but no password is set  
报错的原因：是redis服务没设置密码，而项目配置文件中写了有redis密码  
解决方案：  
1）把项目配置文件中的密码password设置为空或者不设置。  
2）设置redis服务密码——可通过直接修改redis.conf配置文件中的requirepass属性方式,如果修改不生效，可通过命令方式修改，进入redis的客户端

redis 127.0.0.1:6379> CONFIG SET requirepass “root”
    OK
    redis 127.0.0.1:6379> AUTH root
    OK

然后重启项目就可以连接本机的redis服务了。