devbox
2023面试高手
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

spring boot 集成 redis spring-boot-starter-data-redis 2.1.7.RELEASE jedis: pool: #连接池配置 及踩坑经验_error creating bean with name 'redisutils': unsati

作者：2023面试高手 | 2024-03-16 17:54:25

赞

踩

error creating bean with name 'redisutils': unsatisfied dependency expressed

目录

先上一些踩坑报错，各类报错

  @org.springframework.beans.factory.annotation.Autowired(required=true)

Error creating bean with name 'redisUtil': Unsatisfied dependency expressed through field 'redisTemplate'; 

 ERROR org.apache.catalina.core.ContainerBase.

Command timed out after 300 millisecond(s)

ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.dao.QueryTimeoutException: Redis command timed out; nested exception is io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)] with root cause

nested exception is org.springframework.data.redis.serializer.SerializationException: Could not read JSON: Unrecognized token 'sss': was expecting ('true', 'false' or 'null')

介绍

代码

依赖

介绍

参数值

配置加载参数类 RedisConfig

工具类 RedisUtil

调用测试类 RedistCtr

页面访问地址

踩坑记录及解决方法思路

先上一些踩坑报错，各类报错

 

  @org.springframework.beans.factory.annotation.Autowired(required=true)

  1. 2020-12-24 10:53:12.562 ERROR org.springframework.boot.diagnostics.LoggingFailureAnalysisReporter - 
  2.  
  3. ***************************
  4. APPLICATION FAILED TO START
  5. ***************************
  6.  
  7. Description:
  8.  
  9. Field redisTemplate in com.superman.uitl.redis.RedisUtil required a bean of type 'org.springframework.data.redis.core.RedisTemplate' that could not be found.
  10.  
  11. The injection point has the following annotations:
  12.     - @org.springframework.beans.factory.annotation.Autowired(required=true)

  

