1

zj

2024-08-30 1688c7f5fbe02393f4398fa0bb901ac3c30dc9ec

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

@@ -226,10 +226,11 @@
        }
        if (!CollectionUtils.isEmpty(currencies)) {
            Set<String> filtrationSet = currencies.stream()
//                    .map(f -> f.getCurrency() + f.getBuy() + f.getSell()) //组合过滤 ，暂时不使用，直接过滤整个币种
                    .map(f -> f.getCurrency())
                    .map(f -> f.getCurrency() + f.getBuy() + f.getSell()) //组合过滤 ，暂时不使用，直接过滤整个币种
//                    .map(f -> f.getCurrency())
                    .collect(Collectors.toSet());
            redisValueMap.removeIf(data -> filtrationSet.contains(data.getBaseAsset()));
//            redisValueMap.removeIf(data -> filtrationSet.contains(data.getBaseAsset()));
            redisValueMap.removeIf(data -> filtrationSet.contains(data.getBuyAndSell()));
        }