solr_架构案例【京东站内搜索】(附程序源代码)

注意事项：首先要保证部署solr服务的Tomcat容器和检索solr服务中数据的Tomcat容器，它们的端口号不能发生冲突，否则web程序是不可能运行起来的。

一：solr服务的端口号、我这里的solr服务的tomcat容器的端口号已经修改为8083：

二：检索solr服务中数据的tomcat容器的端口号、我这里是8080：

 

最后必须要保证2个容器能正常访问。

需求：使用Solr实现电商网站中商品信息搜索功能，可以根据关键字搜索商品信息，根据商品分类、价格过滤搜索结果，也可以根据价格进行排序，实现分页。

界面如下：

1、架构分析：

自己开发的应用：

Controller层的作用：获取搜索条件，并响应搜索结果到前台页面。

Service层的作用：接收Controller传递过来的参数，根据参数拼装一个查询条件，调用dao层方法，查询商品数据；接收返回的商品列表和商品的总数量，根据每页显示的商品数量计算总页数。

Dao层的作用：接收Service层传递过来的参数，根据参数去检索solr索引库中的商品数据，返回查询结果。

2、WEB工程的搭建(相关的jar必须得全部引入，环境搭建篇中已经注明了)：

需要说明的几点问题：

(a)、在springmvc核心配置文件中配置solr服务时，一定将solr服务的连接地址配置正确，否则无法找到solr索引库：

<?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:p="http://www.springframework.org/schema/p"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xmlns:mvc="http://www.springframework.org/schema/mvc"
    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
        http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd
        http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd">

    <!-- 配置注解扫描-->
    <context:component-scan base-package="com.jd"/>
    
    <!-- 配置注解驱动: 就相当于自动替我们配置注解形式的处理器映射器和处理器适配器 -->
    <mvc:annotation-driven/>
    
    <!-- 配置视图解析器 -->
    <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
        <property name="prefix" value="/WEB-INF/jsp/"></property>
        <property name="suffix" value=".jsp"></property>
    </bean>
    
    <!-- 配置solrServer服务，供数据访问层检索数据使用： -->
    <bean id="solrServer" class="org.apache.solr.client.solrj.impl.HttpSolrServer">
        <!-- 配置构造方法 -->
        <constructor-arg value="http://localhost:8083/solr/collection1"/>
    </bean>
</beans>

(b)、在项目的web.xml配置文件中配置springmvc的前端控制器、post请求的乱码解决等问题：

　　<!-- springMvc前端控制器 -->
    <servlet>
        <servlet-name>springmvc</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:SpringMvc.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>springmvc</servlet-name>
        <url-pattern>*.action</url-pattern>
    </servlet-mapping>

    <!-- 解决post乱码 -->
    <filter>
        <filter-name>CharacterEncodingFilter</filter-name>
        <filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
        <init-param>
            <param-name>encoding</param-name>
            <param-value>utf-8</param-value>
        </init-param>
    </filter>
    <filter-mapping>
        <filter-name>CharacterEncodingFilter</filter-name>
        <url-pattern>/*</url-pattern>
    </filter-mapping>

3、各个开发层的代码实现，程序中基本附带注释：

【Dao层】

package com.jd.dao;

import org.apache.solr.client.solrj.SolrQuery;

import com.jd.pojo.ResultModel;

/**
 * 商品模块Dao接口：
 * @author zxz
 *
 */

public interface ProductDao {
    
    /**
     * 根据检索条件检索solr服务上索引库中的数据：
     * @param solrQuery
     * @return
     * @throws Exception
     */
    public ResultModel search(SolrQuery solrQuery) throws Exception;

}

package com.jd.dao;

import java.util.ArrayList;
import java.util.List;
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 com.jd.pojo.ProductModel;
import com.jd.pojo.ResultModel;

/**
 * 商品模块Dao层开发：
 * 核心功能：接收Service层传递过来的参数，根据参数去检索solr索引库中的商品数据，返回查询结果
 * @author zxz
 *
 */
@Repository
public class ProductDaoImpl implements ProductDao {
    
    //注入solr服务(该solr服务在springmvc的核心配置文件中已经进行配置了)：
    @Autowired
    private SolrServer solrServer;

    //检索solr服务上索引库中的数据：
    @Override
    public ResultModel search(SolrQuery solrQuery) throws Exception {
        //1、查询并获取响应结果：
        QueryResponse response = solrServer.query(solrQuery);
        
        //2、从响应中获取结果集：
        SolrDocumentList results = response.getResults();
        
        //3、处理结果集：
        //专门用于存放响应结果集中的个个商品数据的集合
        List<ProductModel> productList = new ArrayList<ProductModel>();
        //用于将检索到的并处理好的数据封装到ResultModel对象中，用于返回给Service层：
        ResultModel resultModel = new ResultModel();
        //做非空校验，如果检索到的结果集不为空的话，就进行处理并封装结果数据：
        if(results != null){
            //(1)、封装查询到的商品总数：
            resultModel.setRecordCount(results.getNumFound());
            
            //(2)、遍历响应中的结果集，并将数据一一封装进ProductModel对象中：
            for (SolrDocument document : results) {
                //创建ProductModel对象：
                ProductModel product = new ProductModel();
                //商品id：
                product.setPid(String.valueOf(document.get("id")));
                //商品名称：
                product.setName(String.valueOf(document.get("product_name")));
                //商品价格：
                if(String.valueOf(document.get("product_price"))!=null &&
                        !"".equals(String.valueOf(document.get("product_price")))){
                    product.setPrice(Float.valueOf(String.valueOf(document.get("product_price"))));
                }
                //商品图片：
                product.setPicture(String.valueOf(document.get("product_picture")));
                
                //将当前遍历并封装好的ProductModel对象添加到存放商品数据的集合中：
                productList.add(product);
            }
            
            //循环处理并封装好结果集之后，将存放商品数据的集合设置到ResultModel对象中：
            resultModel.setProductList(productList);
        }
        
        //将封装好的数据返回给Service层处理：
        return resultModel;
    }
}

