spring集成中的错误处理

Question

我有三种不同的系统。我使用Spring integration来同步所有这些系统中的数据。

<int-http:inbound-gateway id="gateway"
    path="/save" supported-methods="POST, PUT"
    request-channel="requestChannel" reply-channel="replyChannel"
    request-payload-type="com.model.Request"
    mapped-request-headers="source" error-channel="errorChannel" />

系统2将调用服务方法来持久化数据，如果请求有效，则返回响应，否则抛出异常

<int:service-activator ref="serviceMethod"
    method="saveIfValid" input-channel="requestChannel"
    output-channel="serviceOutput" />

<int:recipient-list-router id="id1"
    input-channel="serviceOutput">
    <int:recipient channel="system1" />
    <int:recipient channel="system3" />
</int:recipient-list-router>

我需要发送服务方法响应到系统1和系统3，只有当操作成功。调用服务方法后，根据服务方法响应，使用Transformer生成对系统3的请求。在transformer之后，我将请求放入mq队列。

<int:transformer id="transformer1"
    method="convert" input-channel="system3"
    output-channel="jmsInput">
    <bean
        class="com.transformer.System3Transformer" />
</int:transformer> 


<int-jms:outbound-channel-adapter id="adapter"
    channel="jmsInput" destination-name="queueName">
</int-jms:outbound-channel-adapter>

更新的JMS出站代码

<int-jms:outbound-channel-adapter id="jms1"
		channel="jmsIn" destination-name="queueName">
		<int-jms:request-handler-advice-chain>
			<bean
				class="org.springframework.integration.handler.advice.ExpressionEvaluatingRequestHandlerAdvice">
				 <property name="onSuccessExpression" value="T(Boolean).TRUE" />
				<property name="successChannelName" value="afterSuccessDeleteChannel" />
			    <property name="onFailureExpression" value="T(Boolean).FALSE" />
				<property name="failureChannelName" value="afterFailRenameChannel" />
			</bean>
		</int-jms:request-handler-advice-chain>
	</int-jms:outbound-channel-adapter>

• 如果服务类失败，我需要发送错误响应并停止流
• 如果服务方法成功持久化数据，但转换失败，系统1将获得成功响应，并记录错误。
• 这里，由于我在出站适配器中使用错误通道，即使transformer中发生错误，它也会返回到系统1。
• 请建议如何在不使用全局错误通道的情况下处理错误，以及如何在jms出站适配器中处理错误。
  • 谢谢你回答我的问题

Answer 1

对于第一种情况，您实际上应该只依赖异常传播-流停止，错误作为HTTP响应发送到system1。

对于第二种情况(Transformer)，您应该研究一下ExpressionEvaluatingRequestHandlerAdvise，并将其与 的 一起使用。

对于 ，如果您应该确认System1，也可以应用同样的方法。

http://docs.spring.io/spring-integration/reference/html/messaging-endpoints-chapter.html#expression-advice

https://github.com/spring-projects/spring-integration-samples/tree/master/medire/retry-more