websocket只连接了一个客户客户端互发消息,但是每发一次消息,服务端就提示连接人数加一个,这是为什么
// concurrent包的线程安全Set,用来存放每个客户端对应的MyWebSocket对象。
服务端
private static CopyOnWriteArraySet<StatusWS> webSocketSet = new CopyOnWriteArraySet<StatusWS>();
private static Map<String, JSONObject> webSocketMap = new HashMap<String, JSONObject>();
// 与某个客户端的连接会话,需要通过它来给客户端发送数据
private Session session;
private String APPID;
/**
* 连接建立成功调用的方法
*/
@OnOpen
public void onOpen(Session session) {
this.session = session;
webSocketSet.add(this); // 加入set中
addOnlineCount(); // 在线数加1
logger.info("有新连接加入!当前在线人数为" + getOnlineCount());
}
客户端:
$("#btnConnection").click(function() {
socket = new WebSocket("ws://203.195.240/status");
//打开事件
socket.onopen = function() {
alert("Socket 已打开");
//socket.send("这是来自客户端的消息" + location.href + new Date());
};
//获得消息事件
socket.onmessage = function(msg) {
console.log(msg.data);
};
//关闭事件
socket.onclose = function() {
alert("Socket已关闭");
};
//发生了错误事件
socket.onerror = function() {
alert("发生了错误");
}
});
//发送消息
$("#btnSend").click(function() {
socket.send("1001,1");
});
//关闭
$("#btnClose").click(function() {
socket.close();
});