/**
|
* Copyright (c) 2016-2020 人人开源 All rights reserved.
|
* <p>
|
* https://www.renren.io
|
* <p>
|
* 版权所有，侵权必究！
|
*/
|
|
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<String, WebSocketData> 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<Long> 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);
|
}
|
}
|
}
|
