Spring Data Solr 3.0.6中如何动态选择Solr Core

嘿，我来帮你搞定Spring Data Solr动态选择Core的问题！结合你用的Spring Data Solr 3.0.6和Solr 7.0.0，这里有几个实用方案，你可以根据自己的业务场景挑选：

其实Spring Data Solr的SolrTemplate本身就提供了带Core名称的重载方法，完全不用改现有配置，直接在调用时指定要操作的Core就行。

比如在你的Service层这么用：

@Autowired
private SolrOperations solrTemplate;

public List<YourEntity> queryFromTargetCore(String coreName, String queryStr) {
    SolrQuery query = new SolrQuery(queryStr);
    // 直接传入Core名称执行查询
    return solrTemplate.query(coreName, query, YourEntity.class).getContent();
}

public void saveToTargetCore(String coreName, YourEntity entity) throws SolrServerException, IOException {
    solrTemplate.saveBean(coreName, entity);
    solrTemplate.commit(coreName);
}

优点：零配置改动，快速上手，适合Core名称需要动态传入、不固定的场景。

如果需要更底层的控制，比如为每个Core创建独立的SolrClient实例，可以在配置类里加一个Core工厂方法：

@Configuration
@EnableSolrRepositories(basePackages = "com.solr.repository")
public class SolrConfiguration {

    @Value("${solr.server.url}")
    private String solrServerBaseUrl; // 配置不带Core的基础地址，比如http://localhost:8983/solr

    // 根据Core名称生成对应的SolrClient
    public SolrClient getSolrClientForCore(String coreName) {
        return new HttpSolrClient.Builder(solrServerBaseUrl + "/" + coreName).build();
    }

    // 保留默认的SolrTemplate（可选，用默认Core初始化）
    @Bean
    public SolrOperations solrTemplate() {
        return new SolrTemplate(getSolrClientForCore("default_core"));
    }
}

然后在Service层按需创建SolrTemplate：

@Autowired
private SolrConfiguration solrConfig;

public void operateOnCore(String coreName) {
    // 用try-with-resources管理SolrClient生命周期
    try (SolrClient targetClient = solrConfig.getSolrClientForCore(coreName)) {
        SolrTemplate targetTemplate = new SolrTemplate(targetClient);
        // 执行你的业务操作
        targetTemplate.saveBean(yourEntity);
        targetTemplate.commit();
    } catch (SolrServerException | IOException e) {
        // 处理异常逻辑
        e.printStackTrace();
    }
}

优点：每个Core用独立的SolrClient实例，适合频繁切换不同Core的场景，资源隔离性更好。

如果你的Solr Core数量是固定的（比如只有core1、core2），可以直接在配置类中为每个Core创建独立的SolrClient和SolrTemplate Bean：

@Configuration
@EnableSolrRepositories(basePackages = "com.solr.repository")
public class SolrConfiguration {

    @Value("${solr.server.url}")
    private String solrServerBaseUrl;

    @Bean(name = "core1SolrClient")
    public SolrClient core1SolrClient() {
        return new HttpSolrClient.Builder(solrServerBaseUrl + "/core1").build();
    }

    @Bean(name = "core2SolrClient")
    public SolrClient core2SolrClient() {
        return new HttpSolrClient.Builder(solrServerBaseUrl + "/core2").build();
    }

    @Bean(name = "core1SolrTemplate")
    public SolrOperations core1SolrTemplate(@Qualifier("core1SolrClient") SolrClient client) {
        return new SolrTemplate(client);
    }

    @Bean(name = "core2SolrTemplate")
    public SolrOperations core2SolrTemplate(@Qualifier("core2SolrClient") SolrClient client) {
        return new SolrTemplate(client);
    }
}

然后在Service层直接注入对应模板：

@Autowired
@Qualifier("core1SolrTemplate")
private SolrOperations core1SolrTemplate;

@Autowired
@Qualifier("core2SolrTemplate")
private SolrOperations core2SolrTemplate;

public List<YourEntity> queryCore1(String queryStr) {
    return core1SolrTemplate.query(new SolrQuery(queryStr), YourEntity.class).getContent();
}

优点：代码直观，不需要每次传入Core名称，适合Core数量固定、业务逻辑对应固定Core的场景。

如果你的自定义Repository需要支持动态Core，可以扩展Repository接口并实现自定义方法：

// 自定义扩展接口
public interface DynamicCoreSolrRepository<T, ID> extends SolrRepository<T, ID> {
    List<T> queryFromCore(String coreName, String queryStr);
}

// 实现类
public class DynamicCoreSolrRepositoryImpl<T, ID> implements DynamicCoreSolrRepository<T, ID> {

    @Autowired
    private SolrOperations solrTemplate;

    @Override
    public List<T> queryFromCore(String coreName, String queryStr) {
        return solrTemplate.query(coreName, new SolrQuery(queryStr), (Class<T>) YourEntity.class).getContent();
    }

    // 其他继承自SolrRepository的方法会自动实现，不用额外写
}

// 你的实体Repository继承这个扩展接口
public interface YourEntityRepository extends DynamicCoreSolrRepository<YourEntity, String> {
}

这样调用Repository时就能直接用queryFromCore方法指定Core了。

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