RedisTemplate 相关的api使用。
http://www.45fan.com/article.php?aid=1D2ojkZ7gc23Gzro

RedisTemplateConfiguration.java

经过亲身测试，其实上无须加上这些配置，如果你加上的话，你用的是jackson的序列化，到时候获取到的对象就是Map类型，如果你要是用的fastjson的序列化，你获取到的就是jsonObject。反正是你获取不到原来的对象，还得想办法重新转化一下，如果你啥都不处理的话，那么你只需要强制转化下就可以了。

对应的配置 去上面的文章找

  1. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  2. import com.fasterxml.jackson.annotation.PropertyAccessor;
  3. import com.fasterxml.jackson.databind.ObjectMapper;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.data.redis.connection.RedisConnectionFactory;
  7. import org.springframework.data.redis.core.RedisTemplate;
  8. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
  9. import org.springframework.data.redis.serializer.StringRedisSerializer;
  11. @Configuration
  12. public class RedisTemplateConfiguration {
  14.     /**
  15.      * redisTemplate 序列化使用的jdkSerializeable, 存储二进制字节码, 所以自定义序列化类
  16.      *
  17.      * @param redisConnectionFactory
  18.      * @return
  19.      */
  20.     @Bean
  21.     public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
  22.         RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
  23.         redisTemplate.setConnectionFactory(redisConnectionFactory);
  25.         // 使用Jackson2JsonRedisSerialize 替换默认序列化
  26.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  28.         ObjectMapper objectMapper = new ObjectMapper();
  29.         objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  30.         jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
  32.         // 设置key和value的序列化规则
  33.         redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
  34.         redisTemplate.setKeySerializer(new StringRedisSerializer());
  36.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
  37.         redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
  39.         redisTemplate.afterPropertiesSet();
  40.         return redisTemplate;
  41.     }
  43. }

fastjson的序列化

https://blog.csdn.net/threelifeadv/article/details/122879037

给一个别人封装好的工具类，感觉挺全的，以后可以用这个工具类操作

工具类——RedisTemplateUtils

