【SpringBoot整合Redis已解决】 Cannot serialize； nested exception is org.springframework.core.serializer.sup

迈不过友情╰ 2024-03-22 08:51 162阅读 0赞

介绍

这里是小编成长之路的历程，也是小编的学习之路。希望和各位大佬们一起成长！

以下为小编最喜欢的两句话：

要有最朴素的生活和最遥远的梦想，即使明天天寒地冻，山高水远，路远马亡。

一个人为什么要努力？ 我见过最好的答案就是：因为我喜欢的东西都很贵，我想去的地方都很远，我爱的人超完美。因此，小编想说：共勉！

问题描述：

序列化错误，想要我在实体类序列化一下，但是其实redis本来就是有序列化的封装类

  1. Cannot serialize; nested exception is org.springframework.core.serializer.support.SerializationFailedException: Failed to serialize object using DefaultSerializer; nested exception is java.lang.IllegalArgumentException: DefaultSerializer requires a Serializable payload but received an object of type [com.lyn.pojo.GoodsShopcar]
  2.     at org.springframework.data.redis.serializer.JdkSerializationRedisSerializer.serialize(JdkSerializationRedisSerializer.java:96)
  3.     at org.springframework.data.redis.core.AbstractOperations.rawHashValue(AbstractOperations.java:186)
  4.     at org.springframework.data.redis.core.DefaultHashOperations.put(DefaultHashOperations.java:251)
  5.     at com.lyn.utlis.RedisUtil.hset(RedisUtil.java:237)
  6.     at com.lyn.controller.CartTwoController.addToCart(CartTwoController.java:30)
  7.     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  8.     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  9.     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  10.     at java.lang.reflect.Method.invoke(Method.java:498)
  11.     at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
  12.     at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:150)
  13.     at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:117)
  14.     at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)
  15.     at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)
  16.     at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
  17.     at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1072)
  18.     at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:965)
  19.     at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)
  20.     at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909)
  21.     at javax.servlet.http.HttpServlet.service(HttpServlet.java:555)
  22.     at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)
  23.     at javax.servlet.http.HttpServlet.service(HttpServlet.java:623)
  24.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:209)
  25.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153)
  26.     at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:51)
  27.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178)
  28.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153)
  29.     at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)
  30.     at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
  31.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178)
  32.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153)
  33.     at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)
  34.     at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
  35.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178)
  36.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153)
  37.     at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)
  38.     at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:117)
  39.     at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:178)
  40.     at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:153)
  41.     at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:167)
  42.     at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:90)
  43.     at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:481)
  44.     at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:130)
  45.     at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:93)
  46.     at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)
  47.     at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
  48.     at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:389)
  49.     at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:63)
  50.     at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:926)
  51.     at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1791)
  52.     at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:52)
  53.     at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191)
  54.     at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659)
  55.     at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
  56.     at java.lang.Thread.run(Thread.java:748)
  57. Caused by: org.springframework.core.serializer.support.SerializationFailedException: Failed to serialize object using DefaultSerializer; nested exception is java.lang.IllegalArgumentException: DefaultSerializer requires a Serializable payload but received an object of type [com.lyn.pojo.GoodsShopcar]
  58.     at org.springframework.core.serializer.support.SerializingConverter.convert(SerializingConverter.java:64)
  59.     at org.springframework.core.serializer.support.SerializingConverter.convert(SerializingConverter.java:33)
  60.     at org.springframework.data.redis.serializer.JdkSerializationRedisSerializer.serialize(JdkSerializationRedisSerializer.java:94)
  61.     ... 54 more
  62. Caused by: java.lang.IllegalArgumentException: DefaultSerializer requires a Serializable payload but received an object of type [com.lyn.pojo.GoodsShopcar]
  63.     at org.springframework.core.serializer.DefaultSerializer.serialize(DefaultSerializer.java:43)
  64.     at org.springframework.core.serializer.Serializer.serializeToByteArray(Serializer.java:56)
  65.     at org.springframework.core.serializer.support.SerializingConverter.convert(SerializingConverter.java:60)
  66.     ... 56 more

解决方法：

小编是因为在util中使用到 RedisTemplate，但是并没有用到redis序列化所以才会报上述错误

9851698c40ea46b78e720faee0c5646a.png

