Spring响应式Mongo固定集合@Tailable Flux流过滤失效问题咨询

核心导致过滤器失效的原因 #

• 字符串比较逻辑错误，!=无法匹配字符串内容
  Java 中!=操作符对所有引用类型的判断逻辑是比对两个对象的内存地址，不会读取字符串存储的实际文本内容。哪怕两个字符串的字符序列完全一致，只要不是同一个内存地址的实例，!=的判断结果就为true。
  你写的过滤逻辑filter(p -> p.getRiderId()!=riderId)，本质上是对每个拉取到的文档判断“当前文档的riderId内存地址和入参riderId的内存地址是否不同”——因为从数据库反序列化出来的riderId字符串、以及从接口入参接收的riderId字符串，都是堆上独立创建的对象，不会复用字符串常量池的缓存，这个判断永远返回true，导致所有文档都会通过过滤器，根本起不到筛选效果，最终你会收到固定集合里的全量记录。哪怕在某些特殊场景下因为常量池复用碰巧判断正确，这种写法也是完全不可靠的。

性能更优的实现方案 #

当前你是在应用层拉取全量固定集合数据后再做客户端过滤，其实可以把过滤条件下推到Mongo数据库层，减少不必要的网络传输和内存开销，同时完全保留尾游标（@Tailable）的实时推送能力：

1. 在Repository中直接定义带筛选条件的尾游标查询方法，Spring Data MongoDB会自动生成匹配的查询语句：

   public interface ActiveRideCappedRepository extends ReactiveMongoRepository<ActiveRideCapped, String> {
       @Tailable
       // 直接匹配riderId不等于入参的记录，在数据库层完成过滤
       Flux<ActiveRideCapped> findActiveRideCappedByRiderIdNot(String riderId);
   }
   

2. 业务层代码直接返回该方法的结果即可，不需要额外在流上添加客户端过滤器：

   @Override
   public Flux<ActiveRideCapped> getRiderLocationStream(String riderId) {
       return activeRideCappedRepository.findActiveRideCappedByRiderIdNot(riderId);
   }
   

保留客户端过滤的修正写法 #

如果需要在拉取全量流的基础上做多维度的自定义筛选，只需要把原来的错误比较逻辑替换为可靠的字符串内容判断即可：

@Override
public Flux<ActiveRideCapped> getRiderLocationStream(String riderId) {
    return activeRideCappedRepository.findActiveRideCappedBy()
            // 替换为准确的字符串内容不等判断，避免空指针
            .filter(p -> !Objects.equals(p.getRiderId(), riderId));
}

注意：使用Objects.equals()而非直接调用p.getRiderId().equals(riderId)，是为了避免当文档的riderId字段为空时抛出空指针异常。

内容的提问来源于stack exchange，提问作者Yogesh Pitale