本篇文章为大家展示了【学习笔记】如何配置Solr索引库，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
Spring配置：
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.2.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.2.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.2.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.2.xsd"> <context:component-scan base-package="cn.xing"/> <bean id="httpSolrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer"> <constructor-arg index="0" value="http://192.168.159.130:8080/solr"/> </bean> </beans>
Java代码操作Solr索引库：
package cn.xing.test;
import java.util.ArrayList;
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.response.QueryResponse;
import org.apache.solr.common.SolrDocument;
import org.apache.solr.common.SolrDocumentList;
import org.apache.solr.common.SolrInputDocument;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import cn.xing.pojo.SearchItem;
import cn.xing.pojo.SearchResult;
/**
* 操作solr索引库
*
* @author Xing
*
*/
@Service
public class Operation {
@Autowired
private SolrServer solrServer;// 是配置的httpSolrServer
/**
* 把所有商品导入索引库，商品对象SearchItem必须和solr配置的业务域字段、类型相同
*/
public void imprtSolrItem() {
try {
List<SearchItem> list = new ArrayList<SearchItem>();
list.add(new SearchItem("1", "湖北", "黄鹤楼", 12, "image1", "省市"));
list.add(new SearchItem("2", "河南", "开封", 12, "image2", "省市"));
list.add(new SearchItem("3", "3", "3", 12, "image2", "222"));
// 把list放入索引库
for (SearchItem searchItem : list) {
SolrInputDocument doc = new SolrInputDocument();
doc.addField("id", searchItem.getId());
doc.addField("item_title", searchItem.getTitle());
doc.addField("item_sell_point", searchItem.getSell_point());
doc.addField("item_price", searchItem.getPrice());
doc.addField("item_image", searchItem.getImage());
doc.addField("item_category_name", searchItem.getCategory_name());
solrServer.add(doc);
}
solrServer.commit();
System.out.println("数据导入成功");
} catch (Exception e) {
e.printStackTrace();
}
}
// 根据查询条件SolrQuery,查询索引库
public List<SearchItem> querySolr(SolrQuery query) throws SolrServerException {
// 根据条件查询索引库
QueryResponse queryResponse = solrServer.query(query);
SolrDocumentList results = queryResponse.getResults();
// 取出总记录数
long num = results.getNumFound();
System.out.println("查询结果的数据条数：" + num);
// 取出商品列表,高亮关键词
// Map<商品id,Map<商品属性字段,List<字段的值>>>
Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();
List<SearchItem> itemList = new ArrayList<>();
for (SolrDocument solrDocument : results) {
SearchItem item = new SearchItem();
item.setId((String) solrDocument.get("id"));
item.setCategory_name((String) solrDocument.get("item_category_name"));
item.setImage((String) solrDocument.get("item_image"));
item.setPrice((long) solrDocument.get("item_price"));
item.setSell_point((String) solrDocument.get("item_sell_point"));
// 取高亮结果，商品标题
List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
if (list != null && list.size() > 0) {
item.setTitle(list.get(0));// 拿到该商品标题
} else {
item.setTitle((String) solrDocument.get("item_title"));
}
itemList.add(item);
}
return itemList;
}
/**
* 根据关键词在solr索引库中搜索商品并分页。
*/
public SearchResult search(String keyword, int page, int rows) throws Exception {
// 设置查询条件，调用querySolr()方法查询
SolrQuery query = new SolrQuery();
query.setQuery(keyword);// 设置查询条件
if (page <= 0)
page = 1;
query.setStart((page - 1) * rows);// 设置分页索引
query.setRows(rows);// 设置查询条数
// 设置默认搜索域
query.set("df", "item_title");
// 设置高亮显示
query.setHighlight(true);
query.addHighlightField("item_title");
query.setHighlightSimplePre("<em style=\"color:red\">");
query.setHighlightSimplePost("</em>");
// 执行查询
List<SearchItem> itemList = this.querySolr(query);
// 设置返回结果
SearchResult rs = new SearchResult();
rs.setItemList(itemList);
/*
* // 设置总页数 int totalpages = rs.getRecourdCount() / rows; if
* (rs.getRecourdCount() % rows > 0) totalpages++; rs.setTotalPages((long)
* totalpages);
*/
return rs;
}
}分页查询数据封装：
package cn.xing.pojo;
import java.io.Serializable;
import java.util.List;
/**
* 搜素商品的结果。对页面需要的数据的封装。
*
* @author Xing
*
*/
public class SearchResult implements Serializable {
private Long totalPages;
private Integer recourdCount;
private List<SearchItem> itemList;
}Solr数据对应的pojo：
package cn.xing.pojo;
import java.io.Serializable;
import org.apache.commons.lang3.StringUtils;
public class SearchItem implements Serializable {
@Override
public String toString() {
return "SearchItem [id=" + id + ", title=" + title + ", sell_point=" + sell_point + ", price=" + price
+ ", image=" + image + ", category_name=" + category_name + "]";
}
// 类型和solr的中文分析器里的schema.xml中配置的type必须一样
private String id;
private String title;
private String sell_point;
private long price;
private String image;
private String category_name;
// 搜索结果页面展示一张图片
public String[] getImages() {
String image2 = this.getImage();
if (StringUtils.isNotBlank(image2)) {
String[] imagesArr = image2.split(",");
return imagesArr;
}
return null;
}
public String getId() {
return id;
}
public void setId(String id) {
this.id = id;
}
}Java测试代码：
package cn.xing.test;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import cn.xing.pojo.SearchItem;
import cn.xing.pojo.SearchResult;
public class test {
public static void main(String[] args) throws Exception {
ApplicationContext ac = new ClassPathXmlApplicationContext("classpath:applicationContext.xml");
Operation operation = ac.getBean(Operation.class);
// 导入数据
operation.imprtSolrItem();
// SearchResult search = operation.search("明明就", 1, 1);
SearchResult search = operation.search("3", 1, 10);
List<SearchItem> itemList = search.getItemList();
for (SearchItem searchItem : itemList) {
System.out.println(searchItem);
}
}
}上述内容就是【学习笔记】如何配置Solr索引库，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
