首页 / JAVA / java – Spring注释@Retryable – 如何设置拦截器

java – Spring注释@Retryable – 如何设置拦截器

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – Spring注释@Retryable – 如何设置拦截器，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4142字，纯文字阅读大概需要6分钟。

内容图文

我在@Serviceclass中的方法上使用@Retryable注释

@Service
@EnableRetry 
public class PushService {

    @Retryable(maxAttempts=5)
    public Result pushIt(myMessage messageIn) {
        ...
    }
}

它就像一个魅力：我直接从RabbitMQ收到一条消息,直到没有错误或者尝试次数达到5次才会被确认,并且当时消息直接进入DLQ,就像我一样通缉.

我唯一的问题是我需要从属性文件中动态设置maxAttempts.解决方案应该是设置一个拦截器,但是唯一一个导致错误的事实,例如当我有：

@Service
@EnableRetry 
public class PushService {

    @Retryable(interceptor="myInterceptor") 
    public Result pushIt(myMessage messageIn) {
        ...
    }
}

其中myInterceptor定义为：

@Bean
public StatefulRetryOperationsInterceptor myInterceptor() {
    return RetryInterceptorBuilder.stateful().maxAttempts(5).build();
}

我得到一个无限循环,但有以下异常：

2015-04-08 07:12:10,970 GMT [SimpleAsyncTaskExecutor-1] (ConditionalRejectingErrorHandler.java:67) WARN  listener.ConditionalRejectingErrorHandler: Execution of Rabbit message listener failed.
org.springframework.amqp.rabbit.listener.exception.ListenerExecutionFailedException: Listener threw exception
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.wrapToListenerExecutionFailedExceptionIfNeeded(AbstractMessageListenerContainer.java:864)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:802)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:690)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$001(SimpleMessageListenerContainer.java:82)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$1.invokeListener(SimpleMessageListenerContainer.java:167)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.invokeListener(SimpleMessageListenerContainer.java:1241)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.executeListener(AbstractMessageListenerContainer.java:660)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.doReceiveAndExecute(SimpleMessageListenerContainer.java:1005)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.receiveAndExecute(SimpleMessageListenerContainer.java:989)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer.access$700(SimpleMessageListenerContainer.java:82)
    at org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer$AsyncMessageProcessingConsumer.run(SimpleMessageListenerContainer.java:1103)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ArrayIndexOutOfBoundsException: 1
    at org.springframework.amqp.rabbit.config.StatefulRetryOperationsInterceptorFactoryBean$3.getKey(StatefulRetryOperationsInterceptorFactoryBean.java:103)
    at org.springframework.retry.interceptor.StatefulRetryOperationsInterceptor.invoke(StatefulRetryOperationsInterceptor.java:132)
    at org.springframework.retry.annotation.AnnotationAwareRetryOperationsInterceptor.invoke(AnnotationAwareRetryOperationsInterceptor.java:118)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179)
    at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:653)
    at com.acme.push.service.PushService$$EnhancerBySpringCGLIB$$9d503bc1.pushMessage(<generated>)
    at com.acme.push.receiver.PushListener.onMessage(PushListener.java:42)
    at org.springframework.amqp.rabbit.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:799)
    ... 10 more

我很确定我保持它太简单了,但我没有找到可能导致此错误的原因的线索以及如何解决它,任何人都知道发生了什么？

解决方法:

不使用注释@Retryable来使用org.springframework.amqp.rabbit.config.RetryInterceptorBuilder的目的.

其目的是与SimpleRabbitListenerContainerFactory类的建议链一起使用.
请参阅参考文档receiving-messages和SimpleMessageListenerContainer#invokeListener签名：

@Override
protected void invokeListener(Channel channel, Message message) throws Exception {
    proxy.invokeListener(channel, message);
}

一旦使用适当的RetryInterceptor配置建议链,您的注释将毫无用处.

内容总结

以上是互联网集市为您收集整理的java – Spring注释@Retryable – 如何设置拦截器全部内容，希望文章能够帮你解决java – Spring注释@Retryable – 如何设置拦截器所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/794238.html

来源：【匿名】

【上一篇】Java开发桌面程序学习（八）——开源库 JFXUtils 让你更简单地进行JavaFX开发【下一篇】JAVA/JSP学习系列之五

更多 ►

【java – Spring注释@Retryable – 如何设置拦截器】教程文章相关的互联网学习教程文章

java中的对象的序列化，以及新的try...catch块学习

