最后更新于 2012 年 11 月 5 日 (Spring MVC 3.2 RC1)

在我的上一篇博文中，我讨论了如何通过返回一个由 Spring MVC 在单独线程中调用的Callable来使 Spring MVC 控制器方法异步。

但是，如果异步处理依赖于接收一个 Spring MVC 未知的线程中的外部事件——例如，接收 JMS 消息、AMQP 消息、Redis pub-sub 通知、Spring Integration 事件等等，该怎么办？我将通过修改Spring AMQP项目中的现有示例来探索这种情况。

示例

Spring AMQP 有一个股票交易示例，其中 QuoteController 通过 Spring AMQP 的RabbitTemplate发送交易执行消息，并通过 Spring AMQP 的 RabbitMQ listener container以消息驱动的 POJO 样式接收交易确认和价格报价消息。

在浏览器中，该示例使用轮询来显示价格报价。对于交易，初始请求提交交易并返回一个确认 ID，然后使用该 ID 轮询以获取最终确认。我已经更新了该示例，以利用 Spring 3.2 Servlet 3 异步支持。 master 分支包含更改前的代码，而 spring-mvc-async 分支包含更改后的代码。下图显示了价格报价请求频率（使用 Chrome 开发者工具）的变化。

更改前：传统轮询

更改后：长轮询

正如您所见，通过常规轮询，新请求非常频繁地发送（间隔毫秒），而在长轮询中，请求可以间隔 5、10、20 秒或更长时间——总请求数量显著减少，同时不损失延迟，即新价格报价出现在浏览器中的时间量。

获取报价

那么需要进行哪些更改呢？从客户端的角度来看，传统轮询和长轮询是无法区分的，因此 HTML 和 JavaScript 没有改变。从服务器的角度来看，请求必须被挂起，直到新的报价到达。这是控制器处理报价请求的方式。

// Class field
private Map<String, DeferredResult> suspendedTradeRequests = new ConcurrentHashMap<String, DeferredResult>();

...

@RequestMapping("/quotes")
@ResponseBody
public DeferredResult<List<Quote>> quotes(@RequestParam(required = false) Long timestamp) {

  final DeferredResult<List<Quote>> result = new DeferredResult<List<Quote>>(null, Collections.emptyList());
  this.quoteRequests.put(result, timestamp);

  result.onCompletion(new Runnable() {
    public void run() {
      quoteRequests.remove(result);
    }
  });

  List<Quote> list = getLatestQuotes(timestamp);
  if (!list.isEmpty()) {
    result.setResult(list);
  }

  return result;
}

在上面的示例中，控制器方法准备并返回一个 DeferredResult，如果报价已可用，则可以立即设置它，或者稍后在通过 RabbitMQ 接收到新报价时设置。DeferredResult 被保存在一个 Map 中，当异步请求通过注册的 onCompletion 回调完成时，它将从中移除。

这是当新报价到达时更新已保存 DeferredResult 实例的控制器方法

// Invoked in Spring AMQP's RabbitMQ listener container thread

public void handleQuote(Quote message) {
  // ...
  for (Entry<DeferredResult<List<Quote>>, Long> entry : this.quoteRequests.entrySet()) {
    List<Quote> newQuotes = getLatestQuotes(entry.getValue());
    entry.getKey().setResult(newQuotes);
  }
  // ...
}

当新报价到达时，上述方法使用最新的报价更新每个已保存的 DeferredResult。由于 DeferredResult 最初是在 @ResponseBody 方法中创建的，因此报价会作为 JSON 写入响应正文。

超时

如果与 DeferredResult 关联的异步请求超时怎么办？从浏览器的角度来看，每个请求都应该返回报价，如果在达到超时，则应返回 0 个报价。

您可能已经注意到，在上面的示例代码中，DeferredResult 是使用两个构造函数参数创建的。第一个是使用的超时值，第二个是在发生超时时使用的默认结果，在本例中是一个空列表。

执行交易

执行交易所需的更改遵循类似的模式。不是发送一个请求来执行交易然后轮询确认，而是一个请求提交交易然后等待确认。

下一篇也是最后一篇文章 介绍了一个持久化的聊天示例。