如何在Micronaut中配置多租户MongoDB集合？（Micronaut Data配置失效）

你的问题出在@Property注解无法被Micronaut Data MongoDB解析为集合名称，以下是几种可行的正确配置方案：

方案一：使用@MongoCollection结合SpEL表达式（推荐，适用于单实体配置） #

Micronaut Data 3.x及以上版本支持在@MongoCollection注解中使用SpEL表达式动态生成集合名，替换你原来的@Property注解即可：

@Getter
@Setter
@MappedEntity
@MongoCollection(name = "#{@threadContext.get('tenant')}_audit_logs")
public class AuditLog {
    @Id
    @GeneratedValue
    private String id;
    // 其他业务字段
}

注意：

• @threadContext是你存储租户信息的Bean的名称（需确保该Bean是Micronaut的Singleton），如果你的Bean类名为ThreadContext，默认Bean名称是首字母小写的threadContext
• 若租户信息为空，建议添加默认集合名的 fallback 逻辑，比如#{@threadContext.get('tenant') ?: 'default'}_audit_logs

方案二：自定义全局命名策略（适用于多实体统一处理） #

如果多个实体都需要租户前缀的集合名，自定义MongoNamingStrategy可以统一处理：

1. 实现MongoNamingStrategy接口：

@Singleton
public class TenantAwareNamingStrategy implements MongoNamingStrategy {
    private final ThreadContext threadContext;

    // 构造注入租户上下文Bean
    public TenantAwareNamingStrategy(ThreadContext threadContext) {
        this.threadContext = threadContext;
    }

    @Override
    public String getCollectionName(Class<?> entityClass) {
        String tenantId = threadContext.get("tenant");
        // 获取实体默认的集合名（从@MappedEntity的value或类名转换而来）
        MappedEntity mappedEntity = entityClass.getAnnotation(MappedEntity.class);
        String baseName = mappedEntity != null && !mappedEntity.value().isEmpty()
                ? mappedEntity.value()
                : CaseFormat.UPPER_CAMEL.to(CaseFormat.LOWER_UNDERSCORE, entityClass.getSimpleName());
        
        // 拼接租户前缀，无租户时使用原集合名
        return tenantId != null && !tenantId.isBlank()
                ? tenantId.toLowerCase() + "_" + baseName
                : baseName;
    }
}

2. 在application.yml中配置使用该命名策略：

micronaut:
  data:
    mongodb:
      naming-strategy: com.yourpackage.TenantAwareNamingStrategy

方案三：在Repository层动态指定集合名（适用于单个Repository特殊场景） #

如果仅需在特定Repository中动态指定集合名，可以重写Repository方法并添加@Collection注解：

public interface AuditLogRepository extends MongoRepository<AuditLog, String> {
    @Override
    @Collection("#{@threadContext.get('tenant')}_audit_logs")
    <S extends AuditLog> S save(S entity);

    // 其他CRUD方法如需使用动态集合名，也需要重写并添加@Collection注解
}

关键注意事项 #

• 确保租户信息在请求上下文正确传递：需通过过滤器/拦截器将租户ID存入ThreadContext的ThreadLocal中，保证在数据库操作时能获取到有效值
• 处理空租户场景：避免因租户信息缺失导致集合名异常，建议添加默认值或抛出异常

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