【项目】仿牛客网社区开发第4章 Redis 一站式高性能存储方案 2 Spring整合Redis

爱被打了一巴掌 2024-03-22 14:32 11阅读 0赞

### 【项目】仿牛客网社区开发 ###

#### 文章目录 ####

*   *  【项目】仿牛客网社区开发
     *   *  第4章 Redis 一站式高性能存储方案
         *   *  2 Spring整合Redis

![在这里插入图片描述][2a82c83d44c14892a28426bcd51b9b91.png_pic_center]

#### 第4章 Redis 一站式高性能存储方案 ####

##### 2 Spring整合Redis #####

*  引入依赖
    
     *  spring-boot-starter-data-redis
 *  配置Redis
    
     *  配置数据库参数
     *  编写配置类，构造RedisTemplate
 *  访问Redis
    
     *  redisTemplate.opsForValue()
     *  redisTemplate.opsForHash()
     *  redisTemplate.opsForList()
     *  redisTemplate.opsForSet()
     *  redisTemplate.opsForZSet()

![在这里插入图片描述][ae7ca6a83ad645bda8e2638c16c4c7d3.png_pic_center]

查一下坐标

![在这里插入图片描述][17c3ceae46274483ba015057f84766fe.png_pic_center]

就是它了，复制依赖

![在这里插入图片描述][6f981d2e6339431e96689783237eb750.png_pic_center]

这里笔者用一个老一点的版本，老师用的2.1.6 RELEASE ，那我2.1.18

![在这里插入图片描述][40a14e574df9474ab97d70c0556b9f45.png_pic_center]

记得刷一下

其实我们不带版本也行，毕竟我们用的是springboot，但是笔者本来的版本就比老师很高了，就不了

![在这里插入图片描述][205ab96d95944d99951977baa3339196.png_pic_center]

这里就是2.7.10 版本了，和springboot 版本一样。

修改配置文件

![在这里插入图片描述][32e8b5124dcf4e699f874bab7dafdaaa.png_pic_center]

这里就随便选了11 库

再来一个配置类

package com.nowcoder.community.config;
    
    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;
    
    /**
     * @Projectname: community
     * @Classname: RedisConfig
     * @Author: Ding Jiaxiong
     * @Date:2023/4/21 17:21
     */
    
    @Configuration
    public class RedisConfig {
        
    
        @Bean
        public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        
            RedisTemplate<String, Object> template = new RedisTemplate<>();
            template.setConnectionFactory(factory);
    
            // 设置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;
        }
    
    }

![在这里插入图片描述][1dadd30d722f4c3f90b4443e097fe1a2.png_pic_center]

整个测试类

![在这里插入图片描述][b6f9e92dc17744899a152128384f1402.png_pic_center]

当前11 库啥也没有

package com.nowcoder.community;
    
    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.RedisTemplate;
    import org.springframework.test.context.ContextConfiguration;
    import org.springframework.test.context.junit4.SpringRunner;
    
    /**
     * @Projectname: community
     * @Classname: RedisTests
     * @Author: Ding Jiaxiong
     * @Date:2023/4/21 17:26
     */
    
    @RunWith(SpringRunner.class)
    @SpringBootTest
    @ContextConfiguration(classes = CommunityApplication.class)
    public class RedisTests {
        
    
    
        @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));
        }
    }

运行结果

![在这里插入图片描述][081b3ea780914201a02066d07e524ab4.png_pic_center]

1 2 1

看看服务器中

![在这里插入图片描述][df8d29afd41a4e62aff2cb5c68fdb6ec.png_pic_center]

没问题

@Test
        public void testHashes() {
        
            String redisKey = "test:user";
    
            redisTemplate.opsForHash().put(redisKey, "id", 1);
            redisTemplate.opsForHash().put(redisKey, "username", "zhangsan");
    
            System.out.println(redisTemplate.opsForHash().get(redisKey, "id"));
            System.out.println(redisTemplate.opsForHash().get(redisKey, "username"));
        }

![在这里插入图片描述][2e16b51878f24ec2ab97d0d31024d157.png_pic_center]

@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));
        }

![在这里插入图片描述][824bfea034754543bd981230a90b5309.png_pic_center]

public void testSets() {
        
            String redisKey = "test:teachers";
    
            redisTemplate.opsForSet().add(redisKey, "刘备", "关羽", "张飞", "赵云", "诸葛亮");
    
            System.out.println(redisTemplate.opsForSet().size(redisKey));
            System.out.println(redisTemplate.opsForSet().pop(redisKey));
            System.out.println(redisTemplate.opsForSet().members(redisKey));
        }

