Tag: asynchronous

亚马逊sqs的异步消费者

我不熟悉队列。 我能够成功发布消息并同步接收它们但是，我现在正试图异步。 sqs提供的参考链接建议使用jmsclient包装器。 如果您已经有一个集成到jms客户端的代码，那么该链接还会提到使用它。 http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSDeveloperGuide/jmsclient.html#samples 但我重新开始，我引用这个例子同步发送和recv消息。 https://github.com/aws/aws-sdk-java/blob/master/src/samples/AmazonSimpleQueueService/SimpleQueueServiceSample.java 我可以使用相同的代码，但使用消息监听器实现它吗？ 任何代码示例将不胜感激。

使用RxJava / Jersey2的异步RestAPI。 线程问题？

我们正在使用反应式编程对REST API进行原型设计。 如图所示，我们保留3层与我们在上一代同步API设计中使用的相同; http://oi59.tinypic.com/339hhki.jpg 使用Jersey2实现的API层将处理请求/反序列化JSON并切换到服务层。 服务层实现业务逻辑。使用反应式编程实现（RxJava） Dao Layer用于Service Layer的持久化操作。因为我们使用CouchBase，所以这将使用CouchBase RxClient。 根据我的理解，流程如下： a） HTTP请求到来，Jersery将从“容器线程池”处理RequestThread内的请求/解析JSON /反序列化请求模型。 b）使用Jersey2异步支持，RequestThread将返回到Container Thread Pool，服务层将在Schedulers.computation（）调度程序中执行。 @Path(“/resource”) public class AsyncUserResource { @GET public void asyncGet(@Suspended final AsyncResponse asyncResponse) { Observable user = userService.getUser(…); //this is executed using Schedulers.computation() inside Service implementation user.subscribe(new Observer() { @Override public void onCompleted() { } @Override public void onError(Throwable […]