电子发烧友App
solr的索引库配置
schema.xml的索引库的搜索域的配置。
其中field的基本属性配置。
fieldType：可以自己定义type的类型，比如中文的分词器IKAnalyzer
field域：主要是用于数据存取的域，里面使用key，value存储数据。
name：类似于key，存储的文本名称
type：存储的数据类型
indexed：是否建立索引，也就是说能不能使用该域进行搜索查找。
stored：是否存储数据，一般对象的基本属性是存储的
multiValued：可以是多个值，和数组基本类似，格式［］
copyField：复制域，主要是将指定的数据复制到某一个域对象中，以至于一个域可以存储多个域的信息，这样就方便构建默认搜索域就行搜索，非常的方便。
dynamicField：动态域，可以使用通配符*，进行存储数据和索取数据。
其中每一个向solr添加的对象都需要一个唯一的id，这样可以保证每一份数据的唯一性
《field name=“id” type=“string” indexed=“true” stored=“true” required=“true” multiValued=“false” /》
《fieldType name=“text_ik” class=“solr.TextField”》
《analyzer class=“org.wltea.analyzer.lucene.IKAnalyzer”/》
《/fieldType》
《field name=“user_username” type=“text_ik” indexed=“true” stored=“true”/》
《field name=“user_age” type=“text_ik” indexed=“true” stored=“true”/》
《field name=“user_address” type=“text_ik” indexed=“true” stored=“true”/》
《field name=“user_keywords” type=“text_ik” indexed=“true” stored=“false” multiValued=“true”/》
《copyField source=“user_age” dest=“user_keywords”/》
《copyField source=“user_username” dest=“user_keywords”/》
《copyField source=“user_address” dest=“user_keywords”/》
《dynamicField name=“*_i” type=“int” indexed=“true” stored=“true”/》
Solr索引库（collection1，2.。）的使用
Solr服务搭建
所需资料
第一步：把solr 的压缩包上传到Linux系统
第二步：解压solr。
第三步：安装Tomcat，解压缩即可。
第四步：把solr.war部署到Tomcat下的webapp目录下。
第五步：启动Tomcat解压。
第六步：把/root/solr-4.10.3/example/lib/ext目录下的所有的jar包，添加到solr工程中。
第七步：创建一个solrhome。/example/solr目录就是一个solrhome。复制此目录到/usr/local/solr/solrhome
第八步：关联solr及solrhome。需要修改solr工程的web.xml文件。并将注释取消
第九步：启动Tomcat，访问http://127.0.0.1:8080/solr/
配置业务域
第一步：把中文分析器添加到工程中。
1、把IKAnalyzer2012FF_u1.jar添加到solr工程的lib目录下
2、把扩展词典、配置文件放到solr工程的WEB-INF/classes目录下。
第二步：配置一个FieldType，制定使用IKAnalyzer
修改Solr的schema.xml文件，添加FieldType：
《fieldType name=“text_ik” class=“solr.TextField”》
《analyzer class=“org.wltea.analyzer.lucene.IKAnalyzer”/》
《/fieldType》
第三步：配置业务域，type制定使用自定义的FieldType。
设置业务系统Field，不同的系统所需要的字段不同；经过分析本系统需要商品Id，商品标题，商品卖点，商品价格，商品图片，分类名称字段
《field name=“item_title” type=“text_ik”（使用中文编辑器） indexed=“true” stored=“true”/》
《field name=“item_sell_point” type=“text_ik” indexed=“true” stored=“true”/》
《field name=“item_price” type=“long” indexed=“true” stored=“true”/》
《field name=“item_image” type=“string” indexed=“false” stored=“true” /》
《field name=“item_category_name” type=“string” indexed=“true” stored=“true” /》
《field name=“item_keywords” type=“text_ik” indexed=“true” stored=“false” multiValued=“true”/》 // 将下面的3个字段复制到keyword字段
《copyField source=“item_title” dest=“item_keywords”/》
《copyField source=“item_sell_point” dest=“item_keywords”/》
《copyField source=“item_category_name” dest=“item_keywords”/》
示例：实现更新商品索引的方法
Service层
@Service
@Transactional
public class SearchItemServiceImpl implements SearchItemService {
@Autowired
private ItemMapper itemMapper;
@Autowired
private SolrServer solrServer;
@Override
public E3Result importItems（） {
try {
// 1.查询到所有商品列表
List《SearchResult》 list = itemMapper.selectAllItem（）;
// 2.导入索引库中
for （SearchResult searchResult： list） {
// 创建文档对象
SolrInputDocument document = new SolrInputDocument（）;
// 向文档对象中添加域
document.addField（“id”，searchResult.getId（））;
document.addField（“item_title”，searchResult.getTitle（））;
document.addField（“item_sell_point”，searchResult.getSell_point（））;
document.addField（“item_price”，searchResult.getPrice（））;
document.addField（“item_image”，searchResult.getImage（））;
document.addField（“item_category_name”，searchResult.getCategory_name（））;
// 将文档添加到索引库中
solrServer.add（document）;
}
// 3.提交
solrServer.commit（）;
return E3Result.ok（）;
} catch （Exception ex）{
ex.printStackTrace（）;
return E3Result.build（500，“建立商品索引时失败”）;
}
}
}
Controller层
@Controller
public class SearchContriller {
@Autowired
private SearchItemService searchItemService;
@RequestMapping（“/index/item/import”）
@ResponseBody
public E3Result impotItemIndex（） {
return searchItemService.importItems（）;
}
}
示例：实现搜索功能（非项目整合版）
@Test
public void queryDocument（） throws Exception {
// 1.创建一个SolrServer对象
SolrServer solrServer = new HttpSolrServer（“http://127.0.0.1:8080/solr”）;
// 2.创建一个查询对象，可以参考solr的后台的查询功能设置条件
SolrQuery query = new SolrQuery（）;
// 3.设置查询条件
// 1）设置查询字段的2中方法
//query.setQuery（“手机”）;
query.set（“q”，“手机”）;
// 2）设置分页条件，从第几条开始，取几条数据
query.setStart（1）;
query.setRows（2）;
// 3）开启高亮
query.setHighlight（true）;
// 4）设置那个字段高亮显示
query.addHighlightField（“item_title”）;
// 5）设置高亮字段的头尾
query.setHighlightSimplePre（“《em》”）;
query.setHighlightSimplePost（“《/em》”）;
// 4）设置搜索域
query.set（“df”， “item_title”）;
// 4.执行查询，得到一个QueryResponse对象。
QueryResponse queryResponse = solrServer.query（query）;
// 5.获取查询结果
// 1）获取查询结果总记录数
SolrDocumentList solrDocumentList = queryResponse.getResults（）;
System.out.println（“查询结果总记录数：” + solrDocumentList.getNumFound（））;
// 2）取查询结果集
Map《String， Map《String， List《String》》》 highlighting = queryResponse.getHighlighting（）;
for （SolrDocument solrDocument ： solrDocumentList） {
System.out.println（solrDocument.get（“id”））;
// 3）取高亮后的结果集
List《String》 list = highlighting.get（solrDocument.get（“id”））.get（“item_title”）;
// 判断集合是否为空，为空就是标题中没有搜索的字段
String title;
if （list ！= null && list.size（） 》 0） {
title = list.get（0）;
} else {
title = （String） solrDocument.get（“item_title”）;
}
System.out.println（title）;
System.out.println（solrDocument.get（“item_sell_point”））;
System.out.println（solrDocument.get（“item_price”））;
System.out.println（solrDocument.get（“item_image”））;
System.out.println（solrDocument.get（“item_category_name”））;
}
}
示例：实现搜索功能（项目整合版）
Controller层
32@Controller
public class SearchController {
@Autowired
private SearchService searchService;
// 搜索页面展示商品条数
@Value（“${SEARCH_RESULT_ROWS}”）
private Integer SEARCH_RESULT_ROWS;
@RequestMapping（“/search”）
// @ResponseBody
public String impotItemIndex（String keyword， @RequestParam（defaultValue=“1”） Integer page， Model model） throws Exception {
// 由于是get请求，需要我们自己处理一下乱码问题
keyword = new String（keyword.getBytes（“iso-8859-1”）， “utf-8”）;
SearchList searchList = searchService.search（keyword， page， SEARCH_RESULT_ROWS）;
//把结果传递给页面
model.addAttribute（“query”， keyword）;
model.addAttribute（“totalPages”， searchList.getTotalPages（））;
model.addAttribute（“page”， page）;
model.addAttribute（“recourdCount”， searchList.getRecordCount（））;
model.addAttribute（“itemList”， searchList.getItemList（））;
//返回逻辑视图
return “search”;
}
}
Service层
37@Service
public class SearchServiceImpl implements SearchService {
@Autowired
private SearchDao searchDao;
@Override
public SearchList search（String keyword， Integer page， Integer rows） throws Exception {
//创建一个SolrQuery对象
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》”）;
//调用dao执行查询
SearchList searchList = searchDao.search（query）;
//计算总页数
Long recordCount = searchList.getRecordCount（）;
int totalPage = （int） （recordCount / rows）;
if （recordCount % rows 》 0）{
totalPage ++;
}
//添加到返回结果的页数
searchList.setTotalPages（totalPage）;
//返回结果
return searchList;
}
}
Dao层（去solr服务器执行查询）
/**
* 商品搜索dao
*/
@Repository
public class SearchDao {
@Autowired
private SolrServer solrServer;
/**
*根据查询条件查询索引库
*/
public SearchList search（SolrQuery query） throws Exception {
//根据query查询索引库
QueryResponse queryResponse = solrServer.query（query）;
//取查询结果。
SolrDocumentList solrDocumentList = queryResponse.getResults（）;
//取查询结果总记录数
long numFound = solrDocumentList.getNumFound（）;
SearchList result = new SearchList（）;
result.setRecordCount（numFound）;
//取商品列表，需要取高亮显示
Map《String， Map《String， List《String》》》 highlighting = queryResponse.getHighlighting（）;
List《SearchResult》 itemList = new ArrayList《》（）;
for （SolrDocument solrDocument ： solrDocumentList） {
SearchResult item = new SearchResult（）;
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”）;
String title = “”;
if （list ！= null && list.size（） 》 0） {
title = list.get（0）;
} else {
title = （String） solrDocument.get（“item_title”）;
}
item.setTitle（title）;
//添加到商品列表
itemList.add（item）;
}
result.setItemList（itemList）;
//返回结果
return result;
}
}
注意：由于我们数据库中image字段存的是xxx，xxx.。。这样的数据，所以我们要在SearchResult中提供一个get方法，获取images字段（返回String数组）；前端使用images［0］方式获取
SearchResult.java
17public class SearchResult implements Serializable {
private String id;
private String title;
private String sell_point;
private Long price;
private String image;
private String category_name;
private String keywords;
public String［］ getImages（） {
if （StringUtils.isNoneBlank（image））{
return image.split（“，”）;
}
return null;
}
SearchList.java
5public class SearchList implements Serializable{
private Long recordCount;
private List《SearchResult》 itemList;
private Integer totalPages;
工商网监
评论