Websocket并发发送消息异常详尽攻略：轻松告别踩坑体验

并发发送消息中的 Spring Websocket 异常及解决方案

并发发送消息的挑战

在使用 Spring Websocket 发送消息时，并发性可能带来以下挑战：

• 线程安全性： 多个线程同时发送消息可能会导致竞态条件和数据不一致。
• 网络问题： 客户端连接中断或网络故障可能导致消息传递失败。
• 消息类型不兼容： 客户端和服务器可能对消息类型有不同的预期，导致消息转换异常。

解决方案

1. 加锁同步发送

加锁同步是一种简单但有效的解决方案，它通过在发送消息前后获取和释放锁来防止线程竞争。

示例代码：

synchronized (this) {
  websocketTemplate.send(destination, message);
}

2. Spring 自带事件驱动队列

Spring Websocket 提供了一个事件驱动队列，可以自动处理并发消息发送并保证消息顺序性。

示例代码：

SimpMessagingTemplate messagingTemplate = new SimpMessagingTemplate(websocketTemplate);
messagingTemplate.convertAndSend(destination, message);

3. 自研事件驱动队列

对于对 Spring 事件驱动队列不满意的情况，可以自研一个事件驱动队列，提供更大的灵活性。

示例代码：

public class EventDrivenQueue {

  private final BlockingQueue<Message> queue = new LinkedBlockingQueue<>();

  public void send(Message message) {
    queue.put(message);
  }

  public Message receive() throws InterruptedException {
    return queue.take();
  }
}

比较

解决方案	优点	缺点
加锁同步发送	简单易用	可能会降低性能
Spring 事件驱动队列	自动处理并发，保证顺序性	可能有性能开销
自研事件驱动队列	高灵活性，可定制	需要自己实现

结论

根据自己的需求选择合适的并发发送消息解决方案至关重要。加锁同步发送适用于小规模系统，Spring 事件驱动队列提供了一种平衡的解决方案，而自研事件驱动队列适用于需要高度定制的场景。

常见问题解答

1. 为什么会出现“No thread-bound request found”异常？

这通常发生在非 HTTP 请求线程中发送消息时，例如在后台线程或 Servlet 过滤器中。

2. 如何解决“WebSocketMessageDeliveryException”？

该异常通常表示客户端已断开连接或网络有问题。请检查客户端连接和网络设置。

3. 如何处理“MessageConversionException”？

确保客户端和服务器对消息类型有相同的预期。检查消息转换器配置并确保它们与预期类型匹配。

4. 使用事件驱动队列有什么好处？

事件驱动队列可以自动处理并发、保证消息顺序性并降低线程竞争风险。

5. 自研事件驱动队列的局限性是什么？

自研事件驱动队列需要自己实现，这可能会增加复杂性和引入错误。