![在这里插入图片描述][5b70d72661274f36812882e5058f1ba0.png_pic_center]

@Test
        public void testSortedSets() {
        
            String redisKey = "test:students";
    
            redisTemplate.opsForZSet().add(redisKey, "唐僧", 80);
            redisTemplate.opsForZSet().add(redisKey, "悟空", 90);
            redisTemplate.opsForZSet().add(redisKey, "八戒", 50);
            redisTemplate.opsForZSet().add(redisKey, "沙僧", 70);
            redisTemplate.opsForZSet().add(redisKey, "白龙马", 60);
    
            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().reverseRange(redisKey, 0, 2));
        }

![在这里插入图片描述][5c442d9a9c834bca83d1c5d84b855832.png_pic_center]

@Test
        public void testKeys() {
        
            redisTemplate.delete("test:user");
    
            System.out.println(redisTemplate.hasKey("test:user"));
    
            redisTemplate.expire("test:students", 10, TimeUnit.SECONDS);
        }

![在这里插入图片描述][9c4364d1b711402eaf6e1c7aa46da6ac.png_pic_center]

额。这里笔者的定时key 并没有创建成功【但是老师的成功了 … 】

![在这里插入图片描述][d77c4c0c13544b3db995a9e504ec8f5b.png_pic_center]

好像只能更新现有的key【作用是设置key 的过期时间】，不能直接创建【OK，记住了】

这些就是常规操作。

// 批量发送命令,节约网络开销.
        @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());
        }

![在这里插入图片描述][1a50034eba5b46b8a8c92b97101527af.png_pic_center]

// 编程式事务
        @Test
        public void testTransaction() {
        
            Object result = redisTemplate.execute(new SessionCallback() {
        
                @Override
                public Object execute(RedisOperations redisOperations) throws DataAccessException {
        
                    String redisKey = "text:tx";
    
                    // 启用事务
                    redisOperations.multi();
                    redisOperations.opsForSet().add(redisKey, "zhangsan");
                    redisOperations.opsForSet().add(redisKey, "lisi");
                    redisOperations.opsForSet().add(redisKey, "wangwu");
    
                    System.out.println(redisOperations.opsForSet().members(redisKey));
    
                    // 提交事务
                    return redisOperations.exec();
                }
            });
            System.out.println(result);
        }

![在这里插入图片描述][1874823b0fe14114adcdee4bebf05c99.png_pic_center]

[2a82c83d44c14892a28426bcd51b9b91.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/2fdb24b4d4a54272bb95813185401605.png
[ae7ca6a83ad645bda8e2638c16c4c7d3.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/697ca554ea9c4dafbf137d6e1ba86b12.png
[17c3ceae46274483ba015057f84766fe.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/2ee5178c1be74324aacf8e77f0246404.png
[6f981d2e6339431e96689783237eb750.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/4ac8f58df6734a069cba945e5037cfb4.png
[40a14e574df9474ab97d70c0556b9f45.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/6a188ea70d8c4840a021d030c76ac1be.png
[205ab96d95944d99951977baa3339196.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/cbca730530894109b27dd376d7743997.png
[32e8b5124dcf4e699f874bab7dafdaaa.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/f6bb2d38daf449b0bc29b0e2d0b1f023.png
[1dadd30d722f4c3f90b4443e097fe1a2.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/2494e012cec04928a20bc60f89a5db31.png
[b6f9e92dc17744899a152128384f1402.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/a1f17ceedc1f47e18aefcc48a6f79406.png
[081b3ea780914201a02066d07e524ab4.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/449faee9fbf040bc97d7229a5231d56f.png
[df8d29afd41a4e62aff2cb5c68fdb6ec.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/7225f2f4e1854607b51ba757023d650a.png
[2e16b51878f24ec2ab97d0d31024d157.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/b0d8affc6e96441298057b165152f907.png
[824bfea034754543bd981230a90b5309.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/1574b11bbe4e4aa5b4a34d8f0129ccdf.png
[5b70d72661274f36812882e5058f1ba0.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/41414d93b6cb422a8345505b6ad72864.png
[5c442d9a9c834bca83d1c5d84b855832.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/e3b8a1a0850746dfbbe96c3582ffb49e.png
[9c4364d1b711402eaf6e1c7aa46da6ac.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/c71deeb073714eafb33db52b8b8532f0.png
[d77c4c0c13544b3db995a9e504ec8f5b.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/2775c014701e4ace9ab5223b315db76d.png
[1a50034eba5b46b8a8c92b97101527af.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/5fe890b8b06244688a1109c287a6d328.png
[1874823b0fe14114adcdee4bebf05c99.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/22/c1405e8ab45040a79b22538fad8a4e20.png