Error creating bean with name 'redisUtil': Unsatisfied dependency expressed through field 'redisTemplate'; 

  1. Consider defining a bean of type 'org.springframework.data.redis.core.RedisTemplate' in your configuration.
  2.  
  3. 2020-12-24 11:04:08.689 ERROR org.springframework.boot.SpringApplication - Application run failed
  4. org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'redisUtil': Unsatisfied dependency expressed through field 'redisTemplate'; nested exception is org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'redisTemplate' defined in class path resource [com/superman/globaldao/redis/RedisConfig.class]: Unsatisfied dependency expressed through method 'redisTemplate' parameter 0; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'redisConnectionFactory' defined in class path resource [org/springframework/boot/autoconfigure/data/redis/LettuceConnectionConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory]: Factory method 'redisConnectionFactory' threw exception; nested exception is java.lang.IllegalStateException: Invalid redis sentinel property 'host1:port'
  5. 	at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:596)
  6. 	at org.springframework.beans.factory.annotation.InjectionMetadata.inject(InjectionMetadata.java:90)
  7. 	at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor.postProcessProperties(AutowiredAnnotationBeanPostProcessor.java:374)
  8. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.populateBean(AbstractAutowireCapableBeanFactory.java:1411)
  9. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:592)
  10. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
  11. 	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
  12. 	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
  13. 	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  14. 	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
  15. 	at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:845)
  16. 	at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:877)
  17. 	at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:549)
  18. 	at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.refresh(ServletWebServerApplicationContext.java:141)
  19. 	at org.springframework.boot.SpringApplication.refresh(SpringApplication.java:743)
  20. 	at org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:390)
  21. 	at org.springframework.boot.SpringApplication.run(SpringApplication.java:312)
  22. 	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1214)
  23. 	at org.springframework.boot.SpringApplication.run(SpringApplication.java:1203)
  24. 	at com.superman.Provider_App.main(Provider_App.java:31)
  25. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  26. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  27. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  28. 	at java.lang.reflect.Method.invoke(Method.java:498)
  29. 	at org.springframework.boot.devtools.restart.RestartLauncher.run(RestartLauncher.java:49)
  30. Caused by: org.springframework.beans.factory.UnsatisfiedDependencyException: Error creating bean with name 'redisTemplate' defined in class path resource [com/superman/globaldao/redis/RedisConfig.class]: Unsatisfied dependency expressed through method 'redisTemplate' parameter 0; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'redisConnectionFactory' defined in class path resource [org/springframework/boot/autoconfigure/data/redis/LettuceConnectionConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory]: Factory method 'redisConnectionFactory' threw exception; nested exception is java.lang.IllegalStateException: Invalid redis sentinel property 'host1:port'
  31. 	at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:769)
  32. 	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:509)
  33. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1321)
  34. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1160)
  35. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:555)
  36. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
  37. 	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
  38. 	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
  39. 	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  40. 	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
  41. 	at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
  42. 	at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
  43. 	at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
  44. 	at org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor$AutowiredFieldElement.inject(AutowiredAnnotationBeanPostProcessor.java:593)
  45. 	... 24 common frames omitted
  46. Caused by: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'redisConnectionFactory' defined in class path resource [org/springframework/boot/autoconfigure/data/redis/LettuceConnectionConfiguration.class]: Bean instantiation via factory method failed; nested exception is org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory]: Factory method 'redisConnectionFactory' threw exception; nested exception is java.lang.IllegalStateException: Invalid redis sentinel property 'host1:port'
  47. 	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:627)
  48. 	at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:607)
  49. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.instantiateUsingFactoryMethod(AbstractAutowireCapableBeanFactory.java:1321)
  50. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBeanInstance(AbstractAutowireCapableBeanFactory.java:1160)
  51. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.doCreateBean(AbstractAutowireCapableBeanFactory.java:555)
  52. 	at org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.createBean(AbstractAutowireCapableBeanFactory.java:515)
  53. 	at org.springframework.beans.factory.support.AbstractBeanFactory.lambda$doGetBean$0(AbstractBeanFactory.java:320)
  54. 	at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.getSingleton(DefaultSingletonBeanRegistry.java:222)
  55. 	at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:318)
  56. 	at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:199)
  57. 	at org.springframework.beans.factory.config.DependencyDescriptor.resolveCandidate(DependencyDescriptor.java:277)
  58. 	at org.springframework.beans.factory.support.DefaultListableBeanFactory.doResolveDependency(DefaultListableBeanFactory.java:1251)
  59. 	at org.springframework.beans.factory.support.DefaultListableBeanFactory.resolveDependency(DefaultListableBeanFactory.java:1171)
  60. 	at org.springframework.beans.factory.support.ConstructorResolver.resolveAutowiredArgument(ConstructorResolver.java:857)
  61. 	at org.springframework.beans.factory.support.ConstructorResolver.createArgumentArray(ConstructorResolver.java:760)
  62. 	... 37 common frames omitted
  63. Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory]: Factory method 'redisConnectionFactory' threw exception; nested exception is java.lang.IllegalStateException: Invalid redis sentinel property 'host1:port'
  64. 	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:185)
  65. 	at org.springframework.beans.factory.support.ConstructorResolver.instantiate(ConstructorResolver.java:622)
  66. 	... 51 common frames omitted
  67. Caused by: java.lang.IllegalStateException: Invalid redis sentinel property 'host1:port'
  68. 	at org.springframework.boot.autoconfigure.data.redis.RedisConnectionConfiguration.createSentinels(RedisConnectionConfiguration.java:122)
  69. 	at org.springframework.boot.autoconfigure.data.redis.RedisConnectionConfiguration.getSentinelConfig(RedisConnectionConfiguration.java:81)
  70. 	at org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration.createLettuceConnectionFactory(LettuceConnectionConfiguration.java:80)
  71. 	at org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration.redisConnectionFactory(LettuceConnectionConfiguration.java:76)
  72. 	at org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration$$EnhancerBySpringCGLIB$$4d3d62c8.CGLIB$redisConnectionFactory$0(<generated>)
  73. 	at org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration$$EnhancerBySpringCGLIB$$4d3d62c8$$FastClassBySpringCGLIB$$375d6246.invoke(<generated>)
  74. 	at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:244)
  75. 	at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:363)
  76. 	at org.springframework.boot.autoconfigure.data.redis.LettuceConnectionConfiguration$$EnhancerBySpringCGLIB$$4d3d62c8.redisConnectionFactory(<generated>)
  77. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  78. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  79. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  80. 	at java.lang.reflect.Method.invoke(Method.java:498)
  81. 	at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:154)
  82. 	... 52 common frames omitted
  83. Caused by: java.lang.NumberFormatException: For input string: "port"
  84. 	at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
  85. 	at java.lang.Integer.parseInt(Integer.java:580)
  86. 	at java.lang.Integer.valueOf(Integer.java:766)
  87. 	at org.springframework.boot.autoconfigure.data.redis.RedisConnectionConfiguration.createSentinels(RedisConnectionConfiguration.java:119)
  88. 	... 65 common frames omitted
  89. 2020-12-24 14:12:15.874 ERROR org.springframework.boot.diagnostics.LoggingFailureAnalysisReporter - 
  90.  
  91. ***************************
  92. APPLICATION FAILED TO START

 

 ERROR org.apache.catalina.core.ContainerBase.

  1. Description:
  2.  
  3. The bean 'redisConnectionFactory', defined in class path resource [org/springframework/boot/autoconfigure/data/redis/LettuceConnectionConfiguration.class], could not be registered. A bean with that name has already been defined in BeanDefinition defined in class path resource [com/superman/globaldao/redis/RedisConfig.class] and overriding is disabled.
  4.  
  5. Action:
  6.  
  7. Consider renaming one of the beans or enabling overriding by setting spring.main.allow-bean-definition-overriding=true
  8.  
  9. 2020-12-24 15:57:58.669 ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is java.lang.NullPointerException] with root cause
  10. java.lang.NullPointerException: null
  11. 	at com.superman.global.core.ctr.RedistCtr.query(RedistCtr.java:44)
  12. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  13. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  14. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  15. 	at java.lang.reflect.Method.invoke(Method.java:498)
  16. 	at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)
  17. 	at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)
  18. 	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104)
  19. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892)
  20. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797)
  21. 	at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
  22. 	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039)
  23. 	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)
  24. 	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005)
  25. 	at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897)
  26. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
  27. 	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882)
  28. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
  29. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
  30. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  31. 	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
  32. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  33. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  34. 	at com.superman.conf.filter.XssAndSqlFilter.doFilter(XssAndSqlFilter.java:81)
  35. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  36. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  37. 	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)
  38. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
  39. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  40. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  41. 	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202)
  42. 	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
  43. 	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490)
  44. 	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)
  45. 	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
  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:408)
  49. 	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
  50. 	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:853)
  51. 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1587)
  52. 	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
  53. 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  54. 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  55. 	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
  56. 	at java.lang.Thread.run(Thread.java:748)
  57. 2020-12-24 16:08:16.013 ERROR org.springframework.boot.diagnostics.LoggingFailureAnalysisReporter - 
  58.  
  59. ***************************
  60. APPLICATION FAILED TO START
  61. ***************************

  

