Spring boot 整合 Redisson

1　　概述

　　Redisson實現了分佈式和可擴展的Java數據結構，功能較爲簡單，不支持字符串操做，不支持排序、事務、管道、分區等Redis特性。Redisson的宗旨是促進使用者對Redis的關注分離，從而讓使用者可以將精力更集中地放在處理業務邏輯上。

 

2     特色

1. Redisson中的方法則是進行比較高的抽象，每一個方法調用可能進行了一個或多個Redis方法調用。
2. Redisson使用非阻塞的I/O和基於Netty框架的事件驅動的通訊層，其方法調用是異步的。Redisson的API是線程安全的，因此能夠操做單個Redisson鏈接來完成各類操做。
3. Redisson不只提供了一系列的分佈式Java經常使用對象，基本能夠與Java的基本數據結構通用，還提供了許多分佈式服務，其中包括（BitSet, Set, Multimap, SortedSet, Map, List, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, AtomicLong, CountDownLatch, Publish/Subscribe, Bloom filter, Remote service, Spring cache, Executor service, Live Object service, Scheduler service）。
   在分佈式開發中，Redisson可提供更便捷的方法。
   
   

3　 第三方框架整合

1. Redisson提供了和Spring框架的各項特性相似的，以Spring XML的命名空間的方式配置RedissonClient實例和它所支持的全部對象和服務；
2. Redisson完整的實現了Spring框架裏的緩存機制；
3. Redisson在Redis的基礎上實現了Java緩存標準規範；
4. Redisson爲Apache Tomcat集羣提供了基於Redis的非黏性會話管理功能。該功能支持Apache Tomcat的六、7和8版。
5. Redisson還提供了Spring Session會話管理器的實現。

 

4　 spring boot 整合 Redisson

1. pom

   ---

   <dependency>
   <groupId>org.redisson</groupId>
   <artifactId>redisson</artifactId>
   <version>3.10.6</version>
   </dependency>

   ---

2. properties

   spring: redisson: enabled: true cluster: false nodes: x.x.x.x:x password: xxxx

    

3. redisson配置類RedissonConfig

   package com.yx.redis.redisson; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.redisson.Redisson; import org.redisson.api.RedissonClient; import org.redisson.config.ClusterServersConfig; import org.redisson.config.Config; import org.redisson.config.SingleServerConfig; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.EnableConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Conditional; import org.springframework.context.annotation.Configuration; import org.springframework.util.ObjectUtils; /** * @Auther: yx * @Date: 2019-04-30 15:55 * @Description: RedissonConfig */ @Configuration @Conditional(RedissonCondition.class) @EnableConfigurationProperties({RedissonProperties.class}) @Slf4j public class RedissonConfig { @Bean public RedissonProperties getRedissonProperties() { return new RedissonProperties(); } /** * 單機模式自動裝配 * @return
        */ @Bean @ConditionalOnProperty(name="spring.redisson.cluster", havingValue = "false") public RedissonClient getSingleRedisson() { Config config = new Config(); RedissonProperties redissonProperties = getRedissonProperties(); String nodes = redissonProperties.getNodes(); if (StringUtils.isEmpty(nodes)) { throw new RuntimeException("nodes is not allow empty! please check your redis config"); } SingleServerConfig serverConfig = config.useSingleServer() .setAddress("redis://" + nodes) .setTimeout(redissonProperties.getTimeout()) .setConnectionPoolSize(redissonProperties.getConnectionPoolSize()) .setConnectionMinimumIdleSize(redissonProperties.getConnectionMinimumIdleSize()); if(StringUtils.isNotBlank(redissonProperties.getPassword())) { serverConfig.setPassword(redissonProperties.getPassword()); } log.info("init redisson success .... "); return Redisson.create(config); } @Bean @ConditionalOnProperty(name="spring.redisson.cluster", havingValue = "true") public RedissonClient getClusterRedisson(){ RedissonProperties redissonProperties = getRedissonProperties(); String[] nodes = redissonProperties.getNodes().split(","); if (ObjectUtils.isEmpty(nodes)) { throw new RuntimeException("nodes is not allow empty! please check your redis config"); } for(int i=0;i<nodes.length;i++){ nodes[i] = "redis://"+nodes[i]; } RedissonClient redisson = null; Config config = new Config(); ClusterServersConfig clusterServersConfig = config.useClusterServers() .setScanInterval(2000) .setTimeout(redissonProperties.getTimeout()) .addNodeAddress(nodes); if(StringUtils.isNotBlank(redissonProperties.getPassword())) { clusterServersConfig.setPassword(redissonProperties.getPassword()); } redisson = Redisson.create(config); log.info("init redisson cluster success .... "); return redisson; } }

    

4. redisson配置類RedissonCondition

   package com.yx.redis.redisson; import org.apache.commons.lang3.StringUtils; import org.springframework.context.annotation.Condition; import org.springframework.context.annotation.ConditionContext; import org.springframework.core.type.AnnotatedTypeMetadata; import org.springframework.util.ObjectUtils; /** * @Auther: yx * @Date: 2019-04-30 15:56 * @Description: RedissionCondition */
   public class RedissonCondition implements Condition { @Override public boolean matches(ConditionContext context, AnnotatedTypeMetadata metadata) { return propertyIsTrue(context, "spring.redisson.enabled"); } private static boolean propertyIsTrue(ConditionContext context, String key) { return context.getEnvironment().getProperty(key, Boolean.TYPE, Boolean.FALSE); } }

    

5. redisson配置類RedissonProperties

   package com.yx.redis.redisson; import lombok.Data; import org.springframework.boot.context.properties.ConfigurationProperties; /** * @Auther: yx * @Date: 2019-04-30 15:52 * @Description: RedissonProperties */ @Data @ConfigurationProperties(prefix = "spring.redisson") public class RedissonProperties { private int timeout = 3000; private Boolean cluster; private String nodes; private String password; private int database = 0; private int connectionPoolSize = 64; private int connectionMinimumIdleSize = 10; private int slaveConnectionPoolSize = 250; private int masterConnectionPoolSize = 250; }