Spring Boot+JPA应用中数据库插入顺序不一致问题求助

API 探路者

2026-7-16

Spring WebSocket 快速调用时数据库插入顺序不一致问题排查与解决

我在Spring应用中遇到数据库插入顺序不一致的问题：服务方法标注了@Transactional注解保证原子性和一致性，但快速调用WebSocket端点/send（通过该端点调用saveUserMessage方法插入消息）时，本应先插入的记录有时会延迟插入。

相关代码

@MessageMapping("/send")
public void send(
        @Payload MessageRequestDTO messageDTO,
        @Header("simpSessionId") String sessionId,
        SimpMessageHeaderAccessor headerAccessor
) {
    // access the header
    Principal principal = (Principal) headerAccessor.getSessionAttributes().get(sessionId);

    if (!principal.getName().equals(messageDTO.sender())) {
        String errorMessage = "You are not eligible to send this message";
        messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/errors", errorMessage);
        return;
    }

    try {

        MessageResponseDTO messageResponseDTO = new MessageResponseDTO(
                randomUUID().toString(),
                messageDTO.conversationId(),
                messageDTO.sender(),
                messageDTO.receiver(),
                messageDTO.message(),
                "PENDING",
                new java.util.Date().toGMTString(),
                new java.util.Date().toGMTString()
        );
        messagingTemplate.convertAndSendToUser(messageDTO.receiver(), "/queue/private", messageResponseDTO);
        messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/private", messageResponseDTO);
        messageService.saveUserMessage(messageDTO);

    } catch (Exception e) {
        messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/errors", e.getMessage());
    }
}

问题原因分析

异步并行执行：WebSocket请求默认是异步处理的，快速调用时多个请求会分配到不同线程并行执行。@Transactional只能保证单条请求内操作的原子性，管不了跨线程的执行顺序。
事务提交延迟：Spring事务提交存在微小时间差，加上线程调度的不确定性，先发起的请求可能因为线程执行慢、事务提交晚，导致数据库插入顺序和请求顺序不一致。
无全局顺序控制：没有对同一对话的消息请求做串行化处理，多个线程同时操作数据库，最终插入顺序完全由线程执行速度决定。

解决方案

方案1：同一对话请求串行化

用ConcurrentHashMap给每个对话维护一个锁，保证同一对话的消息请求按顺序执行：

private final Map<String, Object> conversationLocks = new ConcurrentHashMap<>();

@MessageMapping("/send")
public void send(
        @Payload MessageRequestDTO messageDTO,
        @Header("simpSessionId") String sessionId,
        SimpMessageHeaderAccessor headerAccessor
) {
    // 原有校验逻辑
    Principal principal = (Principal) headerAccessor.getSessionAttributes().get(sessionId);
    if (!principal.getName().equals(messageDTO.sender())) {
        String errorMessage = "You are not eligible to send this message";
        messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/errors", errorMessage);
        return;
    }

    // 获取当前对话的锁对象
    Object lock = conversationLocks.computeIfAbsent(messageDTO.conversationId(), k -> new Object());
    synchronized (lock) {
        try {
            MessageResponseDTO messageResponseDTO = new MessageResponseDTO(
                    randomUUID().toString(),
                    messageDTO.conversationId(),
                    messageDTO.sender(),
                    messageDTO.receiver(),
                    messageDTO.message(),
                    "PENDING",
                    new java.util.Date().toGMTString(),
                    new java.util.Date().toGMTString()
            );
            messagingTemplate.convertAndSendToUser(messageDTO.receiver(), "/queue/private", messageResponseDTO);
            messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/private", messageResponseDTO);
            messageService.saveUserMessage(messageDTO);
        } catch (Exception e) {
            messagingTemplate.convertAndSendToUser(principal.getName(), "/queue/errors", e.getMessage());
        } finally {
            // 可选：长时间无消息时移除锁，避免内存占用
            conversationLocks.remove(messageDTO.conversationId(), lock);
        }
    }
}

方案2：数据库层维护顺序

给消息表加一个sequence字段，插入时生成对话内的递增序列，查询时按这个字段排序：

消息表新增sequence BIGINT字段，和conversation_id设为联合唯一索引。
修改saveUserMessage方法，插入前用数据库原子操作获取当前对话的最大序列值加1，比如：

SELECT COALESCE(MAX(sequence), 0) + 1 FROM message WHERE conversation_id = ?

把这个值作为新消息的sequence插入数据库。
3. 查询消息时，用ORDER BY conversation_id, sequence ASC确保顺序正确。

方案3：调整事务配置

给WebSocket端点方法添加@Transactional，让事务在端点层面管理，减少提交延迟的影响：

@Transactional
@MessageMapping("/send")
public void send(/* 参数 */) {
    // 原有逻辑不变
}

注意：需要确保Spring的异步任务执行器支持事务上下文传递，必要时调整TaskExecutor的配置，比如使用ThreadPoolTaskExecutor并开启事务同步。

内容的提问来源于stack exchange，提问作者ilyasDev