加拿大MES项目
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
wuyouming666
2023-09-07 db0b4745458fd22b6552912b0572a89b2af09564 
 springboot-vue3/src/main/java/com/example/springboot/component/WebSocketServer.java


@@ -4,6 +4,8 @@


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;




@@ -16,8 +18,8 @@


import javax.websocket.server.PathParam;


import javax.websocket.server.ServerEndpoint;




import org.springframework.context.ConfigurableApplicationContext;


import org.springframework.stereotype.Component;






import cn.hutool.json.JSONObject;


import cn.hutool.json.JSONUtil;


@@ -25,6 +27,17 @@


@ServerEndpoint(value = "/api/talk/{username}")


@Component


public class WebSocketServer {




    // @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;


@@ -86,6 +99,7 @@


         jsonObject.set("message", text);


        this.messages.add(text);


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


         


    }




    @OnError


@@ -122,6 +136,7 @@




    public List<String> getMessages() {


        return messages;


        


    }




    public void clearMessages() {