HttpSolrServer-采用静态工厂方法,创建HttpSolrServer单实例

　　HttpSolrServer线程安全,如果使用下面构造器,必须对所有的请求重用相同的实例.如果实例在运行中创建的，
它可能会导致连接泄漏.推荐的做法就是保持每个solr服务url的HttpSolrServer的静态实例,所有的请求都共享这个实例.
参考https://issues.apache.org/jira/browse/SOLR-861查看更多细节.
1.创建配置文件solr-config.properties:

cores=ac,jd

base_url=http://127.0.0.a:13131/solr

　2.创建配置对象ConfigUtil.java 读取properties文件中的配置:

package com.li.util;

import java.util.ResourceBundle;

public class ConfigUtil {

    private static ResourceBundle  resouceBundle = ResourceBundle.getBundle(Config.SEARCH);

    public static String getString(String key){

        return resouceBundle.getString(key);

    }

}

3.配置属性对象类Config.java:

package com.li.util;

public class Config {

    //common

    public static final String COMMA = ",";

    public static final String UNDERLINE = "_";

    public static final String SINGE_BLANK =" ";

    public static final String SLASH ="/";

    public static final String COLON =":";

    public static final String BASE_URL = "base_url";

    public static final String CORES = "cores";

    //配置文件

    public static final String SEARCH = "solr-config";

}

4.静态工厂方法SolrServerFactory.java:

package com.li.solrj;

import java.util.HashMap;

import java.util.Map;

import org.apache.solr.client.solrj.impl.HttpSolrServer;

import com.li.util.Config;

import com.li.util.ConfigUtil;

/**

 * 创建一个HttpSolrServer的静态工厂方法,

 * 用于创建多个集合的单例模式

 * @author Administrator

 *

 */

public class SolrServerFactory {

    public static Map<String,HttpSolrServer> servers ;

    static {

        servers = new HashMap<String,HttpSolrServer>();

        //静态加载所有的solrServer

        String[] cores = ConfigUtil.getString(Config.CORES).split(Config.COMMA);

        String base_url = ConfigUtil.getString(Config.BASE_URL);

        for(String core : cores){

            String url ;

            if(base_url.endsWith(Config.SLASH)){

                url = base_url + core;

            }else{

                url = base_url+Config.SLASH+core;

            }

            HttpSolrServer server = new HttpSolrServer(url);

            servers.put(core, server);

        }

    }

    public HttpSolrServer newInstance(String collection){

        if(servers.containsKey(collection))

            return servers.get(collection);

        String base_url = ConfigUtil.getString(Config.BASE_URL);

        if(base_url.endsWith(Config.SLASH))

            base_url = base_url+collection;

        else

            base_url = base_url + Config.SLASH + collection;

        return servers.put(collection, new HttpSolrServer(base_url));

    }

}

巴特西

HttpSolrServer-采用静态工厂方法,创建HttpSolrServer单实例

最新文章

热门文章