一、导入依赖

导入Solr源码包dist文件夹下的solr-solrj-6.6.2.jar以及solrj-lib文件夹下的所有包到项目中。除此之外,还要加上log4j包和junit测试包。

二、添加/更新数据

Solrj的使用十分简单,下面是一个添加数据的例子:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Test
public void testAdd() throws Exception {
// 指定url
String baseURL = "http://localhost:8080/solr/core1";

// 1.创建Solr单机版客户端
HttpSolrClient solrClient = new HttpSolrClient(baseURL);

// 2.创建一个Document
SolrInputDocument doc = new SolrInputDocument();
doc.addField("id", "10086");
doc.addField("author", "jitwxs");
// 3.添加Document,1000ms自动提交
solrClient.add(doc, 1000);
}

(1)BaseURL就是Solr的首页地址和核:

(2)创建一个SolrClient,其中HttpSolrClient是单机版,CloudSolrClient是集群版。

(3)可以设置提交时间自动提交,也可以手动提交solrClient.commit();

(4)这种初始化SolrClient的方式在Solr 7.0中被废弃,改为:

1
2
3
4
HttpSolrClient solrClient = new HttpSolrClient.Builder(BASE_URL)
.withConnectionTimeout(10000)
.withSocketTimeout(60000)
.build();

查看Solr后台,发现数据已经被添加了:

三、删除数据

删除十分简单,不再具体演示,给出相关API:

1
2
3
4
5
6
7
8
9
10
11
12
13
// 根据id删除单个
solrClient.deleteById("10086");

// 根据id删除多个
List<String> ids = new ArrayList<>();
ids.add("1");
solrClient.deleteById(ids, 1000);

// 根据条件删
solrClient.deleteByQuery("*:*");

// 根据条件删,指定核
solrClient.deleteByQuery("core1", "id:10086", 1000);

四、查询数据

业务需求:

  • 默认域为item_title

  • 关键词:手机

  • 价格:5k以上

  • 价格降序

  • 分页:第1页,每页10条

  • 高亮:红色

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
@Test
public void testQuery() throws Exception {
// 指定Solr服务器url
String baseURL = "http://localhost:8080/solr/core1";

// 创建Solr单机版客户端
SolrClient HttpSolrClient = new HttpSolrClient(baseURL);

/*
* 查询需求
* 设置默认域为item_title
* 关键词:手机
* 价格:5k以上
* 排序:价格降序
* 分页:第1页,每页10条
* 高亮:红色
*/
SolrQuery solrQuery = new SolrQuery();
// 设置默认域
solrQuery.set("df", "item_title");
// 设置关键词
solrQuery.set("q", "手机");
// 设置价格区间
solrQuery.set("fq", "item_price:[5000 TO *]");
// 设置排序
solrQuery.addSort("item_price", ORDER.desc);
// 设置分页
solrQuery.setStart(1);
solrQuery.setRows(5);
// 开启高亮
solrQuery.setHighlight(true);
// 设置高亮字段
solrQuery.addHighlightField("item_title");
// 高亮前缀
solrQuery.setHighlightSimplePre("<span style='color:red'>");
// 高亮后缀
solrQuery.setHighlightSimplePost("</span>");

// 执行查询
QueryResponse response = solrClient.query(solrQuery);
// 获取文档结果集
SolrDocumentList docs = response.getResults();
// 获取高亮结果集
Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();

// 总条数
long numFound = docs.getNumFound();
System.out.println("共查到:" + numFound + "条数据");

for(SolrDocument doc : docs) {
System.out.println("id:" + doc.get("id"));
System.out.println("sell_point:" +doc.get("item_sell_point"));
System.out.println("price:" +doc.get("item_price"));

// 标题高亮
Map<String, List<String>> map = highlighting.get(doc.get("id"));
List<String> list = map.get("item_title");
for(String s : list) {
System.out.println("title:" + s);
}

System.out.println("==================");
}

}