Go语言视频零基础入门到精通

admin

应用场景

  当安装部署完solr之后，我们可以通过solrj来连接solr，进行新建，删除索引等等操作，达到全文检索的效果。

操作步骤
1. Solrj的使用
1.1什么是solrj

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

  Solrj和图形界面操作的区别就类似于数据库中你使用jdbc和mysql客户端的区别一样。

1.2 添加solrj jar包

  Solrj的包

  Solr服务的依赖包

solrj5.4.0的jar包下载地址
2 初始化

  步骤：
  

  创建HttpSolrClient对象（solrj4的HttpSolrServer被废弃），通过它和Solr服务器建立连接；

  说明：
  

  这一步是第一步，通过URL来调用搭建的solr服务，让solr服务给我们提供增删改查索引服务：

3 添加域

  步骤：
  

  1、调用SchemaRequest.AddField，添加域的一个Map；
2、通过HttpSolrClient对象的request方法进行添加域属性；

  说明：
  

  这一步主要是向schema.xml中添加域，标识域的属性，是否存储，是否索引等。

  添加域：
  


  删除域：
  


  更新域：
  


  示例：
  

1. [code]     /** * 添加域或删除域 *  @throws Exception * */
2.     @Test
3.     public void addFields() throws Exception{
4.         //创建HttpSolrClient,可以访问solr服务，参数是solr服务的url
5.         HttpSolrClient server = new  HttpSolrClient("http://192.168.199.23:8080/solr/collection1");
7.         //相当于在managed-schema文件中加入一个field
8.         Map<String, Object> fields = new LinkedHashMap<>();
9.         fields.put("name","product_name");    //域名
10.         fields.put("type","text_ik");         //域的类型，可以是string，int，如果需要分词设为text_ik
11.         fields.put("indexed",true);           //是否索引，默认为true
12.         fields.put("stored",true);            //是否存储，默认为true
13.         fields.put("multiValued",false);      //是否多值，默认为false
14.         fields.put("required",false);         //是否必须，默认false，schema文件中有一个id已默认必须
16.         //添加域
17.         SchemaRequest.AddField addFieldtoSchema = new SchemaRequest.AddField(fields);
18.         server.request(addFieldtoSchema);
19.         //删除域
20. // SchemaRequest.DeleteField delFieldtoSchema = new SchemaRequest.DeleteField("product_name");
21. // server.request(delFieldtoSchema);
22.         //更新域
23. // SchemaRequest.ReplaceField repFieldtoSchema = new SchemaRequest.ReplaceField(fields);
24. // server.request(repFieldtoSchema);
25.      }

复制代码

[/code]
4 新增索引

  步骤：
  

  1、创建SolrInputDocument对象，然后通过它来添加域值；
2、调用SolrInputDocument的对象的addField方法添加域值；
3、通过HttpSolrClient对象将SolrInputDocument添加到索引库；（如果id存在，则进行修改操作）；
4、调用HttpSolrClient对象的commit方法进行提交。

  说明：
  

  这一步主要是给值添加索引。其中域id是必须需要添加的，这是由底层配置文件决定的，id中有一个属性叫required，是唯一一个，如果不添加id，会报错。

  添加，并提交：
  


  示例：
  

1. [code]    /** * 添加域值或修改域值 *  @throws Exception * 根据id来添加，如果id存在则看成是修改进行覆盖，如果id不存在则是添加 */
2.     @Test
3.     public void addFieldValue() throws Exception{
4.         //创建HttpSolrClient,可以访问solr服务，参数是solr服务的url
5.         HttpSolrClient server = new HttpSolrClient("http://192.168.199.23:8080/solr/collection1");
7.         //创建SolrInputDocument对象，然后通过它来添加域值。
8.         SolrInputDocument document = new SolrInputDocument();
10.         // 第一个参数：域的名称，域的名称必须是在schema.xml中定义的,也就是上一步操作了
11.         // 第二个参数：域的值
12.         // 注意：id的域不能少，因为底层schema配置文件决定，id是required的
13.         document.addField("id", "001");
14.         document.addField("product_name", "张家港特产沙洲优黄");
15.         document.addField("product_info", "沙洲优黄是江苏省张家港酿酒有限公司的著名产品。江苏省张家港酿酒有限公司是江苏酿酒行业重点骨干企业，紧靠张家港保税区和对外开放港口张家港，区域经济发达，自然条件优越，投资兴业环境优良。");
17.         //通过HttpSolrServer对象将SolrInputDocument添加到索引库。
18.         // 执行添加操作，如果该id存在，则进行修改
19.         server.add(document);
20.         //提交
21.         server.commit();
22.     }

