1

zj

2024-08-12 440f0f0b37a10c82e54f402be8d4d99c7406b4d4

 websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java

@@ -216,10 +216,7 @@
//                log.info("距离上次发送消息时间未达到指定间隔，不发送消息。");
            }
        }else{
            Map<String,Integer> map = new HashMap<>();
            map.put("status",1);
            pushMessage(session,JSONUtil.toJsonStr(map));
            closeSession(session,"没有订阅消息");
            pushMessage(session,"没有订阅消息");
        }
    }
    private static final Gson gson = new Gson();
@@ -248,9 +245,16 @@
                    .collect(Collectors.toList());
        }
        //价差
        redisValueMap = redisValueMap.stream()
                .filter(data -> Double.parseDouble(data.getSpread()) >= wsBo.getSpread())
                .collect(Collectors.toList());
        if(wsBo.getSystemFiltration()){
            redisValueMap = redisValueMap.stream()
                    .filter(data -> Double.parseDouble(data.getSpread()) <= wsBo.getSpread())
                    .collect(Collectors.toList());
        }else{
            redisValueMap = redisValueMap.stream()
                    .filter(data -> Double.parseDouble(data.getSpread()) >= wsBo.getSpread() && Double.parseDouble(data.getSpread()) >= 1000)
                    .collect(Collectors.toList());
        }

        //最低金额
        if(null !=  wsBo.getMinAmount()){
            redisValueMap = redisValueMap.stream()
@@ -363,6 +367,6 @@
            log.error("强制断开连接----异常: {}", e.getMessage());
        }
        wsServers.remove(this);
        log.info("客户端未及时发送订阅消息，断开连接");
        log.info(reason);
    }
}