专栏首页工作笔记精华RedisTemplate执行lua脚本,集群模式下报错解决

RedisTemplate执行lua脚本,集群模式下报错解决

redis集群配置:

在使用spring的RedisTemplate执行lua脚本时,报错EvalSha is not supported in cluster environment,不支持cluster。

代码:

 @Test
     public void test4() throws Exception {
         DefaultRedisScript script = new DefaultRedisScript();
         script.setScriptSource(new StaticScriptSource("redis.call('SET', KEYS[1], ARGV[1]); return ARGV[1]"));
         script.setResultType(String.class);
         Object result = redisTemplate.execute(script, Arrays.asList("test_key1"), Arrays.asList("hello,key1"));
         System.out.println(result);
     }
 报错信息:
org.springframework.dao.InvalidDataAccessApiUsageException: EvalSha is not supported in cluster environment.
 
     at org.springframework.data.redis.connection.jedis.JedisClusterConnection.evalSha(JedisClusterConnection.java:3561)
     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
     at java.lang.reflect.Method.invoke(Method.java:498)
     at org.springframework.data.redis.core.CloseSuppressingInvocationHandler.invoke(CloseSuppressingInvocationHandler.java:57)
     at com.sun.proxy.$Proxy136.evalSha(Unknown Source)
     at org.springframework.data.redis.core.script.DefaultScriptExecutor.eval(DefaultScriptExecutor.java:81)
     at org.springframework.data.redis.core.script.DefaultScriptExecutor$1.doInRedis(DefaultScriptExecutor.java:71)
     at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:207)
     at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:169)
     at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:157)
     at org.springframework.data.redis.core.script.DefaultScriptExecutor.execute(DefaultScriptExecutor.java:60)
     at org.springframework.data.redis.core.script.DefaultScriptExecutor.execute(DefaultScriptExecutor.java:54)
     at org.springframework.data.redis.core.RedisTemplate.execute(RedisTemplate.java:300)
     at com.wwwarehouse.xdw.contractcenter.zzz.RedisTest.test4(RedisTest.java:70)
     at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
     at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
     at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
     at java.lang.reflect.Method.invoke(Method.java:498)
     at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
     at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
     at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
     at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
     at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)
     at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
     at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
     at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:252)
     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94)
     at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
     at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
     at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
     at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
     at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
     at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
     at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
     at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
     at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191)
     at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
     at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
     at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51)
     at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:242)
     at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
 

但是redis是支持lua脚本的,只要拿到原redis的connection对象,通过connection去执行即可:

 @Test
     public void test5() throws Exception {
         List<String> keys = new ArrayList<String>();
         keys.add("test_key1");
         List<String> args = new ArrayList<String>();
         args.add("hello,key1");
         String LUA = "redis.call('SET', KEYS[1], ARGV[1]); return ARGV[1]";
         //spring自带的执行脚本方法中,集群模式直接抛出不支持执行脚本异常,此处拿到原redis的connection执行脚本
         String result = (String)redisTemplate.execute(new RedisCallback<String>() {
             public String doInRedis(RedisConnection connection) throws DataAccessException {
                 Object nativeConnection = connection.getNativeConnection();
                 // 集群模式和单点模式虽然执行脚本的方法一样,但是没有共同的接口,所以只能分开执行
                 // 集群
                 if (nativeConnection instanceof JedisCluster) {
                     return (String) ((JedisCluster) nativeConnection).eval(LUA, keys, args);
                 }
 
                 // 单点
                 else if (nativeConnection instanceof Jedis) {
                     return (String) ((Jedis) nativeConnection).eval(LUA, keys, args);
                 }
                 return null;
             }
         });
         System.out.println(result);
     }
 输出: hello,key1

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • tried to access method com.google.common.base.Stopwatch

    Caused by: org.apache.hadoop.hbase.DoNotRetryIOException: java.lang.IllegalAcces...

    stys35
  • Flink * 转

    stys35
  • flink-connector-kafka 冲突

    我的博客即将同步至腾讯云+社区,邀请大家一同入驻:https://cloud.tencent.com/developer/support-plan?invite...

    stys35
  • redis 反序列化deserialize异常问题解决

    可以看出是sping对redis查询的返回结果进行deserialize的时候出错了

    MickyInvQ
  • Redis一次Read time out引发的过期key删除策略分析

    一台业务CVM调用主从版的Redis偶发性的会出现客户端jedis抛出 SocketTimeoutException: Read time out 的报错,报错...

    elontian田凌翔
  • 又出生产事故!那些年我曾犯过的错-SecureRandom

    本人上周亲手写下了一个牛逼的bug,直接导致的结果是,晚上12点升级后台接口以后,第二天早上7点多开始,所有的app页面出现卡顿,白屏。

    黄泽杰
  • java.sql.SQLException: connection holder is null

    java.sql.SQLException: connection holder is null

    一个会写诗的程序员
  • 杨校老师课堂之Java基础集合专题知识点整理

    LinkedList是List的子类,List中的方法LinkedList都是可以使用,这里就不做详细介绍,我们只需要了解LinkedList 的特有方法即可。...

    杨校
  • DeepLearningNotes

    f(\frac{x_1+x_2}{2})\leq{\frac{f(x_1)+f(x_2)}{2}}

    DuncanZhou
  • There is no known eureka server; cluster server list is empty

    IT云清

扫码关注云+社区

领取腾讯云代金券