在util中或者config中加入redisconfig，实现redis序列化

  1. @SpringBootConfiguration
  2. public class RedisConfig {
  4.     @Bean
  5.     public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
  6.         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
  7.         redisTemplate.setConnectionFactory(redisConnectionFactory);
  8.         //创建一个json的序列化对象
  9.         GenericJackson2JsonRedisSerializer jackson2JsonRedisSerializer = new GenericJackson2JsonRedisSerializer();
  10.         //设置value的序列化方式json
  11.         redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
  12.         //设置key序列化方式String
  13.         redisTemplate.setKeySerializer(new StringRedisSerializer());
  14.         //设置hash key序列化方式String
  15.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
  16.         //设置hash value序列化json
  17.         redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
  18.         // 设置支持事务
  19.         redisTemplate.setEnableTransactionSupport(true);
  20.         redisTemplate.afterPropertiesSet();
  21.         return redisTemplate;
  22.     }
  24.     @Bean
  25.     public RedisSerializer<Object> redisSerializer() {
  26.         //创建JSON序列化器
  27.         ObjectMapper objectMapper = new ObjectMapper();
  28.         objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  29.         //必须设置，否则无法将JSON转化为对象，会转化成Map类型
  30.         objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL);
  31.         return new GenericJackson2JsonRedisSerializer(objectMapper);
  32.     }
  34. }

再在redisutil中引入的时候就可以使用到@Autowired，不然没有序列化使用@Autowired

就会冒红

