solrcloud和solr在集群中建立索方法是什么
本篇内容介绍了“solrcloud和solr在集群中建立索方法是什么”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
1 通过通过zookeeper通道建立索引
public static void main(String[] args) throws IOException, SolrServerException { //注意,zkHost在windows伪分布式与hadoop分布式设置不一样 //windows伪分布式zkHost最后不需要加"/solr",linux的hadoop中需要添加"/solr" String zkHost = "node1:2181,node2:2181,node3:2181/solr"; String defaultCollection = "collection1"; CloudSolrServer server = new CloudSolrServer(zkHost); server.setDefaultCollection(defaultCollection); for (int i = 0; i < 1000; ++i) { SolrInputDocument doc = new SolrInputDocument(); doc.addField("cat", "book"); doc.addField("id", "book-" + i); doc.addField("name", "The Legend of Po part " + i); server.add(doc); if (i % 100 == 0) server.commit(); // periodically flush } server.commit(); }
2 注意,CDH中,可以看zookeeper的设置,最大链接数为60,所以对于zookeeper一般用单例
public class myCloudSolrServer { // solrServer public static CloudSolrServer solrServer; //效率不高的方法 // public static synchronized CloudSolrServer getSolrServer() { // if (solrServer == null) { // try { // solrServer = new CloudSolrServer(Const.ZK_HOST + "/solr"); // final int zkClientTimeout = 20000; // 心跳20秒 // final int zkConnectTimeout = 10000; // 设置链接主机超时(单位毫秒) // // solrServer.setDefaultCollection(Const.defaultCollection); // solrServer.setZkClientTimeout(zkClientTimeout); // solrServer.setZkConnectTimeout(zkConnectTimeout); // } catch (Exception e) { // e.printStackTrace(); // } // } // return solrServer; // } //支持大并发方法 public static CloudSolrServer getSolrServer() { if (solrServer == null) { synchronized (myCloudSolrServer.class) { if (solrServer == null) { try { solrServer = new CloudSolrServer(Const.ZK_HOST + "/solr"); final int zkClientTimeout = 20000; // 心跳20秒 final int zkConnectTimeout = 10000; // 设置链接主机超时(单位毫秒) solrServer.setDefaultCollection(Const.defaultCollection); solrServer.setZkClientTimeout(zkClientTimeout); solrServer.setZkConnectTimeout(zkConnectTimeout); } catch (Exception e) { e.printStackTrace(); } } } } return solrServer; } }
3 急群中可以指定到某个分片
public static void main(String[] args) throws IOException, SolrServerException { String url= "node1:8983/solr/core_shard1_replica1"; String defaultCollection = "collection1"; HttpSolrServer server = new HttpSolrServer (url); server.setDefaultCollection(defaultCollection); for (int i = 0; i < 1000; ++i) { SolrInputDocument doc = new SolrInputDocument(); doc.addField("cat", "book"); doc.addField("id", "book-" + i); doc.addField("name", "The Legend of Po part " + i); server.add(doc); if (i % 100 == 0) server.commit(); // periodically flush } server.commit(); }
注意,在建立索引的时候,不要每一个就去commit,为了提高效率,一般用
Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>(); for(){ SolrInputDocument doc = new SolrInputDocument(); docs.add(doc); } server.add(docs); server.commit();
其实 server.commit()效率也不高,一般用软提交
“solrcloud和solr在集群中建立索方法是什么”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注网站,小编将为大家输出更多高质量的实用文章!