使用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();
        }

    }

}

查詢刪除效果如下所示：