在自定义方法上使用@Async 注释处理异步过程中的错误与@Gateways 方法

问题描述

我有一个过程，我需要将文件异步上传到 Sftp 服务器。因此，在探索了有关网关中异步的更多信息后，我发现我需要在 @MessagingGateway 参数中定义错误通道，然后处理程序来处理传播到错误通道的异常，但我觉得以这种方式处理对我来说很复杂，因为我将有根据文件上传、成功或失败更新 Pojo 字段并持久化到数据库中。

于是想到了自定义方法，用@Async注解，调用网关方法。还用 try 块包围网关方法并捕获下游发生的任何异常

代码示例：

 @Async
void upload(Resource file,FileStatus fileStatus){
    try{
        uploadGateway.upload(file,fileStatus.getFilePath(),fileStatus.getFileName());
    }catch(RuntimeException e){
        fileStatus.setUploadStatus("Failed");
        //save into db
    }
}

上传网关没有错误通道，以便将错误返回给调用者

 @MessagingGateway
 public interface UploadGateway {


@Gateway(requestChannel = "input.channel")
void upload(@Payload Resource file,@Header("path") String path,@Header("name") String fileName);
}

处理程序：

 @Bean
public IntegrationFlow uploadDocument() {
    return IntegrationFlows.from("input.channel")
            .log(LoggingHandler.Level.WARN)
            .handle(Sftp.outboundAdapter(sftpSessionFactory(),FileExistsMode.FAIL)
                    .autocreateDirectory(true)
                    .remoteDirectoryExpression("headers['path']")
                    .fileNameExpression("headers['name']"))
            .get();
}

问题： 如果我以这种方式处理错误，会有什么后果？这是处理下游流程中发生的任何错误的正确方法吗？

解决方法

由于 @MessagingGateway 就像消息传递中的 RPC，因此在其方法调用中捕获异常是完全可以的。由于您使流程完全同步，因此它的工作方式类似于典型的 Java 异常子系统。

您对使用 errorChannel 进行异步错误处理的担忧确实有道理，因为它与标准 Java 异步方法处理及其错误处理的复杂性相似。

另一方面，如果在其他流程中将是一些复杂的逻辑，那么通过 errorChannel 处理下游错误是非常值得推荐的。另外，您将返回一些补偿信息。

然而，最终选择权在您手中：自己处理错误没有任何缺点。

请参阅Error Handling章节了解更多值得思考的食物。