复制代码

[/code]
5 修改索引

  注：修改索引其实是和新增一样的，新增索引的时候域id是必须的，id也是唯一的：
如果新增的时候id不存在，则进行新增或添加操作；
如果新增的时候id存在，则进行修改操作，覆盖原来已添加的；
代码与新增过程保持不变。

6 删除索引

  步骤：
  

  1、通过调用HttpSolrClient对象的deleteByQuery方法进行删除操作；
2、调用HttpSolrClient对象的commit方法进行提交。

  说明：
  

  这一步主要通过solrj对已建的索引进行删除操作。
  主要有以下三种形式：

  根据id来删除索引：
  


  根据查询条件来删除：
  


  全部删除，注意慎用：
  


  示例：
  

1. [code]    /** * 删除域值 *  @throws Exception * 根据id来进行删除 */
2.     @Test
3.     public void delFieldValue() throws Exception{
4.         //创建HttpSolrClient,可以访问solr服务，参数是solr服务的url
5.         HttpSolrClient server = new HttpSolrClient("http://192.168.199.23:8080/solr/collection1");
7.         // 根据id删除
8. // server.deleteById("001");
9.         // 根据查询条件删除
10.         server.deleteByQuery("product_name:沙洲优黄");
11.         // 全部删除、慎用！！！！
12. // server.deleteByQuery("*:*");
14.         // 提交
15.         server.commit();
16.     }

复制代码

[/code]
7 查询索引

  步骤：
  

  1、创建solrQuery对象，来对对象设置查询条件；
2、创建QueryResponse对象，通过HttpSolrClient对象调用query方法，来获得执行搜索获得的返回值；
3、创建SolrDocumentList方法，通过QueryResponse对象调用getResults方法，来根据查询条件匹配出结果对象
4、最后进行遍历输出

  说明：
  

  这一步主要对前面新建了索引的数据进行查询。
查询参数：

  创建solrQuery对象：
  


  设置查询条件（q），两种写法：
  


  设置过滤查询条件（fq），两种写法：
  


  设置排序（sort），两种写法：
  


  设置分页信息（start，rows）：
  


  设置fl指定返回结果字段：
  


  设置默搜索域df：
  


  设置高亮：
  


  执行搜索获得返回值：
  


  根据查询条件匹配出结果对象：
  


  结果展示：
  


  示例：
  

1. [code]    @Test
2.     public void search() throws Exception {
4.         // 创建HttpSolrServer,可以访问solr服务
5.         // 参数就是solr服务的url
6.         HttpSolrClient server = new HttpSolrClient("http://192.168.199.23:8080/solr/collection1");
8.         // 创建solrQuery对象
9.         SolrQuery query = new SolrQuery();
11.         // 设置q，查询条件
12.         //query.setQuery("product_name:张家港");
13.         query.set("q", "product_name:沙洲优黄");
15.         // 设置fq，过滤查询条件
16.         //query.setFilterQueries("product_info:张家港");
17.         query.set("fq", "product_info:江苏省");
19.         // 设置sort，排序
20.         //query.setSort("id", ORDER.desc);
21.         query.set("sort", "id desc");
23.         // 设置start、rows，分页信息(写上默认值)
24.         query.setStart(0);
25.         query.setRows(10);
27.         // 设置fl，即要显示的域的列表
28.         query.set("fl", "id,product_name","product_info");
30.         // 设置默认搜索域
31.         query.set("df", "product_info,product_name,id");
33.         // 设置高亮
34.         query.setHighlight(true);
35.         query.addHighlightField("product_info");
36.         query.addHighlightField("product_name");
37.         query.setHighlightSimplePre("<font style="color:red">");
38.         query.setHighlightSimplePost("</font>");
40.         // 执行搜索，并获得返回值
41.         QueryResponse response = server.query(query);
43.         // 根据查询条件匹配出的结果对象
44.         SolrDocumentList list = response.getResults();
46.         // 匹配出的结果总数
47.         long count = list.getNumFound();
49.         //输出查询结果
50.         System.out.println("匹配出的结果总数:" + count);
51.         for (SolrDocument solrDocument : list) {
52.             System.out.println("商品id：" + solrDocument.get("id"));
53.             System.out.println("商品名称：" + solrDocument.get("product_name"));
54.             System.out.println("商品信息：" + solrDocument.get("product_info"));
55.         }
57.         System.out.println("----------------------------------------------------");
58. }