Command timed out after 300 millisecond(s)

  1. Consider revisiting the entries above or defining a bean of type 'org.springframework.data.redis.core.RedisTemplate' in your configuration.
  2.  
  3. 2020-12-24 16:29:10.795 ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.dao.QueryTimeoutException: Redis command timed out; nested exception is io.lettuce.core.RedisCommandTimeoutException: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)] with root cause
  4. io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)
  5. 	at io.lettuce.core.ExceptionFactory.createTimeoutException(ExceptionFactory.java:51)
  6. 	at io.lettuce.core.protocol.CommandExpiryWriter.lambda$potentiallyExpire$0(CommandExpiryWriter.java:167)
  7. 	at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
  8. 	at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:127)
  9. 	at io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:66)
  10. 	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
  11. 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  12. 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  13. 	at java.lang.Thread.run(Thread.java:748)
  14. 2020-12-24 16:29:32.654 ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.dao.QueryTimeoutException: Redis command timed out; nested exception is io.lettuce.core.RedisCommandTimeoutException: io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)] with root cause
  15. io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)
  16. 	at io.lettuce.core.ExceptionFactory.createTimeoutException(ExceptionFactory.java:51)
  17. 	at io.lettuce.core.protocol.CommandExpiryWriter.lambda$potentiallyExpire$0(CommandExpiryWriter.java:167)
  18. 	at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
  19. 	at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:127)
  20. 	at io.netty.util.concurrent.DefaultEventExecutor.run(DefaultEventExecutor.java:66)
  21. 	at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
  22. 	at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  23. 	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  24. 	at java.lang.Thread.run(Thread.java:748)
  25. 2020-12-24 16:31:15.241 ERROR org.apache.catalina.core.Conta

 

ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.dao.QueryTimeoutException: Redis command timed out; nested exception is io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)] with root cause

  1. 2020-12-24 16:38:30.727 ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.dao.QueryTimeoutException: Redis command timed out; nested exception is io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)] with root cause
  2. io.lettuce.core.RedisCommandTimeoutException: Command timed out after 300 millisecond(s)
  3. 	at io.lettuce.core.ExceptionFactory.createTimeoutException(ExceptionFactory.java:51)
  4. 	at io.lettuce.core.LettuceFutures.awaitOrCancel(LettuceFutures.java:114)
  5. 	at io.lettuce.core.FutureSyncInvocationHandler.handleInvocation(FutureSyncInvocationHandler.java:69)
  6. 	at io.lettuce.core.internal.AbstractInvocationHandler.invoke(AbstractInvocationHandler.java:80)
  7. 	at com.sun.proxy.$Proxy104.get(Unknown Source)
  8. 	at org.springframework.data.redis.connection.lettuce.LettuceStringCommands.get(LettuceStringCommands.java:66)
  9. 	at org.springframework.data.redis.connection.DefaultedRedisConnection.get(DefaultedRedisConnection.java:253)
  10. 	at org.springframework.data.redis.core.DefaultValueOperations$1.inRedis(DefaultValueOperations.java:57)
  11. 	at org.springframework.data.redis.core.AbstractOperations$ValueDeserializingRedisCallback.doInRedis(AbstractOperations.java:59)
  12. 	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:224)
  13. 	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  14. 	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  15. 	at org.springframework.data.redis.core.DefaultValueOperations.get(DefaultValueOperations.java:53)
  16. 	at com.superman.uitl.redis.RedisUtil.get(RedisUtil.java:90)
  17. 	at com.superman.global.core.ctr.RedistCtr.query(RedistCtr.java:43)
  18. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  19. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  20. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  21. 	at java.lang.reflect.Method.invoke(Method.java:498)
  22. 	at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)
  23. 	at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)
  24. 	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104)
  25. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892)
  26. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797)
  27. 	at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
  28. 	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039)
  29. 	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)
  30. 	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005)
  31. 	at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897)
  32. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
  33. 	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882)
  34. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
  35. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
  36. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  37. 	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
  38. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  39. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  40. 	at com.superman.conf.filter.XssAndSqlFilter.doFilter(XssAndSqlFilter.java:81)
  41. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  42. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  43. 	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)
  44. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
  45. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  46. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  47. 	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202)
  48. 	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
  49. 	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490)
  50. 	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)
  51. 	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
  52. 	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)
  53. 	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
  54. 	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408)
  55. 	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
  56. 	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:853)
  57. 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1587)
  58. 	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
  59. 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  60. 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  61. 	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
  62. 	at java.lang.Thread.run(Thread.java:748)

 