https://blog.csdn.net/threelifeadv/article/details/122879037

  1. package com.example.demo.mideng;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.data.redis.connection.DataType;
  5. import org.springframework.data.redis.core.Cursor;
  6. import org.springframework.data.redis.core.RedisTemplate;
  7. import org.springframework.data.redis.core.ScanOptions;
  8. import org.springframework.data.redis.core.ZSetOperations;
  9. import org.springframework.stereotype.Component;
  11. import java.util.Collection;
  12. import java.util.Date;
  13. import java.util.List;
  14. import java.util.Map;
  15. import java.util.Set;
  16. import java.util.concurrent.TimeUnit;
  18. /**
  19.  * @author: 公众号:干货食堂
  20.  * Project Name: demo
  21.  * File Name: RedisTemplateUtils
  22.  * Package Name: com.example.demo.mideng
  23.  * Date: 2022/7/2 17:29
  24.  * Copyright (c) 2022,All Rights Reserved.
  25.  * @Description
  26.  */
  27. @Component
  28. public class RedisTemplateUtils {
  30.     @Autowired
  31.     private RedisTemplate redisTemplate;
  33.     //========================RedisTemplate操作string类型数据============================================
  35.     /**
  36.      * @param key
  37.      * @param value
  38.      * @return void
  39.      * @description string设置 key和 value的值
  40.      * @author chengjunyu
  41.      * @date 2022/2/11
  42.      */
  43.     public void set(String key, Object value) {
  44.         redisTemplate.opsForValue().set(key, value);
  45.     }
  47.     /**
  48.      * @param key
  49.      * @param value
  50.      * @param seconds
  51.      * @param timeUnit
  52.      * @return void
  53.      * @description string设置 key和 value的值并设置过期时间和时间单位
  54.      * @author chengjunyu
  55.      * @date 2022/2/12
  56.      */
  57.     public void setWithExpire(String key, Object value, Long seconds, TimeUnit timeUnit) {
  58.         redisTemplate.opsForValue().set(key, value, seconds, timeUnit);
  59.     }
  61.     /**
  62.      * @param * @param key
  63.      * @return java.lang.Object
  64.      * @description string获取 key对应的 value值
  65.      * @author chengjunyu
  66.      * @date 2022/2/11
  67.      */
  68.     public Object get(String key) {
  69.         return redisTemplate.opsForValue().get(key);
  70.     }
  72.     /**
  73.      * @param * @param key
  74.      * @return boolean
  75.      * @description 判断在 redis中是不是存在对应的 key值，有的话就返回 true，没有就返回 false
  76.      * @author chengjunyu
  77.      * @date 2022/2/11
  78.      */
  79.     public Boolean hasKey(String key) {
  80.         return redisTemplate.hasKey(key);
  81.     }
  83.     /**
  84.      * @param key
  85.      * @return boolean
  86.      * @description 删除redis中对应的key值
  87.      * @author chengjunyu
  88.      * @date 2022/2/11
  89.      */
  90.     public Boolean del(String key) {
  91.         return redisTemplate.delete(key);
  92.     }
  94.     /**
  95.      * @param keys
  96.      * @return long
  97.      * @description 批量删除 redis中对应的 key值，其中 keys是数组 keys:Collection<K> keys
  98.      * @author chengjunyu
  99.      * @date 2022/2/11
  100.      */
  101.     public Long batchDel(Collection<String> keys) {
  102.         return redisTemplate.delete(keys);
  103.     }
  105.     /**
  106.      * @param key
  107.      * @return byte[]
  108.      * @description 把 key值序列化成 byte[]类型
  109.      * @author chengjunyu
  110.      * @date 2022/2/11
  111.      */
  112.     public byte[] dump(String key) {
  113.         return redisTemplate.dump(key);
  114.     }
  116.     /**
  117.      * @param *       @param key
  118.      * @param seconds
  119.      * @return void
  120.      * @description 对传入的 key值设置过期时间
  121.      * @author chengjunyu
  122.      * @date 2022/2/11
  123.      */
  124.     public Boolean expire(String key, long seconds) {
  125.         return redisTemplate.expire(key, seconds, TimeUnit.SECONDS);
  126.     }
  128.     /**
  129.      * @param *    @param key
  130.      * @param date
  131.      * @return boolean
  132.      * @description 对传入的 key值设置过期日期
  133.      * @author chengjunyu
  134.      * @date 2022/2/11
  135.      */
  136.     public Boolean expireAt(String key, Date date) {
  137.         return redisTemplate.expireAt(key, date);
  138.     }
  140.     /**
  141.      * @param * @param key
  142.      * @return java.util.Set<java.lang.String>
  143.      * @description 模糊查询，返回一个没有重复的 Set类型
  144.      * @author chengjunyu
  145.      * @date 2022/2/11
  146.      */
  147.     public Set<String> getStringKeys(String key) {
  148.         return redisTemplate.keys(key);
  149.     }
  151.     /**
  152.      * @param oldKey
  153.      * @param newKey
  154.      * @return void
  155.      * @description 根据新的 key的名称修改 redis中老的 key的名称
  156.      * @author chengjunyu
  157.      * @date 2022/2/12
  158.      */
  159.     public void rename(String oldKey, String newKey) {
  160.         redisTemplate.rename(oldKey, newKey);
  161.     }
  163.     /**
  164.      * @param oldKey
  165.      * @param newKey
  166.      * @return boolean
  167.      * @description 重命名旧的 key值
  168.      * @author chengjunyu
  169.      * @date 2022/2/12
  170.      */
  171.     public Boolean renameIfAbsent(String oldKey, String newKey) {
  172.         return redisTemplate.renameIfAbsent(oldKey, newKey);
  173.     }
  175.     /**
  176.      * @param key
  177.      * @return org.springframework.data.redis.connection.DataType
  178.      * @description 获取 key值的类型
  179.      * @author chengjunyu
  180.      * @date 2022/2/12
  181.      */
  182.     public DataType type(String key) {
  183.         return redisTemplate.type(key);
  184.     }
  186.     /**
  187.      * @param
  188.      * @return java.lang.String
  189.      * @description 随机从 redis中获取一个 key
  190.      * @author chengjunyu
  191.      * @date 2022/2/12
  192.      */
  193.     public Object randomKey() {
  194.         return redisTemplate.randomKey();
  195.     }
  197.     /**
  198.      * @param key
  199.      * @return void
  200.      * @description 获取当前 key的剩下的过期时间
  201.      * @author chengjunyu
  202.      * @date 2022/2/12
  203.      */
  204.     public Long getExpire(String key) {
  205.         return redisTemplate.getExpire(key);
  206.     }
  208.     /**
  209.      * @param key
  210.      * @param timeUnit
  211.      * @return java.lang.Long
  212.      * @description 获取 key剩余的过期时间，同时设置时间单位
  213.      * @author chengjunyu
  214.      * @date 2022/2/12
  215.      */
  216.     public Long getExpire(String key, TimeUnit timeUnit) {
  217.         return redisTemplate.getExpire(key, timeUnit);
  218.     }
  220.     /**
  221.      * @param key
  222.      * @return java.lang.Boolean
  223.      * @description 将 key进行持久化
  224.      * @author chengjunyu
  225.      * @date 2022/2/12
  226.      */
  227.     public Boolean persist(String key) {
  228.         return redisTemplate.persist(key);
  229.     }
  231.     /**
  232.      * @param key
  233.      * @param dbIndex
  234.      * @return java.lang.Boolean
  235.      * @description 将当前数据库的 key移动到指定 redis中数据库当中
  236.      * @author chengjunyu
  237.      * @date 2022/2/12
  238.      */
  239.     public Boolean move(String key, int dbIndex) {
  240.         return redisTemplate.move(key, dbIndex);
  241.     }
  243.     /**
  244.      * @param key
  245.      * @param start
  246.      * @param end
  247.      * @return java.lang.String
  248.      * @description 截取 key的子字符串
  249.      * @author chengjunyu
  250.      * @date 2022/2/12
  251.      */
  252.     public String subString(String key, long start, long end) {
  253.         return redisTemplate.opsForValue().get(key, start, end);
  254.     }
  256.     /**
  257.      * @param key
  258.      * @param value
  259.      * @return java.lang.Object
  260.      * @description 设置 key跟 value的值，同时获取 key的值
  261.      * @author chengjunyu
  262.      * @date 2022/2/12
  263.      */
  264.     public Object getAndSet(String key, Object value) {
  265.         return redisTemplate.opsForValue().getAndSet(key, value);
  266.     }
  268.     /**
  269.      * @param keys
  270.      * @return java.util.List<java.lang.Object>
  271.      * @description 设置多个 key跟 value的值，同时获取 key的值
  272.      * @author chengjunyu
  273.      * @date 2022/2/12
  274.      */
  275.     public List<Object> multiGetSet(List<String> keys) {
  276.         return redisTemplate.opsForValue().multiGet(keys);
  277.     }
  279.     /**
  280.      * @param *     @param key
  281.      * @param value
  282.      * @return java.lang.Integer
  283.      * @description 获取原来的 key的值后在后面新增上新的字符串
  284.      * @author chengjunyu
  285.      * @date 2022/2/12
  286.      */
  287.     public Integer append(String key, String value) {
  288.         return redisTemplate.opsForValue().append(key, value);
  289.     }
  291.     /**
  292.      * @param * @param key
  293.      * @return java.lang.Long
  294.      * @description value 值 +1
  295.      * @author chengjunyu
  296.      * @date 2022/2/12
  297.      */
  298.     public Long increment(String key) {
  299.         return redisTemplate.opsForValue().increment(key);
  300.     }
  302.     /**
  303.      * @param key
  304.      * @param increment
  305.      * @return java.lang.Long
  306.      * @description 增量方式增加或减少 long值
  307.      * @author chengjunyu
  308.      * @date 2022/2/12
  309.      */
  310.     public Long incrementLong(String key, long increment) {
  311.         return redisTemplate.opsForValue().increment(key, increment);
  312.     }
  314.     /**
  315.      * @param key
  316.      * @param increment
  317.      * @return void
  318.      * @description 增量方式增加double值
  319.      * @author chengjunyu
  320.      * @date 2022/2/12
  321.      */
  322.     public void incrementDouble(String key, double increment) {
  323.         redisTemplate.opsForValue().increment(key, increment);
  324.     }
  326.     /**
  327.      * @param * @param map
  328.      * @return java.lang.Boolean
  329.      * @description 不存在即新增map的操作
  330.      * @author chengjunyu
  331.      * @date 2022/2/12
  332.      */
  333.     public Boolean multiSetIfAbsent(Map<? extends String, ?> map) {
  334.         return redisTemplate.opsForValue().multiSetIfAbsent(map);
  335.     }
  337.     /**
  338.      * @param * @param map
  339.      * @return void
  340.      * @description 保存 map集合
  341.      * @author chengjunyu
  342.      * @date 2022/2/12
  343.      */
  344.     public void multiSet(Map<String, String> map) {
  345.         redisTemplate.opsForValue().multiSet(map);
  346.     }
  348.     /**
  349.      * @param * @param keys
  350.      * @return java.util.List<java.lang.Object>
  351.      * @description 获取 map集合
  352.      * @author chengjunyu
  353.      * @date 2022/2/12
  354.      */
  355.     public List<Object> multiGet(List<String> keys) {
  356.         return redisTemplate.opsForValue().multiGet(keys);
  357.     }
  359.     /**
  360.      * @param key
  361.      * @return java.lang.Long
  362.      * @description 获取指定 key的字符串的长度
  363.      * @author chengjunyu
  364.      * @date 2022/2/12
  365.      */
  366.     public Long sizeString(String key) {
  367.         return redisTemplate.opsForValue().size(key);
  368.     }
  370.     /**
  371.      * @param key
  372.      * @param value
  373.      * @param offset
  374.      * @return void
  375.      * @description 根据偏移量 offset 的值，覆盖重写 value的值
  376.      * @author chengjunyu
  377.      * @date 2022/2/12
  378.      */
  379.     public void offsetValue(String key, Object value, Long offset) {
  380.         redisTemplate.opsForValue().set(key, value, offset);
  381.     }
  383.     /**
  384.      * @param key
  385.      * @param offset
  386.      * @return java.lang.Boolean
  387.      * @description 对 key所储存的字符串值，获取指定偏移量上的位(bit)
  388.      * @author chengjunyu
  389.      * @date 2022/2/12
  390.      */
  391.     public Boolean getOffsetValue(String key, Long offset) {
  392.         return redisTemplate.opsForValue().getBit(key, offset);
  393.     }
  395.     /**
  396.      * @param key
  397.      * @param value
  398.      * @return java.lang.Boolean
  399.      * @description 重新设置 key对应的值，如果存在返回 false，否则返回 true
  400.      * @author chengjunyu
  401.      * @date 2022/2/12
  402.      */
  403.     public Boolean setIfAbsent(String key, Object value) {
  404.         return redisTemplate.opsForValue().setIfAbsent(key, value);
  405.     }
  407.     //========================RedisTemplate操作hash类型数据============================================
  409.     /**
  410.      * @param key
  411.      * @param field
  412.      * @param value
  413.      * @return void
  414.      * @description 新增map值
  415.      * @author chengjunyu
  416.      * @date 2022/2/12
  417.      */
  418.     public void put(String key, Object field, Object value) {
  419.         redisTemplate.opsForHash().put(key, field, value);
  420.     }
  422.     /**
  423.      * @param key
  424.      * @param map
  425.      * @return void
  426.      * @description 以map集合的形式添加键值对
  427.      * @author chengjunyu
  428.      * @date 2022/2/12
  429.      */
  430.     public void putAll(String key, Map<Object, Object> map) {
  431.         redisTemplate.opsForHash().putAll(key, map);
  432.     }
  434.     /**
  435.      * @param key
  436.      * @param field
  437.      * @return java.lang.Object
  438.      * @description 获取 map中指定的 key值，如果存在则返回值，没有就返回null
  439.      * @author chengjunyu
  440.      * @date 2022/2/12
  441.      */
  442.     public Object getMapValue(String key, String field) {
  443.         return redisTemplate.opsForHash().get(key, field);
  444.     }
  446.     /**
  447.      * @param * @param key
  448.      * @return java.util.Map<java.lang.Object, java.lang.Object>
  449.      * @description 根据 key获取 Map对象
  450.      * @author chengjunyu
  451.      * @date 2022/2/12
  452.      */
  453.     public Map<Object, Object> getMap(String key) {
  454.         return redisTemplate.opsForHash().entries(key);
  455.     }
  457.     /**
  458.      * @param key
  459.      * @param hashKey
  460.      * @param value
  461.      * @return java.lang.Boolean
  462.      * @description 当 hashKey不存在的时候，进行设置 map的值
  463.      * @author chengjunyu
  464.      * @date 2022/2/12
  465.      */
  466.     public Boolean putIfAbsent(String key, Object hashKey, Object value) {
  467.         return redisTemplate.opsForHash().putIfAbsent(key, hashKey, value);
  468.     }
  470.     /**
  471.      * @param key
  472.      * @param fields
  473.      * @return java.lang.Long
  474.      * @description 删除多个map的字段
  475.      * @author chengjunyu
  476.      * @date 2022/2/12
  477.      */
  478.     public Long del(String key, List<Object> fields) {
  479.         return redisTemplate.opsForHash().delete(key, fields);
  480.     }
  482.     /**
  483.      * @param *     @param key
  484.      * @param field
  485.      * @return java.lang.Boolean
  486.      * @description 查看 hash表中指定字段是否存在
  487.      * @author chengjunyu
  488.      * @date 2022/2/12
  489.      */
  490.     public Boolean hasKey(String key, Object field) {
  491.         return redisTemplate.opsForHash().hasKey(key, field);
  492.     }
  494.     /**
  495.      * @param key
  496.      * @param field
  497.      * @param increment
  498.      * @return java.lang.Long
  499.      * @description 给 map中指定字段的整数值加上 long型增量 increment
  500.      * @author chengjunyu
  501.      * @date 2022/2/12
  502.      */
  503.     public Long incrementLong(String key, Object field, long increment) {
  504.         return redisTemplate.opsForHash().increment(key, field, increment);
  505.     }
  507.     /**
  508.      * @param key
  509.      * @param field
  510.      * @param increment
  511.      * @return java.lang.Double
  512.      * @description 给 map中指定字段的整数值加上 double型增量 increment
  513.      * @author chengjunyu
  514.      * @date 2022/2/12
  515.      */
  516.     public Double incrementDouble(String key, Object field, double increment) {
  517.         return redisTemplate.opsForHash().increment(key, field, increment);
  518.     }
  520.     /**
  521.      * @param key
  522.      * @return java.util.Set<java.lang.Object>
  523.      * @description 获取 map中的所有字段
  524.      * @author chengjunyu
  525.      * @date 2022/2/12
  526.      */
  527.     public Set<Object> keys(String key) {
  528.         return redisTemplate.opsForHash().keys(key);
  529.     }
  531.     /**
  532.      * @param key
  533.      * @return java.util.Set<java.lang.Object>
  534.      * @description 获取 map中所有字段的数量
  535.      * @author chengjunyu
  536.      * @date 2022/2/12
  537.      */
  538.     public Long sizeHash(String key) {
  539.         return redisTemplate.opsForHash().size(key);
  540.     }
  542.     /**
  543.      * @param key
  544.      * @return java.util.List<java.lang.Object>
  545.      * @description 获取hash表中存在的所有的值
  546.      * @author chengjunyu
  547.      * @date 2022/2/12
  548.      */
  549.     public List<Object> values(String key) {
  550.         return redisTemplate.opsForHash().values(key);
  551.     }
  553.     /**
  554.      * @param key
  555.      * @param scanOptions
  556.      * @return org.springframework.data.redis.core.Cursor<java.util.Map.Entry < java.lang.Object, java.lang.Object>>
  557.      * @description 查看匹配的键值对
  558.      * @author chengjunyu
  559.      * @date 2022/2/12
  560.      */
  561.     public Cursor<Map.Entry<Object, Object>> scan(String key, ScanOptions scanOptions) {
  562.         return redisTemplate.opsForHash().scan(key, scanOptions);
  563.     }
  564.     //========================RedisTemplate操作list类型数据============================================
  566.     /**
  567.      * @param key
  568.      * @param value
  569.      * @return java.lang.Long
  570.      * @description 把值添加在 list的最前面
  571.      * @author chengjunyu
  572.      * @date 2022/2/12
  573.      */
  574.     public Long leftPush(String key, Object value) {
  575.         return redisTemplate.opsForList().leftPush(key, value);
  576.     }
  578.     /**
  579.      * @param key
  580.      * @param values
  581.      * @return java.lang.Long
  582.      * @description 把值添加在 list
  583.      * @author chengjunyu
  584.      * @date 2022/2/12
  585.      */
  586.     public Long leftPush(String key, Object... values) {
  587.         return redisTemplate.opsForList().leftPushAll(key, values);
  588.     }
  590.     /**
  591.      * @param key
  592.      * @param value
  593.      * @return java.lang.Long
  594.      * @description 直接把一个新的 list添加到老的 list上面去
  595.      * @author chengjunyu
  596.      * @date 2022/2/12
  597.      */
  598.     public Long leftPushAll(String key, List<Object> value) {
  599.         return redisTemplate.opsForList().leftPushAll(key, value);
  600.     }
  602.     /**
  603.      * @param key
  604.      * @param value
  605.      * @return long
  606.      * @description List存在的时候就加入新的值
  607.      * @author chengjunyu
  608.      * @date 2022/2/12
  609.      */
  610.     public long leftPushIfPresent(String key, Object value) {
  611.         return redisTemplate.opsForList().leftPushIfPresent(key, value);
  612.     }
  614.     /**
  615.      * @param key
  616.      * @param value
  617.      * @return java.lang.Long
  618.      * @description 把值添加在 list的最后面
  619.      * @author chengjunyu
  620.      * @date 2022/2/12
  621.      */
  622.     public long rightPush(String key, Object value) {
  623.         return redisTemplate.opsForList().rightPush(key, value);
  624.     }
  626.     /**
  627.      * @param key
  628.      * @param values
  629.      * @return long
  630.      * @description 把值添加在 list的最后面
  631.      * @author chengjunyu
  632.      * @date 2022/2/12
  633.      */
  634.     public long rightPushAll(String key, Object... values) {
  635.         return redisTemplate.opsForList().rightPushAll(key, values);
  636.     }
  638.     /**
  639.      * @param key
  640.      * @param values
  641.      * @return long
  642.      * @description 把值添加在 list的最后面
  643.      * @author chengjunyu
  644.      * @date 2022/2/12
  645.      */
  646.     public long rightPushAll(String key, List<Object> values) {
  647.         return redisTemplate.opsForList().rightPushAll(key, values);
  648.     }
  650.     /**
  651.      * @param key
  652.      * @param index
  653.      * @return java.lang.Object
  654.      * @description 根据索引获取 list中的值
  655.      * @author chengjunyu
  656.      * @date 2022/2/12
  657.      */
  658.     public Object index(String key, long index) {
  659.         return redisTemplate.opsForList().index(key, index);
  660.     }
  662.     /**
  663.      * @param key
  664.      * @param start
  665.      * @param end
  666.      * @return java.util.List<java.lang.Object>
  667.      * @description 获取 list中开始索引到结束索引的所有值
  668.      * @author chengjunyu
  669.      * @date 2022/2/12
  670.      */
  671.     public List<Object> range(String key, long start, long end) {
  672.         return redisTemplate.opsForList().range(key, start, end);
  673.     }
  675.     /**
  676.      * @param key
  677.      * @return java.lang.Object
  678.      * @description 移除并获取列表中第一个元素
  679.      * @author chengjunyu
  680.      * @date 2022/2/12
  681.      */
  682.     public Object leftPop(String key) {
  683.         return redisTemplate.opsForList().leftPop(key);
  684.     }
  686.     /**
  687.      * @param key
  688.      * @param seconds
  689.      * @param timeUnit
  690.      * @return java.lang.Object
  691.      * @description 移除并获取列表中第一个元素
  692.      * @author chengjunyu
  693.      * @date 2022/2/12
  694.      */
  695.     public Object leftPop(String key, Long seconds, TimeUnit timeUnit) {
  696.         return redisTemplate.opsForList().leftPop(key, seconds, timeUnit);
  697.     }
  699.     /**
  700.      * @param key
  701.      * @return java.lang.Object
  702.      * @description 移除并获取列表中最后一个元素
  703.      * @author chengjunyu
  704.      * @date 2022/2/12
  705.      */
  706.     public Object rightPop(String key) {
  707.         return redisTemplate.opsForList().rightPop(key);
  708.     }
  710.     /**
  711.      * @param key
  712.      * @param seconds
  713.      * @param timeUnit
  714.      * @return java.lang.Object
  715.      * @description 移除并获取列表中最后一个元素
  716.      * @author chengjunyu
  717.      * @date 2022/2/12
  718.      */
  719.     public Object rightPop(String key, Long seconds, TimeUnit timeUnit) {
  720.         return redisTemplate.opsForList().rightPop(key, seconds, timeUnit);
  721.     }
  723.     /**
  724.      * @param sourceKey
  725.      * @param destinationKey
  726.      * @return java.lang.Object
  727.      * @description 从一个队列的右边弹出一个元素并将这个元素放入另一个指定队列的最左边
  728.      * @author chengjunyu
  729.      * @date 2022/2/12
  730.      */
  731.     public Object rightPopAndLeftPush(String sourceKey, String destinationKey) {
  732.         return redisTemplate.opsForList().rightPopAndLeftPush(sourceKey, destinationKey);
  733.     }
  735.     /**
  736.      * @param sourceKey
  737.      * @param destinationKey
  738.      * @param seconds
  739.      * @param timeUnit
  740.      * @return java.lang.Object
  741.      * @description 从一个队列的右边弹出一个元素并将这个元素放入另一个指定队列的最左边
  742.      * @author chengjunyu
  743.      * @date 2022/2/12
  744.      */
  745.     public Object rightPopAndLeftPush(String sourceKey, String destinationKey, long seconds, TimeUnit timeUnit) {
  746.         return redisTemplate.opsForList().rightPopAndLeftPush(sourceKey, destinationKey, seconds, timeUnit);
  747.     }
  749.     /**
  750.      * @param key
  751.      * @return java.lang.Long
  752.      * @description 获取 list的大小
  753.      * @author chengjunyu
  754.      * @date 2022/2/12
  755.      */
  756.     public Long sizeList(String key) {
  757.         return redisTemplate.opsForList().size(key);
  758.     }
  760.     /**
  761.      * @param key
  762.      * @param start
  763.      * @param end
  764.      * @return void
  765.      * @description 剪裁 List列表
  766.      * @author chengjunyu
  767.      * @date 2022/2/12
  768.      */
  769.     public void trim(String key, long start, long end) {
  770.         redisTemplate.opsForList().trim(key, start, end);
  771.     }
  773.     /**
  774.      * @param key
  775.      * @param index
  776.      * @param value
  777.      * @return java.lang.Long
  778.      * @description 删除集合中值等于value的元素
  779.      * @author chengjunyu
  780.      * @date 2022/2/12
  781.      */
  782.     public Long remove(String key, long index, Object value) {
  783.         return redisTemplate.opsForList().remove(key, index, value);
  784.     }
  785.     //========================RedisTemplate操作set类型数据============================================
  787.     /**
  788.      * @param key
  789.      * @param values
  790.      * @return java.lang.Long
  791.      * @description 添加元素到 set中
  792.      * @author chengjunyu
  793.      * @date 2022/2/12
  794.      */
  795.     public Long add(String key, Collection<Object> values) {
  796.         return redisTemplate.opsForSet().add(key, values);
  797.     }
  799.     /**
  800.      * @param key
  801.      * @return java.lang.Object
  802.      * @description 从 set中删除一个随机元素，并返回该元素
  803.      * @author chengjunyu
  804.      * @date 2022/2/12
  805.      */
  806.     public Object pop(String key) {
  807.         return redisTemplate.opsForSet().pop(key);
  808.     }
  810.     /**
  811.      * @param key
  812.      * @return long
  813.      * @description 获取 set集合的大小
  814.      * @author chengjunyu
  815.      * @date 2022/2/12
  816.      */
  817.     public Long sizeSet(String key) {
  818.         return redisTemplate.opsForSet().size(key);
  819.     }
  821.     /**
  822.      * @param key
  823.      * @param value
  824.      * @return java.lang.Boolean
  825.      * @description 判断 set集合中是否存在value值
  826.      * @author chengjunyu
  827.      * @date 2022/2/12
  828.      */
  829.     public Boolean isMember(String key, Object value) {
  830.         return redisTemplate.opsForSet().isMember(key, value);
  831.     }
  833.     /**
  834.      * @param key
  835.      * @param otherKey
  836.      * @return java.util.Set<java.lang.Object>
  837.      * @description 获取两个集合的交集并返回一个集合
  838.      * @author chengjunyu
  839.      * @date 2022/2/12
  840.      */
  841.     public Set<Object> intersect(String key, String otherKey) {
  842.         return redisTemplate.opsForSet().intersect(key, otherKey);
  843.     }
  845.     /**
  846.      * @param key
  847.      * @param collection
  848.      * @return java.util.Set<java.lang.Object>
  849.      * @description 获取两个集合的交集并返回一个集合
  850.      * @author chengjunyu
  851.      * @date 2022/2/12
  852.      */
  853.     public Set<Object> intersect(String key, Collection<String> collection) {
  854.         return redisTemplate.opsForSet().intersect(key, collection);
  855.     }
  857.     /**
  858.      * @param key1
  859.      * @param key2
  860.      * @param destKey
  861.      * @return java.lang.Long
  862.      * @description 获取两个集合交集，并存储到 destKey
  863.      * @author chengjunyu
  864.      * @date 2022/2/12
  865.      */
  866.     public Long intersectAndStore(String key1, String key2, String destKey) {
  867.         return redisTemplate.opsForSet().intersectAndStore(key1, key2, destKey);
  868.     }
  870.     /**
  871.      * @param key
  872.      * @param key1
  873.      * @return java.util.Set<java.lang.Object>
  874.      * @description 获取两个集合的并集
  875.      * @author chengjunyu
  876.      * @date 2022/2/12
  877.      */
  878.     public Set<Object> union(String key, String key1) {
  879.         return redisTemplate.opsForSet().union(key, key1);
  880.     }
  882.     /**
  883.      * @param key
  884.      * @param collection
  885.      * @return java.util.Set<java.lang.Object>
  886.      * @description 获取两个集合的并集
  887.      * @author chengjunyu
  888.      * @date 2022/2/12
  889.      */
  890.     public Set<Object> union(String key, Collection<String> collection) {
  891.         return redisTemplate.opsForSet().union(key, collection);
  892.     }
  894.     /**
  895.      * @param key
  896.      * @param key1
  897.      * @param destKey
  898.      * @return java.lang.Long
  899.      * @description 获取两个集合的并集，并存储到 destKey
  900.      * @author chengjunyu
  901.      * @date 2022/2/12
  902.      */
  903.     public Long unionAndStore(String key, String key1, String destKey) {
  904.         return redisTemplate.opsForSet().unionAndStore(key, key1, destKey);
  905.     }
  907.     /**
  908.      * @param key
  909.      * @param key1
  910.      * @return java.util.Set<java.lang.Object>
  911.      * @description 获取两个集合的差集
  912.      * @author chengjunyu
  913.      * @date 2022/2/12
  914.      */
  915.     public Set<Object> difference(String key, String key1) {
  916.         return redisTemplate.opsForSet().difference(key, key1);
  917.     }
  919.     /**
  920.      * @param key
  921.      * @param collection
  922.      * @return java.util.Set<java.lang.Object>
  923.      * @description 获取两个集合的差集
  924.      * @author chengjunyu
  925.      * @date 2022/2/12
  926.      */
  927.     public Set<Object> difference(String key, Collection<String> collection) {
  928.         return redisTemplate.opsForSet().difference(key, collection);
  929.     }
  931.     /**
  932.      * @param key
  933.      * @param key1
  934.      * @param destKey
  935.      * @return java.lang.Long
  936.      * @description 获取两个集合的差集，并存储到 destKey
  937.      * @author chengjunyu
  938.      * @date 2022/2/12
  939.      */
  940.     public Long differenceAndStore(String key, String key1, String destKey) {
  941.         return redisTemplate.opsForSet().differenceAndStore(key, key1, destKey);
  942.     }
  944.     /**
  945.      * @param key
  946.      * @return java.util.Set<java.lang.Object>
  947.      * @description 获取集合中的所有元素
  948.      * @author chengjunyu
  949.      * @date 2022/2/12
  950.      */
  951.     public Set<Object> members(String key) {
  952.         return redisTemplate.opsForSet().members(key);
  953.     }
  955.     /**
  956.      * @param key
  957.      * @return java.lang.Object
  958.      * @description 随机获取集合中一个元素
  959.      * @author chengjunyu
  960.      * @date 2022/2/12
  961.      */
  962.     public Object randomMember(String key) {
  963.         return redisTemplate.opsForSet().randomMember(key);
  964.     }
  966.     /**
  967.      * @param key
  968.      * @param count
  969.      * @return java.util.List<java.lang.Object>
  970.      * @description 随机获取集合中 count个元素，返回一个 List集合
  971.      * @author chengjunyu
  972.      * @date 2022/2/12
  973.      */
  974.     public List<Object> randomMembers(String key, long count) {
  975.         return redisTemplate.opsForSet().randomMembers(key, count);
  976.     }
  978.     /**
  979.      * @param key
  980.      * @param count
  981.      * @return java.util.Set<java.lang.Object>
  982.      * @description 随机获取集合中 count个元素，去重后返回一个 Set集合
  983.      * @author chengjunyu
  984.      * @date 2022/2/12
  985.      */
  986.     public Set<Object> distinctRandomMembers(String key, long count) {
  987.         return redisTemplate.opsForSet().distinctRandomMembers(key, count);
  988.     }
  990.     /**
  991.      * @param key
  992.      * @param scanOptions
  993.      * @return org.springframework.data.redis.core.Cursor<java.lang.Object>
  994.      * @description 遍历 set
  995.      * @author chengjunyu
  996.      * @date 2022/2/12
  997.      */
  998.     public Cursor<Object> scanSet(String key, ScanOptions scanOptions) {
  999.         return redisTemplate.opsForSet().scan(key, scanOptions);
  1000.     }
  1002.     /**
  1003.      * @param key
  1004.      * @param objects
  1005.      * @return java.lang.Long
  1006.      * @description 移除元素
  1007.      * @author chengjunyu
  1008.      * @date 2022/2/12
  1009.      */
  1010.     public Long remove(String key, Collection<Object> objects) {
  1011.         return redisTemplate.opsForSet().remove(key, objects);
  1012.     }
  1013.     //========================RedisTemplate操作zset类型数据============================================
  1015.     /**
  1016.      * @param key
  1017.      * @param value
  1018.      * @param score
  1019.      * @return java.lang.Boolean
  1020.      * @description 添加元素到 zset，从小到大排序
  1021.      * @author chengjunyu
  1022.      * @date 2022/2/12
  1023.      */
  1024.     public Boolean add(String key, Object value, double score) {
  1025.         return redisTemplate.opsForZSet().add(key, value, score);
  1026.     }
  1028.     /**
  1029.      * @param key
  1030.      * @param value
  1031.      * @param score
  1032.      * @return java.lang.Double
  1033.      * @description 增加元素的 score值同时返回增加后的 score值
  1034.      * @author chengjunyu
  1035.      * @date 2022/2/12
  1036.      */
  1037.     public Double incrementScore(String key, Object value, double score) {
  1038.         return redisTemplate.opsForZSet().incrementScore(key, value, score);
  1039.     }
  1041.     /**
  1042.      * @param key
  1043.      * @param object
  1044.      * @return java.lang.Long
  1045.      * @description 返回 zset元素在集合的从小到大排名
  1046.      * @author chengjunyu
  1047.      * @date 2022/2/12
  1048.      */
  1049.     public Long rank(String key, Object object) {
  1050.         return redisTemplate.opsForZSet().rank(key, object);
  1051.     }
  1053.     /**
  1054.      * @param key
  1055.      * @param object
  1056.      * @return java.lang.Long
  1057.      * @description 返回 zset元素在集合的由大到小排名
  1058.      * @author chengjunyu
  1059.      * @date 2022/2/12
  1060.      */
  1061.     public Long reverseRank(String key, Object object) {
  1062.         return redisTemplate.opsForZSet().reverseRank(key, object);
  1063.     }
  1065.     /**
  1066.      * @param key
  1067.      * @param start
  1068.      * @param end
  1069.      * @return java.util.Set<org.springframework.data.redis.core.ZSetOperations.TypedTuple < java.lang.Object>>
  1070.      * @description 获取 zset集合中指定区间的元素
  1071.      * @author chengjunyu
  1072.      * @date 2022/2/12
  1073.      */
  1074.     public Set<ZSetOperations.TypedTuple<Object>> reverseRangeWithScores(String key, long start, long end) {
  1075.         return redisTemplate.opsForZSet().reverseRangeWithScores(key, start, end);
  1076.     }
  1078.     /**
  1079.      * @param key
  1080.      * @param min
  1081.      * @param max
  1082.      * @return java.util.Set<java.lang.Object>
  1083.      * @description 查询 zset集合中的元素并从小到大排序
  1084.      * @author chengjunyu
  1085.      * @date 2022/2/12
  1086.      */
  1087.     public Set<Object> reverseRangeByScore(String key, double min, double max) {
  1088.         return redisTemplate.opsForZSet().reverseRangeByScore(key, min, max);
  1089.     }
  1091.     /**
  1092.      * @param key
  1093.      * @param min
  1094.      * @param max
  1095.      * @param start
  1096.      * @param end
  1097.      * @return java.util.Set<java.lang.Object>
  1098.      * @description 从高到低进行排序，然后获取最小与最大值之间的值
  1099.      * @author chengjunyu
  1100.      * @date 2022/2/12
  1101.      */
  1102.     public Set<Object> reverseRangeByScore(String key, double min, double max, long start, long end) {
  1103.         return redisTemplate.opsForZSet().reverseRangeByScore(key, min, max, start, end);
  1104.     }
  1106.     /**
  1107.      * @param key
  1108.      * @param min
  1109.      * @param max
  1110.      * @return java.util.Set<org.springframework.data.redis.core.ZSetOperations.TypedTuple < java.lang.Object>>
  1111.      * @description 查询 zset集合中的元素并从小到大排序
  1112.      * @author chengjunyu
  1113.      * @date 2022/2/12
  1114.      */
  1115.     public Set<ZSetOperations.TypedTuple<Object>> reverseRangeByScoreWithScores(String key, double min, double max) {
  1116.         return redisTemplate.opsForZSet().reverseRangeByScoreWithScores(key, min, max);
  1117.     }
  1119.     /**
  1120.      * @param key
  1121.      * @param min
  1122.      * @param max
  1123.      * @return java.lang.Long
  1124.      * @description 根据score值获取元素数量
  1125.      * @author chengjunyu
  1126.      * @date 2022/2/12
  1127.      */
  1128.     public Long count(String key, double min, double max) {
  1129.         return redisTemplate.opsForZSet().count(key, min, max);
  1130.     }
  1132.     /**
  1133.      * @param key
  1134.      * @return java.lang.Long
  1135.      * @description 获取 zset集合的大小
  1136.      * @author chengjunyu
  1137.      * @date 2022/2/12
  1138.      */
  1139.     public Long sizeZset(String key) {
  1140.         return redisTemplate.opsForZSet().size(key);
  1141.     }
  1143.     /**
  1144.      * @param key
  1145.      * @return java.lang.Long
  1146.      * @description 获取 zset集合的大小
  1147.      * @author chengjunyu
  1148.      * @date 2022/2/12
  1149.      */
  1150.     public Long zCard(String key) {
  1151.         return redisTemplate.opsForZSet().zCard(key);
  1152.     }
  1154.     /**
  1155.      * @param key
  1156.      * @param value
  1157.      * @return java.lang.Double
  1158.      * @description 获取集合中 key、value元素的 score值
  1159.      * @author chengjunyu
  1160.      * @date 2022/2/12
  1161.      */
  1162.     public Double score(String key, Object value) {
  1163.         return redisTemplate.opsForZSet().score(key, value);
  1164.     }
  1166.     /**
  1167.      * @param key
  1168.      * @param start
  1169.      * @param end
  1170.      * @return java.lang.Long
  1171.      * @description 移除 zset中指定索引元素
  1172.      * @author chengjunyu
  1173.      * @date 2022/2/12
  1174.      */
  1175.     public Long removeRange(String key, long start, long end) {
  1176.         return redisTemplate.opsForZSet().removeRange(key, start, end);
  1177.     }
  1179.     /**
  1180.      * @param key
  1181.      * @param min
  1182.      * @param max
  1183.      * @return java.lang.Long
  1184.      * @description 移除 zset中指定 score范围的集合成员
  1185.      * @author chengjunyu
  1186.      * @date 2022/2/12
  1187.      */
  1188.     public Long removeRangeByScore(String key, double min, double max) {
  1189.         return redisTemplate.opsForZSet().removeRangeByScore(key, min, max);
  1190.     }
  1192.     /**
  1193.      * @param key
  1194.      * @param key1
  1195.      * @param destKey
  1196.      * @return java.lang.Long
  1197.      * @description 获取 key和 key1的并集并存储在 destKey中
  1198.      * @author chengjunyu
  1199.      * @date 2022/2/12
  1200.      */
  1201.     public Long zSetUnionAndStore(String key, String key1, String destKey) {
  1202.         return redisTemplate.opsForZSet().unionAndStore(key, key1, destKey);
  1203.     }
  1205.     /**
  1206.      * @param key
  1207.      * @param collection
  1208.      * @param destKey
  1209.      * @return java.lang.Long
  1210.      * @description 获取 key和 collection集合的并集并存储在 destKey中
  1211.      * @author chengjunyu
  1212.      * @date 2022/2/12
  1213.      */
  1214.     public Long zSetUnionAndStore(String key, Collection<String> collection, String destKey) {
  1215.         return redisTemplate.opsForZSet().unionAndStore(key, collection, destKey);
  1216.     }
  1218.     /**
  1219.      * @param key
  1220.      * @param key1
  1221.      * @param destKey
  1222.      * @return java.lang.Long
  1223.      * @description 获取 key和 key1的交集并存储在 destKey中
  1224.      * @author chengjunyu
  1225.      * @date 2022/2/12
  1226.      */
  1227.     public Long zSetIntersectAndStore(String key, String key1, String destKey) {
  1228.         return redisTemplate.opsForZSet().intersectAndStore(key, key1, destKey);
  1229.     }
  1231.     /**
  1232.      * @param key
  1233.      * @param collection
  1234.      * @param destKey
  1235.      * @return java.lang.Long
  1236.      * @description 获取 key和 collection集合的交集并存储在 destKey中
  1237.      * @author chengjunyu
  1238.      * @date 2022/2/12
  1239.      */
  1240.     public Long zSetIntersectAndStore(String key, Collection<String> collection, String destKey) {
  1241.         return redisTemplate.opsForZSet().intersectAndStore(key, collection, destKey);
  1242.     }
  1244.     /**
  1245.      * @param key
  1246.      * @param values
  1247.      * @return java.lang.Long
  1248.      * @description 删除多个values的值
  1249.      * @author chengjunyu
  1250.      * @date 2022/2/12
  1251.      */
  1252.     public Long remove(String key, Object... values) {
  1253.         return redisTemplate.opsForZSet().remove(key, values);
  1254.     }
  1256. }

