全文索引服务solr入门三之solrJ的应用

三. 使用solrJ和spring集成

再上一篇和上上一篇文章中我们先搭建了一个solr服务器和学习了solr服务器后台的使用，这一次我们将直接进入实战：和spring集成，在继承之前我们先看看所需要的solr的jar文件都是那些（spring的那些大家就自己玩吧，我相信都知道的）

所需的jar文件

直接上图片，就是图上的这些图片，当然大家可以自己找maven依赖（jar文件这个最简单了，没有的话一定会报classnotfoundException，加上就好了）

spring的配置

<?xml version="1.0" encoding="UTF-8"?>  
  <beans xmlns="http://www.springframework.org/schema/beans"  
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"  
    xmlns:context="http://www.springframework.org/schema/context"  
    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"  
    xsi:schemaLocation="http://www.springframework.org/schema/beans  
    http://www.springframework.org/schema/beans/spring-beans-3.1.xsd  
    http://www.springframework.org/schema/mvc  
    http://www.springframework.org/schema/mvc/spring-mvc-3.1.xsd  
    http://www.springframework.org/schema/context  
    http://www.springframework.org/schema/context/spring-context-3.1.xsd  
    http://www.springframework.org/schema/aop  
    http://www.springframework.org/schema/aop/spring-aop-3.1.xsd  
    http://www.springframework.org/schema/tx  
    http://www.springframework.org/schema/tx/spring-tx-3.1.xsd ">  
    <!-- 配置扫描包 -->  
    <context:component-scan base-package="cn.bridgeli"/>  
    <!-- 配置注解驱动 -->  
    <mvc:annotation-driven/>  
    <!-- 配置注解驱动 -->  
    <tx:annotation-driven/>  
    <!-- jsp视图解析器 -->  
    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver" >  
      <!-- 前缀 -->  
      <property name="prefix" value="/WEB-INF/jsp/"></property>  
      <!-- 后缀 -->  
      <property name="suffix" value=".jsp"></property>  
    </bean>  
    <!-- 单机版solr -->  
    <bean class="org.apache.solr.client.solrj.impl.HttpSolrServer">  
      <constructor-arg name="baseURL" value="http://localhost:8080/solr/"></constructor-arg>  
    </bean>  
    <!-- 集群版SolrCloud -->  
    <!--  
      <bean class="org.apache.solr.client.solrj.impl.CloudSolrServer">  
        <constructor-arg name="zkHost" value="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183"></constructor-arg>  
        <property name="defaultCollection" value="collection2"></property>  
      </bean>  
    -->  
</beans>

简单吧，大家只要注意到单机版就行了，因为我们这次只用到了单机版，下面就要看源码实现了

具体代码实现

①. controller

package cn.bridgeli.controller;

import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Controller;  
import org.springframework.ui.Model;  
import org.springframework.web.bind.annotation.RequestMapping;

import cn.bridgeli.model.ResultModel;  
import cn.bridgeli.service.ProductService;  
@Controller  
public class ProductController {

  @Autowired  
  private ProductService productService;

  @RequestMapping("/list")  
  public String queryProduct(String queryString, String catalog_name, String price, String sort, Integer page, Model model) throws Exception {  
    //查询商品列表  
    ResultModel resultModel = productService.queryProduct(queryString, catalog_name, price, sort, page);  
    //列表传递给jsp  
    model.addAttribute("result", resultModel);  
    //参数回显  
    model.addAttribute("queryString", queryString);  
    model.addAttribute("caltalog_name", catalog_name);  
    model.addAttribute("price", price);  
    model.addAttribute("sort", sort);  
    model.addAttribute("page", page);

    return "product_list";  
  }  
}

②. service

package cn.bridgeli.service;

import org.apache.solr.client.solrj.SolrQuery;  
import org.apache.solr.client.solrj.SolrQuery.ORDER;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Service;

import cn.bridgeli.common.Commons;  
import cn.bridgeli.dao.ProductDao;  
import cn.bridgeli.model.ResultModel;  
@Service  
public class ProductServiceImpl implements ProductService {

  @Autowired  
  private ProductDao productDao;

