领先一步
VMware 提供培训和认证,助您加速进步。
了解更多亲爱的Spring社区!
我很荣幸地宣布 Spring 支持 Amazon Web Services 的项目已达到通用可用 (General Availability):Spring Integration for AWS 2.0.0.RELEASE 和 Spring Cloud Stream Binder for AWS Kinesis 1.0.0.RELEASE。
这两个构件都可以在 Spring Release 仓库和 Maven Central 中找到,并可作为依赖项使用。
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-aws</artifactId>
<version>2.0.0.RELEASE</version>
</dependency>
...
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-stream-binder-kinesis</artifactId>
<version>1.0.0.RELEASE</version>
</dependency>
当使用第二个项目时,不需要包含 spring-integration-aws。
Spring Integration for AWS 2.0 版本的主要目标当然是围绕 AWS Kinesis 支持,这得益于 Spring Cloud Stream Binder for AWS Kinesis 的工作。特别是,我们引入了 DynamoDbMetadataStore 和 DynamoDbLockRegistry 来支持 AWS Kinesis 的分布式 Binder 消费者。同时,遵循 Spring Integration 的良好抽象,这些新组件可以在任何其他分布式任务中使用,当您的应用程序部署在 Amazon 云环境中或依赖 AWS 服务时。例如,AWS S3 Inbound Channel Adapters 可以使用 DynamoDbMetadataStore 来配合 S3PersistentAcceptOnceFileListFilter,以防止在多个分布式应用程序实例中重复访问同一已处理的资源。DynamoDbLockRegistry 可用于应用程序集群中的领导者选举。有关 LockRegistryLeaderInitiator 的更多信息,请参阅 Spring Integration 参考手册。
除了这些新组件,SNS 和 SQS Channel Adapters 现在也支持将头映射到消息属性。有关更多详细信息,请参阅 AbstractMessageAttributesHeaderMapper 的 Javadoc 及其实现。
Kinesis Channel Adapters 也支持头映射,但机制完全不同,我们只能将它们与载荷一起**嵌入**到记录体中。有关更多详细信息,请参阅 Spring Integration 中的 EmbeddedJsonHeadersMessageMapper。当 headerMode 为 embedded(默认)时,Kinesis Binder 中也使用了类似的嵌入技术。
有关 Spring Integration for AWS 2.0 中的新功能以及 Spring Cloud Stream Binder for AWS Kinesis 的详细信息,请参阅之前的发布 公告。
还请参阅 Spring Cloud Stream 示例,了解有关 Kinesis Binder 在云流式应用程序中使用的更多想法。
感谢所有以任何方式为这些项目做出贡献的人。
我们期待任何反馈,并热切希望在未来的版本中根据社区需求进一步改进这些项目。
Spring Integration AWS 项目页面 | Spring Cloud Stream Binder for AWS Kinesis 项目页面 | 帮助 | 聊天