Solr学习笔记(3)——SolrJ管理索引库集群

　　solrj是访问Solr服务的java客户端&＃xff0c;提供索引和搜索的请求方法&＃xff0c;SolrJ通常嵌入在业务系统中&＃xff0c;通过SolrJ的API接口操作Solr服务&＃xff0c;如下图&＃xff1a;

2.1 添加文档

• 实现步骤&＃xff1a;

　　第一步&＃xff1a;创建一个java工程

　　第二步&＃xff1a;导入相关jar包

　　第三步&＃xff1a;和Solr服务器建立连接。HttpSolrServer对象建立连接

　　第四步&＃xff1a;创建一个SolrInputDocument对象&＃xff0c;然后添加域

　　第五步&＃xff1a;将SolrInputDocument添加到索引库

　　第六步&＃xff1a;提交

• 代码实现

  //向索引库中添加索引
  &＃64;Testpublic void addDocument() throws Exception {//和solr服务器创建连接//参数&＃xff1a;solr服务器的地址SolrServer solrServer &＃61; new HttpSolrServer("http://localhost:8080/solr");//创建一个文档对象SolrInputDocument document &＃61; new SolrInputDocument();//向文档中添加域//第一个参数&＃xff1a;域的名称&＃xff0c;域的名称必须是在schema.xml中定义的//第二个参数&＃xff1a;域的值document.addField("id", "c0001");document.addField("title_ik", "使用solrJ添加的文档");document.addField("content_ik", "文档的内容");document.addField("product_name", "商品名称");//把document对象添加到索引库中
  solrServer.add(document);//提交修改
  solrServer.commit();} 

2.2 删除文档

• 根据id删除

  //删除文档&＃xff0c;根据id删除
  &＃64;Testpublic void deleteDocumentByid() throws Exception {//创建连接SolrServer solrServer &＃61; new HttpSolrServer("http://localhost:8080/solr");//根据id删除文档solrServer.deleteById("c0001");//提交修改
  solrServer.commit();} 

• 根据查询删除

  //根据查询条件删除文档
  &＃64;Testpublic void deleteDocumentByQuery() throws Exception {//创建连接SolrServer solrServer &＃61; new HttpSolrServer("http://localhost:8080/solr");//根据查询条件删除文档solrServer.deleteByQuery("*:*");//提交修改
  solrServer.commit();}

2.3 修改文档

　　在solrJ中修改没有对应的update方法&＃xff0c;只有add方法&＃xff0c;只需要添加一条新的文档&＃xff0c;和被修改的文档id一致就&＃xff0c;可以修改了。本质上就是先删除后添加。

2.4 查询文档

• 简单查询

  //查询索引
  &＃64;Testpublic void queryIndex() throws Exception {//创建连接SolrServer solrServer &＃61; new HttpSolrServer("http://localhost:8080/solr");//创建一个query对象SolrQuery query &＃61; new SolrQuery();//设置查询条件query.setQuery("*:*");//执行查询QueryResponse queryResponse &＃61; solrServer.query(query);//取查询结果SolrDocumentList solrDocumentList &＃61; queryResponse.getResults();//共查询到商品数量System.out.println("共查询到商品数量:" &＃43; solrDocumentList.getNumFound());//遍历查询的结果for (SolrDocument solrDocument : solrDocumentList) {System.out.println(solrDocument.get("id"));System.out.println(solrDocument.get("product_name"));System.out.println(solrDocument.get("product_price"));System.out.println(solrDocument.get("product_catalog_name"));System.out.println(solrDocument.get("product_picture"));}}

• 复杂查询(其中包含查询、过滤、分页、排序、高亮显示等处理)

  //复杂查询索引
  &＃64;Testpublic void queryIndex2() throws Exception {//创建连接SolrServer solrServer &＃61; new HttpSolrServer("http://localhost:8080/solr");//创建一个query对象SolrQuery query &＃61; new SolrQuery();//设置查询条件query.setQuery("钻石");//过滤条件query.setFilterQueries("product_catalog_name:幽默杂货");//排序条件query.setSort("product_price", ORDER.asc);//分页处理query.setStart(0);query.setRows(10);//结果中域的列表query.setFields("id","product_name","product_price","product_catalog_name","product_picture");//设置默认搜索域query.set("df", "product_keywords");//高亮显示query.setHighlight(true);//高亮显示的域query.addHighlightField("product_name");//高亮显示的前缀query.setHighlightSimplePre("");//高亮显示的后缀query.setHighlightSimplePost("");//执行查询QueryResponse queryResponse &＃61; solrServer.query(query);//取查询结果SolrDocumentList solrDocumentList &＃61; queryResponse.getResults();//共查询到商品数量System.out.println("共查询到商品数量:" &＃43; solrDocumentList.getNumFound());//遍历查询的结果for (SolrDocument solrDocument : solrDocumentList) {System.out.println(solrDocument.get("id"));//取高亮显示String productName &＃61; "";Map>> highlighting &＃61; queryResponse.getHighlighting();List list &＃61; highlighting.get(solrDocument.get("id")).get("product_name");//判断是否有高亮内容if (null !&＃61; list) {productName &＃61; list.get(0);} else {productName &＃61; (String) solrDocument.get("product_name");}System.out.println(productName);System.out.println(solrDocument.get("product_price"));System.out.println(solrDocument.get("product_catalog_name"));System.out.println(solrDocument.get("product_picture"));}} 

3.1 添加文档

　　使用步骤&＃xff1a;

　　第一步&＃xff1a;把solrJ相关的jar包添加到工程中。

　　第二步&＃xff1a;创建一个SolrServer对象&＃xff0c;需要使用CloudSolrServer子类。构造方法的参数是zookeeper的地址列表。　　

　　第三步&＃xff1a;需要设置DefaultCollection属性。

　　第四步&＃xff1a;创建一SolrInputDocument对象。

　　第五步&＃xff1a;向文档对象中添加域

　　第六步&＃xff1a;把文档对象写入索引库。

　　第七步&＃xff1a;提交。

3.2 查询文档

　　创建一个CloudSolrServer对象&＃xff0c;其他处理和单机版一致。