下面的代码是一位大佬写的redisutil

  1. import org.springframework.beans.factory.annotation.Autowired;
  2. import org.springframework.data.redis.core.RedisTemplate;
  3. import org.springframework.stereotype.Component;
  4. import org.springframework.util.CollectionUtils;
  6. import javax.annotation.Resource;
  7. import java.util.Collection;
  8. import java.util.List;
  9. import java.util.Map;
  10. import java.util.Set;
  11. import java.util.concurrent.TimeUnit;
  13. //  封装 RedisTemplate的一些操作 RedisUtil
  14. @Component
  15. public final class RedisUtil {
  17.     @Autowired
  18.     private RedisTemplate<String, Object> redisTemplate;
  20.     // =============================common============================
  21.     /**
  22.      * 指定缓存失效时间
  23.      * @param key  键
  24.      * @param time 时间(秒)
  25.      */
  26.     public boolean expire(String key, long time) {
  27.         try {
  28.             if (time > 0) {
  29.                 redisTemplate.expire(key, time, TimeUnit.SECONDS);
  30.             }
  31.             return true;
  32.         } catch (Exception e) {
  33.             e.printStackTrace();
  34.             return false;
  35.         }
  36.     }
  38.     /**
  39.      * 根据key 获取过期时间
  40.      * @param key 键 不能为null
  41.      * @return 时间(秒) 返回0代表为永久有效
  42.      */
  43.     public long getExpire(String key) {
  44.         return redisTemplate.getExpire(key, TimeUnit.SECONDS);
  45.     }
  48.     /**
  49.      * 判断key是否存在
  50.      * @param key 键
  51.      * @return true 存在 false不存在
  52.      */
  53.     public boolean hasKey(String key) {
  54.         try {
  55.             return redisTemplate.hasKey(key);
  56.         } catch (Exception e) {
  57.             e.printStackTrace();
  58.             return false;
  59.         }
  60.     }
  63.     /**
  64.      * 删除缓存
  65.      * @param key 可以传一个值 或多个
  66.      */
  67.     @SuppressWarnings("unchecked")
  68.     public void del(String... key) {
  69.         if (key != null && key.length > 0) {
  70.             if (key.length == 1) {
  71.                 redisTemplate.delete(key[0]);
  72.             } else {
  73.                 redisTemplate.delete((Collection<String>) CollectionUtils.arrayToList(key));
  74.             }
  75.         }
  76.     }
  79.     // ============================String=============================
  81.     /**
  82.      * 普通缓存获取
  83.      * @param key 键
  84.      * @return 值
  85.      */
  86.     public Object get(String key) {
  87.         return key == null ? null : redisTemplate.opsForValue().get(key);
  88.     }
  90.     /**
  91.      * 普通缓存放入
  92.      * @param key   键
  93.      * @param value 值
  94.      * @return true成功 false失败
  95.      */
  97.     public boolean set(String key, Object value) {
  98.         try {
  99.             redisTemplate.opsForValue().set(key, value);
  100.             return true;
  101.         } catch (Exception e) {
  102.             e.printStackTrace();
  103.             return false;
  104.         }
  105.     }
  108.     /**
  109.      * 普通缓存放入并设置时间
  110.      * @param key   键
  111.      * @param value 值
  112.      * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
  113.      * @return true成功 false 失败
  114.      */
  116.     public boolean set(String key, Object value, long time) {
  117.         try {
  118.             if (time > 0) {
  119.                 redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
  120.             } else {
  121.                 set(key, value);
  122.             }
  123.             return true;
  124.         } catch (Exception e) {
  125.             e.printStackTrace();
  126.             return false;
  127.         }
  128.     }
  131.     /**
  132.      * 递增
  133.      * @param key   键
  134.      * @param delta 要增加几(大于0)
  135.      */
  136.     public long incr(String key, long delta) {
  137.         if (delta < 0) {
  138.             throw new RuntimeException("递增因子必须大于0");
  139.         }
  140.         return redisTemplate.opsForValue().increment(key, delta);
  141.     }
  144.     /**
  145.      * 递减
  146.      * @param key   键
  147.      * @param delta 要减少几(小于0)
  148.      */
  149.     public long decr(String key, long delta) {
  150.         if (delta < 0) {
  151.             throw new RuntimeException("递减因子必须大于0");
  152.         }
  153.         return redisTemplate.opsForValue().increment(key, -delta);
  154.     }
  157.     // ================================Map=================================
  159.     /**
  160.      * HashGet
  161.      * @param key  键 不能为null
  162.      * @param item 项 不能为null
  163.      */
  164.     public Object hget(String key, String item) {
  165.         return redisTemplate.opsForHash().get(key, item);
  166.     }
  168.     /**
  169.      * 获取所有给定字段的值
  170.      * author: xu
  171.      * @param key
  172.      * @return
  173.      */
  174.     public Map<Object, Object> hgetall(String key) {
  175.         return redisTemplate.opsForHash().entries(key);
  176.     }
  179.     /**
  180.      * 获取hashKey对应的所有键值
  181.      * @param key 键
  182.      * @return 对应的多个键值
  183.      */
  184.     public Map<Object, Object> hmget(String key) {
  185.         return redisTemplate.opsForHash().entries(key);
  186.     }
  188.     /**
  189.      * HashSet
  190.      * @param key 键
  191.      * @param map 对应多个键值
  192.      */
  193.     public boolean hmset(String key, Map<String, Object> map) {
  194.         try {
  195.             redisTemplate.opsForHash().putAll(key, map);
  196.             return true;
  197.         } catch (Exception e) {
  198.             e.printStackTrace();
  199.             return false;
  200.         }
  201.     }
  204.     /**
  205.      * HashSet 并设置时间
  206.      * @param key  键
  207.      * @param map  对应多个键值
  208.      * @param time 时间(秒)
  209.      * @return true成功 false失败
  210.      */
  211.     public boolean hmset(String key, Map<String, Object> map, long time) {
  212.         try {
  213.             redisTemplate.opsForHash().putAll(key, map);
  214.             if (time > 0) {
  215.                 expire(key, time);
  216.             }
  217.             return true;
  218.         } catch (Exception e) {
  219.             e.printStackTrace();
  220.             return false;
  221.         }
  222.     }
  225.     /**
  226.      * 向一张hash表中放入数据,如果不存在将创建
  227.      *
  228.      * @param key   键
  229.      * @param item  项
  230.      * @param value 值
  231.      * @return true 成功 false失败
  232.      */
  233.     public boolean hset(String key, String item, Object value) {
  234.         try {
  235.             redisTemplate.opsForHash().put(key, item, value);
  236.             return true;
  237.         } catch (Exception e) {
  238.             e.printStackTrace();
  239.             return false;
  240.         }
  241.     }
  243.     /**
  244.      * 向一张hash表中放入数据,如果不存在将创建
  245.      *
  246.      * @param key   键
  247.      * @param item  项
  248.      * @param value 值
  249.      * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
  250.      * @return true 成功 false失败
  251.      */
  252.     public boolean hset(String key, String item, Object value, long time) {
  253.         try {
  254.             redisTemplate.opsForHash().put(key, item, value);
  255.             if (time > 0) {
  256.                 expire(key, time);
  257.             }
  258.             return true;
  259.         } catch (Exception e) {
  260.             e.printStackTrace();
  261.             return false;
  262.         }
  263.     }
  266.     /**
  267.      * 删除hash表中的值
  268.      *
  269.      * @param key  键 不能为null
  270.      * @param item 项 可以使多个 不能为null
  271.      */
  272.     public void hdel(String key, Object... item) {
  273.         redisTemplate.opsForHash().delete(key, item);
  274.     }
  277.     /**
  278.      * 判断hash表中是否有该项的值
  279.      *
  280.      * @param key  键 不能为null
  281.      * @param item 项 不能为null
  282.      * @return true 存在 false不存在
  283.      */
  284.     public boolean hHasKey(String key, String item) {
  285.         return redisTemplate.opsForHash().hasKey(key, item);
  286.     }
  289.     /**
  290.      * hash递增 如果不存在,就会创建一个 并把新增后的值返回
  291.      *
  292.      * @param key  键
  293.      * @param item 项
  294.      * @param by   要增加几(大于0)
  295.      */
  296.     public double hincr(String key, String item, double by) {
  297.         return redisTemplate.opsForHash().increment(key, item, by);
  298.     }
  301.     /**
  302.      * hash递减
  303.      *
  304.      * @param key  键
  305.      * @param item 项
  306.      * @param by   要减少记(小于0)
  307.      */
  308.     public double hdecr(String key, String item, double by) {
  309.         return redisTemplate.opsForHash().increment(key, item, -by);
  310.     }
  313.     // ============================set=============================
  315.     /**
  316.      * 根据key获取Set中的所有值
  317.      * @param key 键
  318.      */
  319.     public Set<Object> sGet(String key) {
  320.         try {
  321.             return redisTemplate.opsForSet().members(key);
  322.         } catch (Exception e) {
  323.             e.printStackTrace();
  324.             return null;
  325.         }
  326.     }
  329.     /**
  330.      * 根据value从一个set中查询,是否存在
  331.      *
  332.      * @param key   键
  333.      * @param value 值
  334.      * @return true 存在 false不存在
  335.      */
  336.     public boolean sHasKey(String key, Object value) {
  337.         try {
  338.             return redisTemplate.opsForSet().isMember(key, value);
  339.         } catch (Exception e) {
  340.             e.printStackTrace();
  341.             return false;
  342.         }
  343.     }
  346.     /**
  347.      * 将数据放入set缓存
  348.      *
  349.      * @param key    键
  350.      * @param values 值 可以是多个
  351.      * @return 成功个数
  352.      */
  353.     public long sSet(String key, Object... values) {
  354.         try {
  355.             return redisTemplate.opsForSet().add(key, values);
  356.         } catch (Exception e) {
  357.             e.printStackTrace();
  358.             return 0;
  359.         }
  360.     }
  363.     /**
  364.      * 将set数据放入缓存
  365.      *
  366.      * @param key    键
  367.      * @param time   时间(秒)
  368.      * @param values 值 可以是多个
  369.      * @return 成功个数
  370.      */
  371.     public long sSetAndTime(String key, long time, Object... values) {
  372.         try {
  373.             Long count = redisTemplate.opsForSet().add(key, values);
  374.             if (time > 0)
  375.                 expire(key, time);
  376.             return count;
  377.         } catch (Exception e) {
  378.             e.printStackTrace();
  379.             return 0;
  380.         }
  381.     }
  384.     /**
  385.      * 获取set缓存的长度
  386.      *
  387.      * @param key 键
  388.      */
  389.     public long sGetSetSize(String key) {
  390.         try {
  391.             return redisTemplate.opsForSet().size(key);
  392.         } catch (Exception e) {
  393.             e.printStackTrace();
  394.             return 0;
  395.         }
  396.     }
  399.     /**
  400.      * 移除值为value的
  401.      *
  402.      * @param key    键
  403.      * @param values 值 可以是多个
  404.      * @return 移除的个数
  405.      */
  407.     public long setRemove(String key, Object... values) {
  408.         try {
  409.             Long count = redisTemplate.opsForSet().remove(key, values);
  410.             return count;
  411.         } catch (Exception e) {
  412.             e.printStackTrace();
  413.             return 0;
  414.         }
  415.     }
  417.     // ===============================list=================================
  419.     /**
  420.      * 获取list缓存的内容
  421.      *
  422.      * @param key   键
  423.      * @param start 开始
  424.      * @param end   结束 0 到 -1代表所有值
  425.      */
  426.     public List<Object> lGet(String key, long start, long end) {
  427.         try {
  428.             return redisTemplate.opsForList().range(key, start, end);
  429.         } catch (Exception e) {
  430.             e.printStackTrace();
  431.             return null;
  432.         }
  433.     }
  436.     /**
  437.      * 获取list缓存的长度
  438.      *
  439.      * @param key 键
  440.      */
  441.     public long lGetListSize(String key) {
  442.         try {
  443.             return redisTemplate.opsForList().size(key);
  444.         } catch (Exception e) {
  445.             e.printStackTrace();
  446.             return 0;
  447.         }
  448.     }
  451.     /**
  452.      * 通过索引 获取list中的值
  453.      *
  454.      * @param key   键
  455.      * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
  456.      */
  457.     public Object lGetIndex(String key, long index) {
  458.         try {
  459.             return redisTemplate.opsForList().index(key, index);
  460.         } catch (Exception e) {
  461.             e.printStackTrace();
  462.             return null;
  463.         }
  464.     }
  467.     /**
  468.      * 将list放入缓存
  469.      *
  470.      * @param key   键
  471.      * @param value 值
  472.      */
  473.     public boolean lSet(String key, Object value) {
  474.         try {
  475.             redisTemplate.opsForList().rightPush(key, value);
  476.             return true;
  477.         } catch (Exception e) {
  478.             e.printStackTrace();
  479.             return false;
  480.         }
  481.     }
  484.     /**
  485.      * 将list放入缓存
  486.      * @param key   键
  487.      * @param value 值
  488.      * @param time  时间(秒)
  489.      */
  490.     public boolean lSet(String key, Object value, long time) {
  491.         try {
  492.             redisTemplate.opsForList().rightPush(key, value);
  493.             if (time > 0)
  494.                 expire(key, time);
  495.             return true;
  496.         } catch (Exception e) {
  497.             e.printStackTrace();
  498.             return false;
  499.         }
  501.     }
  504.     /**
  505.      * 将list放入缓存
  506.      *
  507.      * @param key   键
  508.      * @param value 值
  509.      * @return
  510.      */
  511.     public boolean lSet(String key, List<Object> value) {
  512.         try {
  513.             redisTemplate.opsForList().rightPushAll(key, value);
  514.             return true;
  515.         } catch (Exception e) {
  516.             e.printStackTrace();
  517.             return false;
  518.         }
  520.     }
  523.     /**
  524.      * 将list放入缓存
  525.      *
  526.      * @param key   键
  527.      * @param value 值
  528.      * @param time  时间(秒)
  529.      * @return
  530.      */
  531.     public boolean lSet(String key, List<Object> value, long time) {
  532.         try {
  533.             redisTemplate.opsForList().rightPushAll(key, value);
  534.             if (time > 0)
  535.                 expire(key, time);
  536.             return true;
  537.         } catch (Exception e) {
  538.             e.printStackTrace();
  539.             return false;
  540.         }
  541.     }
  543.     /**
  544.      * 根据索引修改list中的某条数据
  545.      *
  546.      * @param key   键
  547.      * @param index 索引
  548.      * @param value 值
  549.      * @return
  550.      */
  552.     public boolean lUpdateIndex(String key, long index, Object value) {
  553.         try {
  554.             redisTemplate.opsForList().set(key, index, value);
  555.             return true;
  556.         } catch (Exception e) {
  557.             e.printStackTrace();
  558.             return false;
  559.         }
  560.     }
  562.     /**
  563.      * 移除N个值为value
  564.      *
  565.      * @param key   键
  566.      * @param count 移除多少个
  567.      * @param value 值
  568.      * @return 移除的个数
  569.      */
  571.     public long lRemove(String key, long count, Object value) {
  572.         try {
  573.             Long remove = redisTemplate.opsForList().remove(key, count, value);
  574.             return remove;
  575.         } catch (Exception e) {
  576.             e.printStackTrace();
  577.             return 0;
  578.         }
  580.     }
  582. }

以上就是小编所实践的内容，希望能够帮助到大家，感谢各位大佬的观看！！！

发表评论

表情：
评论列表 （有 0 条评论，162人围观）

还没有评论，来说两句吧...

相关阅读