Quarkus集成MongoDB时如何动态设置集合名称？

Quarkus生态（含原生mongodb-client、mongodb-panache扩展）没有提供Spring Data那种在@Document注解中直接写SpEL动态解析集合名的开箱能力，基于请求上下文动态选择集合的思路可行，但不需要重复创建MongoClient这类重资源对象，以下是可直接落地的实现方式：

方案1：基于quarkus-mongodb-client原生API实现 #

• 核心原则：MongoClient是封装了连接池的线程安全重资源对象，全局保持单例复用即可，不需要每次请求新建实例。动态集合选择只需要在数据操作环节，根据当前请求上下文计算出最终集合名，再获取对应集合实例操作即可，该操作是轻量无额外开销的。
• 实现步骤：封装RequestScoped作用域的集合提供器，统一处理动态集合名计算逻辑：

import jakarta.enterprise.context.RequestScoped;
import jakarta.inject.Inject;
import jakarta.ws.rs.core.HttpHeaders;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoCollection;
import org.eclipse.microprofile.config.inject.ConfigProperty;

@RequestScoped
public class RequestMongoCollectionProvider {
    @Inject
    MongoClient mongoClient;
    @Inject
    HttpHeaders headers;

    @ConfigProperty(name = "quarkus.mongodb.database")
    String databaseName;

    public <T> MongoCollection<T> getEntityCollection(Class<T> entityClass, String collectionSuffix) {
        // 从请求头/请求上下文提取动态标识，比如租户ID、业务等级标识
        String dynamicPrefix = headers.getHeaderString("X-Biz-Tag");
        // 拼接得到最终集合名，和原Spring SpEL逻辑对齐，例如标识为premium时得到premiumCustomer
        String finalCollectionName = dynamicPrefix + collectionSuffix;
        return mongoClient.getDatabase(databaseName).getCollection(finalCollectionName, entityClass);
    }
}

• 使用时直接注入该提供器，传入实体类型和固定集合后缀即可获取对应动态集合，不需要在实体类上绑定固定集合名。

方案2：基于MongoDB with Panache扩展实现 #

Panache默认通过@MongoEntity注解绑定静态集合名，但其提供了集合名解析的SPI扩展点，可无侵入实现动态集合逻辑，不需要修改原有业务数据操作代码：

1. 实体类正常编写，注解中填写固定的集合名后缀部分即可：

import io.quarkus.mongodb.panache.PanacheMongoEntity;
import io.quarkus.mongodb.panache.common.MongoEntity;

@MongoEntity(collection = "Customer")
public class Customer extends PanacheMongoEntity {
    // 实体字段、getter、setter省略
}

2. 自定义集合名解析器实现Panache提供的MongoCollectionNameResolver接口，设置为请求作用域，在实现中读取请求上下文拼接动态集合名：

import jakarta.enterprise.context.RequestScoped;
import jakarta.inject.Inject;
import jakarta.ws.rs.core.HttpHeaders;
import io.quarkus.mongodb.panache.common.MongoCollectionNameResolver;

@RequestScoped
public class DynamicCollectionNameResolver implements MongoCollectionNameResolver {
    @Inject
    HttpHeaders headers;

    @Override
    public String getCollectionName(Class<?> entityClass, String fixedNameFromAnnotation) {
        String dynamicPrefix = headers.getHeaderString("X-Biz-Tag");
        return dynamicPrefix + fixedNameFromAnnotation;
    }
}

该实现会被Panache自动识别优先级，所有Panache内置的持久化、查询方法（persist()、listAll()、find()等）都会自动使用解析后的动态集合名，业务层无需额外调整。

响应式栈场景（使用quarkus-mongodb-client-reactive、mongodb-panache-reactive）下上述逻辑完全通用，仅需将同步类替换为对应的响应式版本即可，核心解析逻辑不需要改动。

关于新建MongoDatabase实例的思路：MongoDatabase本身是轻量对象，只要复用全局单例的MongoClient，每次调用getDatabase()获取实例不会有性能问题，只是相比直接使用官方扩展点的实现，需要自行封装更多数据操作逻辑，维护成本更高。

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