package project.web.socketio;//package project.web.data.socketio;
|
//
|
//import java.util.HashMap;
|
//import java.util.HashSet;
|
//import java.util.Map;
|
//import java.util.Set;
|
//
|
//import org.slf4j.Logger;
|
//import org.slf4j.LoggerFactory;
|
//import org.springframework.beans.factory.DisposableBean;
|
//import org.springframework.beans.factory.InitializingBean;
|
//
|
//import com.corundumstudio.socketio.SocketIOClient;
|
//import com.corundumstudio.socketio.SocketIOServer;
|
//
|
//public class SocketIOService implements InitializingBean, DisposableBean {
|
// private static final Logger logger = LoggerFactory.getLogger(SocketIOService.class);
|
//
|
// private SocketIOConfig SocketIOConfig;
|
// private SocketIOServer socketIOServer;
|
//
|
// // 每个主题的订阅用户 topic --> set of clients
|
// private Map<String, Set<SocketIOClient>> topicSubscribers = new HashMap<>();
|
//
|
// // 每个主题的最新消息 topic --> latest content
|
// private Map<String, String> topicContent = new HashMap<>();
|
//
|
// @Override
|
// public void afterPropertiesSet() {
|
// socketIOServer = SocketIOConfig.socketIOServer();
|
//
|
// // 与前端建立连接
|
// socketIOServer.addConnectListener(client -> {
|
// if (null != client.getHandshakeData().getSingleUrlParam("user")
|
// && null != client.getHandshakeData().getSingleUrlParam("subscriptions")) {
|
// logger.info("user " + client.getHandshakeData().getSingleUrlParam("user") + " connected to socketio");
|
// String subscriptions = client.getHandshakeData().getSingleUrlParam("subscriptions");
|
// for (String topic : subscriptions.split(",")) {
|
// if (topicSubscribers.containsKey(topic)) {
|
// topicSubscribers.get(topic).add(client);
|
// } else {
|
// Set<SocketIOClient> s = new HashSet<>();
|
// s.add(client);
|
// topicSubscribers.put(topic, s);
|
// }
|
// if (topicContent.containsKey(topic)) {
|
// client.sendEvent("publish", topic, topicContent.get(topic));
|
// }
|
// }
|
// }
|
// });
|
// // 与前端断开连接
|
// socketIOServer.addDisconnectListener(client -> {
|
// if (null != client.getHandshakeData().getSingleUrlParam("user")
|
// && null != client.getHandshakeData().getSingleUrlParam("subscriptions")) {
|
// logger.info("user " + client.getHandshakeData().getSingleUrlParam("user") + " disconnected to socketio");
|
// String subscriptions = client.getHandshakeData().getSingleUrlParam("subscriptions");
|
// for (String topic : subscriptions.split(",")) {
|
// topicSubscribers.get(topic).remove(client);
|
// }
|
// }
|
// });
|
// socketIOServer.start();
|
// logger.info("socketio started on port " + socketIOServer.getConfiguration().getPort());
|
// }
|
//
|
// @Override
|
// public void destroy() {
|
// if (null != socketIOServer) {
|
// socketIOServer.stop();
|
// logger.info("socketio stopped");
|
// }
|
// }
|
//
|
// public void publish(String topic, String content) {
|
// System.out.println("topic: " + topic);
|
// System.out.println("content: " + content);
|
// topicContent.put(topic, content);
|
// System.out.println("11111111111111111111111111111" + topicSubscribers);
|
// if (topicSubscribers.containsKey(topic)) {
|
// for (SocketIOClient client : topicSubscribers.get(topic)) {
|
// System.out.println("22222222222222222222222222222" + client);
|
// client.sendEvent("publish", topic, content);
|
// }
|
// }
|
// }
|
//
|
// public void setSocketIOServer(SocketIOServer socketIOServer) {
|
// this.socketIOServer = socketIOServer;
|
// }
|
//
|
// public void setSocketIOConfig(SocketIOConfig socketIOConfig) {
|
// SocketIOConfig = socketIOConfig;
|
// }
|
//
|
//}
|