nested exception is org.springframework.data.redis.serializer.SerializationException: Could not read JSON: Unrecognized token 'sss': was expecting ('true', 'false' or 'null')

  1. 2020-12-24 16:50:07.288 ERROR org.apache.catalina.core.ContainerBase.[Tomcat].[localhost].[/].[dispatcherServlet] - Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.data.redis.serializer.SerializationException: Could not read JSON: Unrecognized token 'sss': was expecting ('true', 'false' or 'null')
  2.  at [Source: (byte[])"sss"; line: 1, column: 7]; nested exception is com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'sss': was expecting ('true', 'false' or 'null')
  3.  at [Source: (byte[])"sss"; line: 1, column: 7]] with root cause
  4. com.fasterxml.jackson.core.JsonParseException: Unrecognized token 'sss': was expecting ('true', 'false' or 'null')
  5.  at [Source: (byte[])"sss"; line: 1, column: 7]
  6. 	at com.fasterxml.jackson.core.JsonParser._constructError(JsonParser.java:1804)
  7. 	at com.fasterxml.jackson.core.base.ParserMinimalBase._reportError(ParserMinimalBase.java:703)
  8. 	at com.fasterxml.jackson.core.json.UTF8StreamJsonParser._reportInvalidToken(UTF8StreamJsonParser.java:3532)
  9. 	at com.fasterxml.jackson.core.json.UTF8StreamJsonParser._handleUnexpectedValue(UTF8StreamJsonParser.java:2627)
  10. 	at com.fasterxml.jackson.core.json.UTF8StreamJsonParser._nextTokenNotInObject(UTF8StreamJsonParser.java:832)
  11. 	at com.fasterxml.jackson.core.json.UTF8StreamJsonParser.nextToken(UTF8StreamJsonParser.java:729)
  12. 	at com.fasterxml.jackson.databind.ObjectMapper._initForReading(ObjectMapper.java:4141)
  13. 	at com.fasterxml.jackson.databind.ObjectMapper._readMapAndClose(ObjectMapper.java:4000)
  14. 	at com.fasterxml.jackson.databind.ObjectMapper.readValue(ObjectMapper.java:3129)
  15. 	at org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer.deserialize(Jackson2JsonRedisSerializer.java:73)
  16. 	at org.springframework.data.redis.core.AbstractOperations.deserializeValue(AbstractOperations.java:334)
  17. 	at org.springframework.data.redis.core.AbstractOperations$ValueDeserializingRedisCallback.doInRedis(AbstractOperations.java:60)
  18. 	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:224)
  19. 	at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:184)
  20. 	at org.springframework.data.redis.core.AbstractOperations.execute(AbstractOperations.java:95)
  21. 	at org.springframework.data.redis.core.DefaultValueOperations.get(DefaultValueOperations.java:53)
  22. 	at com.superman.uitl.redis.RedisUtil.get(RedisUtil.java:90)
  23. 	at com.superman.global.core.ctr.RedistCtr.query(RedistCtr.java:43)
  24. 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  25. 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  26. 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  27. 	at java.lang.reflect.Method.invoke(Method.java:498)
  28. 	at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:190)
  29. 	at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)
  30. 	at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104)
  31. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:892)
  32. 	at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:797)
  33. 	at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)
  34. 	at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1039)
  35. 	at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)
  36. 	at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005)
  37. 	at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897)
  38. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:634)
  39. 	at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882)
  40. 	at javax.servlet.http.HttpServlet.service(HttpServlet.java:741)
  41. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)
  42. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  43. 	at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)
  44. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  45. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  46. 	at com.superman.conf.filter.XssAndSqlFilter.doFilter(XssAndSqlFilter.java:81)
  47. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  48. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  49. 	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)
  50. 	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:118)
  51. 	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)
  52. 	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)
  53. 	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:202)
  54. 	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)
  55. 	at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490)
  56. 	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)
  57. 	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)
  58. 	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)
  59. 	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)
  60. 	at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408)
  61. 	at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)
  62. 	at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:853)
  63. 	at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1587)
  64. 	at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)
  65. 	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
  66. 	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
  67. 	at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)
  68. 	at java.lang.Thread.run(Thread.java:748)

 

 

 

