如何在SFTP Sink写入文件后触发通知或调用服务（无需新增流）

• 自定义SFTP Sink的写入后回调
  主流流处理框架（比如Spring Cloud Stream、Apache Flink）的SFTP Sink大多支持扩展逻辑。你可以直接改造现有SFTP Sink的实现，在文件成功写入并完成持久化后，同步或异步触发目标服务调用。
  拿Spring Cloud Stream举例，你可以自定义SftpFileTransferCallback，在afterWrite方法里嵌入服务调用逻辑：

  public class CallbackWithServiceInvoke implements SftpFileTransferCallback {
      private final TargetBusinessService targetService;
  
      public CallbackWithServiceInvoke(TargetBusinessService targetService) {
          this.targetService = targetService;
      }
  
      @Override
      public void afterWrite(String remoteFilePath, File localFile) {
          // 确认文件写入SFTP成功后，调用目标服务
          targetService.processUploadedFile(remoteFilePath);
      }
  }
  

  之后把这个自定义回调注入到SFTP Sink的配置里，替换默认回调即可。

• 监听Sink的生命周期事件
  要是不想改动Sink核心代码，可以监听框架发布的文件写入完成事件。很多流处理框架会在Sink完成文件持久化后发送内部事件，你只需要注册一个事件监听器，捕获到事件后直接触发服务调用。
  比如在Spring环境中，监听自定义的文件写入完成事件：

  @EventListener
  public void onSftpFileWritten(SftpFileWrittenEvent event) {
      String uploadedFilePath = event.getRemoteFilePath();
      targetService.processUploadedFile(uploadedFilePath);
  }
  

  这种方式不需要修改SFTP Sink本身，只需要新增事件监听逻辑即可。

• 合并Sink与服务调用为单个节点
  你可以替换原有的SFTP Sink，用一个自定义节点来同时完成SFTP写入和服务调用。这个节点先调用SFTP客户端完成文件上传，确认上传成功后立即触发目标服务调用，把两个逻辑合并到同一个流节点里，不需要新增独立的监听流。
  这种方式需要你自己封装SFTP上传逻辑，但能保证文件上传和服务调用的原子性——只有上传成功才会触发服务调用。

内容的提问来源于stack exchange，提问作者Venu Gopal