• SpringBoot集成redis依赖包及步骤

    redis作为nosql数据库，通常用于缓存，加锁和分布式缓存等，特地学习了如何融入SpringBoot

    1、在maven中引入spring-boot-starter-data-redis包

    1. 		<dependency>
    2. 			<groupId>org.springframework.boot</groupId>
    3. 			<artifactId>spring-boot-starter-data-redis</artifactId>
    4. 		</dependency>
    5.  
    6. 		<dependency>
    7. 			<groupId>org.apache.commons</groupId>
    8. 			<artifactId>commons-pool2</artifactId>
    9. 		</dependency>
    10.  
    11. 		<dependency>
    12. 			<groupId>com.alibaba</groupId>
    13. 			<artifactId>fastjson</artifactId>
    14. 			<version>1.2.47</version>
    15. 		</dependency>
    16.  
    17. 		<!--huTool工具-->
    18. 		<dependency>
    19. 			<groupId>cn.hutool</groupId>
    20. 			<artifactId>hutool-all</artifactId>
    21. 			<version>5.8.5</version>
    22. 		</dependency>

    2、配置文件中的redis连接设置 

    映射的是org.springframework.boot.autoconfigure.data.redis.RedisProperties

    中的属性

    集群：

    1. spring.redis.password=123456
    2. spring.redis.cluster.nodes=10.193.240.170:7000,10.193.241.0:7001 
    3. spring.redis.cluster.max-redirects=3

    单个实例：

    1.  spring.redis.host=localhost # Redis服务器地址
    2.  spring.redis.database=0  # Redis数据库索引（默认为0）
    3.  spring.redis.port=6379 # Redis服务器连接端口
    4.  spring.redis.password=123456 # Redis服务器连接密码（默认为空）
    5.  spring.redis.timeout=300ms # 连接超时时间（毫秒）

    3、redisTemplate配置类Config

    1. @Configuration
    2. @Slf4j
    3. public class RedisTemplateConfig {
    4.  
    5.     @Autowired
    6.     private RedisProperties redisProperties;
    7.  
    8.     @Bean
    9.     @ConditionalOnMissingBean
    10.     public StringRedisTemplate stringRedisTemplate1(RedisConnectionFactory redisConnectionFactory) {
    11.         String prefix = StrUtil.isBlank(redisProperties.getBizPrefix()) ? ""
    12.                 : redisProperties.getBizPrefix() + RedisConstants.BIZ_PREFIX_SPLIT;
    13.         log.info("biz-prefix > {}", prefix);
    14.  
    15.         StringRedisTemplate template = new StringRedisTemplate();
    16.         template.setConnectionFactory(redisConnectionFactory);
    17.         RedisSerializer<Object> redisSerializer = redisSerializer();
    18.         // 值采用json序列化
    19.         template.setValueSerializer(redisSerializer);
    20.         template.setKeySerializer(new StringRedisSerializer(prefix));
    21.         // 设置hash key 和value序列化模式
    22.         template.setHashKeySerializer(new StringRedisSerializer(prefix));
    23.         template.setHashValueSerializer(redisSerializer);
    24.         template.afterPropertiesSet();
    25.         return template;
    26.     }
    27.  
    28.  
    29.     @Bean
    30.     public RedisSerializer<Object> redisSerializer() {
    31.         //创建JSON序列化器
    32.         Jackson2JsonRedisSerializer<Object> serializer = new Jackson2JsonRedisSerializer<>(Object.class);
    33.         ObjectMapper objectMapper = new ObjectMapper();
    34.         objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
    35.         //必须设置，否则无法将JSON转化为对象，会转化成Map类型
    36.         objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance,ObjectMapper.DefaultTyping.NON_FINAL);
    37.         serializer.setObjectMapper(objectMapper);
    38.         return serializer;
    39.     }
    40.  
    41.  
    42. }

    4、RedisProperties属性类

    1. package com.example.data.redis.config.property;
    2.  
    3. import lombok.Data;
    4. import org.springframework.boot.context.properties.ConfigurationProperties;
    5. import org.springframework.stereotype.Component;
    6.  
    7. @Data
    8. @Component
    9. @ConfigurationProperties(prefix = "demo.redis")
    10. public class RedisProperties {
    11.     /**
    12.      * 是否开启 true/false
    13.      */
    14.     private boolean enabled = true;
    15.  
    16.     /**
    17.      * 业务标识前缀
    18.      */
    19.     private String bizPrefix;
    20.  
    21. }

    5、在service注入

    要注意这里RedisTemplate配置类config的返回泛型和注入的泛型要一致，不然会提示

     The following candidates were found but could not be injected:
        - Bean method 'stringRedisTemplate' in 'RedisAutoConfiguration' not loaded because @ConditionalOnMissingBean (types: org.springframework.data.redis.core.StringRedisTemplate; SearchStrategy: all) found beans of type 'org.springframework.data.redis.core.StringRedisTemplate' stringRedisTemplate

    注入代码如下：

    1.  
    2. /**
    3.  * redis操作service实现类
    4.  */
    5. @Service
    6. public class RedisServiceImpl implements RedisService {
    7.  
    8.     @Autowired
    9.     private RedisTemplate   redisTemplate;
    10.  
    11.     /**
    12.      * 设置缓存
    13.      * Params:
    14.      * key – 缓存键 value – 缓存value expSec – 失效时间(秒)
    15.      */
    16.     @Override
    17.     public void set(String key, Object value, long time) {
    18.         redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
    19.     }
    20.  
    21.     /**
    22.      * 设置缓存
    23.      * @param key
    24.      * @param value
    25.      */
    26.     @Override
    27.     public void set(String key, Object value) {
    28.         redisTemplate.opsForValue().set(key,value);
    29.     }
    30.  
    31.     /**
    32.      * 获取缓存对象,返回string
    33.      * Params:
    34.      * key – 缓存键
    35.      * Returns:
    36.      * 返回缓存实体
    37.      */
    38.     @Override
    39.     public Object get(String key) {
    40.         return redisTemplate.opsForValue().get(key);
    41.     }
    42.  
    43.     /**
    44.      * 删除缓存数据
    45.      * Params:
    46.      * @param key – 缓存键
    47.      * @return
    48.      */
    49.     @Override
    50.     public Boolean del(String key) {
    51.         return redisTemplate.delete(key);
    52.     }
    53.  
    54.     @Override
    55.     public Long del(List<String> keys) {
    56.         return redisTemplate.delete(keys);
    57.     }
    58.  
    59.     /**
    60.      * 指定缓存失效时间
    61.      * Params:
    62.      * key – 键 time – 时间(秒)
    63.      * Returns:
    64.      * true成功 false失败
    65.      */
    66.     @Override
    67.     public Boolean expire(String key, long time) {
    68.         return redisTemplate.expire(key,time,TimeUnit.SECONDS);
    69.     }
    70.  
    71.     /**
    72.      * 根据key 获取过期时间
    73.      * @param key
    74.      * @return
    75.      */
    76.     @Override
    77.     public Long getExpire(String key) {
    78.         return redisTemplate.getExpire(key);
    79.     }
    80.  
    81.     /**
    82.      * 判断key是否存在
    83.      * Params:
    84.      * key – 键
    85.      * Returns:
    86.      * true 存在 false不存
    87.      * @param key
    88.      * @return
    89.      */
    90.     @Override
    91.     public Boolean hasKey(String key) {
    92.         return redisTemplate.hasKey(key);
    93.     }
    94.  
    95.     /**
    96.      * 将键对应的值按指定步长增加
    97.      * @param key
    98.      * @param delta
    99.      * @return
    100.      */
    101.     @Override
    102.     public Long incr(String key, long delta) {
    103.         return redisTemplate.opsForValue().increment(key, delta);
    104.     }
    105.  
    106.     /**
    107.      * 将键对应的值按指定步长减少
    108.      * @param key
    109.      * @param delta
    110.      * @return
    111.      */
    112.     @Override
    113.     public Long decr(String key, long delta) {
    114.         return redisTemplate.opsForValue().decrement(key, delta);
    115.     }
    116.  
    117.     /**
    118.      * 获取指定变量中的hashMap值
    119.      * @param key
    120.      * @param hashKey
    121.      * @return
    122.      */
    123.     @Override
    124.     public Object hGet(String key, String hashKey) {
    125.         return redisTemplate.opsForHash().get(key, hashKey);
    126.     }
    127.     /**
    128.      * 设置指定变量中的hashMap值，并设置过期时间
    129.      * @param key
    130.      * @param hashKey
    131.      * @return
    132.      */
    133.     @Override
    134.     public Boolean hSet(String key, String hashKey, Object value, long time) {
    135.         redisTemplate.opsForHash().put(key, hashKey, value);
    136.         return expire(key, time);
    137.     }
    138.  
    139.     /**
    140.      * 新增hashMap值
    141.      * @param key
    142.      * @param hashKey
    143.      * @param value
    144.      */
    145.     @Override
    146.     public void hSet(String key, String hashKey, Object value) {
    147.         redisTemplate.opsForHash().put(key, hashKey, value);
    148.     }
    149.  
    150.     @Override
    151.     public Map<Object, Object> hGetAll(String key) {
    152.         return redisTemplate.opsForHash().entries(key);
    153.     }
    154.  
    155.     @Override
    156.     public Boolean hSetAll(String key, Map<String, Object> map, long time) {
    157.         redisTemplate.opsForHash().putAll(key, map);
    158.         return expire(key, time);
    159.     }
    160.  
    161.     @Override
    162.     public void hSetAll(String key, Map<String, ?> map) {
    163.         redisTemplate.opsForHash().putAll(key, map);
    164.     }
    165.  
    166.     @Override
    167.     public void hDel(String key, Object... hashKey) {
    168.         redisTemplate.opsForHash().delete(key, hashKey);
    169.     }
    170.  
    171.     @Override
    172.     public Boolean hHasKey(String key, String hashKey) {
    173.         return redisTemplate.opsForHash().hasKey(key, hashKey);
    174.     }
    175.  
    176.     @Override
    177.     public Long hIncr(String key, String hashKey, Long delta) {
    178.         return redisTemplate.opsForHash().increment(key,hashKey,delta);
    179.     }
    180.  
    181.     @Override
    182.     public Long hDecr(String key, String hashKey, Long delta) {
    183.         return redisTemplate.opsForHash().increment(key, hashKey, -delta);
    184.     }
    185.  
    186.     /**
    187.      * 根据key获取set集合
    188.      * @param key
    189.      * @return
    190.      */
    191.     @Override
    192.     public Set<Object> sMembers(String key) {
    193.         return redisTemplate.opsForSet().members(key);
    194.     }
    195.  
    196.     /**
    197.      * 添加key
    198.      * @param key
    199.      * @param values
    200.      * @return
    201.      */
    202.     @Override
    203.     public Long sAdd(String key, Object... values) {
    204.         return redisTemplate.opsForSet().add(key, values);
    205.     }
    206.  
    207.     @Override
    208.     public Long sAdd(String key, long time, Object... values) {
    209.         Long count = redisTemplate.opsForSet().add(key, values);
    210.         expire(key, time);
    211.         return count;
    212.     }
    213.  
    214.     @Override
    215.     public Boolean sIsMember(String key, Object value) {
    216.         return redisTemplate.opsForSet().isMember(key,value);
    217.     }
    218.  
    219.     @Override
    220.     public Long sSize(String key) {
    221.         return redisTemplate.opsForSet().size(key);
    222.     }
    223.  
    224.     @Override
    225.     public Long sRemove(String key, Object... values) {
    226.         return redisTemplate.opsForSet().remove(key,values);
    227.     }
    228.  
    229.     @Override
    230.     public List<Object> lRange(String key, long start, long end) {
    231.         return redisTemplate.opsForList().range(key, start, end);
    232.     }
    233.  
    234.     @Override
    235.     public Long lSize(String key) {
    236.         return redisTemplate.opsForList().size(key);
    237.     }
    238.  
    239.     @Override
    240.     public Object lIndex(String key, long index) {
    241.         return redisTemplate.opsForList().index(key, index);
    242.     }
    243.  
    244.     @Override
    245.     public Long lPush(String key, Object value) {
    246.         return redisTemplate.opsForList().rightPush(key, value);
    247.     }
    248.  
    249.     @Override
    250.     public Long lPush(String key, Object value, long time) {
    251.         Long index = redisTemplate.opsForList().rightPush(key, value);
    252.         expire(key, time);
    253.         return index;
    254.     }
    255.  
    256.     @Override
    257.     public Long lPushAll(String key, Object... values) {
    258.         return redisTemplate.opsForList().rightPushAll(key, values);
    259.     }
    260.  
    261.     @Override
    262.     public Long lPushAll(String key, Long time, Object... values) {
    263.         Long count = redisTemplate.opsForList().rightPushAll(key, values);
    264.         expire(key, time);
    265.         return count;
    266.     }
    267.  
    268.     @Override
    269.     public Long lRemove(String key, long count, Object value) {
    270.         return redisTemplate.opsForList().remove(key, count, value);
    271.     }
    272. }

    配置好后就重启启动OK

  • 相关阅读:
    牛客多校2 - Link with Game Glitch（spfa求正环，套汇，二分答案）
    Rust for循环语法糖背后的API
    linux之定时任务
    DIN模型和SIM模型原理与实践
    学习pytorch15 优化器
    1.django简介及安装
    ElementUI浅尝辄止37：Select 选择器
    数字化时代，中小企业如何落地数字化转型
    关于jupyter notebook的使用经验
    【杂谈】快来看看如何使用LGMT这样的蜜汁缩写来进行CodeReview吧！
  • 原文地址：https://blog.csdn.net/qq_31450641/article/details/133877798