最近项目需要web客户端与服务器保持长链接的场景并需要服务器向所有链接的客户端推送消息，于是自然使用了WebSocket技术，自然要考虑到服务器于多个客户端线程安全的问题。于是乎，想当然的在WebSocket服务器端通过一个线程安全的队列来保持所有客户端的Session.
private volatile static List<Session> sessions = Collections.synchronizedList(new ArrayList());
private Session session;
* 客户端链接成功后讲其保存在线程安全的集合中
@OnOpen
public void onOpen(Session session) throws IOException {
this.session = session;
sessions.add(this);
* 客户端断开链接后将其从线程安全的集合中移除
@OnClose
public void onClose() {
sessions.remove(this);
public static void sendMessage(String clientInfoJson) {
try {
if (sessions.size() != 0) {
for (session s : sessions) {
if (s != null) {
s.getBasicRemote().sendText(clientInfoJson);
} catch (IOException e) {
e.printStackTrace();
上述代码感觉上好像没问题。Session信息是保存在线程安全的集合，又通过volatile变量来修饰保证了内存可见性，但实际运行时却发现并没有想象的那么好。当客户端断开链接，时服务器需要发送消息给客户端时.服务端抛出异常:
IllegalStateException: The WebSocket session [0] has been closed and no method (apart from close()) may be called on a closed session
不难看出,是服务端在关闭Session即将Session从线程安全的队列移除时，在发送消息的方法里应该被移除的Session消息却进入了发送消息的环节，在执行getBasicRemote().sendText(clientInfoJson);操作时发生了异常。
解决方法:
Google了大量资料后发现如果要解决这种线程安全的问题,不能通过线程安全的集合来保存Session解决。而应该保存整个类，并通过CopyOnWriteArraySet容器来操作。
@ServerEndpoint("/getLocation")
@Component
public class TransmissionLocationWebSocket {
@Autowired
public TerminalService terminalServiceInWebSocket;
private static CopyOnWriteArraySet<TransmissionLocationWebSocket> sessions = new CopyOnWriteArraySet<TransmissionLocationWebSocket>();
* 线程不安全
private Session session;
* 链接成功后的回掉
@OnOpen
public void onOpen(Session session) throws IOException {
System.out.println("链接成功");
this.session = session;
sessions.add(this);
public static void sendUserLocal(String clientInfoJson,) {
try {
if (sessions.size() != 0) {
for (TransmissionLocationWebSocket s : sessions) {
if (s != null) {
s.session.getBasicRemote().sendText(clientInfoJson);
} catch (IOException e) {
e.printStackTrace();
@OnClose
public void onClose() {
System.out.println("设置离线");
sessions.remove(this);
完美解决
备注：虽然我上面贴出来的代码是在COW中保存了整个类，但我测试的时候发生，保存Session也是可以的。
Copy-On-Write简称COW，是一种用于程序设计中的优化策略。其基本思路是，从一开始大家都在共享同一个内容，当某个人想要修改这个内容的时候，才会真正把内容Copy出去形成一个新的内容然后再改，这是一种延时懒惰策略。从JDK1.5开始Java并发包里提供了两个使用CopyOnWrite机制实现的并发容器,它们是CopyOnWriteArrayList和CopyOnWriteArraySet。CopyOnWrite容器非常有用，可以在非常多的并发场景中使用到。
CopyOnWrite容器即写时复制的容器。通俗的理解是当我们往一个容器添加元素的时候，不直接往当前容器添加，而是先将当前容器进行Copy，复制出一个新的容器，然后新的容器里添加元素，添加完元素之后，再将原容器的引用指向新的容器。这样做的好处是我们可以对CopyOnWrite容器进行并发的读，而不需要加锁，因为当前容器不会添加任何元素。所以CopyOnWrite容器也是一种读写分离的思想，读和写不同的容器。
Websocket发送信息报错The WebSocket session [0] has been closed and no method (apart from close()) may be c
WebSocket后台报错：The WebSocket session [0] has been closed and no method (apart from close()) may be called on a closed session
在这个过程中，前台页面不停的刷新页面，session在不停的关闭和开启，服务器推送数据时，会出现session连接已经被关闭了，但是此时服务器还在...
主要原因：在建立连接存储对象
信息的时候保存了用户ID，在断开连接时移除当前对象失败。
private static CopyOnWriteArraySet<Accept
WebSocket>
webSocketSet = new CopyOnWriteArraySet<>();
@OnOpen
public void onOpen(@PathParam("userid...
使用
WebSocket协议服务端主动向客户端发送消息时，该
Session对象关闭了才会出现该
异常。
可使用
session.isOpen()方法判断该连接是否打开，再进行推送消息。
if(wsController.
session.isOpen()){
wsController.
session.getBasicRemote().sendText(message);
这个错误通常是因为 WebSocket 会话已经被关闭，但是在代码中仍然调用了一些方法，例如发送消息等。解决这个问题的方法是在使用 WebSocket 之前检查会话是否已经被关闭，如果已经关闭，则不再调用任何方法。
以下是一些可能导致 WebSocket 会话关闭的原因：
- 网络连接中断
- 服务器关闭 WebSocket 连接
- 客户端关闭 WebSocket 连接
您可以在连接关闭后通过检查会话状态来避免此错误。例如，在 JavaScript 中，您可以使用以下代码检查 WebSocket 是否已关闭：
if (webSocket.readyState === WebSocket.OPEN) {
// 进行 WebSocket 操作
这样，如果 WebSocket 已经关闭，就不会执行 WebSocket 操作，从而避免了该错误的发生。
hongdounuoyan:
秒杀系统中如何动态生成下单随机URL
普通网友:
Redis原理(二) Redis的对象类型及其内部编码
titer1:
Spring boot初始化Mongo数据库(将.json文件持久化到Mongo数据库)
qq_31459039:
