websocketSerivce/src/main/java/org/example/websocket/server/WsServer.java
@@ -229,7 +229,8 @@ .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())); }