【Service层】

package com.jd.service;

import com.jd.pojo.ResultModel;

/**
 * 商品模块Service层接口：
 * @author zxz
 *
 */

public interface ProductService {
    
    /**
     * 根据各种检索条件去调用dao层的方法，得到符合检索条件的数据：
     * @param queryString
     * @param catalog_name
     * @param price
     * @param page
     * @param sort
     * @return
     * @throws Exception
     */
    public ResultModel search(String queryString, String catalog_name, 
            String price, Integer page, String sort) throws Exception;

}

package com.jd.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 com.jd.dao.ProductDao;
import com.jd.pojo.ResultModel;

/**
 * 商品模块Service层开发：
 * 核心功能：接收Controller传递过来的参数，根据参数拼装一个查询条件，调用dao层方法，查询商品数据。
 *              接收返回的商品列表和商品的总数量，根据每页显示的商品数量计算总页数。
 * @author zxz
 *
 */
@Service
public class ProductServiceImpl implements ProductService {
    
    //注入Dao：
    @Autowired
    private ProductDao productDao;
    
    //定义常量，代表每页显示的商品条数：
    private final static Integer PAGE_SIZE = 60;

    //根据检索条件得到数据：
    @Override
    public ResultModel search(String queryString, String catalog_name, String price, Integer page, String sort)
            throws Exception {
        //1、封装查询条件对象，因为需要调用dao层的方法，dao层的检索方法就需要一个solr服务的查询条件对象：
        SolrQuery solrQuery = new SolrQuery();
        
        //2、设置默认查询的域(该默认的域已经在solrHome/collection1/conf/schema.xml配置文件中配置了业务域)：
        solrQuery.setQuery("product_keywords");
        
        //3、设置查询的关键字:
        if(queryString!=null && !"".equals(queryString)){
            solrQuery.setQuery(queryString);
        }else{
            //如果没有查询的关键字，则默认查询所有商品数据：
            solrQuery.setQuery("*:*");
        }
        
        //4、根据商品分类进行过滤：
        if(catalog_name!=null && !"".equals(catalog_name)){
            //注意查询语法：不要忽略":"号
            solrQuery.addFilterQuery("product_catalog_name:" + catalog_name);
        }
        
        //5、根据商品价格进行过滤：
        if(price!=null && !"".equals(price)){
            //因为传递过来的的商品价格的格式为：100-300，所以需要切割并根据价格区间过滤商品数据：
            String[] split = price.split("-");
            if(split!=null && split.length>1){
                //为什么判断长度必须大于1，因为根据价格过滤需要最小值和最大值，必须有俩个值才能过滤成功
                solrQuery.addFilterQuery("product_price:["+split[0]+" TO "+split[1]+"]");
            }
        }
        
        //6、按照商品价格排序展示商品数据：
        if("1".equals(sort)){
            solrQuery.setSort("product_price",ORDER.asc);
        }else{
            solrQuery.setSort("product_price",ORDER.desc);
        }
        
        //7、分页查询商品数据：
        //首先校验数据合法性，如果当前页的值为空或小于1，则默认开始查询第一页数据：
        if(page == null){
            page = 1;
        }
        if(page < 1){
            page = 1;
        }
        //计算起始索引：
        Integer startIndex = (page-1) * PAGE_SIZE;
        //设置起始索引：
        solrQuery.setStart(startIndex);
        //设置每页显示的商品记录数：
        solrQuery.setRows(PAGE_SIZE);
        
        //8、根据封装后的SolrQuery查询对象查询商品数据：
        ResultModel resultModel = productDao.search(solrQuery);
        //设置当前页数：
        resultModel.setCurPage(page);
        //计算总页数：
        Long pageCount = (long) Math.ceil((resultModel.getRecordCount()*1.0) / PAGE_SIZE);
        //设置总页数：
        resultModel.setPageCount(pageCount);
        
        return resultModel;
    }
}

【Controller层】

package com.jd.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 com.jd.pojo.ResultModel;
import com.jd.service.ProductService;

/**
 * 商品模块：
 * @author zxz
 *
 */

@Controller
public class ProductController {
    
    //注入Service接口：
    @Autowired
    private ProductService productService;
    
    @RequestMapping("/list")
    //根据条件和分页信息检索商品数据：
    public String proList(String queryString, String catalog_name, 
            String price, Integer page, String sort,Model model) throws Exception{
        
        //调用service层的方法得到检索后的数据：
        ResultModel resultModel = productService.search(queryString, catalog_name, price, page, sort);
        
        //将检索得到的数据返回给页面：
        model.addAttribute("result", resultModel);   //注意：这里的名称必须和jsp页面上获取数据的名称保持一致
        
        //回显查询条件：
        model.addAttribute("queryString", queryString);　　　　　　//这里的条件回显时，名称也必须和jsp页面上获取数据的名称保持一致
        model.addAttribute("catalog_name", catalog_name);
        model.addAttribute("price", price);
        model.addAttribute("sort", sort);
        
        return "product_list";
    }
}

最后pojo类的数据模型截个图给大家分享一下(案例所需的基本程序都在这里了，希望能帮到大家，如果有什么不对的地方望各位指教！！！)：