设为首页 收藏本站
查看: 994|回复: 0

[经验分享] solr 集群(SolrCloud 分布式集群部署步骤)

[复制链接]

尚未签到

发表于 2017-12-19 12:26:08 | 显示全部楼层 |阅读模式
import java.io.IOException;  import java.util.ArrayList;  
  import java.util.Collection;  
  import org.apache.solr.client.solrj.SolrQuery;  
  import org.apache.solr.client.solrj.SolrServer;  
  import org.apache.solr.client.solrj.SolrServerException;  
  import org.apache.solr.client.solrj.impl.CloudSolrServer;  
  import org.apache.solr.client.solrj.response.QueryResponse;  
  import org.apache.solr.common.SolrDocument;  
  import org.apache.solr.common.SolrDocumentList;  
  import org.apache.solr.common.SolrInputDocument;  
  import org.apache.commons.logging.Log;
  import org.apache.commons.logging.LogFactory;   

  public>  public static final Log LOG = LogFactory.getLog(SolrCloudTest.class);
  private static CloudSolrServer cloudSolrServer;   
  private  static synchronized CloudSolrServer getCloudSolrServer(final String zkHost) {   
  LOG.info("connect to :"+zkHost+"\n");
  if(cloudSolrServer == null) {   
  try {   
  cloudSolrServer = new CloudSolrServer(zkHost);   
  }catch(Exception e) {   
  e.printStackTrace();                    
  }   
  }                    
  return cloudSolrServer;   
  }   
  private void addIndex(SolrServer solrServer) {         
  try {
  Collection<SolrInputDocument> docs = new ArrayList<SolrInputDocument>();
  for (int i = 0;i<=200;i++){
  SolrInputDocument doc = new SolrInputDocument();
  String key = "";
  key = String.valueOf(i);
  doc.addField("id", key);
  doc.addField("test_s", key+"value");
  docs.add(doc);                  
  }     
  LOG.info("docs info:"+docs+"\n");
  solrServer.add(docs);               
  solrServer.commit();                    
  }catch(SolrServerException e) {   
  System.out.println("Add docs Exception !!!");   
  e.printStackTrace();            
  }catch(IOException e){   
  e.printStackTrace();   
  }catch (Exception e) {   
  System.out.println("Unknowned Exception!!!!!");   
  e.printStackTrace();   
  }                          
  }                        
  public void search(SolrServer solrServer, String Str) {         
  SolrQuery query = new SolrQuery();
  query.setRows(20);
  query.setQuery(Str);   
  try {  
  LOG.info("query string: "+ Str);
  System.out.println("query string: "+ Str);
  QueryResponse response = solrServer.query(query);   
  SolrDocumentList docs = response.getResults();
  System.out.println(docs);
  System.out.println(docs.size());
  System.out.println("doc num:" + docs.getNumFound());   
  System.out.println("elapse time:" + response.getQTime());            
  for (SolrDocument doc : docs) {   
  String area = (String) doc.getFieldValue("test_s");   

  String>
  System.out.println("id: " +>  System.out.println("tt_s: " + area);   
  System.out.println();   
  }   
  } catch (SolrServerException e) {   
  e.printStackTrace();   
  } catch(Exception e) {   
  e.printStackTrace();   
  }   
  }
  public static void main(String[] args) {      
  final String zkHost = "192.168.0.2:8080";         
  final String  defaultCollection = "userinfo";   
  final int  zkClientTimeout = 10000;   
  final int zkConnectTimeout = 10000;                     
  CloudSolrServer cloudSolrServer = getCloudSolrServer(zkHost);                     
  cloudSolrServer.setDefaultCollection(defaultCollection);   
  cloudSolrServer.setZkClientTimeout(zkClientTimeout);   
  cloudSolrServer.setZkConnectTimeout(zkConnectTimeout);
  try{
  cloudSolrServer.connect();
  System.out.println("connect solr cloud zk sucess");                 
  } catch (Exception e){   
  LOG.error("connect to collection "+defaultCollection+" error\n");
  System.out.println("error message is:"+e);
  e.printStackTrace();
  System.exit(1);
  }
  SolrCloudTest solrt = new SolrCloudTest();
  try{
  solrt.addIndex(cloudSolrServer);
  } catch(Exception e){
  e.printStackTrace();
  }
  solrt.search(cloudSolrServer, "id:*");            ;   
  cloudSolrServer.shutdown();            
  }         
  }

运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-425688-1-1.html 上篇帖子: solr 创建指定路由的collection 下篇帖子: solr 数据备份
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表