使用

  1. @Autowired
  2. private RedisTemplateUtils redisTemplateUtils;
  4. Dog dog = new Dog();
  5. dog.setName("zz");
  6. dog.setColor("cc2");
  7. redisTemplate.opsForValue().set("token",dog,30, TimeUnit.MINUTES);
  8. Dog dd = (Dog)redisTemplateUtils.get("token");
  9. System.out.println(dd);

API的使用

@Resource
private RedisTemplate redisTemplate;

set数据类型

获取set数据类型

  1. Set<Integer> followers = redisTemplate.opsForSet()
  2.                 .members(RedisKeyConstant.followers.getKey() + dinerId);

两个set类型key的交集

  1. Set<Integer> dinerIds = redisTemplate.opsForSet().intersect(loginDinerKey, dinerKey);

添加数据

  1.  redisTemplate.opsForSet().add(RedisKeyConstant.following.getKey() + dinerId, followDinerId);

移除数据

  1. redisTemplate.opsForSet().remove(RedisKeyConstant.following.getKey() + dinerId, followDinerId);

hash数据类型

保存

  1. redisTemplate.opsForHash().putAll(key, restaurantMap);

list类型数据

获取list的前10条数据

  1. // 从 Redis 取十条最新评论
  2. List<LinkedHashMap> reviews = redisTemplate.opsForList().range(key, 0, NINE);

