spring实战3 spring整合单例redis

小灰灰 2022-05-19 13:04 108阅读 0赞

# 前奏 #

工欲善其事必先利其器；预备一下工具对于整个环境的整合有极大的帮助

1.  linux环境中单例redis服务搭建，参考博客 [centos7自学之7-redis-4.0.1单例服务器搭建][centos7_7-redis-4.0.1]
2.  redisDesktopManage redis可视化工具安装
3.  idea开发工具

# 开始 #

现如今，越来越多的公司注重用户对网站访问速度的体验。而缓存技术的出现无疑很好的适用以上场景。

因此掌握一门缓存技术对一名IT男无疑是必要的。

## 建项目 ##

新建spring集成的web项目（spring-redis）-不用边看边做，后面会贴源码

## 添加配置文件 ##

新建配置文件 redis.properties

#访问地址
    redis.host=172.16.191.102
    # redis.host=192.168.1.106
    #访问端口
    redis.port=6379
    #授权密码，有没有这一项取决于要连接的redis服务是否设置了此项
    redis.auth=123456
    redis.dbIndex=0
    #连接池的最大数据库连接数。设为0表示无限制
    redis.maxIdle=1024
    #最大空闲数，数据库连接的最大空闲时间。超过空闲时间，数据库连接将被标记为不可用，然后被释放。设为0表示无限制。
    redis.maxActive=200
    #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
    redis.maxWait=10000
    #在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
    redis.testOnBorrow=true

## spring集成redis配置文件 ##

<context:property-placeholder location="classpath:properties/redis.properties" ignore-resource-not-found="true" />
    
    
    
    
    <bean id="poolConfig" class="redis.clients.jedis.JedisPoolConfig">
        <property name="maxIdle" value="${redis.maxIdle}" />
        <property name="maxTotal" value="${redis.maxActive}" />
        <property name="maxWaitMillis" value="${redis.maxWait}" />
        <property name="testOnBorrow" value="${redis.testOnBorrow}" />
    </bean>
    
    
    <bean id="jedisConnectionFactory" class="org.springframework.data.redis.connection.jedis.JedisConnectionFactory">
        <property name="hostName" value="${redis.host}" />
        <property name="port" value="${redis.port}" />
        <property name="password" value="${redis.auth}" />
        <property name="database" value="${redis.dbIndex}" />
        <property name="poolConfig" ref="poolConfig" />
    </bean>
    
    <bean id="stringKeySerializer" class="org.springframework.data.redis.serializer.StringRedisSerializer"/>
    
    <bean id="jdkSerializationRedisSerializer" class="org.springframework.data.redis.serializer.JdkSerializationRedisSerializer"/>
    <bean id="genericJackson2JsonRedisSerializer" class="org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer"/>
    
    
    
    <bean id="redisTemplate" class="org.springframework.data.redis.core.RedisTemplate">
        <property name="connectionFactory" ref="jedisConnectionFactory" />
        
        <property name="keySerializer" ref="stringKeySerializer"/>
        <property name="hashKeySerializer" ref="stringKeySerializer"/>
        <property name="valueSerializer" ref="genericJackson2JsonRedisSerializer"/>
        <property name="hashValueSerializer" ref="genericJackson2JsonRedisSerializer"/>
    </bean>
    
    <bean id="stringRedisTemplate" class="org.springframework.data.redis.core.StringRedisTemplate">
        <property name="connectionFactory" ref="jedisConnectionFactory" />
    </bean>

## redis增删改查 ##

@Repository(value = "redisRepository")
    public class RedisRepository extends AbstractSpringRedisCacheEnhance { 
    
        @Autowired
        RedisTemplate<String, Object> redisTemplate;
    
        @Override
        public StringRedisTemplate getStringRedisTemplate() {
            return null;
        }
    
        @Override
        public RedisTemplate<String, Object> getRedisTemplate() {
            return redisTemplate;
        }
    }

此处增删改查写在了抽象类当中，具体代码上千行，有兴趣的可以访问我代码仓库查看（后面会附上仓库链接）

## 测试 ##

编写测试类，测试增删改查api

