活动 网站 源码,苏州网络推广企业,内蒙古呼和浩特天气预报,如皋市建设局网站1.引言 有时在调用Web服务时#xff0c;我们可能有兴趣在发生错误的情况下重试该操作。 使用Spring Integration时#xff0c;我们可以使用RequestHandlerRetryAdvice类实现此功能。 此类将使我们在放弃并引发异常之前重试指定次数的操作。 这篇文章将向您展示如何完成此任务… 1.引言 有时在调用Web服务时我们可能有兴趣在发生错误的情况下重试该操作。 使用Spring Integration时我们可以使用RequestHandlerRetryAdvice类实现此功能。 此类将使我们在放弃并引发异常之前重试指定次数的操作。 这篇文章将向您展示如何完成此任务。 测试应用程序将调用Web服务如果响应失败它将等待指定的时间然后重试直到收到响应或达到重试限制为止。 如果达到限制失败的请求将被存储到数据库中。 主要这篇文章显示以下示例 使用出站网关调用Web服务 配置重试建议以在必要时重试该操作 MongoDB集成。 该应用程序的源代码可以在github上找到。 您还可以在github上获取由应用程序调用的Web服务项目的源代码。 2.Web服务调用 用例 客户端调用Web服务并接收响应。 该请求通过“系统入口”网关进入消息传递系统。 然后它到达出站网关调用Web服务并等待响应。 收到响应后将其发送到响应通道。 上图是此配置的结果 context:component-scan base-packagexpadro.spring.integration /!-- Initial service request --
int:gateway idsystemEntry default-request-channelrequestChannelservice-interfacexpadro.spring.integration.gateway.ClientService /int:channel idrequestChannelint:queue /
/int:channelint-ws:outbound-gateway idmarshallingGatewayrequest-channelrequestChannel reply-channelresponseChannelurihttp://localhost:8080/spring-ws/orders marshallermarshallerunmarshallermarshallerint:poller fixed-rate500 /
/int-ws:outbound-gatewayoxm:jaxb2-marshaller idmarshaller contextPathxpadro.spring.integration.types /!-- Service is running - Response received --
int:channel idresponseChannel /int:service-activator refclientServiceActivator methodhandleServiceResult input-channelresponseChannel / 映射到响应通道的是一个服务激活器它仅记录结果。 TestInvocation.java将请求发送到入口网关 ContextConfiguration({classpath:xpadro/spring/integration/config/int-config.xml,classpath:xpadro/spring/integration/config/mongodb-config.xml})
RunWith(SpringJUnit4ClassRunner.class)
public class TestInvocation {private Logger logger LoggerFactory.getLogger(this.getClass());Autowiredprivate ClientService service;Testpublic void testInvocation() throws InterruptedException, ExecutionException {logger.info(Initiating service request...);ClientDataRequest request new ClientDataRequest();request.setClientId(123);request.setProductId(XA-55);request.setQuantity(new BigInteger(5));service.invoke(request);logger.info(Doing other stuff...);Thread.sleep(60000);}
} 使用此配置如果服务调用失败则将引发MessagingException并将其发送到错误通道。 在下一节中我们将添加重试配置。 3.添加重试建议 用例 初始请求失败因为该服务未激活。 我们将重试该操作直到从服务收到响应为止。 在这种情况下我们需要将重试建议添加到Web服务出站网关 int-ws:outbound-gateway idmarshallingGateway interceptorclientInterceptorrequest-channelrequestChannel reply-channelresponseChannelurihttp://localhost:8080/spring-ws/orders marshallermarshallerunmarshallermarshallerint:poller fixed-rate500 /int-ws:request-handler-advice-chainref beanretryAdvice //int-ws:request-handler-advice-chain
/int-ws:outbound-gateway 现在Web服务出站网关会将调用委派给重试建议重试建议将按指定的次数尝试操作多次直到从服务获得响应为止。 让我们定义重试建议 bean idretryAdvice classorg.springframework.integration.handler.advice.RequestHandlerRetryAdvice property nameretryTemplatebean classorg.springframework.retry.support.RetryTemplateproperty namebackOffPolicybean classorg.springframework.retry.backoff.FixedBackOffPolicyproperty namebackOffPeriod value4000 //bean/propertyproperty nameretryPolicybean classorg.springframework.retry.policy.SimpleRetryPolicyproperty namemaxAttempts value4 //bean/property/bean/property
/bean 为了实现其目标建议使用RetryTemplate该模板由Spring Retry项目提供。 我们可以通过定义退避和重试策略来自定义其行为。 退避政策 在每次重试之间建立一段时间。 更有趣的类型是 FixedBackOffPolicy 在我们的示例中使用。 每次重试之间将等待相同的指定时间。 ExponentialBackOffPolicy 从确定的时间量开始它将使每次重试的时间加倍。 您可以通过建立乘数来更改默认行为。 重试策略 确定将重试失败操作的次数。 一些类型 SimpleRetryPolicy 在我们的示例中使用。 指定重试次数限制。 ExceptionClassifierRetryPolicy 允许我们根据引发的异常来建立不同的maxAttempts。 TimeoutRetryPolicy 将继续重试直到达到超时为止。 4不走运记录失败的请求 用例 服务将无法恢复无法将请求存储到数据库中。 配置的最后部分如下 !-- Log failed invocation --
int:service-activator refclientServiceActivator methodhandleFailedInvocation input-channelerrorChannel output-channellogChannel /int:channel idlogChannel /bean idmongoDbFactory classorg.springframework.data.mongodb.core.SimpleMongoDbFactoryconstructor-argbean classcom.mongodb.Mongo//constructor-argconstructor-arg valuetest/
/beanint-mongodb:outbound-channel-adapter idmongodbAdapter channellogChannelcollection-namefailedRequests mongodb-factorymongoDbFactory / 订阅错误通道的服务激活器将检索失败的消息并将其发送到出站适配器出站适配器会将其插入到mongoDB数据库中。 服务激活器 public Message? handleFailedInvocation(MessagingException exception) {logger.info(Failed to succesfully invoke service. Logging to DB...);return exception.getFailedMessage();
} 如果我们未能成功从服务获得响应则该请求将存储到数据库中 六结论 我们已经了解了Spring Integration如何从Spring Retry项目获得支持以实现操作的重试。 我们使用了int-wsrequest-handler-advice-chain 但是int命名空间也支持此元素以将该功能添加到其他类型的端点。 参考在XavierPadró的Blog博客上我们的JCG合作伙伴 Xavier Padro 使用RequestHandlerRetryAdvice重试了Web服务操作 。 翻译自: https://www.javacodegeeks.com/2014/02/retry-web-service-operations-with-requesthandlerretryadvice.html
