websocket问题，服务器往客户端发送数据会崩溃

Question

连接成功且客户端发送过来的数据能在服务器显示，可是执行this.session.getBasicRemote().sendText(message);会崩溃

Answer 1

不清楚你的错误信息是什么，我也实现了一个，没有错误。

以下是代码

 package websocket;

import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;

@ServerEndpoint("/websocket/{name}")
public class WebSockate {
    // 当前在线人数
    private static int inlineCount = 0;
    // 连接集合
    private static CopyOnWriteArraySet<WebSockate> webSocketSet = new CopyOnWriteArraySet<WebSockate>();
    // session
    Session session = null;

    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        // 线程不安全
        inlineCount++;
        System.out.println("多了一个=>" + inlineCount);
        webSocketSet.add(this);
    }

    @OnMessage
    public void onMessage(String message,@PathParam("name")String name) {
        //System.out.println(name);
        for (WebSockate socket : webSocketSet) {
            String str = "var message=[]; message[\"name\"]='"+name+"';message[\"message\"]='"+message+"'";
            socket.sendMessage(str);
        }
    }

    @OnClose
    public void onClose() {
        webSocketSet.remove(this);
        inlineCount--;
        System.out.println("少了一个->" + inlineCount);
    }

    @OnError
    public void onError(Session session, Throwable error) {
        System.out.println("发生错误");
        error.printStackTrace();
    }

    //发送消息
    public void sendMessage(String message) {
        try {
            session.getBasicRemote().sendText(message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}