应用场景

使用solr时，有时需要通过程序动态的加载配置文件，如修改了solrconfig.xml、schema.xml，需要通过重新加载core来达到重新加载配置文件的目的。

另外，针对索引分类，也需要动态的创建core.

代码示例

import java.io.File;
import java.io.IOException;import org.apache.solr.client.solrj.SolrServerException;
import org.apache.solr.client.solrj.impl.HttpSolrServer;
import org.apache.solr.client.solrj.request.CoreAdminRequest;
import org.apache.solr.common.util.NamedList;
import org.apache.solr.util.FileUtils;public class CoreAdminRequestDemo {public static final String SOLR_URL = "http://172.168.63.233:8983/solr";public static final String DEFAULT_CORE_NAME = "collection1";public static final String NEW_CORE_NAME = "demo";public static void main(String[] args) {try {// createCore(NEW_CORE_NAME);reloadCore(DEFAULT_CORE_NAME);} catch (IOException e) {e.printStackTrace();} catch (SolrServerException e) {e.printStackTrace();}}/*** * @param coreName* @throws SolrServerException* @throws IOException*/public static void reloadCore(String coreName) throws SolrServerException,IOException {// 连接solr服务器HttpSolrServer server = new HttpSolrServer(SOLR_URL);CoreAdminRequest.reloadCore(coreName, server);System.out.println("重新加载" + coreName + "成功");}/*** * @param coreName* @throws SolrServerException* @throws IOException*/public static void createCore(String coreName) throws SolrServerException,IOException {// 连接solr服务器HttpSolrServer server = new HttpSolrServer(SOLR_URL);// 获得solr.xml配置好的cores作为默认，获得默认core的路径NamedList<Object> list = CoreAdminRequest.getStatus(DEFAULT_CORE_NAME, server).getCoreStatus().get(DEFAULT_CORE_NAME);String path = (String) list.get("instanceDir");// 获得solrhome,也就是solr放置索引的主目录String solrHome = path.substring(0, path.indexOf(DEFAULT_CORE_NAME));// 建立新core所在文件夹File corePath = new File(solrHome + File.separator + NEW_CORE_NAME);if (!corePath.exists()) {corePath.mkdir();}// 建立新core下的conf文件夹File confPath = new File(corePath.getAbsolutePath() + File.separator+ "conf/");if (!confPath.exists()) {confPath.mkdir();}// 将默认core下conf里的solrconfig.xml和schema.xml拷贝到新core的conf下。这步是必须的// 因为新建的core solr会去其conf文件夹下找这两个文件，如果没有就会报错，新core则不会创建成功FileUtils.copyFile(new File(path + "conf/solrconfig.xml"), new File(confPath.getAbsolutePath() + File.separator+ "solrconfig.xml"));FileUtils.copyFile(new File(path + "conf/schema.xml"), new File(confPath.getAbsolutePath() + File.separator + "schema.xml"));// 创建新core,同时会把新core的信息添加到solr.xml里CoreAdminRequest.createCore(coreName, coreName, server);}
}