web整合Solr

作者: 唯死撑尔 | 来源:发表于2019-07-20 18:38 被阅读0次

1..Solr案例实战

1.1.需求

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

界面如下：

1.2.分析

开发人员需要的文档：静态页面（根据UI设计由美工给出）、数据库设计、原型设计

1.2.1.UI分析

1.2.2.架构分析

image.png

架构分为：

（1）、solr服务器。（已经做完，同入门示例）

（2）、自己开发的应用（重点）

（3）、数据库mysql

自己开发的应用

Controller 负责和前端页面进行请求和响应的交互

Service 封装查询条件，调用dao。

Dao 搜索索引库，返回搜索结果。

1.3.环境准备

Solr：4.10.3

Jdk环境：1.7.0_72（solr4.10 不能使用jdk1.7以下）

Ide环境：Eclipse

Web服务器（servlet容器）：Tomcat 7X

1.4.功能开发

1.4.1.第一步：创建web工程，导入jar包

image.png

--导入的jar包说明：

Solrj的包

Solr服务的日志包

Spring的包（包含springmvc）

核心包 4个 core 、bean、context、expresstion

注解包 aop

Web包 web、webmvc

Commons日志包 common-logging

Jstl包

--导入静态资源和jsp页面说明：

静态资源放在webapp目录下，jsp页面放到/WEB-INF/目录下

1.4.2.第二步：Spring整合Solr、Springmvc

1.4.2.1.创建springmvc.xml

在config包下，创建springmvc.xml文件

<?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.gzsxt" />

       <!-- 配置注解驱动 -->

       <mvc: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>

       <bean class="org.apache.solr.client.solrj.impl.HttpSolrServer">

              <constructor-arg      value="http://localhost:8080/solr/solrCore0719"></constructor-arg>

       </bean>

</beans>

1.4.2.2.创建Web.xml

<?xml version="1.0" encoding="UTF-8"?>     

<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"      xmlns="http://xmlns.jcp.org/xml/ns/javaee"      xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee      http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd" id="WebApp_ID" version="3.1">

  <display-name>JD0719</display-name>

  <!-- 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>

    </servlet>

    <servlet-mapping>

         <servlet-name>springmvc</servlet-name>

         <url-pattern>/</url-pattern>

    </servlet-mapping>

    <filter>

         <filter-name>Character Encoding</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>Character Encoding</filter-name>

         <url-pattern>*.action</url-pattern>

    </filter-mapping>

</web-app>

1.4.3.第三步：整合测试

1.4.3.1.需求：

访问搜索页面。

1.4.3.2.创建PageController类

package cn.gzsxt.solr.controller;     

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.PathVariable;

import org.springframework.web.bind.annotation.RequestMapping;

@Controller

public class PageController {

    @RequestMapping(value="/{page}")

    public String showPage(@PathVariable("page")String page){

       return page;

    }

}

1.4.3.4.注意事项

（1）Solr服务器要先开启。

（2）Solr服务器部署的Tomcat和本web应用的部署的Tomcat不是同一个。

（3）要同时启动两个Tomcat，要注意端口冲突问题。

        6.修改Solr服务器的Tomcat的端口

--在server.xml文件中，修改端口

--tomcat端口说明：

8005：关机端口

8080：默认服务端口

8009：请求转向端口。

--注意：这三个端口都需要修改。不然启动会冲突

本次课程中，将solr的tomcat端口，修改为8888.

1.4.3.5.修改Springmvc.xml

--修改Solr服务的端口

<bean class="org.apache.solr.client.solrj.impl.HttpSolrServer">     

    <constructor-arg value="http://localhost:8888/solr/solrCore0719"></constructor-arg>

</bean>

1.4.3.6.访问搜索页面

地址：http://localhost:8080/solr-demo-02-jd/product_list.action

image.png

整合成功！！！

1.4.4.第四步：搜索功能实现

分析代码结构：

请求路径=list.action

请求方式=POST

请求参数=queryString、catalog_name、price、curPage、sort（共5个）

