| File was renamed from hangzhoumesParent/moduleService/CacheGlassModule/src/main/java/com/mes/common/WebSocketServer.java |
| | |
|---|
| | | package com.mes.common; |
|---|
| | | package com.mes.tools; |
|---|
| | | |
|---|
| | | import cn.hutool.json.JSONObject; |
|---|
| | | import cn.hutool.json.JSONUtil; |
|---|
| | |
|---|
| | | |
|---|
| | | public static ConfigurableApplicationContext applicationContext; |
|---|
| | | |
|---|
| | | // 解决无法注入mapper问题 //使用方法 |
|---|
| | | // homeMapper=WebSocketServer.applicationContext.getBean(HomeMapper.class); |
|---|
| | | public static void setApplicationContext(ConfigurableApplicationContext configurableApplicationContext) { |
|---|
| | | WebSocketServer.applicationContext = configurableApplicationContext; |
|---|
| | | } |
|---|
| | | |
|---|
| | | private static final Logger log = LoggerFactory.getLogger(WebSocketServer.class); |
|---|
| | | private List<String> messages; |
|---|
| | | /** |
|---|
| | |
|---|
| | | */ |
|---|
| | | public static final Map<String, ArrayList<WebSocketServer>> sessionMap = new ConcurrentHashMap<>(); |
|---|
| | | |
|---|
| | | String username; |
|---|
| | | Session session; |
|---|
| | | public String username; |
|---|
| | | public Session session; |
|---|
| | | |
|---|
| | | public WebSocketServer() { |
|---|
| | | this.messages = new ArrayList<>(); |
|---|
| | |
|---|
| | | JSONObject jsonObject = new JSONObject(); |
|---|
| | | jsonObject.set("message", text); |
|---|
| | | this.messages.add(text); |
|---|
| | | this.sendMessage(jsonObject.toString()); // JSONUtil.toJsonStr(jsonObject) |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @OnError |
|---|
