为了创建 WebSocket 服务器,我使用了Java-WebSocket库。它看起来像这样,并且正在工作。
但现在我想升级,所以服务器只能有一个活动的客户端连接。
是否有某种选项可以执行此操作,或者我应该检查所有连接并关闭所有非第一个活动连接?
我试过这样:
@Override
public void onOpen(WebSocket conn, ClientHandshake handshake)
{
System.out.println("WebSocketServer::onOpen()");
boolean first = true;
Collection<WebSocket> con = this.connections();
synchronized(con) {
for (WebSocket c : con) {
if (first && c.isOpen()) {
first = false;
} else {
c.close();
}
}
}
}
但这会关闭所有连接,并杀死 Websocket 服务器。我究竟做错了什么?