返回结果=定义Product 以及ProductModel

1.4.4.1.Pojo

1.4.4.1.1.分析

结合查询界面，分析得出：

--需要一个商品的pojo（Product），存放商品信息

--需要一个包装pojo（ResultModel），它包括商品列表信息、商品分页信息

1.4.4.1.2.创建Product类

public class Product {     

    // 商品编号

    private String pid;

    // 商品名称

    private String name;

    // 商品分类名称

    private String catalog_name;

    // 价格

    private double price;

    // 商品描述

    private String description;

    // 图片名称

    private String picture;

}

1.4.4.1.3.创建ResultModel类

public class ResultModel {     

    private List<Product> productList;

    // 商品总数

    private Long recordCount;

    // 总页数

    private int pageCount;

    // 当前页

    private int currentPage;

}

1.4.4.2.Dao

1.4.4.2.1.功能

接收service层传递过来的参数，根据参数查询索引库，返回查询结果。

1.4.4.2.2.创建ProductDao接口，定义一个查询方法

public interface ProductDao {     

   //查询商品信息，包括分页信息

   public ResultModel queryProduct(SolrQuery query) throws      Exception;

}

1.4.4.2.3.创建ProductDaoImpl，重新改查询方法

package cn.gzsxt.dao.impl;     

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.impl.HttpSolrServer;

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.gzsxt.bean.Product;

import cn.gzsxt.bean.ResultModel;

import cn.gzsxt.dao.ProductDao;

@Repository

public class ProductDaoImpl implements ProductDao {

   @Autowired

   private HttpSolrServer server;

   @Override

   public ResultModel queryProduct(SolrQuery query) throws      Exception {

      ResultModel result = new ResultModel();

       // 通过server查询索引库

      QueryResponse response = server.query(query);

       // 获得查询结果

      SolrDocumentList documentList = response.getResults();

       // 把查询结果总数设置到ResultModel

      result.setRecordCount(documentList.getNumFound());

      List<Product> productList = new ArrayList<>();

      Product product = null;

       // 高亮信息

      Map<String, Map<String, List<String>>> highlighting =      response

             .getHighlighting();

      for (SolrDocument solrDocument : documentList) {

          product = new Product();

          product.setPid((String) solrDocument.get("id"));

          String prodName = (String)      solrDocument.get("product_name");

          List<String> list =      highlighting.get(solrDocument.get("id")).get(

                "product_name");

          if (list != null)

             prodName = list.get(0);

          product.setName(prodName);

          product.setCatalog_name((String) solrDocument

                .get("product_catalog_name"));

          product.setPrice((float)      solrDocument.get("product_price"));

          product.setPicture((String)      solrDocument.get("product_picture"));

          productList.add(product);

      }

       // 把商品列表放到ResultMap中

      result.setProductList(productList);

      return result;

   }

}

1.4.4.3.Service

1.4.4.3.1.功能分析

接收action传递过来的参数，根据参数拼装一个查询条件，调用dao层方法，查询商品列表??

接收返回的商品列表和商品的总数量，根据每页显示的商品数量计算总页数。

1.4.4.3.2.创建ProductService接口，定义一个查询方法

public interface ProductService {     

   public ResultModel queryProduct(String queryString, String      cataName,

           String price, String sort, Integer curPage) throws      Exception;

}

1.4.4.3.3.创建ProductServiceImpl类，重写改查询方法

package cn.gzsxt.service.impl;     

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.gzsxt.dao.ProductDao;

import cn.gzsxt.service.ProductService;

import cn.gzsxt.vo.ResultModel;

@Service

public class ProductServiceImpl implements ProductService {

    @Autowired

    private ProductDao productDao;

    @Override