复制代码

[/code]
8 高亮设置

  步骤：
  

  1、创建solrQuery对象，来对对象设置查询条件；
2、创建QueryResponse对象，通过HttpSolrClient对象调用query方法，来获得执行搜索获得的返回值；
3、创建SolrDocumentList对象，通过QueryResponse对象调用getResults方法，来根据查询条件匹配出结果对象；
4、调用QueryResponse对象的getHighlighting方法获取高亮列表； 5、遍历结果列表，获得本文档的高亮信息；
6、循环遍历高亮后的信息，进行输出。

  说明：
  

  这一步主要给查询条件给出的字段，给予高亮显示。

  获取高亮列表：
  


  获得文档高亮信息，以及高亮结果展示：
  


  示例：
  

1. [code]  @Test
2.     public void search() throws Exception {
4.         // 创建HttpSolrServer,可以访问solr服务
5.         // 参数就是solr服务的url
6.         HttpSolrClient server = new HttpSolrClient("http://192.168.199.23:8080/solr/collection1");
8.         // 创建solrQuery对象
9.         SolrQuery query = new SolrQuery();
11.         // 设置q，查询条件
12.         //query.setQuery("product_name:张家港");
13.         query.set("q", "product_name:沙洲优黄");
15.         // 设置fq，过滤查询条件
16.         //query.setFilterQueries("product_info:张家港");
17.         query.set("fq", "product_info:江苏省");
19.         // 设置sort，排序
20.         //query.setSort("id", ORDER.desc);
21.         query.set("sort", "id desc");
23.         // 设置start、rows，分页信息(写上默认值)
24.         query.setStart(0);
25.         query.setRows(10);
27.         // 设置fl，即要显示的域的列表
28.         query.set("fl", "id,product_name","product_info");
30.         // 设置默认搜索域
31.         query.set("df", "product_info,product_name,id");
33.         // 设置高亮
34.         query.setHighlight(true);
35.         query.addHighlightField("product_info");
36.         query.addHighlightField("product_name");
37.         query.setHighlightSimplePre("<font style="color:red">");
38.         query.setHighlightSimplePost("</font>");
40.         // 执行搜索，并获得返回值
41.         QueryResponse response = server.query(query);
43.         // 根据查询条件匹配出的结果对象
44.         SolrDocumentList list = response.getResults();
46.         // 匹配出的结果总数
47.         long count = list.getNumFound();
49.         //获取高亮列表
50.         Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
52.         for (SolrDocument solrDocument : list) {
53.             System.out.println("商品id：" + solrDocument.get("id"));
54.             System.out.println("商品名称：" + solrDocument.get("product_name"));
55.             System.out.println("商品信息：" + solrDocument.get("product_info"));
57.             //获得本文档的高亮信息
58.             List<String> list2 = highlighting.get(solrDocument.get("id")).get("product_info");
59.             if(list2!=null){
60.                 System.out.println("高亮后的信息："+list2.get(0));
61.             }
62.             //获得本文档的高亮信息
63.             List<String> list3 = highlighting.get(solrDocument.get("id")).get("product_name");
64.             if(list2!=null){
65.                 System.out.println("高亮后的信息："+list3.get(0));
66.             }
67.         }
68.     }

复制代码

[/code]