介绍

1.加载依赖

2.加载配置

3.spring 配置类 bean 自动读取使用配置

4.工具类

5.调用服务控制层

6.调用测试

ok

 

代码

依赖

  1. <!-- 集成redis使用 -->
  2. 		<dependency>
  3. 			<groupId>org.springframework.boot</groupId>
  4. 			<artifactId>spring-boot-starter-data-redis</artifactId>
  5. 			<version>2.1.7.RELEASE</version>
  6. 		</dependency>
  7.  
  8. 		<dependency>
  9. 			<groupId>org.springframework.boot</groupId>
  10. 			<artifactId>spring-boot-starter-cache</artifactId>
  11. 		</dependency>
  12. 		
  13. 		<dependency>
  14. 			<groupId>org.apache.commons</groupId>
  15. 			<artifactId>commons-pool2</artifactId>
  16. 			<version>2.1</version>
  17. 		</dependency>
  18.  
  19. 		<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-context -->
  20. 		<dependency>
  21. 			<groupId>org.springframework.cloud</groupId>
  22. 			<artifactId>spring-cloud-context</artifactId>
  23. 			<version>2.1.6.RELEASE</version>
  24. 		</dependency>
  25.  
  26. 		<!-- 集成redis使用 -->

介绍

有缺少json的可以再把json 搞上 import com.fasterxml.jackson.annotation.JsonAutoDetect; 如下，或网上搜搜挺多的

  1. <dependency>
  2. <groupId>com.fasterxml.jackson.core</groupId>
  3. <artifactId>jackson-annotations</artifactId>
  4. </dependency>

 