写入数据

最新的数据在前面。

  1. redisTemplate.opsForList().leftPush(key, reviews);

管道技术

管道为什么快？平常的是 一个插入请求ok之后，再接着插入下一个，管道是等插入完了之后再统一获取响应。

批量插入hash类型

一个是逐行插入，一个是批量插入。
2w条数据，逐行插入大概是2分钟。批量插入30秒左右

  1. package com.imooc.restaurants.service;
  3. import cn.hutool.core.bean.BeanUtil;
  4. import com.google.common.collect.Maps;
  5. import com.imooc.commons.constant.RedisKeyConstant;
  6. import com.imooc.commons.model.pojo.Restaurant;
  7. import com.imooc.restaurants.RestaurantApplicationTest;
  8. import com.imooc.restaurants.mapper.RestaurantMapper;
  9. import lombok.extern.slf4j.Slf4j;
  10. import org.junit.jupiter.api.Test;
  11. import org.springframework.data.redis.core.RedisCallback;
  12. import org.springframework.data.redis.core.RedisTemplate;
  13. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
  14. import org.springframework.data.redis.serializer.StringRedisSerializer;
  16. import javax.annotation.Resource;
  17. import java.util.List;
  18. import java.util.Map;
  20. @Slf4j
  21. public class RestaurantTest extends RestaurantApplicationTest {
  23.     @Resource
  24.     private RedisTemplate redisTemplate;
  25.     @Resource
  26.     private RestaurantMapper restaurantMapper;
  28.     // 逐行插入
  29.     @Test
  30.     void testSyncForHash() {
  31.         List<Restaurant> restaurants = restaurantMapper.findAll();
  32.         long start = System.currentTimeMillis();
  33.         restaurants.forEach(restaurant -> {
  34.             Map<String, Object> restaurantMap = BeanUtil.beanToMap(restaurant);
  35.             String key = RedisKeyConstant.restaurants.getKey() + restaurant.getId();
  36.             redisTemplate.opsForHash().putAll(key, restaurantMap);
  37.         });
  38.         long end = System.currentTimeMillis();
  39.         log.info("执行时间：{}", end - start); // 执行时间：118957
  40.     }
  42.     // Pipeline 管道插入
  43.     @Test
  44.     void testSyncForHashPipeline() {
  45.         List<Restaurant> restaurants = restaurantMapper.findAll();
  46.         long start = System.currentTimeMillis();
  47.         List<Long> list = redisTemplate.executePipelined((RedisCallback<Long>) connection -> {
  48.             for (Restaurant restaurant : restaurants) {
  49.                 try {
  50.                     String key = RedisKeyConstant.restaurants.getKey() + restaurant.getId();
  51.                     Map<String, Object> restaurantMap = BeanUtil.beanToMap(restaurant);
  52.                     StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
  53.                     Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  54.                     Map<byte[], byte[]> restaurantStringMap = Maps.newHashMap();
  55.                     restaurantMap.forEach((k, v) -> {
  56.                         restaurantStringMap.put(stringRedisSerializer.serialize(k), jackson2JsonRedisSerializer.serialize(v));
  57.                     });
  58.                     connection.hMSet(stringRedisSerializer.serialize(key), restaurantStringMap);
  59.                 } catch (Exception e) {
  60.                     log.info(restaurant.toString());
  61.                     continue;
  62.                 }
  63.             }
  64.             return null;
  65.         });
  66.         long end = System.currentTimeMillis();
  67.         log.info("执行时间：{}", end - start); // 执行时间：35606
  68.     }
  70. }