Java Spring Webflux：MyInterface与ReactiveCrudRepository类型不兼容问题解决

问题场景 #

开发Spring Webflux应用时，定义了通用仓库接口MyInterface统一操作：

public interface MyInterface {
    Mono<MyPojo> save(MyPojo myPojo);
}

Redis仓库通过实现类正常实现该接口：

@Repository("redis")
public class MyRedisRepository implements MyInterface {
    private final ReactiveRedisOperations<String, String> reactiveRedisOperations;

    public MyRedisRepository(ReactiveRedisOperations<String, String> reactiveRedisOperations) {
        this.reactiveRedisOperations = reactiveRedisOperations;
    }

    @Override
    public Mono<MyPojo> save(MyPojo myPojo) {
        return reactiveRedisOperations.opsForValue().set("someKey", "someValue").map(__ -> myPojo);
    }
}

但Elastic仓库通过接口同时继承ReactiveElasticsearchRepository和MyInterface时，编译报错：

types question.MyInterface and org.springframework.data.repository.reactive.ReactiveCrudRepository<question.MyPojo,java.lang.String> are incompatible;

需求是保留MyInterface，让所有仓库统一实现该接口。

错误原因 #

冲突根源在于两个接口的save方法签名不兼容：

• MyInterface的save方法签名是Mono<MyPojo> save(MyPojo myPojo)，参数和返回值都是具体的MyPojo类型。
• ReactiveElasticsearchRepository继承了ReactiveCrudRepository，后者的save方法是泛型定义：<S extends T> Mono<S> save(S entity)。

Java泛型擦除后，两个方法的签名看起来都是Mono save(Object)，但实际泛型约束不同，编译器无法判定这是合法的重载或重写，因此抛出不兼容错误。

解决方法 #

方法一：对齐MyInterface的方法签名 #

修改MyInterface，使其save方法的泛型定义与ReactiveCrudRepository保持一致：

public interface MyInterface<T> {
    <S extends T> Mono<S> save(S entity);
}

然后调整Redis仓库的实现：

@Repository("redis")
public class MyRedisRepository implements MyInterface<MyPojo> {
    private final ReactiveRedisOperations<String, String> reactiveRedisOperations;

    public MyRedisRepository(ReactiveRedisOperations<String, String> reactiveRedisOperations) {
        this.reactiveRedisOperations = reactiveRedisOperations;
    }

    @Override
    public <S extends MyPojo> Mono<S> save(S entity) {
        return reactiveRedisOperations.opsForValue().set("someKey", "someValue").map(__ -> entity);
    }
}

Elastic仓库接口只需指定泛型即可：

@Repository("elastic")
public interface MyElasticRepository extends ReactiveElasticsearchRepository<MyPojo, String>, MyInterface<MyPojo> {
}

这样两个接口的save方法签名完全匹配，编译冲突消除。

方法二：使用适配器类桥接 #

如果不想修改MyInterface的原有定义，可以通过适配器类避免直接继承两个接口：

1. 调整Elastic仓库接口，仅继承ReactiveElasticsearchRepository：

public interface MyElasticRepository extends ReactiveElasticsearchRepository<MyPojo, String> {
}

2. 创建适配器抽象类，实现MyInterface并委托给Elastic仓库：

public abstract class ElasticRepositoryAdapter implements MyInterface {
    protected final MyElasticRepository elasticRepo;

    public ElasticRepositoryAdapter(MyElasticRepository elasticRepo) {
        this.elasticRepo = elasticRepo;
    }

    @Override
    public Mono<MyPojo> save(MyPojo myPojo) {
        return elasticRepo.save(myPojo);
    }
}

3. 创建带@Repository注解的实现类：

@Repository("elastic")
public class MyElasticRepositoryImpl extends ElasticRepositoryAdapter {
    public MyElasticRepositoryImpl(MyElasticRepository elasticRepo) {
        super(elasticRepo);
    }
}

这种方式通过适配器封装Elastic仓库的操作，既保留了MyInterface的原有定义，又避开了接口继承冲突。

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