SolrJ是JAVA操作Solr的客户端,可以直接操作Solr服务进行索引的增、删、改、查功能。
一、使用前先引入SolrJ的依赖。
<!-- solr客户端 -->
<dependency>
<groupId>org.apache.solr</groupId>
<artifactId>solr-solrj</artifactId>
<version>4.10.3</version>
</dependency>
二、使用时可以直接创建Solr服务的对象进行操作,也可以通过Spring容器进行管理Solr服务的Bean,实际开发推荐使用Spring容器进行管理,依赖关系更易管理。
1)直接创建一个连接单机版的HttpSolrServer对象:
SolrServer solrServer = new HttpSolrServer("http://192.168.1.8:8080/solr/collection1");
2)直接创建一个连接集群版的CloudSolrServer对象:
// 创建一个CloudSolrServer对象,构造方法中指定zookeeper的地址列表
CloudSolrServer cloudSolrServer = new CloudSolrServer("192.168.1.8:2182,192.168.1.8:2183,192.168.1.8:2184");
// 需要设置默认的Collection
cloudSolrServer.setDefaultCollection("collection2");
3)通过Spring注入一个HttpSolrServer对象:
<!-- 单机版solr的连接 -->
<bean id="httpSolrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer">
<constructor-arg name="baseURL" value="http://192.168.1.8:8080/solr/collection1"/>
</bean>
4)通过Spring注入一个CloudSolrServer对象:
<bean id="cloudSolrServer" class="org.apache.solr.client.solrj.impl.CloudSolrServer">
<constructor-arg name="zkHost" value="192.168.1.8:2182,192.168.1.8:2183,192.168.1.8:2184"></constructor-arg>
<property name="defaultCollection" value="collection2"></property>
</bean>
注:HttpSolrServer和CloudSolrServer都继承SolrServer,因此使用时建议直接注入SolrServer进行操作,这样单机和集群切换不会影响具体的业务代码,大大减少了代码的维护量。
三、使用SolrServer向索引库添加索引
// 创建文档对象SolrInputDocument
SolrInputDocument document = new SolrInputDocument();
// 向文档中添加域,必须有id域,域的名称必须在schema.xml中定义
document.addField("id", "123456");
document.addField("item_title", "测试商品");
document.addField("item_price", 1000);
// 把文档对象写入索引库
solrServer.add(document);
// 提交
solrServer.commit();
四、使用SolrServer删除索引库中指定的记录
solrServer.deleteById("123456");
//提交
solrServer.commit();
或者
solrServer.deleteByQuery("item_title:测试商品3");
solrServer.commit();
五、使用SolrServer查询索引库的内容
//创建一个SolrQuery对象
SolrQuery query = new SolrQuery();
//设置查询条件、过滤条件、分页条件、排序条件、高亮
//query.set("q", "*:*");
query.setQuery("手机");
//分页条件
query.setStart(0);
query.setRows(10);
//设置默认搜索域
query.set("df", "item_keywords");
//设置高亮
query.setHighlight(true);
//高亮显示的域
query.addHighlightField("item_title");
query.setHighlightSimplePre("<div>");
query.setHighlightSimplePost("</div>");
//执行查询,得到一个Response对象
QueryResponse response = solrServer.query(query);
//取查询结果
SolrDocumentList solrDocumentList = response.getResults();
//取查询结果总记录数
System.out.println("查询结果总记录数:" + solrDocumentList.getNumFound());
for (SolrDocument solrDocument : solrDocumentList) {
System.out.println(solrDocument.get("id"));
//取高亮显示
Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
String itemTitle = "";
if (list != null && list.size() >0) {
itemTitle = list.get(0);
} else {
itemTitle = (String) solrDocument.get("item_title");
}
System.out.println(itemTitle);
System.out.println(solrDocument.get("item_sell_point"));
System.out.println(solrDocument.get("item_price"));
}