61、springmvc-异步请求-返回DeferredResult

61.1 DeferredResult 官方文案

61.2 使用

/**
 * 创建订单加入 订单处理队列
 *
 * @return
 */
@ResponseBody
@RequestMapping("/createOrder")
public DeferredResult<Object> createOrder() {
    // 超时间  10秒钟
    DeferredResult<Object> deferredResult = new DeferredResult<Object>(10 * 1000L, "create order error");
    DeferredResultQueue.save(deferredResult);
    return deferredResult;
}

/**
 * 另外一个线程 从队列中读取 订单任务 开始创建 ，并返回结果
 *
 * @return
 */
@ResponseBody
@RequestMapping("/create")
public String create() {
    String uuid = UUID.randomUUID().toString();
    DeferredResult deferredResult = DeferredResultQueue.get();
    deferredResult.setResult(uuid);
    return "success===>>>> " + uuid;
}

• 创建一个 DeferredResultQueue 队列

  public class DeferredResultQueue {

  private static Queue<DeferredResult<Object>> queue = new ConcurrentLinkedQueue<DeferredResult<Object>>();
  
  public static void save(DeferredResult<Object> object) {
      queue.add(object);
  }
  
  public static DeferredResult<Object> get() {
      return queue.poll();
  }

  }

• 在10秒 超时之前 调用 /create 和 /createOrder 返回结果一直

• 如果超时 返回 create order error

---