对象的序列化和反序列化：1、对象的序列需要实现java.util.Serializable或者是java.io.Externalizable接口。2、Serializable只是一个接口，代表着可序列化，并没有定义任何的抽象方法，只能序列化非静态的，以及没有使用transient关键字修饰的属性，使用此接口最好声明一个“private static final long serialVersionUID = 1L;”常量，确保在类的修改等操作之后，也能够反序列化3、其中Externalizable接口继承Serializab...

后端JSP文件里Java语言如果操作Oracle Spatial提供的JGeometry对象

记个流水账，记录下这个困扰自己多时的问题最后怎么解决的。当时觉得该尝试的都尝试了，纳闷到底怎样能解决的，最后还是解决了~正确的代码如下：<%@ page contentType="text/html; charset=gb2312" language="java" import="java.sql.*,java.lang.*,oracle.spatial.geometry.*,oracle.spatial.util.*,oracle.sql.*" errorPage="" %> <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml...

java function retry wrapper【代码】

import java.util.concurrent.Callable;/*** Created by huahui.yang on 1/29/16.*/publicclass RetryWrapper<A> {public A retry(Callable<A> callable) throws Exception {A result = null;for (int i = 0; i < 3; i++) {System.out.println("retry time remain:" + (3 - i));try {result = callable.call();break;} catch (Exception e) {}}return result;} }/*** Created by huahui.yang on 1/29/16.*/publicclass JOB {public...

java7新特性之Try-with-resources (TWR)【图】

java7新特性之Try-with-resources (TWR)This change is easy to explain, but it has proved to have hidden subtleties, which made it much less easy to implement than originally hoped. The basic idea is to allow a resource (for example, a file or something a bit like one) to be scoped to a block in such a way that the resource is automatically closed when control exits the block. This is an important ch...

java里的finally与try catch块的return的执行顺序【代码】

代码int a =1; try {return a; }finally {return 2; }上面这段代码最终会返回 2 ，因为finally一定会程序return返回之前执行。当程序执行到try 块里的return时，因为finally还没有执行，所以这里程序并不会返回，而是接着执行finally块的代码，由于finally里的代码有个return语句，所以执行到这里程序结束。再看一段代码，这里程序执行到try块的return语句时，由于还有个finally块没执行，于是程序没有返回，接着执行finally块，fi...

java异常，try...catch...finally代码执行情况，以及代码最终返回值详解

（1）finally块中的代码是无论try中是否发生异常，也无论catch是否可以捕获异常，也不管try和catch中是否有return语句，都会执行的部分（2）如果finally中有return语句，那么try...catch...finally结构一定从finally中的return回去（3）如果finally中没有return语句，那么try...catch...finally结构才会从try或catch中的return回去，但是finally值中代码不会影响最终的返回值public static void main(String[] args) { 　　int t...

Java-try-catch-finally【代码】【图】

try-catch语句还可以包括第三部分，就是finally子句。它表示无论是否出现异常，都应当执行的内容。try-catch-finally语句的一般语法形式为：try { // 可能会发生异常的程序代码 } catch (Type1 id1) { // 捕获并处理try抛出的异常类型Type1 } catch (Type2 id2) { // 捕获并处理try抛出的异常类型Type2 } finally { // 无论是否发生异常，都将执行的语句块 } 带finally子句的异常处理程序。publicclass TestException...

java-基础-【三】try/catch/finally【代码】

原文地址：https://my.oschina.net/bieber/blog/703251一、单层的try/catchpublicint test(int a,int b){try{return a+b;}catch (Exception e){thrownew CustomException();} }通过javap -v查看JVM编译成class字节码之后是如何处理这个try/catch的publicint test(int, int);flags: ACC_PUBLICCode:stack=2, locals=4, args_size=30: iload_1 // 将第一个int参数压入队列（第一个入参）1: iload_2 ...

java：try...catch...finally

try...catch...finally 规则:可以没有 finally 块如果没有 catch 块，则必须跟一个 finally 块当在 try 块或 catch 块中遇到 return 语句时，finally 语句块将在 return 之前被执行。在以下4种特殊情况下，finally 块不会被执行:在 finally 语句块中发生了异常。在前面的代码中用了 System.exit() 退出程序。程序所在的线程死亡。关闭CPU。原文：https://www.cnblogs.com/cag2050/p/10472723.html

Javascript try catch finally【代码】

来个不会卖萌的函数吧：//public.js//异常输出 function exception(ex) {console.log("@大哥，发现异常信息,开始记录...");console.log("异常类型：" + ex.name);console.log("异常信息：" + ex.message);console.log("行号：" + ex.lineNumber);console.log("文件名：" + ex.fileName);//console.log("堆栈：" + ex.stack);console.log("异常记录完成...@大哥，快来看啊！"); }//Firefox测试过是正常的，其他浏览器自己试吧...调用...

java7 try-with-resources【代码】

在 java7之前，java的异常处理结构是 try catch finally , try代码块里打开的资源，它们的关闭都得放到finally里，挺繁琐的一个语法规则，相信被广大开发者吐槽过。举个简单例子看下：publicstaticvoid main(String[] args) {File file = new File("/workspace/test.txt") ;FileInputStream fis = null ;try {fis = new FileInputStream(file) ;StringBuffer buffer = new StringBuffer() ;int c ;while ((c =fis.read()) !=...

[CareerCup] 14.2 Try-catch-finally Java中的异常处理

14.2 In Java, does the finally block get executed if we insert a return statement inside the try block of a try-catch-finally? 这道题问我们Java中的finally块是否会被执行，当我们在try中加入了返回return。答案是即便try中加入了return或者continue或者break等命令，finally块仍然会被执行。但是下列两种情况下finally里的内容不会被执行：1. 当虚拟机Virtual Machine在try/catch模块中就退出了的时候2. 当线程在处理try...

Java 中的 try catch 影响性能吗？【图】

前几天在 code review 时发现有一段代码中存在滥用try catch的现象。其实这种行为我们也许都经历过，刚参加工作想尽量避免出现崩溃问题，因此在很多地方都想着 try catch一下。但实际上这种习惯不仅会让代码很难看，更会影响代码的运行性能。有些人会觉得，不就是一个 try catch 么，怎么会影响性能啊。那就让我们来测试看看吧。实验首先，我们看看没有try-catch情况下，进行100万次加法的耗时：经过5次统计，其平均耗时为：18160...

java-资源管理器try-with-resource【代码】

在java编程中会遇到很多关闭资源的问题，但是，往往我们的关闭不能百分百正确，所以java7中出现了新的资源管理器方法try-with-resource，这是一项重要的改进，因为没人能再手动关闭资源时做到100%正确，有人在想Coin项目提交这一提案时，提交者宣称jdk中有三分之二的close()用法都有bug，汗颜。 java6资源管理器的做法，简写InputStream in = null;try{is = url.openStream();OutputStream out = new FileOutputStream(file);.....

RxJava retryWhen操作符实现错误重试机制【代码】

业务需求当我们在app里发起网络请求时，可能会因为各种问题导致失败。如何利用RxJava来实现出现错误后重试若干次，并且可以设定重试的时间间隔。具体实现网络请求使用Retrofit来做，请求用户信息接口@GET("/userinfo?noToken=1")Observable<Response> getUserInfoNoToken();请求用户信息接口的逻辑代码userApi.getUserInfoNoToken()//总共重试3次，重试间隔3000毫秒.retryWhen(new RetryWithDelay(3, 3000)).observeOn(AndroidSche...

首页 / JAVA / java – Spring注释@Retryable – 如何设置拦截器

java – Spring注释@Retryable – 如何设置拦截器

内容导读

内容图文

内容总结

内容备注

内容手机端

【java – Spring注释@Retryable – 如何设置拦截器】教程文章相关的互联网学习教程文章

java中的对象的序列化，以及新的try...catch块学习

后端JSP文件里Java语言如果操作Oracle Spatial提供的JGeometry对象

java function retry wrapper【代码】

java7新特性之Try-with-resources (TWR)【图】

java里的finally与try catch块的return的执行顺序【代码】

java异常，try...catch...finally代码执行情况，以及代码最终返回值详解

Java-try-catch-finally【代码】【图】

java-基础-【三】try/catch/finally【代码】

java：try...catch...finally

Javascript try catch finally【代码】

java7 try-with-resources【代码】

[CareerCup] 14.2 Try-catch-finally Java中的异常处理

Java 中的 try catch 影响性能吗？【图】

java-资源管理器try-with-resource【代码】

RxJava retryWhen操作符实现错误重试机制【代码】

SPRING - 相关标签

JAVA - 相关标签

TRY - 相关标签

JAVA - 技术教程分类

JAVA - 最新教程

JAVA - 最热教程