    public ResultModel queryProduct(String queryString, String cataName,

             String price, String sort, Integer curPage) throws Exception {

         //封装查询条件

         SolrQuery query = new SolrQuery();

         //判断查询条件是否为空

         if(!"".equals(queryString)&& null != queryString){

             query.setQuery(queryString);

         }else{

             query.setQuery("*:*");

         }

         //判断过滤条件是否为空

         if(!"".equals(cataName)&& null !=cataName){

             query.addFilterQuery("product_catalog_name:"+cataName);

         }

         //判断商品价格是否为空

         if(!"".equals(price) && null != price){

             String[] prices = price.split("-");

             if(prices.length == 2){

                  query.addFilterQuery("product_price:["+prices[0]+" TO      "+prices[1]+"]");

             }

         }

         //设置排序

         if("1".equals(sort)){

             query.setSort("product_price", ORDER.desc);

         }else {

             query.setSort("product_price", ORDER.asc);

         }

         //设置分页信息

         if(null == curPage){

             curPage = 1;

         }

         query.setStart((curPage-1)*20);

         query.setRows(20);  //每页20条数据

         //设置默认搜索域

         query.set("df","product_name");

         query.setHighlight(true);

         query.addHighlightField("product_name");

         query.setHighlightSimplePre("<font style=\"color:red\">");

         query.setHighlightSimplePost("</font>");

         ResultModel result = productDao.queryProduct(query);

         result.setCurrentPage(curPage);

         // 总页数 = 总数量 / 每页数据条数  结果向上取整

         double ceil = Math.ceil(result.getRecordCount().doubleValue()/20);

         result.setPageCount((int)ceil);

         return result;

    }

}

1.4.4.4.Controller

1.4.4.4.1.创建ProductController类，定义查询接口

package cn.gzsxt.controller;     

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.ui.ModelMap;

import org.springframework.web.bind.annotation.RequestMapping;

import cn.gzsxt.service.ProductService;

import cn.gzsxt.vo.ResultModel;

@Controller

public class ProductController {

    @Autowired

    private ProductService productService;

    @RequestMapping("/list.action")

    public String queryProduct(String queryString, String catalog_name,

             String price, String sort, Integer curPage, ModelMap model)

             throws Exception {

         ResultModel resultModel = productService.queryProduct(queryString,      catalog_name,

                  price, sort, curPage);

         model.addAttribute("result", resultModel);

         model.addAttribute("queryString", queryString);

         model.addAttribute("catalog_name", catalog_name);

         model.addAttribute("price", price);

         model.addAttribute("sort", sort);

         model.addAttribute("page", curPage);

         return "product_list";

    }

}

1.4.4.5.测试搜索功能

地址：http://localhost:8080/solr-demo-02-jd/list.action

image.png

web整合Solr

1..Solr案例实战

1.1.需求

1.2.分析

1.2.1.UI分析

1.2.2.架构分析

1.3.环境准备

1.4.功能开发

1.4.1.第一步：创建web工程，导入jar包

1.4.2.第二步：Spring整合Solr、Springmvc

1.4.2.1.创建springmvc.xml

1.4.2.2.创建Web.xml

1.4.3.第三步：整合测试

1.4.3.1.需求：

1.4.3.2.创建PageController类

1.4.3.4.注意事项

1.4.3.5.修改Springmvc.xml

1.4.3.6.访问搜索页面

1.4.4.第四步：搜索功能实现

1.4.4.1.Pojo

1.4.4.1.1.分析

1.4.4.1.2.创建Product类

1.4.4.1.3.创建ResultModel类

1.4.4.2.Dao

1.4.4.2.1.功能

1.4.4.2.2.创建ProductDao接口，定义一个查询方法

1.4.4.2.3.创建ProductDaoImpl，重新改查询方法

1.4.4.3.Service

1.4.4.3.1.功能分析

1.4.4.3.2.创建ProductService接口，定义一个查询方法

1.4.4.3.3.创建ProductServiceImpl类，重写改查询方法

1.4.4.4.Controller

1.4.4.4.1.创建ProductController类，定义查询接口

1.4.4.5.测试搜索功能

相关文章

网友评论

延伸阅读

深度阅读

栏目导航

热点阅读

分布式

项目