参数值

  1. spring: 
  2.     redis:
  3.        #url: redis://user:password@127.0.0.1:6379 #该地址配置以后会重置host,port,password的规则。   
  4.        host: 127.0.0.1 
  5.        port: 6379
  6.        #密码
  7.        password: 123456
  8.        database: 0 #指定数据库，默认为0
  9.        timeout: 300 #连接超时时间，单位毫秒，默认为0
  10.        ssl: false # 是否启用SSL连接，默认false
  11.        jedis: 
  12.           pool: #连接池配置
  13.               max-active: 8 #最大活跃连接数，默认8个。
  14.               max-idle: 8 #最大空闲连接数，默认8个。
  15.               max-wait: -1 #获取连接的最大等待时间，默认-1，表示无限制，单位毫秒。默认值可能会因为获取不到连接，导致事务无法提交，数据库被锁，大量线程处于等待状态的情况。
  16.               min-idle: 0 #最小空闲连接数，默认0。
  17.        #sentinel:
  18.        #    master: mymaster #哨兵mastser
  19.        #    nodes: host1:port,host2:port #哨兵节点
  20.        #cluster:
  21.        #    max-redirects: # 集群模式下，集群最大转发的数量
  22.        #    nodes: host1:port,host2:port # 集群节点

这个spring 前边有可能有个空格注意，不过也没啥大事，启动的时候要是系统报错也就看到了，你肯定没关注这句话，也可能页面自动给加载没了那个空格，自行关注吧

 

配置加载参数类 RedisConfig

  1. package com.superman.globaldao.redis;
  2.  
  3. import org.springframework.context.annotation.Bean;
  4. import org.springframework.context.annotation.Configuration;
  5. import org.springframework.data.redis.connection.RedisConnectionFactory;
  6. import org.springframework.data.redis.core.RedisTemplate;
  7. import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
  8. import org.springframework.data.redis.serializer.StringRedisSerializer;
  9.  
  10. import com.fasterxml.jackson.annotation.JsonAutoDetect;
  11. import com.fasterxml.jackson.annotation.PropertyAccessor;
  12. import com.fasterxml.jackson.databind.ObjectMapper;
  13.  
  14. /**
  15.  * redis 配置<br/>
  16.  * ----redisTemplate 中的 判断key是否纯在 接口 会一直返回false <br/>
  17.  * ----采用 get(key)==null 来判断是否存在<br/>
  18.  * <label style="color:red;">
  19.  * 这里服务使用json 序列号，所以 上传的每个key val 要使用这里服务的 get set  如果直接使用redis-cli 有时候会解析不出来
  20.  * </label>
  21.  * 
  22.  * @author jianghy
  23.  *
  24.  * @version 1.0
  25.  */
  26. @Configuration
  27. public class RedisConfig {
  28.  
  29. 	@Bean
  30. 	@SuppressWarnings("all")
  31. 	public RedisTemplate<String, Object> redisTemplate( RedisConnectionFactory factory) {
  32. 		RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
  33. 		template.setConnectionFactory(factory);
  34. 		Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer( Object.class);
  35. 		ObjectMapper om = new ObjectMapper();
  36. 		om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  37. 		om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  38. 		jackson2JsonRedisSerializer.setObjectMapper(om);
  39. 		StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
  40. 		// key采用String的序列化方式
  41. 		template.setKeySerializer(stringRedisSerializer);
  42. 		// hash的key也采用String的序列化方式
  43. 		template.setHashKeySerializer(stringRedisSerializer);
  44. 		// value序列化方式采用jackson
  45. 		template.setValueSerializer(jackson2JsonRedisSerializer);
  46. 		// hash的value序列化方式采用jackson
  47. 		template.setHashValueSerializer(jackson2JsonRedisSerializer);
  48. 		template.afterPropertiesSet();
  49. 		return template;
  50. 	}
  51.  
  52. }

 