  @Override  
  public ResultModel queryProduct(String queryString, String caltalog_name, String price, String sort, Integer page) throws Exception {  
    //拼装查询条件  
    SolrQuery query = new SolrQuery();  
    //查询条件  
    if (null != queryString && !"".equals(queryString)) {  
      query.setQuery(queryString);  
    } else {  
      query.setQuery("*:*");
    }  
    //商品分类名称过滤  
    if (null != caltalog_name && !"".equals(caltalog_name)) {  
      query.addFilterQuery("category:" + caltalog_name);  
    }  
    //价格区间过滤  
    if (null != price && !"".equals(price)) {  
      String[] strings = price.split("-");  
      query.addFilterQuery("price:["+strings[0]+" TO "+strings[1]+"]");  
    }  
    //排序条件  
    if ("1".equals(sort)) {  
      query.setSort("price", ORDER.desc);  
    } else {  
      query.setSort("price", ORDER.asc);  
    }  
    //分页处理  
    if (null == page) {  
      page = 1;  
    }  
    //start  
    int start = (page-1) * Commons.PAGE_SIZE;  
    query.setStart(start);  
    query.setRows(Commons.PAGE_SIZE);

    //高亮设置  
    query.setHighlight(true);  
    query.addHighlightField("name");  
    query.setHighlightSimplePre("<span style="color:red">");  
    query.setHighlightSimplePost("</span>");

    //查询商品列表  
    ResultModel resultModel = productDao.queryProduct(query);  
    //计算总页数  
    long recordCount = resultModel.getRecordCount();  
    int pages = (int) (recordCount/Commons.PAGE_SIZE);  
    if (recordCount % Commons.PAGE_SIZE > 0) {  
      pages ++;  
    }  
    resultModel.setPageCount(pages);  
    resultModel.setCurPage(page);  
    return resultModel;  
  }  
}

这里只列出了实现，结果过于简单就算了，dao也会一样

③. dao

package cn.bridgeli.dao;

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.response.QueryResponse;  
import org.apache.solr.common.SolrDocument;  
import org.apache.solr.common.SolrDocumentList;  
import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.stereotype.Repository;

import cn.bridgeli.model.ProductModel;  
import cn.bridgeli.model.ResultModel;  
@Repository  
public class ProductDaoImpl implements ProductDao {

  @Autowired  
  private SolrServer solrServer;

  @Override  
  public ResultModel queryProduct(SolrQuery query) throws Exception {

    ResultModel resultModel = new ResultModel();  
    //根据query对象查询商品列表  
    QueryResponse queryResponse = solrServer.query(query);  
    SolrDocumentList solrDocumentList = queryResponse.getResults();  
    //取查询结果的总数量  
    resultModel.setRecordCount(solrDocumentList.getNumFound());  
    List<ProductModel> productList = new ArrayList<>();  
    //遍历查询结果  
    for (SolrDocument solrDocument : solrDocumentList) {  
      //取商品信息  
      ProductModel productModel = new ProductModel();  
      productModel.setId((String) solrDocument.get("id"));  
      //取高亮显示  
      String productName = "";  
      Map<String, Map<String, List<String>>> highlighting = queryResponse.getHighlighting();  
      List<String> list = highlighting.get(solrDocument.get("id")).get("name");  
      if (null != list) {  
        productName = list.get(0);  
      } else {  
        productName = (String) solrDocument.get("name");  
      }  
      productModel.setName(productName);  
      productModel.setPrice((float) solrDocument.get("price"));  
      productModel.setCategory((String) solrDocument.get("category"));  
      productModel.setUrl((String) solrDocument.get("url"));  
      //添加到商品列表  
      productList.add(productModel);  
    }  
    //商品列表添加到resultmodel中  
    resultModel.setProductList(productList);  
    return resultModel;  
  }

}

④. model

有两个分别是：

package cn.bridgeli.model;

public class ProductModel {  
  // 商品编号  
  private String id;  
  // 商品名称  
  private String name;  
  // 商品分类名称  
  private String category;  
  // 价格  
  private float price;  
  // 商品描述  
  private String content;  
  // 图片名称  
  private String url;

  //setXX and getXX  
}

package cn.bridgeli.model;

import java.util.List;

public class ResultModel {  
  // 商品列表  
  private List<ProductModel> productList;  
  // 商品总数  
  private Long recordCount;  
  // 总页数  
  private int pageCount;  
  // 当前页  
  private int curPage;

  //setXX and getXX  
}

数据库文件

CREATE TABLE `products` (  
`pid` int(11) NOT NULL AUTO_INCREMENT COMMENT '商品编号',  
`name` varchar(255) DEFAULT NULL COMMENT '商品名称',  
`catalog` int(11) DEFAULT NULL COMMENT '商品分类ID',  
`catalog_name` varchar(50) DEFAULT NULL COMMENT '商品分类名称',  
`price` double DEFAULT NULL COMMENT '价格',  
`number` int(11) DEFAULT NULL COMMENT '数量',  
`description` longtext COMMENT '商品描述',  
`picture` varchar(255) DEFAULT NULL COMMENT '图片名称',  
`release_time` datetime DEFAULT NULL COMMENT '上架时间',  
PRIMARY KEY (`pid`)  
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;

好了，只要初始化上数据，我们的一个单机版solr搜索服务器中完成了，开始庆祝吧。