基于AWS SDK 2.x的spring-integration-aws SNS-SQS适配器及Spring Batch远程分区咨询

有，Spring Integration AWS从5.3.x版本开始正式提供基于AWS SDK 2.x的SNS/SQS适配器实现，完全满足你依赖SDK V2的业务需求，包括Spring Batch远程分区场景。

核心要点 #

• 依赖配置：
  引入Spring Integration AWS的对应版本，确保依赖的是SDK V2实现。以Maven为例，可通过AWS SDK V2的BOM统一版本，同时引入Spring Integration AWS：

  <dependencyManagement>
      <dependencies>
          <!-- AWS SDK 2.x BOM -->
          <dependency>
              <groupId>software.amazon.awssdk</groupId>
              <artifactId>bom</artifactId>
              <version>2.20.0</version> <!-- 替换为最新稳定版 -->
              <type>pom</type>
              <scope>import</scope>
          </dependency>
      </dependencies>
  </dependencyManagement>
  
  <dependencies>
      <!-- Spring Integration AWS （自动适配SDK V2） -->
      <dependency>
          <groupId>org.springframework.integration</groupId>
          <artifactId>spring-integration-aws</artifactId>
          <version>5.5.15</version> <!-- 匹配Spring Boot/Spring Integration版本，5.3+均支持V2 -->
      </dependency>
  </dependencies>
  

  若项目中存在SDK V1依赖，需显式排除以避免冲突。

• SNS-SQS适配器使用：
  使用SDK V2对应的客户端（SqsAsyncClient、SnsAsyncClient）配置适配器，示例代码：

  @Bean
  public MessageChannel sqsInputChannel() {
      return new DirectChannel();
  }
  
  @Bean
  public MessageProducer sqsMessageDrivenChannelAdapter(SqsAsyncClient sqsAsyncClient) {
      SqsMessageDrivenChannelAdapter adapter = new SqsMessageDrivenChannelAdapter(sqsAsyncClient, "your-queue-name");
      adapter.setOutputChannel(sqsInputChannel());
      return adapter;
  }
  
  @Bean
  public MessageHandler snsMessageHandler(SnsAsyncClient snsAsyncClient) {
      SnsMessageHandler handler = new SnsMessageHandler(snsAsyncClient, "your-topic-arn");
      handler.setOutputChannelName("snsOutputChannel");
      return handler;
  }
  

  Spring Integration AWS 6.x及以上版本（适配Spring Boot 3.x）已完全移除SDK V1依赖，仅支持V2。

• Spring Batch远程分区适配：
  基于SQS的Spring Batch远程分区，只需将原SDK V1的SQS客户端替换为V2的SqsAsyncClient，配置分区管理器和消息通道时使用上述V2适配器即可。分区的消息传递逻辑与V1版本一致，底层SDK的切换对业务代码无侵入。

注意事项 #

• 确保Spring Integration AWS版本与Spring Boot/Spring Integration版本兼容：Spring Boot 2.4+对应Spring Integration AWS 5.3+；Spring Boot 3.x对应Spring Integration AWS 6.x。
• 优先使用AWS SDK V2的异步客户端（AsyncClient系列），与Spring Integration的异步处理模型更契合。
• 避免项目中同时存在AWS SDK V1和V2依赖，可通过Maven/Gradle的依赖排除功能清理冲突依赖。

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