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