基于Spring Boot+Solr7.1.0运行时动态创建Solr Core方案咨询

针对你用Spring Boot + Spring Data Solr 7.1.0实现按客户动态创建独立Core的需求，我整理了一套可行的方案，结合你的场景拆解成具体步骤：

Solr本身支持通过Admin API动态管理Core，我们可以借助这个能力在运行时为每个客户创建独立Core；同时针对Spring Data Solr默认绑定固定Core的特性，需要做动态Core切换的适配，再通过Solr的ConfigSet机制保证所有客户Core的schema与模板完全一致。

1. 利用Solr Admin API创建客户专属Core #

Solr 7.1.0提供了HTTP接口用于创建Core，我们可以在Spring Boot中通过RestTemplate调用该接口完成创建。推荐使用ConfigSet来管理模板配置，这样能最大程度保证schema一致性。

准备模板ConfigSet #

先把你的模板schema（managed-schema或schema.xml）、solrconfig.xml等配置文件放到Solr的configsets目录下，比如创建solr/server/solr/configsets/customer_template_config目录，将模板配置文件放入其中。

代码实现Core创建 #

@Autowired
private RestTemplate restTemplate;

@Value("${spring.data.solr.host}")
private String solrHost;

public boolean createCustomerCore(String customerId) {
    String coreName = "customer_" + customerId;
    
    // 先校验Core是否已存在，避免重复创建
    if (isCoreExists(coreName)) {
        return true;
    }

    MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
    params.add("action", "CREATE");
    params.add("name", coreName);
    // 引用提前准备好的模板ConfigSet
    params.add("configSet", "customer_template_config");
    params.add("wt", "json");

    try {
        ResponseEntity<String> response = restTemplate.postForEntity(
            solrHost + "/admin/cores",
            params,
            String.class
        );
        // 解析响应判断创建是否成功（可根据Solr返回的JSON状态码判断）
        JsonNode root = new ObjectMapper().readTree(response.getBody());
        return "0".equals(root.get("responseHeader").get("status").asText());
    } catch (Exception e) {
        // 处理创建异常，比如日志记录、告警等
        log.error("Failed to create core for customer: {}", customerId, e);
        return false;
    }
}

// 校验Core是否存在的辅助方法
private boolean isCoreExists(String coreName) {
    try {
        ResponseEntity<String> response = restTemplate.getForEntity(
            solrHost + "/admin/cores?action=STATUS&core=" + coreName + "&wt=json",
            String.class
        );
        JsonNode root = new ObjectMapper().readTree(response.getBody());
        return root.has("status") && root.get("status").has(coreName);
    } catch (Exception e) {
        log.error("Failed to check core existence: {}", coreName, e);
        return false;
    }
}

2. 动态切换Spring Data Solr的Core访问 #

Spring Data Solr默认的SolrTemplate绑定固定Core，我们需要实现动态创建对应Core的SolrTemplate，或者自定义仓库实现来支持Core切换。

方案一：动态生成SolrTemplate #

@Configuration
public class DynamicSolrConfig {

    @Value("${spring.data.solr.host}")
    private String solrHost;

    @Bean
    public SolrClient baseSolrClient() {
        return new HttpSolrClient.Builder(solrHost).build();
    }

    // 根据Core名动态生成SolrTemplate
    public SolrTemplate getSolrTemplateForCore(String coreName) {
        SolrClient coreClient = new HttpSolrClient.Builder(solrHost + "/" + coreName).build();
        return new SolrTemplate(coreClient);
    }
}

业务层使用示例：

@Autowired
private DynamicSolrConfig dynamicSolrConfig;

public void saveCustomerData(String customerId, YourEntity entity) {
    SolrTemplate solrTemplate = dynamicSolrConfig.getSolrTemplateForCore("customer_" + customerId);
    solrTemplate.saveBean(entity);
    solrTemplate.commit();
}

方案二：自定义动态仓库实现 #

如果习惯用Spring Data Solr的仓库接口，可以自定义实现类来支持Core切换：

// 自定义仓库接口
public interface CustomerSolrRepository extends SolrCrudRepository<YourEntity, String> {
    // 自定义查询方法
}

// 仓库实现类
public class CustomerSolrRepositoryImpl implements CustomerSolrRepository {

    private final String solrHost;
    private SolrTemplate currentSolrTemplate;

    @Autowired
    public CustomerSolrRepositoryImpl(@Value("${spring.data.solr.host}") String solrHost) {
        this.solrHost = solrHost;
    }

    // 设置当前操作的Core
    public void setCurrentCore(String coreName) {
        SolrClient coreClient = new HttpSolrClient.Builder(solrHost + "/" + coreName).build();
        this.currentSolrTemplate = new SolrTemplate(coreClient);
    }

    @Override
    public <S extends YourEntity> S save(S entity) {
        Objects.requireNonNull(currentSolrTemplate, "Core not set!");
        currentSolrTemplate.saveBean(entity);
        currentSolrTemplate.commit();
        return entity;
    }

    // 其他Crud方法同理实现，复用currentSolrTemplate
}

业务层使用示例：

@Autowired
private CustomerSolrRepository customerSolrRepository;

public void processCustomerData(String customerId, YourEntity entity) {
    ((CustomerSolrRepositoryImpl) customerSolrRepository).setCurrentCore("customer_" + customerId);
    customerSolrRepository.save(entity);
}

3. 严格保证Schema一致性 #

• 锁定ConfigSet：禁止直接修改单个客户Core的schema，所有schema变更都通过更新模板ConfigSet实现，然后调用Solr的RELOAD接口刷新所有客户Core：POST /solr/admin/cores?action=RELOAD&core=customer_xxx
• 配置Schema权限：在solrconfig.xml中设置ManagedIndexSchemaFactory的mutable属性为false，禁用单个Core的schema修改API：

  <schemaFactory class="ManagedIndexSchemaFactory">
      <bool name="mutable">false</bool>
      <str name="managedSchemaResourceName">managed-schema</str>
  </schemaFactory>
  

• Solr认证处理：如果你的Solr开启了Basic Auth或其他认证，需要在RestTemplate中添加认证拦截器，携带认证信息调用Admin API。
• 资源管控：每个Core会占用Solr的内存和磁盘资源，要根据服务器配置限制客户Core数量，或者定期清理长期 inactive 的Core。
• 版本兼容性：确保Spring Data Solr版本与Solr 7.1.0匹配，推荐使用Spring Data Solr 2.1.x系列（比如2.1.10.RELEASE）。
• 数据备份：定期通过Solr的Backup API为每个客户Core做数据备份，避免数据丢失：POST /solr/admin/cores?action=BACKUP&core=customer_xxx&location=/backup/path

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