使用SolrJ（即java客户端）开发Solr。

• 2019 年 10 月 8 日
• 筆記

1、什么是SolrJ呢？ 　　答：Solrj是访问Solr服务的java客户端，提供索引和搜索的请求方法，SolrJ通常在嵌入在业务系统中，通过SolrJ的API接口操作Solr服务。开始配置schema.xml，/home/hadoop/soft/solr-4.10.3/example/solr/collection1/conf。添加IK中文分析器，然后定义定义自己的业务域。

注意：

　　a、Indexed，Indexed Field可以进行搜索和排序。你还可以在indexed Field上运行Solr分析过程，此过程可修改内容以改进或更改结果。 　　b、Stored，Stored Field内容保存在索引中。这对于检索和醒目显示内容很有用，但对于实际搜索则不是必须的，例如，很多应用程序存储指向内容位置的指针而不是存储实际的文件内容。

 1 [root@localhost tomcat]# cd /home/hadoop/soft/solr-4.10.3/   2 [root@localhost solr-4.10.3]# ls   3 bin  CHANGES.txt  contrib  dist  docs  example  licenses  LICENSE.txt  LUCENE_CHANGES.txt  NOTICE.txt  README.txt  SYSTEM_REQUIREMENTS.txt   4 [root@localhost solr-4.10.3]# cd example/solr   5 [root@localhost solr]# ls   6 bin  collection1  README.txt  solr.xml  zoo.cfg   7 [root@localhost solr]# cd collection1/   8 [root@localhost collection1]# ls   9 conf  core.properties  data  README.txt  10 [root@localhost collection1]# cd conf/  11 [root@localhost conf]# ls  12 admin-extra.html              clustering    lang                         protwords.txt                            _schema_analysis_synonyms_english.json  solrconfig.xml  synonyms.txt      xslt  13 admin-extra.menu-bottom.html  currency.xml  mapping-FoldToASCII.txt      _rest_managed.json                       schema.xml                              spellings.txt   update-script.js  14 admin-extra.menu-top.html     elevate.xml   mapping-ISOLatin1Accent.txt  _schema_analysis_stopwords_english.json  scripts.conf                            stopwords.txt   velocity  15 [root@localhost conf]# 

然后添加IK中文分词器，自定义业务域：

其中IK中文分词器，自定义业务域具体内容如下所示：

将这些添加完毕以后，重启Tomcat，然后看看，可以搜索到新增的业务域字段。

 1 <!-- 然后添加如下配置即可：-->   2 <fieldType name="text_ik" class="solr.TextField">   3 <!-- 索引时候的分词器 -->   4 <analyzer type="index" isMaxWordLength="false" class="org.wltea.analyzer.lucene.IKAnalyzer"></analyzer>   5 <!-- 查询时候的分词器 -->   6 <analyzer type="query" isMaxWordLength="true" class="org.wltea.analyzer.lucene.IKAnalyzer"></analyzer>   7 </fieldType>   8   9 <!--IKAnalyzer Field-->  10 <!-- type="text_ik"代表使用了Ik中文分词器。 -->  11 <!-- indexed="true"代表进行索引操作。 -->  12 <!-- stored="true"代表将该字段内容进行存储。 -->  13 <field name="product_name" type="text_ik" indexed="true" stored="true" />  14 <field name="product_price" type="long" indexed="true" stored="true" />  15 <field name="product_picture" type="string" indexed="false" stored="true" />  16 <field name="product_description" type="text_ik" indexed="true" stored="true" />  17 <field name="product_catalog_name" type="string" indexed="true" stored="false" />

可以看到搜索到新增的业务域字段。

