于紫祥_1901
2020-11-06 0099e6c9db0c858cb6905477830c79305dca39bb
src/main/java/com/moral/webSocketServer/WebSocketServerNew.java
@@ -35,11 +35,6 @@
    // 与某个客户端的连接会话,需要通过它来给客户端发送数据
    private Session session;
    private String orgId;
    private String accountId;
    private Connection connection;
    private Channel channel;
@@ -57,12 +52,13 @@
        this.session = session;
        //这个一定要写,第一次很容易忽略!
        webSocketSet.add(this);
        //取参
        String[] flag=param.split("&");
        String orgId = flag[0];
        String accountId = flag[1];
        String monitPointId = flag[2];
        String p=flag[3];
        String QUEUE_NAME = "deviceData_" + accountId;
        Map<String, Object> paramMap = new HashMap<String, Object>();
        List<Device> deviceList = deviceService.getDeviceById2(Integer.parseInt(monitPointId));
@@ -116,9 +112,7 @@
    @OnClose
    public void onClose() {
//**从安全Set中 移除当前连接对象*//**//**//**//**//**//**//**//*
        webSocketSet.remove(this);
        try {
            connection.close();