/**
* Copyright (c) 2016-2020 人人开源 All rights reserved.
*
* https://www.renren.io
*
* 版权所有,侵权必究!
*/
package com.zt.modules.message.websocket;
import java.io.IOException;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import com.alibaba.fastjson.JSON;
import com.zt.common.constant.Constant;
import com.zt.modules.message.websocket.config.WebSocketConfig;
import com.zt.modules.message.websocket.data.MessageData;
import com.zt.modules.message.websocket.data.WebSocketData;
/**
* WebSocket服务
*
* @author Mark sunlightcs@gmail.com
*/
@Slf4j
@Component
@ServerEndpoint(value = "/websocket", configurator = WebSocketConfig.class)
public class WebSocketServer {
/**
* 客户端连接信息
*/
private static Map servers = new ConcurrentHashMap<>();
@OnOpen
public void open(Session session) {
Long userId = (Long) session.getUserProperties().get(Constant.Field.USER);
servers.put(session.getId(), new WebSocketData(userId, session));
}
@OnClose
public void onClose(Session session) {
//客户端断开连接
servers.remove(session.getId());
log.debug("websocket close, session id:" + session.getId());
}
@OnError
public void onError(Session session, Throwable throwable) {
servers.remove(session.getId());
log.error(throwable.getMessage(), throwable);
}
@OnMessage
public void onMessage(Session session, String msg) {
log.info("session id: " + session.getId()+", message:" + msg);
}
/**
* 发送信息
* @param userIdList 用户ID列表
* @param message 消息内容
*/
public void sendMessage(List userIdList, MessageData> message) {
userIdList.forEach(userId -> sendMessage(userId, message));
}
/**
* 发送信息
* @param userId 用户ID
* @param message 消息内容
*/
public void sendMessage(Long userId, MessageData> message) {
servers.values().forEach(info -> {
if (userId.equals(info.getUserId())) {
sendMessage(info.getSession(), message);
}
});
}
/**
* 发送信息给全部用户
* @param message 消息内容
*/
public void sendMessageAll(MessageData> message) {
servers.values().forEach(info -> sendMessage(info.getSession(), message));
}
public void sendMessage(Session session, MessageData> message) {
try {
session.getBasicRemote().sendText(JSON.toJSONString(message));
} catch (IOException e) {
log.error("send message error," + e.getMessage(), e);
}
}
}