苍穹外卖项目实战：Spring Task 定时任务与 WebSocket 消息推送

2.2 代码实现

在 Task 包下创建一个 OrderTask。

/**
 * 定时任务类，定时处理订单状态
 */
@Component
@Slf4j
public class OrderTask {
    @Autowired
    private OrderMapper orderMapper;

    /**
     * 定时处理超时订单
     */
    @Scheduled(cron = "0 * * * * ?") // 每分钟触发一次
    public void processTimeoutOrder() {
        log.info("定时处理超时订单：{}", LocalDateTime.now());
        LocalDateTime time = LocalDateTime.now().plusMinutes(-15);
        List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.PENDING_PAYMENT, time);
        if (ordersList != null && ordersList.size() > 0) {
            for (Orders orders : ordersList) {
                orders.setStatus(Orders.CANCELLED);
                orders.setCancelReason("订单超时，自动取消");
                orders.setCancelTime(LocalDateTime.now());
                orderMapper.update(orders);
            }
        }
    }

    /**
     * 处理一直处于派送中状态中的订单
     */
    @Scheduled(cron = "0 0 1 * * ?") // 每天凌晨 1 点执行一次
    public void processDeliverOrder() {
        log.info("定时处理处于派送中的订单：{}", LocalDateTime.now());
        LocalDateTime time = LocalDateTime.now().plusMinutes(-60);
        List<Orders> ordersList = orderMapper.getByStatusAndOrderTimeLT(Orders.DELIVERY_IN_PROGRESS, time);
        if (ordersList != null && ordersList.size() > 0) {
            for (Orders orders : ordersList) {
                orders.setStatus(Orders.COMPLETED);
                orderMapper.update(orders);
            }
        }
    }
}

在 OrderMapper 类下新增查询方法：

/**
 * 根据订单状态和下单时间查询订单
 * @param status
 * @param orderTime
 * @return
 */
@Select("select * from orders where status = #{status} and order_time < #{orderTime}")
List<Orders> getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime);

3. WebSocket

3.1 介绍

WebSocket 是基于 TCP 的一种新的网络协议，它实现了浏览器与服务器全双工通信——浏览器和服务器只需要完成一次握手，两者之间就可以创建持久性的连接，并进行双向数据传输。

应用场景：

• 视频弹幕
• 网页聊天
• 体育实况更新
• 股票基金报价实时更新

3.2 入门案例

步骤：

1. 直接使用 websocket.html 页面作为 WebSocket 客户端
2. 导入 WebSocket 的 Maven 坐标
3. 导入 WebSocket 服务器组件 WebSocketServer，用于和客户端通信
4. 导入配置类 WebSocketConfiguration，注册 WebSocket 的服务器组件
5. 导入定时任务类 WebSocketTask，定时向客户端推送数据

/**
 * WebSocket 服务
 */
@Component
@ServerEndpoint("/ws/{sid}")
public class WebSocketServer {
    // 存放会话对象
    private static Map<String, Session> sessionMap = new HashMap<>();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session, @PathParam("sid") String sid) {
        System.out.println("客户端：" + sid + "建立连接");
        sessionMap.put(sid, session);
    }

    /**
     * 收到客户端消息后调用的方法
     *
     * @param message 客户端发送过来的消息
     */
    @OnMessage
    public void onMessage(String message, @PathParam("sid") String sid) {
        System.out.println("收到来自客户端：" + sid + "的信息:" + message);
    }

    /**
     * 连接关闭调用的方法
     *
     * @param sid
     */
    @OnClose
    public void onClose(@PathParam("sid") String sid) {
        System.out.println("连接断开:" + sid);
        sessionMap.remove(sid);
    }

    /**
     * 群发
     *
     * @param message
     */
    public void sendToAllClient(String message) {
        Collection<Session> sessions = sessionMap.values();
        for (Session session : sessions) {
            try {
                // 服务器向客户端发送消息
                session.getBasicRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

/**
 * WebSocket 配置类，用于注册 WebSocket 的 Bean
 */
@Configuration
public class WebSocketConfiguration {
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}

@Component
public class WebSocketTask {
    @Autowired
    private WebSocketServer webSocketServer;

    /**
     * 通过 WebSocket 每隔 5 秒向客户端发送消息
     */
    @Scheduled(cron = "0/5 * * * * ?")
    public void sendMessageToClient() {
        webSocketServer.sendToAllClient("这是来自服务端的消息：" + DateTimeFormatter.ofPattern("HH:mm:ss").format(LocalDateTime.now()));
    }
}

4. 来单提醒

4.1 需求分析

用户下单且支付成功后，需要第一时间通知外卖商家：

• 语音播报
• 弹出提示框

4.2 代码实现

修改 OrderServiceImpl 中的 paySuccess 方法。

/**
 * 支付成功，修改订单状态
 * @param outTradeNo
 */
public void paySuccess(String outTradeNo) {
    // 根据订单号查询订单
    Orders ordersDB = orderMapper.getByNumber(outTradeNo);
    // 根据订单 id 更新订单的状态、支付方式、支付状态、结账时间
    Orders orders = Orders.builder()
            .id(ordersDB.getId())
            .status(Orders.TO_BE_CONFIRMED)
            .payStatus(Orders.PAID)
            .checkoutTime(LocalDateTime.now())
            .build();
    orderMapper.update(orders);
    // 通过 WebSocket 向客户端推送消息
    Map<String, Object> map = new HashMap<>();
    map.put("type", 1); // 1 来单提醒
    map.put("orderId", ordersDB.getId());
    map.put("content", "订单号：" + outTradeNo);
    String json = JSON.toJSONString(map);
    webSocketServer.sendToAllClient(json);
}

支付成功后就通过 WebSocket 向客户端推送消息。

5. 客户催单

5.1 需求分析

用户在小程序中点击催单按钮后，需要第一时间通知外卖商家：

• 语音播报
• 弹出提示框

用户催单接口设计：

5.2 代码开发

在 User 包下的 OrderController 类中增加接口。

/**
 * 客户催单
 * @param id
 * @return
 */
@GetMapping("/reminder/{id}")
public Result reminder(@PathVariable Long id) {
    log.info("客户催单：{}", id);
    orderService.reminder(id);
    return Result.success();
}

在 OrderServiceImp 中增加客户催单方法。

/**
 * 客户催单
 * @param id
 */
@Override
public void reminder(Long id) {
    // 根据 id 查询订单
    Orders ordersDB = orderMapper.getById(id);
    // 校验订单是否存在，并且状态为 4
    if (ordersDB == null) {
        throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
    }
    // 通过 WebSocket 向客户端浏览器推送消息
    Map<String, Object> map = new HashMap<>();
    map.put("type", 2); // 2 表示客户催单
    map.put("orderId", id);
    map.put("content", "订单号：" + ordersDB.getId());
    String json = JSON.toJSONString(map);
    webSocketServer.sendToAllClient(json);
}