1、提供一個傳送mq服務

@RequestMapping("/api/mq/rabbit")
public interface RabbitMqApiService {

    @RequestMapping("/sendMq")
    ResponseBO sendMq(RabbitCallBackBO rabbitCallBackBO);
}

2、在建立訂單後，傳送mq訊息，這裡很關鍵的地方是設定傳送的延遲時間

RabbitCallBackBO rabbitCallBackBO = new RabbitCallBackBO();
                    rabbitCallBackBO.setCallBackHttpUrl
 
("http://www.yyjunheng.com/client/task/order/timeout/cancel");
                    rabbitCallBackBO.setParams("{\"orderId\":" + order.getId() + "}");
                    rabbitCallBackBO.setMessageType(2);
                    rabbitCallBackBO.setDelayMillisecond(Long.valueOf(delayTime));//這裡設定的延遲時間比如30分鐘，30分鐘後回撥用http://www.yyjunheng.com/client/task/order/timeout/cancel
 

                    rabbitCallBackBO.setRouterKey("order.cancel");
                    rabbitCallBackBO.setExchangeName("exchange_business");
                    rabbitCallBackBO.setResultValue("code");
                    rabbitCallBackBO.setResultCode(0);
                    rabbitCallBackBO.setContentType
 
(1);
                    rabbitCallBackBO.setHttpMethod(1);
                    String resultVO = HttpUtil.getInstance().postWithJson("http://www.yyjunheng.com/api/mq/rabbit/sendMq", JSON.toJSONString(rabbitCallBackBO));

3、提供一個取消訂單的服務，就是上面mq訊息的回撥

@RequestMapping("/client/task")
public interface HealthTaskApiService {
    /**
     * 30分鐘未支付訂單 更新 為 取消訂單 （門店下單 還原庫存）
     */
    @GetMapping("/order/timeout/cancel")
    ResponseVO cancelTimeOutOrder(String orderId, HttpServletRequest request);

實現

  @Override
    public ResponseVO updateForCancelOrder(String orderId, HttpServletRequest request) {
        HealthOrder order = healthOrderDao.getUniqueOrder(orderId);
        //這個判斷很重要，30分鐘的回調回來如果訂單不是待支付狀態則不能取消訂單，否則取消訂單
        if (order == null || OrderStateConstant.ARREARAGE_ORDER.getStatusId() != order.getStatusId()) {
            throw new BusinessException(ErrorMsg.BillException.BIll_INFO_ERROR, false);
        }
        order.setStatusId(OrderStateConstant.CANCEL_ORDER.getStatusId());
        //業務程式碼....
        }