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

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内容保存在索引中。这对于检索和醒目显示内容很有用，但对于实际搜索则不是必须的，例如，很多应用程序存储指向内容位置的指针而不是存储实际的文件内容。

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

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

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

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

<!-- 然后添加如下配置即可：-->
<fieldType name="text_ik" class="solr.TextField">
<!-- 索引时候的分词器 -->
<analyzer type="index" isMaxWordLength="false" class="org.wltea.analyzer.lucene.IKAnalyzer"></analyzer>
<!-- 查询时候的分词器 -->
<analyzer type="query" isMaxWordLength="true" class="org.wltea.analyzer.lucene.IKAnalyzer"></analyzer>
</fieldType>

<!--IKAnalyzer Field-->
<!-- type="text_ik"代表使用了Ik中文分词器。 -->
<!-- indexed="true"代表进行索引操作。 -->
<!-- stored="true"代表将该字段内容进行存储。 -->
<field name="product_name" type="text_ik" indexed="true" stored="true" />
<field name="product_price" type="long" indexed="true" stored="true" />
<field name="product_picture" type="string" indexed="false" stored="true" />
<field name="product_description" type="text_ik" indexed="true" stored="true" />
<field name="product_catalog_name" type="string" indexed="true" stored="false" />

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

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

package com.taotao.search.service;

import java.io.IOException;
import java.util.List;
import java.util.Map;

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.HttpSolrServer;
import org.apache.solr.client.solrj.response.QueryResponse;
import org.apache.solr.client.solrj.response.UpdateResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;
import org.apache.solr.common.SolrInputDocument;
import org.junit.Before;
import org.junit.Test;

/**
 * 使用SolrJ创建索引，通过调用SolrJ提供的API请求Solr服务，Document通过SolrInputDocument进行构建。
 * 创建索引，使用SolrJ创建索引，通过调用SolrJ提供的API请求Solr服务，Document通过SolrInputDocument进行构建。
 * 
 * @ClassName: ProductSolrUtils.java
 * @author: biehl
 * @since: 2019年9月12日 上午10:49:13
 * @Copyright: ©2019 biehl 版权所有
 * @version: 0.0.1
 * @Description:
 */
public class ProductSolrUtils {

    // solr的地址路径
    private String solrServerUrl = "http://192.168.110.142:8080/solr-4.10.3/collection1";
    private SolrServer solrServer = null;

    /**
     * 
     */
    @Before
    public void before() {
        // 初始化执行
        // 1、创建SolrServer对象。创建一个HttpSolrServer对象
        solrServer = new HttpSolrServer(this.solrServerUrl);
    }

    /**
     * 说明：根据id（唯一约束）域来更新Document的内容，如果根据id值搜索不到id域则会执行添加操作，如果找到则更新。
     * 
     * @throws IOException
     * @throws SolrServerException
     * 
     */
    @Test
    public void productSolrCreateIndex() {
        try {
            // 2、需要指定Solr服务的url
            // 3、创建一个文档对象SolrInputDocument
            SolrInputDocument document = new SolrInputDocument();
            // 4、向文档中添加域，必须写id域，域的名称必须在schema.xml中定义
            document.addField("id", "p0001");
            document.addField("product_name", "小米手机9x");
            document.addField("product_price", 8888);
            document.addField("product_picture", "好用得咧");
            document.addField("product_description", "什么玩意？");
            document.addField("product_catalog_name", "手机");

            // 5、把文档对象写入到索引库中
            // 向solr里面添加文档
            UpdateResponse response = solrServer.add(document);
            // 6、提交
            solrServer.commit();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 删除索引
     * 
     * 说明：deleteById(String id)根据id删除索引，此方法为重载方法，也可以传个多个id批量删除， 也可以调用deleteByQuery()
     * 根据查询条件删除
     */
    @Test
    public void taotaoSolrJDeleteById() {
        try {
            // 向solr里面添加文档
            // 1、创建SolrServer对象。创建一个HttpSolrServer对象
            // SolrServer server = new
            // HttpSolrServer("http://192.168.110.142:8080/solr-4.10.3/collection1");

            // 2、 删除操作，//根据id删除
            solrServer.deleteById("p0001");

            // 3、提交
            solrServer.commit();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    /**
     * 删除索引，查询条件删除
     * 
     */
    @Test
    public void taotaoSolrJDeleteByQuery() {
        try {
            // 向solr里面添加文档
            // 1、创建SolrServer对象。创建一个HttpSolrServer对象
            // SolrServer server = new
            // HttpSolrServer("http://192.168.110.142:8080/solr-4.10.3/collection1");

            // 2、 删除操作
            solrServer.deleteByQuery("id:p0002");

            // 3、提交
            solrServer.commit();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * 
     */
    @Test
    public void searchDocument() {
        try {
            // 1、创建一个SolrServer对象
            // SolrServer solrServer = new
            // HttpSolrServer("http://192.168.110.142:8080/solr-4.10.3/collection1");
            // 2、创建一个SolrQuery对象
            SolrQuery solrQuery = new SolrQuery();
            // 3、设置查询条件，过滤条件，分页条件，排序条件，高亮
            // key的q就是指查询条件。
            // solrQuery.set("q", "*:*"); //等价于solrQuery.setQuery("*:*");
            // 查询所有的不能指定高亮的。
            // solrQuery.setQuery("*:*");// *:*是查询出所有的。
            // 这里没有指定在那里域上面进行搜索，所以需要指定默认搜索域
            solrQuery.setQuery("小米手机9");
            // 分页默认是0-10。分页条件。
            solrQuery.setStart(0);// 起始数
            solrQuery.setRows(20);// 查询出多少条
            // 设置默认搜索域。就是如果Query不设置查询那个字段，这里必须指定一个默认值，进行搜索。
            solrQuery.set("df", "product_name");
            // 设置高亮。
            solrQuery.setHighlight(true);// 开启高亮
            // 设置高亮显示的域
            solrQuery.addHighlightField("product_catalog_name");
            // 设置高亮显示的前缀和后缀
            solrQuery.setHighlightSimplePre("<em>");
            solrQuery.setHighlightSimplePost("</em>");

            // 4、执行查询，得到一个Response对象
            QueryResponse response = solrServer.query(solrQuery);

            // 5、取出查询结果总记录数
            SolrDocumentList solrDocumentList = response.getResults();
            // 查询出结果总记录数
            System.out.println("查询结果总记录数： " + solrDocumentList.getNumFound());

            for (SolrDocument solrDocument : solrDocumentList) {
                System.out.println("id : " + solrDocument.get("id"));
                // 取出高亮显示
                Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
                List<String> list = highlighting.get(solrDocument.get("id")).get("product_name");
                String product_name = "";
                if (list != null && list.size() > 0) {
                    product_name = list.get(0);
                } else {
                    product_name = (String) solrDocument.get("product_name");
                }
                System.out.println(product_name);
                System.out.println("product_price : " + solrDocument.get("product_price"));
                System.out.println("product_picture : " + solrDocument.get("product_picture"));
                System.out.println("product_description : " + solrDocument.get("product_description"));
                System.out.println("product_catalog_name : " + solrDocument.get("product_catalog_name"));
                System.out.println("=============================================");
            }

            // 提交
            solrServer.commit();
        } catch (SolrServerException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }

    }

}

查询删除效果如下所示：