2、然后你可以愉快的编程了，嘻嘻。

  1 package com.taotao.search.service;    2    3 import java.io.IOException;    4 import java.util.List;    5 import java.util.Map;    6    7 import org.apache.solr.client.solrj.SolrQuery;    8 import org.apache.solr.client.solrj.SolrServer;    9 import org.apache.solr.client.solrj.SolrServerException;   10 import org.apache.solr.client.solrj.impl.HttpSolrServer;   11 import org.apache.solr.client.solrj.response.QueryResponse;   12 import org.apache.solr.client.solrj.response.UpdateResponse;   13 import org.apache.solr.common.SolrDocument;   14 import org.apache.solr.common.SolrDocumentList;   15 import org.apache.solr.common.SolrInputDocument;   16 import org.junit.Before;   17 import org.junit.Test;   18   19 /**   20  * 使用SolrJ创建索引，通过调用SolrJ提供的API请求Solr服务，Document通过SolrInputDocument进行构建。   21  * 创建索引，使用SolrJ创建索引，通过调用SolrJ提供的API请求Solr服务，Document通过SolrInputDocument进行构建。   22  *   23  * @ClassName: ProductSolrUtils.java   24  * @author: biehl   25  * @since: 2019年9月12日 上午10:49:13   26  * @Copyright: ©2019 biehl 版权所有   27  * @version: 0.0.1   28  * @Description:   29  */   30 public class ProductSolrUtils {   31   32     // solr的地址路径   33     private String solrServerUrl = "http://192.168.110.142:8080/solr-4.10.3/collection1";   34     private SolrServer solrServer = null;   35   36     /**   37      *   38      */   39     @Before   40     public void before() {   41         // 初始化执行   42         // 1、创建SolrServer对象。创建一个HttpSolrServer对象   43         solrServer = new HttpSolrServer(this.solrServerUrl);   44     }   45   46     /**   47      * 说明：根据id（唯一约束）域来更新Document的内容，如果根据id值搜索不到id域则会执行添加操作，如果找到则更新。   48      *   49      * @throws IOException   50      * @throws SolrServerException   51      *   52      */   53     @Test   54     public void productSolrCreateIndex() {   55         try {   56             // 2、需要指定Solr服务的url   57             // 3、创建一个文档对象SolrInputDocument   58             SolrInputDocument document = new SolrInputDocument();   59             // 4、向文档中添加域，必须写id域，域的名称必须在schema.xml中定义   60             document.addField("id", "p0001");   61             document.addField("product_name", "小米手机9x");   62             document.addField("product_price", 8888);   63             document.addField("product_picture", "好用得咧");   64             document.addField("product_description", "什么玩意？");   65             document.addField("product_catalog_name", "手机");   66   67             // 5、把文档对象写入到索引库中   68             // 向solr里面添加文档   69             UpdateResponse response = solrServer.add(document);   70             // 6、提交   71             solrServer.commit();   72         } catch (Exception e) {   73             e.printStackTrace();   74         }   75     }   76   77     /**   78      * 删除索引   79      *   80      * 说明：deleteById(String id)根据id删除索引，此方法为重载方法，也可以传个多个id批量删除， 也可以调用deleteByQuery()   81      * 根据查询条件删除   82      */   83     @Test   84     public void taotaoSolrJDeleteById() {   85         try {   86             // 向solr里面添加文档   87             // 1、创建SolrServer对象。创建一个HttpSolrServer对象   88             // SolrServer server = new   89             // HttpSolrServer("http://192.168.110.142:8080/solr-4.10.3/collection1");   90   91             // 2、 删除操作，//根据id删除   92             solrServer.deleteById("p0001");   93   94             // 3、提交   95             solrServer.commit();   96         } catch (SolrServerException e) {   97             e.printStackTrace();   98         } catch (IOException e) {   99             e.printStackTrace();  100         }  101  102     }  103  104     /**  105      * 删除索引，查询条件删除  106      *  107      */  108     @Test  109     public void taotaoSolrJDeleteByQuery() {  110         try {  111             // 向solr里面添加文档  112             // 1、创建SolrServer对象。创建一个HttpSolrServer对象  113             // SolrServer server = new  114             // HttpSolrServer("http://192.168.110.142:8080/solr-4.10.3/collection1");  115  116             // 2、 删除操作  117             solrServer.deleteByQuery("id:p0002");  118  119             // 3、提交  120             solrServer.commit();  121         } catch (SolrServerException e) {  122             e.printStackTrace();  123         } catch (IOException e) {  124             e.printStackTrace();  125         }  126     }  127  128     /**  129      *  130      */  131     @Test  132     public void searchDocument() {  133         try {  134             // 1、创建一个SolrServer对象  135             // SolrServer solrServer = new  136             // HttpSolrServer("http://192.168.110.142:8080/solr-4.10.3/collection1");  137             // 2、创建一个SolrQuery对象  138             SolrQuery solrQuery = new SolrQuery();  139             // 3、设置查询条件，过滤条件，分页条件，排序条件，高亮  140             // key的q就是指查询条件。  141             // solrQuery.set("q", "*:*"); //等价于solrQuery.setQuery("*:*");  142             // 查询所有的不能指定高亮的。  143             // solrQuery.setQuery("*:*");// *:*是查询出所有的。  144             // 这里没有指定在那里域上面进行搜索，所以需要指定默认搜索域  145             solrQuery.setQuery("小米手机9");  146             // 分页默认是0-10。分页条件。  147             solrQuery.setStart(0);// 起始数  148             solrQuery.setRows(20);// 查询出多少条  149             // 设置默认搜索域。就是如果Query不设置查询那个字段，这里必须指定一个默认值，进行搜索。  150             solrQuery.set("df", "product_name");  151             // 设置高亮。  152             solrQuery.setHighlight(true);// 开启高亮  153             // 设置高亮显示的域  154             solrQuery.addHighlightField("product_catalog_name");  155             // 设置高亮显示的前缀和后缀  156             solrQuery.setHighlightSimplePre("<em>");  157             solrQuery.setHighlightSimplePost("</em>");  158  159             // 4、执行查询，得到一个Response对象  160             QueryResponse response = solrServer.query(solrQuery);  161  162             // 5、取出查询结果总记录数  163             SolrDocumentList solrDocumentList = response.getResults();  164             // 查询出结果总记录数  165             System.out.println("查询结果总记录数： " + solrDocumentList.getNumFound());  166  167             for (SolrDocument solrDocument : solrDocumentList) {  168                 System.out.println("id : " + solrDocument.get("id"));  169                 // 取出高亮显示  170                 Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();  171                 List<String> list = highlighting.get(solrDocument.get("id")).get("product_name");  172                 String product_name = "";  173                 if (list != null && list.size() > 0) {  174                     product_name = list.get(0);  175                 } else {  176                     product_name = (String) solrDocument.get("product_name");  177                 }  178                 System.out.println(product_name);  179                 System.out.println("product_price : " + solrDocument.get("product_price"));  180                 System.out.println("product_picture : " + solrDocument.get("product_picture"));  181                 System.out.println("product_description : " + solrDocument.get("product_description"));  182                 System.out.println("product_catalog_name : " + solrDocument.get("product_catalog_name"));  183                 System.out.println("=============================================");  184             }  185  186             // 提交  187             solrServer.commit();  188         } catch (SolrServerException e) {  189             e.printStackTrace();  190         } catch (IOException e) {  191             e.printStackTrace();  192         }  193  194     }  195  196 }

查询删除效果如下所示：

待续……