@RunWith(SpringRunner.class)
    @ContextConfiguration({
       "classpath*:/spring/applicationContext.xml"})
    public class RedisRepositoryTest { 
    
        private Logger logger = LoggerFactory.getLogger(getClass());
        @Autowired private RedisRepository redisRepository;
    
        public Map<String, Object> generateMap(){
            Map<String, Object> returnMap = new HashMap<>();
            returnMap.put("aa", "aa");
            Map<String, Object> innerMap = new HashMap<>();
            innerMap.put("ss", 3);
            innerMap.put("rr",false);
            innerMap.put("tt","中文");
            returnMap.put("bb", innerMap);
            returnMap.put("cc", 1.000);
            returnMap.put("dd", true);
            returnMap.put("ee", 1);
            return returnMap;
        }
        public List<Map<String, Object>> generateList(){
            List<Map<String, Object>> list = new ArrayList<>();
            for (int i = 0; i < 10; i++) {
                list.add(generateMap());
            }
            return list;
        }
        @Test
        public void clear(){
            redisRepository.clear();
        }
        @Test
        public void testSet(){
            redisRepository.valueSet("name", "robot");
            redisRepository.valueSet("name2", "robot", 1600, TimeUnit.SECONDS);
            redisRepository.valueSet("set:map", generateMap());
            redisRepository.valueSet("set:map", generateMap(), 1600, TimeUnit.SECONDS);
            redisRepository.valueSet("set:list", generateList());
            redisRepository.valueSet("set:list", generateList(), 1600, TimeUnit.SECONDS);
        }
    
        @Test
        public void testGet(){
            logger.info("{}", redisRepository.valueGet("name", false));
            logger.info("{}", redisRepository.valueGet("name2", true));
            logger.info("{}", redisRepository.valueGet("set:map", false));
            logger.info("{}", redisRepository.valueGet("set:map", true));
            logger.info("{}", redisRepository.valueGet("set:list", false));
            logger.info("{}", redisRepository.valueGet("set:list", true));
            //logger.info("{}", redisRepository.getAndSet("name", "new value",false));
            //logger.info("{}", redisRepository.getAndSet("name", "new value",true));
        }
    
        @Test
        public void testIncrement(){
            for (int i = 0; i < 10; i++) {
                logger.info("{}", redisRepository.valueIncrement("mobile:15911111111", 1l, 60, TimeUnit.MINUTES));
                logger.info("{}", redisRepository.valueIncrement("tel:15911111111", 1.0, 70, TimeUnit.MINUTES));
            }
        }
        @Test
        public void testSetArray(){
            for (int i = 0; i < 10; i++) {
                logger.info("{}", redisRepository.setAdd("set:array1",i));
            }
            for (int i = 5; i < 20; i++) {
                logger.info("{}", redisRepository.setAdd("set:array1",i));
                logger.info("{}", redisRepository.setAdd("set:array2",i));
            }
            //logger.info("{}", redisRepository.setPop("set:array"));
            logger.info("{}", redisRepository.setDifference("set:array1","set:array2"));
            logger.info("{}", redisRepository.setDifferenceAndStore("set:array1","set:array2", "set:array3"));
    
            logger.info("{}", redisRepository.setAdd("set:add:map",generateMap()));
            logger.info("{}", redisRepository.setAdd("set:add:list",generateList()));
            logger.info("{}", redisRepository.setPop("set:add:map"));
            logger.info("{}", redisRepository.setPop("set:add:list"));
        }
        @Test
        public void testList(){
            for (int i = 0; i < 10; i++) {
                logger.info("{}", redisRepository.listLeftPush("list:lilo:list", generateList()));
                logger.info("{}", redisRepository.listLeftPush("list:liro:list", generateList()));
                logger.info("{}", redisRepository.listRightPush("list:rilo:list", generateList()));
                logger.info("{}", redisRepository.listRightPush("list:riro:list", generateList()));
            }
    
            for (int i = 0; i < 5; i++) {
                logger.info("{}", redisRepository.listLeftPop("list:lilo:list"));
                logger.info("{}", redisRepository.listRightPop("list:liro:list"));
                logger.info("{}", redisRepository.listLeftPop("list:rilo:list"));
                logger.info("{}", redisRepository.listRightPop("list:riro:list"));
            }
            for (int i = 0; i < 10; i++) {
                logger.info("{}", redisRepository.listLeftPush("list:lilo:map", generateMap()));
                logger.info("{}", redisRepository.listLeftPush("list:liro:map", generateMap()));
                logger.info("{}", redisRepository.listRightPush("list:rilo:map", generateMap()));
                logger.info("{}", redisRepository.listRightPush("list:riro:map", generateMap()));
            }
    
            for (int i = 0; i < 5; i++) {
                logger.info("{}", redisRepository.listLeftPop("list:lilo:map"));
                logger.info("{}", redisRepository.listRightPop("list:liro:map"));
                logger.info("{}", redisRepository.listLeftPop("list:rilo:map"));
                logger.info("{}", redisRepository.listRightPop("list:riro:map"));
            }
        }
        @Test
        public void testZSet(){
            for (int i = 0; i < 10; i++) {
                logger.info("{}", redisRepository.zSetAdd("zset:map", generateMap(), i));
            }
            redisRepository.zSetIncrementScore("zset:Map", "4", 30);
        }
        @Test
        public void testHash(){
            for (int i = 0; i < 10; i++) {
                redisRepository.hashPut("hash:map", String.valueOf(i), generateMap());
                logger.info("{}", redisRepository.hashGet("hash:map", String.valueOf(i)));
            }
            for (int i = 0; i < 10; i++) {
                redisRepository.hashPut("hash:list", String.valueOf(i), generateList());
                logger.info("{}", redisRepository.hashGet("hash:list", String.valueOf(i)));
            }
        }
    }

## 效果图 ##

![这里写图片描述][70]

# 源码 #

[spring-redis][]

[centos7_7-redis-4.0.1]: https://blog.csdn.net/u012806787/article/details/77478582
[70]: /images/20220519/4f23bb71bf9e41a88f55861ef0635a27.png
[spring-redis]: https://github.com/shiyuan2he/spring/tree/master/spring-redis