工具类 RedisUtil

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

 

调用测试类 RedistCtr

  1. package com.superman.global.core.ctr;
  2.  
  3. import javax.servlet.http.HttpServletRequest;
  4.  
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.RequestMapping;
  7. import org.springframework.web.bind.annotation.RestController;
  8.  
  9. import com.alibaba.druid.support.logging.Log;
  10. import com.alibaba.druid.support.logging.LogFactory;
  11. import com.superman.uitl.redis.RedisUtil;
  12.  
  13. /**
  14.  * 调用redis服务
  15.  *
  16.  * @author jianghy
  17.  *
  18.  * @version 1.0
  19.  */
  20. @RestController
  21. @RequestMapping("/RedisttestCtr")
  22. public class RedisttestCtr {
  23. 	
  24. 	private final static Log log = LogFactory.getLog(RedisttestCtr.class);
  25.  
  26. 	@Autowired
  27. 	private RedisUtil ru;
  28. 	
  29. 	/**
  30. 	 * reids 查看 key 
  31. 	 * 
  32. 	 * @param key 查询key
  33. 	 * 
  34. 	 * @return
  35. 	 */
  36. 	@RequestMapping(value="/query", produces = "text/html;charset=UTF-8;")
  37. 	public String query(HttpServletRequest req){
  38. 		String userid = req.getParameter("userid");
  39. 		String key = req.getParameter("key")==null?"":req.getParameter("key");
  40. 		log.info(userid+" get redis key:"+key);
  41. 		if(key.equals(""))return "params error";
  42. 		 
  43. 		Object c = ru.get(key);
  44. 		System.out.println(c);
  45. 		return c==null?"null":c.toString();
  46.  
  47. 		
  48. 	}
  49. 	
  50. 	/**
  51. 	 * reids 添加  key 
  52. 	 * 
  53. 	 * @param key 查询key
  54. 	 * @param val 查询val
  55. 	 * 
  56. 	 * @return
  57. 	 */
  58. 	@RequestMapping(value="/execute", produces = "text/html;charset=UTF-8;")
  59. 	public String execute(HttpServletRequest req){
  60. 		String userid = req.getParameter("userid");
  61. 		String key = req.getParameter("key")==null?"":req.getParameter("key");
  62. 		String val = req.getParameter("val")==null?"":req.getParameter("val");
  63. 		log.info(userid+" get redis key:"+key);
  64. 		if(key.equals(""))return "params error";
  65. 		boolean rest = ru.set(key,val);
  66. 		return rest==true?"success":"fial";
  67. 				
  68. 	}
  69. 	
  70. 	
  71. 	
  72. 	
  73. 	
  74. 	
  75. 	
  76. }

 

页面访问地址

https://localhost:9087/RedisttestCtr/query?key=aa

https://localhost:9087/RedisttestCtr/execute?key=aa&val=ss

 

踩坑记录及解决方法思路

踩坑种类

1.序列化问题

2.未启动redis

3.redis 加载卡住

4.加载参数为加载

5.jedis 和 其他pool 的问题

6.泛型<Stirng,String> <String,Object>

7.各类问题，使用如上这批代码即可

8.hashKey 一直返回false 问题

9.redis-cli 上传的 set  值 和 程序set 上的值不一样，导致无法解析出报错

10.都用如上这批代码即可

 

 

 

 

 

 

ok

 

 

 

 

 

 

持续更新

 

 

 

 

 

 

 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/251164
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号