我是软件开发新手,我想使用响应式编程以非阻塞的方式从aws sqs获取消息,我该怎么做
发布于 2020-02-10 04:06:10
Java AWS SDK2中内置了异步客户端--在这种情况下,您需要的是SqsAsyncClient
。
您可以使用此方法按原样返回的CompleteableFuture
,如果您想专门使用项目反应器(如问题中标记的那样),那么您可以简单地将上面的代码包装在Mono.fromFuture()
中以返回一个Mono<ReceiveMessageResponse>
。
https://stackoverflow.com/questions/60140164
复制相似问题