苍穹外卖里的定时任务与实时消息推送实践

Mapper 里新增的查询就一句 SQL：

@Select("select * from orders where status = #{status} and order_time < #{orderTime}")
List<Orders> getByStatusAndOrderTimeLT(Integer status, LocalDateTime orderTime);

定时任务本身很简单，但要注意数据库端的查询效率。如果订单量大，order_time 字段要有索引，否则每分钟扫全表会很吃性能。

用 WebSocket 做实时通知

WebSocket 的好处是能在浏览器和服务器之间保持一个长连接，双向传输数据。比起定时轮询，实时性好太多，而且浪费的流量小。这里用它来给商家端推送新订单提醒和催单提醒。

最简单的集成方式是引入 spring-boot-starter-websocket（或者直接引入 javax.websocket-api 等），然后注册一个 ServerEndpoint 处理类。项目中写了一个 WebSocketServer，用 @ServerEndpoint("/ws/{sid}") 注解，sid 作为客户端标识，放在一个静态 Map 里管理所有会话。

@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);
    }

    @OnMessage
    public void onMessage(String message, @PathParam("sid") String sid) {
        System.out.println("收到来自客户端：" + sid + "的信息:" + message);
    }

    @OnClose
    public void onClose(@PathParam("sid") String sid) {
        System.out.println("连接断开:" + sid);
        sessionMap.remove(sid);
    }

    public void sendToAllClient(String message) {
        Collection<Session> sessions = sessionMap.values();
        for (Session session : sessions) {
            try {
                session.getBasicRemote().sendText(message);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

为了让这个端点生效，需要向 Spring 容器注册 ServerEndpointExporter：

@Configuration
public class WebSocketConfiguration {
    @Bean
    public ServerEndpointExporter serverEndpointExporter() {
        return new ServerEndpointExporter();
    }
}

测试的时候，可以写一个定时任务每隔几秒推一条消息，看看客户端能不能正常收到。比如：

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

    @Scheduled(cron = "0/5 * * * * ?")
    public void sendMessageToClient() {
        webSocketServer.sendToAllClient("这是来自服务端的消息：" 
            + DateTimeFormatter.ofPattern("HH:mm:ss").format(LocalDateTime.now()));
    }
}

实际项目中，推送给商家的消息肯定会带上业务数据，比如订单号、类型。下面两个场景会详细说。

支付成功后通知商家（来单提醒）

用户支付成功后，订单状态变为待确认，同时要通过 WebSocket 告诉商家端。改动点在 OrderServiceImpl 的 paySuccess 方法中，最后增加几行：

public void paySuccess(String outTradeNo) {
    // 根据订单号查询订单
    Orders ordersDB = orderMapper.getByNumber(outTradeNo);
    // 更新订单状态
    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);
}

前端收到 type=1 后就可以触发语音播报和弹框。这里推的是所有连接的客户端，如果一台电脑同时开了多个商家端页面，可能会响多次。实际可以结合 sid 做一些区分，不过当前项目要求不高，粗暴群发也能用。

客户催单的推送

用户侧小程序有一个'催单'按钮，点击后调用接口 /user/order/reminder/{id}。Controller 很简单：

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

Service 实现会先校验订单状态，应该是已支付且状态为'已确认'（或者状态码 4）才允许催单。

@Override
public void reminder(Long id) {
    Orders ordersDB = orderMapper.getById(id);
    if (ordersDB == null) {
        throw new OrderBusinessException(MessageConstant.ORDER_STATUS_ERROR);
    }

    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);
}

前端同样根据 type=2 做播报和弹窗。

整个过程就这样串联起来了：定时任务处理长时不付款的订单，支付成功时实时提醒，用户催单后再次提醒。虽然代码量不大，但把这两个基础组件用起来，项目的即时性体验会好很多。

实际开发中，定时任务的 cron 频率需要权衡业务对延迟的容忍度和系统负载。15 分钟的轮询间隔用一个每分钟触发的方法是比较粗糙的，如果要做得更精确，可以在每分钟轮询时过滤订单时间在 15 分钟~14 分钟之间的，但这里直接粗暴处理也没啥大问题。WebSocket 的群发模式在用户量上去之后可以考虑带上目标 sid，或者改用消息队列 + 单播，避免对所有连接广播。目前这个阶段就先这样了。