wordpress全站静态,百度开放云制作网站,东莞网站建设要注意什么,网站审批AWS已经发布了Java版本2的AWS开发工具包 #xff0c;该开发工具包现在支持针对不同AWS服务的API调用的非阻塞IO。 在本文中#xff0c;我将探讨如何使用AWS开发工具包2.x的DynamoDB API以及如何使用Spring Webflux堆栈公开响应式端点-这种方式#xff0c;应用程序是端对端响… AWS已经发布了Java版本2的AWS开发工具包 该开发工具包现在支持针对不同AWS服务的API调用的非阻塞IO。 在本文中我将探讨如何使用AWS开发工具包2.x的DynamoDB API以及如何使用Spring Webflux堆栈公开响应式端点-这种方式应用程序是端对端响应式的大概应该非常有效地使用资源我有计划在此设置上做一些测试作为后续步骤。 申请详情 简单地看一下代码并在那儿跟随它可能会更容易-在我的GitHub存储库中可以找到它。 该应用程序很简单-使用以下Kotlin代码对酒店实体执行CRUD操作 data class Hotel(val id: String UUID.randomUUID().toString(),val name: String? null,val address: String? null,val state: String? null,val zip: String? null
) 我想公开端点以保存和检索酒店实体并按州获取酒店列表。 AWS开发工具包2的详细信息 AWS SDK 2 api的所有软件包名称现在都以“ software.amazon.awssdk”前缀开头使用以下代码创建与DynamoDB进行交互的客户端 import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider
import software.amazon.awssdk.regions.Region
import software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClientval client: DynamoDbAsyncClient DynamoDbAsyncClient.builder().region(Region.of(dynamoProperties.region)).credentialsProvider(DefaultCredentialsProvider.builder().build()).build() 创建DynamoDbAsyncClient实例后使用此客户端的任何操作都将返回Java 8 CompletableFuture类型。 例如。 保存酒店实体时 val putItemRequest PutItemRequest.builder().tableName(hotels).item(HotelMapper.toMap(hotel)).build()val result: CompletableFuturePutItemResponse dynamoClient.putItem(putItemRequest) 并通过ID检索记录 val getItemRequest: GetItemRequest GetItemRequest.builder().key(mapOf(Constants.ID to AttributeValue.builder().s(id).build())).tableName(Constants.TABLE_NAME).build()val response: CompletableFutureGetItemResponse dynamoClient.getItem(getItemRequest) CompletableFuture提供了一组全面的功能以在可用时转换结果。 与Spring Webflux集成 Spring Webflux是一个反应式Web框架。 现在借助AWS开发工具包2中的非阻塞IO支持可以使用DynamoDB编写端到端的响应式和非阻塞应用程序。 Spring Webflux使用反应堆核心提供反应流支持与AWS开发工具包2集成的技巧是将Java 8 CompletableFuture转换为反应堆核心类型方法是通过ID从DynamoDB检索项目时采用以下方式 val getItemRequest: GetItemRequest GetItemRequest.builder().key(mapOf(Constants.ID to AttributeValue.builder().s(id).build())).tableName(Constants.TABLE_NAME).build()return Mono.fromCompletionStage(dynamoClient.getItem(getItemRequest)).map { resp -HotelMapper.fromMap(id, resp.item())} Spring Webflux期望不同Web终结点方法签名的返回类型为响应类型因此用于说出酒店列表的典型终结点如下 RequestMapping(value [/hotels], method [RequestMethod.GET])
fun getHotelsByState(RequestParam(state) state: String): FluxHotel {return hotelRepo.findHotelsByState(state)
} Spring Webflux还支持描述应用程序API的功能性方法因此一个等效的API可通过其ID检索酒店但表示为功能性DSL如下所示 Configuration
class HotelAdditionalRoutes {Beanfun routes(hotelRepo: HotelRepo) router {GET(/hotels/{id}) { req -val id req.pathVariable(id)val response: MonoServerResponse hotelRepo.getHotel(id).flatMap { hotel -ServerResponse.ok().body(BodyInserters.fromObject(hotel))}response.switchIfEmpty(ServerResponse.notFound().build())}}
}结论 AWS SDK 2使编写端到端反应性和非阻塞应用程序变得简单。 我已使用Spring Webflux和AWS开发工具包2发电机客户端在此处编写此类应用程序。 整个工作示例可在我的GitHub存储库中找到-https ://github.com/bijukunjummen/boot-with-dynamodb其中包含有关如何启动DynamoDB本地版本并将其用于测试应用程序的说明。 翻译自: https://www.javacodegeeks.com/2018/12/reactive-spring-webflux-aws-dynamodb.html
