加拿大MES项目
blame | 历史 | 补丁 | 提交 | 提交对比 | show whitespace
clll
2023-09-06 ee84c191faa2c235703eaa8cdc765729bed71a4f 
 springboot-vue3/src/main/java/com/example/springboot/component/WebSocketServer.java


@@ -4,8 +4,11 @@


import java.util.List;


import java.util.Map;


import java.util.concurrent.ConcurrentHashMap;




import org.apache.catalina.core.ApplicationContext;


import org.slf4j.Logger;


import org.slf4j.LoggerFactory;






import javax.websocket.OnClose;


import javax.websocket.OnError;


@@ -25,13 +28,16 @@


@Component


public class WebSocketServer {




  static ConfigurableApplicationContext applicationContext;


  // 解决无法注入mapper问题  //使用方法


  // homeMapper=WebSocketServer.applicationContext.getBean(HomeMapper.class);


    // @Autowired


    // HomeMapper homeMapper;




    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;


@@ -42,11 +48,9 @@




  String username;


  Session session;




  public WebSocketServer() {


    this.messages = new ArrayList<>();


  }




  /**


   * 连接建立成功调用的方法


   */


@@ -83,7 +87,6 @@


   * 后台收到客户端发送过来的消息


   * onMessage 是一个消息的中转站


   * 接受 浏览器端 socket.send 发送过来的 json数据


   * 


   * @param message 客户端发送过来的消息


   */


  @OnMessage


@@ -96,6 +99,7 @@


    jsonObject.set("message", text);


    this.messages.add(text);


    this.sendMessage(jsonObject.toString()); // JSONUtil.toJsonStr(jsonObject)


         


  }




  @OnError


@@ -132,6 +136,7 @@




  public List<String> getMessages() {


    return messages;


        


  }




  public void clearMessages() {