商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

时间:2023-11-12 13:18:44

1.   课程计划

1、搜索工程的搭建

2、linux下solr服务的搭建

3、Solrj使用测试

4、把数据库中的数据导入索引库

5、搜索功能的实现

2.   搜索工程搭建

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

要实现搜索功能,需要搭建solr服务、搜索服务工程、搜索系统(表现层的工程)

2.1. Solr服务搭建

2.1.1.    Solr的环境

  Solr是java开发。

  solr的安装文件需要安装jdk。

  安装环境Linux。

  需要安装Tomcat。

2.1.2.    搭建步骤

  第一步:把solr 的压缩包上传到Linux系统。

      Alt+p打开sftp窗口:输入put "F:/java/ziyuan/solr-4.10.3.tgz.tgz"

  第二步:解压solr :tar -xvf solr-4.10.3.tgz.tgz

      新建一个目录安装solr: cd /usr/local     --->     mkdir solr

  第三步:安装Tomcat,解压缩即可。

  第四步:把solr部署到Tomcat下。

      将tomcat拷贝到solr目录下:cp apache-tomcat-7.0.52 /usr/local/solr -r

  第五步:解压缩war包。可以启动Tomcat解压。

      war包所在位置:solr-4.10.3/example/webapps/solr.war

      将该war包拷贝到:cp  solr.war /usr/local/solr/apache-tomcat-7.0.52/webapps

      启动Tomcat解压:

          cd /usr/local/solr/apache-tomcat-7.0.52/bin/

          ./startup.sh

          ./shutdown.sh

          ../webapps

          rm -rf solr.war  (删除掉这个war文件)         

  第六步:把/root/solr-4.10.3/example/lib/ext目录下的所有的jar包,添加到solr工程中。

    [root@localhost webapps]# cp /root/solr-4.10.3/example/lib/ext/*.jar /usr/local/solr/apache-tomcat-7.0.52/webapps/solr/WEB-INF/lib

  第七步:创建一个solrhome。/example/solr目录就是一个solrhome。复制此目录到/usr/local/solr/solrhome:

    [root@localhost webapps]# cp /root/solr-4.10.3/example/solr  /usr/local/solr/solrhome -r

  第八步:关联solr及solrhome。需要修改solr工程的web.xml文件。

    cd /usr/local/solr/apache-tomcat-7.0.52/webapps/solr/WEB-INF/

    修改web.xml文件: vim web.xml :

    商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

  第九步:启动Tomcat:

    cd /usr/local/solr/apache-tomcat-7.0.52/bin/

    ./startup.sh

    查看输出:

      商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

    网页测试:http://192.168.25.131:8080/solr/

  和windows下的配置完全一样。

2.1.3.    Solr的使用

  添加文档必须有id域,其他域 必须在solr的schema.xml中定义。

2.2. 配置业务域

schema.xml中定义

  1、商品Id      使用schema.xml中的id域

  2、商品标题

  3、商品卖点

  4、商品价格

  5、商品图片

  6、分类名称

  7、商品描述

创建对应的业务域。需要制定中文分析器。创建步骤:

  第一步:把中文分析器添加到solr工程中。

    1、把IKAnalyzer2012FF_u1.jar添加到solr工程的lib目录下

     [root@localhost IKAnalyzer]# cp IKAnalyzer2012FF_u1.jar /usr/local/solr/apache-tomcat-7.0.52/webapps/solr/WEB-INF/lib

    2、把扩展词典、配置文件放到solr工程的WEB-INF/classes目录下。

        cd /usr/local/solr/apache-tomcat-7.0.52/webapps/solr/WEB-INF

     [root@localhost WEB-INF]# mkdir classes

     [root@localhost WEB-INF]# cp /root/IKAnalyzer/*.dic *.xml ./classes

  第二步:配置一个FieldType,制定使用IKAnalyzer

    修改schema.xml文件,添加FieldType:

      cd /usr/local/solr/solrhome/collection1/conf/

      vim schema.xml

<fieldType name="text_ik" class="solr.TextField">
<analyzer class="org.wltea.analyzer.lucene.IKAnalyzer"/>
</fieldType>

  第三步:配置业务域,type制定使用自定义的FieldType。

    设置业务系统Field(type="text_ik"要分词(string不分词),indexed="true"要索引,stored="true"要存储)

<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_desc" type="text_ik" indexed="true" stored="false" /> <field name="item_keywords" type="text_ik" indexed="true" stored="false" multiValued="true"/>
<copyField source="item_title" dest="item_keywords"/>
<copyField source="item_sell_point" dest="item_keywords"/>
<copyField source="item_category_name" dest="item_keywords"/>
<copyField source="item_desc" dest="item_keywords"/>

  第四步:重启tomcat

    cd /usr/local/solr/apache-tomcat-7.0.52/bin

    [root@localhost bin]# ./startup.sh

2.3. 搜索服务工程搭建

可以参考taotao-manager创建。

  taotao-search(聚合工程pom

    |--taotao-search-interface(jar

    |--taotao-search-Service(war

(1)taotao-search的pom.xml:

<modules>
<module>taotao-search-interface</module>
<module>taotao-search-service</module>
</modules>
<build>
<plugins>
<!-- tomcat插件 -->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<configuration>
<port>8084</port>
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>

(2)taotao-search-interface的pom.xml:

  依赖taotao-commom、taotao-manager-pojo

(3)taotao-search-service的pom.xml:

<dependencies>
<!-- dubbo相关 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<!-- 排除依赖 -->
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
<exclusion>
<groupId>org.jboss.netty</groupId>
<artifactId>netty</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
</dependency>
<dependency>
<groupId>com.taotao</groupId>
<artifactId>taotao-search-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
<!-- solr客户端 -->
<dependency>
<groupId>org.apache.solr</groupId>
<artifactId>solr-solrj</artifactId>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.12.4</version>
<configuration>
<!-- 跳过测试 -->
<skipTests>true</skipTests>
</configuration>
</plugin>
</plugins>
</build>

配置文件:

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

applicationContext-dao.xml:

  由于搜索的数据涉及到3张表,需要自己定义mapper,而mapper的使用,只在搜索服务工程中,所以mapper接口及映射文件需要放在taotao-search-service工程中。

<!-- 数据源 -->
<!-- sqlsessionfactory -->
<!-- mapper扫描器 --> <context:property-placeholder location="classpath:properties/*.properties" />
<!-- 数据库连接池 -->
<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource"
destroy-method="close">
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="driverClassName" value="${jdbc.driver}" />
<property name="maxActive" value="10" />
<property name="minIdle" value="5" />
</bean>
<!-- 让spring管理sqlsessionfactory 使用mybatis和spring整合包中的 -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<!-- 数据库连接池 -->
<property name="dataSource" ref="dataSource" />
<!-- 加载mybatis的全局配置文件 -->
<property name="configLocation" value="classpath:mybatis/SqlMapConfig.xml" />
</bean>
<!-- 只用于搜索的mapper -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.taotao.search.mapper" />
</bean>

3.   测试使用solrJ管理索引库

  使用SolrJ可以实现索引库的增删改查操作。

3.1. 添加文档

  第1步:把solrJ的jar包添加到工程中。

  第2步:创建一个SolrServer,使用HttpSolrServer创建对象。

  第3步:创建一个文档对象SolrInputDocument对象。

  第4步:向文档中添加域。必须有id域,域的名称必须在schema.xml中定义。

  第5步:把文档添加到索引库中。

  第6步:提交。

@Test
public void addDocument() throws Exception {
// 第1步:把solrJ的jar包添加到工程中。
// 第2步:创建一个SolrServer,使用HttpSolrServer创建对象。
SolrServer solrServer = new HttpSolrServer("http://192.168.25.131:8080/solr");
// 第3步:创建一个文档对象SolrInputDocument对象。
SolrInputDocument document = new SolrInputDocument();
// 第4步:向文档中添加域。必须有id域,域的名称必须在schema.xml中定义。
document.addField("id", "test001");
document.addField("item_title", "测试商品");
document.addField("item_price", "199");
// 第5步:把文档添加到索引库中。
solrServer.add(document);
// 第6步:提交。
solrServer.commit();
}

3.2. 删除文档

3.2.1.    根据id删除

  第1步:创建一个SolrServer对象。

  第2步:调用SolrServer对象的根据id删除的方法。

  第3步:提交。

@Test
public void deleteDocumentById() throws Exception {
// 第一步:创建一个SolrServer对象。
SolrServer solrServer = new HttpSolrServer("http://192.168.25.131:8080/solr");
// 第二步:调用SolrServer对象的根据id删除的方法。
solrServer.deleteById("1");
// 第三步:提交。
solrServer.commit();
}

3.2.2.    根据查询删除

    @Test
public void deleteDocumentByQuery() throws Exception {
SolrServer solrServer = new HttpSolrServer("http://192.168.25.131:8080/solr");
solrServer.deleteByQuery("title:change.me");
solrServer.commit();

3.3. 查询索引库

查询步骤:

  第1步:创建一个SolrServer对象

  第2步:创建一个SolrQuery对象。

  第3步:向SolrQuery中添加查询条件、过滤条件。。。

  第4步:执行查询。得到一个Response对象。

  第5步:取查询结果。

  第6步:遍历结果并打印。

3.3.1.    简单查询

@Test
public void queryDocument() throws Exception {
// 第一步:创建一个SolrServer对象
SolrServer solrServer = new HttpSolrServer("http://192.168.25.131:8080/solr");
// 第二步:创建一个SolrQuery对象。
SolrQuery query = new SolrQuery();
// 第三步:向SolrQuery中添加查询条件、过滤条件。。。
query.setQuery("*:*");
// 第四步:执行查询。得到一个Response对象。
QueryResponse response = solrServer.query(query);
// 第五步:取查询结果。
SolrDocumentList solrDocumentList = response.getResults();
System.out.println("查询结果的总记录数:" + solrDocumentList.getNumFound());
// 第六步:遍历结果并打印。
for (SolrDocument solrDocument : solrDocumentList) {
System.out.println(solrDocument.get("id"));
System.out.println(solrDocument.get("item_title"));
System.out.println(solrDocument.get("item_price"));
}
}

3.3.2.    带高亮显示

  @Test
public void queryDocumentWithHighLighting() throws Exception {
// 第一步:创建一个SolrServer对象
SolrServer solrServer = new HttpSolrServer("http://192.168.25.154:8080/solr");
// 第二步:创建一个SolrQuery对象。
SolrQuery query = new SolrQuery();
// 第三步:向SolrQuery中添加查询条件、过滤条件。。。
query.setQuery("测试");
//指定默认搜索域
query.set("df", "item_keywords");
//开启高亮显示
query.setHighlight(true);
//高亮显示的域
query.addHighlightField("item_title");
query.setHighlightSimplePre("<em>");
query.setHighlightSimplePost("</em>");
// 第四步:执行查询。得到一个Response对象。
QueryResponse response = solrServer.query(query);
// 第五步:取查询结果。
SolrDocumentList solrDocumentList = response.getResults();
System.out.println("查询结果的总记录数:" + solrDocumentList.getNumFound());
// 第六步:遍历结果并打印。
for (SolrDocument solrDocument : solrDocumentList) {
System.out.println(solrDocument.get("id"));
//取高亮显示
Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
String itemTitle = null;
if (list != null && list.size() > 0) {
itemTitle = list.get(0);
} else {
itemTitle = (String) solrDocument.get("item_title");
}
System.out.println(itemTitle);
System.out.println(solrDocument.get("item_price"));
}
}

4.   把商品数据导入到索引库中

  域包括tb_item(商品表),tb_item_cat(商品类目表),tb_item_desc(商品描述表)这三张表的数据。

  要实现功能:从数据库将数据导出来后,导入到索引库。

4.1. 功能分析

  在schema.xml中定义以下业务域(已经定义好):

    商品Id

    商品标题

    商品卖点

    商品价格

    商品图片

    分类名称

    商品描述

  

  需要从tb_item, tb_item_cat, tb_item_desc表中查询数据。

  Sql语句:(返回值是列表,需要有一个POJO封装一行记录,再存放到List中返回)

    SELECT
    a.id, a.title, a.sell_point, a.price, a.image, b. NAME category_name, c.item_desc
    FROM
     tb_item a, tb_item_cat b, tb_item_desc c
    WHERE
    a.cid = b.id
    AND a.id = c.item_id
    AND a.`status` = 1;

应该在taotao-manager-web工程中调用导入索引库的服务。

  在taotao-manager-web后台系统中 做一个导入索引库的功能界面(例如:有个按钮,点击即可将数据从数据库中导入到索引库)。

  商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

  业务逻辑:

    1、点击按钮,表现层调用服务层的工程的导入索引库的方法

    2、服务层实现 调用mapper接口的方法查询所有的商品的数据

    3、将数据一条条添加到solrinputdocument文档中

    4、将文档添加到索引库中

    5、提交,并返回导入成功即可

4.2. Dao层

4.2.1.    创建POJO

  创建以下POJO用于存放查询到的用于搜索的商品的数据,并放入taotao-common中

/**
* 搜索的商品数据POJO
*/
public class SearchItem implements Serializable {
private Long id; //商品的id
private String title;//商品标题
private String sell_point;//商品卖点
private Long price; //价格
private String image;//商品图片的路径
private String category_name;//商品分类名称
private String item_desc;//商品的描述
set/get......
}

4.2.2.    定义mapper接口

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决接口(SearchItemMapper)

/**
* 定义mappre,关联查询3张表 查询出搜索时的商品数据
*/
public interface SearchItemMapper {
//查询所有商品数据
public List<SearchItem> getSearchItemList();
}

4.2.3.    Mapper映射文件(SearchItemMapper.xml)

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.taotao.search.mapper.SearchItemMapper" >
<select id="getSearchItemList" resultType="com.taotao.common.pojo.SearchItem">
SELECT
a.id,
a.title,
a.sell_point,
a.price,
a.image,
b. NAME category_name,
c.item_desc
FROM
tb_item a,
tb_item_cat b,
tb_item_desc c
WHERE
a.cid = b.id
AND a.id = c.item_id
AND a.status = 1 </select>
</mapper>

4.3. Service层

  参数:无

  业务逻辑:taotao-search中实现

    1、查询所有商品数据。

    2、创建一个SolrServer对象。

    3、为每个商品创建一个SolrInputDocument对象。

    4、为文档添加域

    5、向索引库中添加文档。

    6、返回TaotaoResult。

4.3.1.    创建applicationContext-solr.xml

  在 applicationContext-solr.xml中配置SolrServer对象。

    <bean class="org.apache.solr.client.solrj.impl.HttpSolrServer">
<constructor-arg name="baseURL" value="http://192.168.25.131:8080/solr"></constructor-arg>
</bean>

4.3.2.    定义service接口

  商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决接口:

public interface SearchService {
/**
* 导入所有的商品数据到索引库中
*/
public TaotaoResult importAllItems() throws Exception;
}

4.3.3.    service实现类

taotao-search-service 的 com.taotao.search.service.impl 包下:

@Service
public class SearchServiceImpl implements SearchService { // 1.注入mapper
@Autowired
private SearchItemMapper searchItemMapper; @Autowired
private SolrServer solrServer; @Override
public TaotaoResult importAllItems() throws Exception {
//2.调用mapper的方法,查询所有的商品的数据
List<SearchItem> searchItemList = searchItemMapper.getSearchItemList();
//3.通过solorj将数据写入到索引库中
//3.1 创建httpSolrServer(配置文件applicationContext-solr.xml已经创建了)
//3.2 创建SolrInputDocument ,将列表searchItemList中的元素一个个放到索引库中
for(SearchItem searchItem:searchItemList){
//为每个商品创建一个SolrInputDocument对象。
SolrInputDocument document = new SolrInputDocument();
//为文档添加域
document.addField("id", searchItem.getId().toString());//这里是字符串需要转换
document.addField("item_title", searchItem.getTitle());
document.addField("item_sell_point", searchItem.getSell_point());
document.addField("item_price", searchItem.getPrice());
document.addField("item_image", searchItem.getImage());
document.addField("item_category_name", searchItem.getCategory_name());
document.addField("item_desc", searchItem.getItem_desc());
//添加到索引库
solrServer.add(document);
}
//提交
solrServer.commit();
//4.返回TaotaoResult
return TaotaoResult.ok();
}
}

4.3.4.    在taotao-search-service中发布服务

<!-- 使用dubbo发布服务 -->
<!-- 提供方应用信息,用于计算依赖关系 -->
<dubbo:application name="taotao-search" />
<dubbo:registry protocol="zookeeper" address="192.168.25.131:2181" />
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20882" />
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.taotao.search.service.SearchService" ref="searchServiceImpl" timeout="300000"/>

4.4. 表现层

4.4.1.    创建JSP(前端页面实现)

  index.jsp中添加网站索引管理:

  商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

  在taotao-manager-web中创建 indexManager.jsp :

<%@ page language="java" contentType="text/html; charset=UTF-8" pageEncoding="UTF-8"%>
<div>
<a href="javascript:void(0)" class="easyui-linkbutton" onclick="importAll()">一键导入商品数据到索引库</a>
</div> <script type="text/javascript">
// 通过ajax 发送请求
function importAll(){
$.ajax({
url:"/index/importAll",
type:"GET",
success:function(data){
//taotaoresult
if(data.status==200){
alert("导入成功");
}else{
alert("导入失败");
}
} });
}
</script>

4.4.2.  引用服务

  在 taotao-manager-web 中的 springmvc.xml 引用服务。

<dubbo:reference interface="com.taotao.search.service.SearchService" id="searchService" timeout="300000"/>

4.4.3.  添加taotao-search-interface的依赖

  在taotao-manager-web工程中的pom.xml中添加

4.4.4.   Controller

  请求的url:/index/importAll

  参数:无

  返回值:json数据。TaotaoResult。

@Controller
public class SearchItemController { @Autowired
private SearchService searchService;
/**
* 导入所有的商品数据到索引库中
* @return
*/
@RequestMapping("/index/importAll")
@ResponseBody
public TaotaoResult importAllItems(){ try {
return searchService.importAllItems();
} catch (Exception e) {
e.printStackTrace();
return TaotaoResult.build(500, "导入数据失败");
}
}
}

4.4.5.    测试

  测试出错,原因是未将工程中的映射文件发布到classpath中。

  在taotao-search-service工程的pom文件中添加如下配置:

<!-- 如果不添加此节点mybatis的mapper.xml文件都会被漏掉。 -->
<build>
<resources>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
<!-- 如果没有此节点,src/main/resources目录下的配置文件将被忽略 -->
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
</resources>
</build>

还需要在taotao-search-service中加入mybatis和数据库连接池的依赖:

<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
<!-- Mybatis -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
</dependency>
<!-- 分页插件pagehelper -->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
</dependency> <!-- MySql -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<!-- 连接池 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
</dependency>

效果:

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

导入成功后solr索引库数据:

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

5.   商品搜索功能实现

5.1. 搜索表现层工程搭建

  搜索结果页面的展示。

  Taotao-search-web,打包方式war。可以参考taotao-manager-web创建。

5.1.1.    Pom文件

 <dependencies>
<!-- common -->
<dependency>
<groupId>com.taotao</groupId>
<artifactId>taotao-common</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- search-interface -->
<dependency>
<groupId>com.taotao</groupId>
<artifactId>taotao-search-interface</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- dubbo相关 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<!-- 排除依赖 -->
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
<exclusion>
<groupId>org.jboss.netty</groupId>
<artifactId>netty</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
</dependency> <!-- Spring -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-beans</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aspects</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jms</artifactId>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
</dependency>
<!-- JSP相关 -->
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jsp-api</artifactId>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<!-- tomcat插件 -->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<configuration>
<port>8085</port>
<path>/</path>
</configuration>
</plugin>
</plugins>
</build>

5.1.2.    配置文件

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

springmvc.xml:

<!-- 组件扫描 -->
<!-- 注解驱动 -->
<!-- 视图解析器 -->
<!-- 调用服务 -->
<context:component-scan base-package="com.taotao.search.controller" />
<mvc:annotation-driven />
<bean
class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="prefix" value="/WEB-INF/jsp/" />
<property name="suffix" value=".jsp" />
</bean> <!-- 引用dubbo服务 -->
<dubbo:application name="taotao-search-web" />
<dubbo:registry protocol="zookeeper" address="192.168.25.131:2181" />
<!-- <dubbo:reference interface="com.taotao.search.service.SearchItemService" id="searchItemService" timeout="30000"/> -->

web.xml:

<display-name>taotao-search-web</display-name>
<welcome-file-list>
<welcome-file>index.jsp</welcome-file>
</welcome-file-list>
<!-- 解决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> <!-- springmvc的前端控制器 -->
<servlet>
<servlet-name>taotao-search-web</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<!-- contextConfigLocation不是必须的, 如果不配置contextConfigLocation, springmvc的配置文件默认在:WEB-INF/servlet的name+"-servlet.xml" -->
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:spring/springmvc.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>taotao-search-web</servlet-name>
<url-pattern>*.html</url-pattern>
</servlet-mapping>

5.1.3.    静态页面

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

5.2. 搜索功能分析

  在首页的搜索框中输入搜索条件,然后跳转到搜索结果页面。搜索结果页面在taotao-search-web工程中。

  

  首页搜索框的点击按钮处理函数在:首页的JS中,应当改成8085,如图:

  商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

  请求的url/search

  http://localhost:8085/search.html?q=

  参数

    1、q 查询条件。

    2、page 页码。默认为1   每页显示多少行 在controller中写死即可。比如:60

  返回值: String。(商品的列表信息,总页数 ,总记录数,数据回显)   定义一个返回结果类SearchResult,存放商品的列表信息,总页数 ,总记录数。

  业务逻辑

    1、接收查询条件。

    2、创建一个SolrServer对象,需要注入。

    3、创建一个SolrQuery对象。

    4、需要设置查询条件、分页条件、设置默认搜索域、高亮设置。

    5、执行查询,返回QueryResponse对象。

    6、取返回结果,封装到List<SearchItem>中。

    7、返回查询结果的总记录数,计算查询结果的总页数。

    8、得到查询结果,渲染jsp.

5.3. Dao层

5.3.1.    功能分析

  访问索引库的类。定义一些通用的数据访问方法。(注:不能用逆向工程了。dao层功能在taotao-search-service工程中的com.taotao.search.dao包中定义)

  业务逻辑就是查询索引库。

  参数:SolrQuery对象

  业务逻辑:

    1、根据Query对象进行查询。

    2、返回查询结果。包括List<SearchItem>、查询结果的总记录数。

  需要把返回结果封装到pojo中,至少包含两个属性:List<SearchItem>、Long recordCount。再包含一个总页数。

  创建如下SearchResult对象,放入taotao-common中

public class SearchResult implements Serializable {
private List<SearchItem> itemList;//搜索结果列表
private long recordCount;//总记录数
private long pageCount;//总页数
set/get......
}

5.3.2.    创建SearchDao

由于搜索功能只在搜索工程中用到,可以不写接口,只写类(将Search直接定义为类,没必要定义为接口再实现)。返回值:SearchResult

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

/**
* 从索引库中搜索商品的DAO
* @author smileZTT
*
*/
@Repository
public class SearchDao { //1.创建solrServer对象 由sprin管理注入
@Autowired
private SolrServer solrServer; /*根据查询条件查询商品的结果集*/
public SearchResult search(SolrQuery query) throws Exception { SearchResult searchResult = new SearchResult(); //2.直接执行查询
QueryResponse response = solrServer.query(query);
//3.获取结果集
SolrDocumentList results = response.getResults(); //4.遍历结果集
List<SearchItem> itemList = new ArrayList<SearchItem>();
for(SolrDocument solrDocument : results){
SearchItem item = new SearchItem();
item.setId(Long.parseLong(solrDocument.get("id").toString()));
item.setCategory_name(solrDocument.get("item_category_name").toString());
item.setImage(solrDocument.get("item_image").toString());
item.setPrice((long) solrDocument.get("item_price"));
item.setSell_point(solrDocument.get("item_sell_point").toString());
//取高亮显示
Map<String, Map<String, List<String>>> highlighting = response.getHighlighting();
List<String> list = highlighting.get(solrDocument.get("id")).get("item_title");
String itemTitle = "";
//有高亮显示时
if(list != null && list.size() > 0) {
itemTitle = list.get(0);
}else {//没有高亮显示时
itemTitle = solrDocument.get("item_title").toString();
}
item.setTitle(itemTitle);
//添加到商品列表
itemList.add(item);
}
//5.设置searchResult中的属性,然后返回
searchResult.setItemList(itemList);//设置搜索结果列表
searchResult.setRecordCount(results.getNumFound());//设置总记录数
return searchResult;
}
}

5.4. Service层

5.4.1.    功能分析

  参数:queryString:查询条件

      Page:页码

      Rows:每页显示的记录数。

  业务逻辑

    1、创建一个SolrQuery对象。

    2、设置查询条件

    3、设置分页条件

    4、需要指定默认搜索域。

    5、设置高亮

    6、执行查询,调用SearchDao。得到SearchResult

    7、需要计算总页数。

    8、返回SearchResult

5.4.2.   service接口

接口已存在,只需要添加方法即可。

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

public interface SearchService {

    /**
* 导入所有的商品数据到索引库中
*/
public TaotaoResult importAllItems() throws Exception; /**
* 根据搜索条件搜索
* @param queryString 查询的主条件
* @param page 查询的当前页码
* @param rows 每页显示的行数,这个在Controller中写死
* @return
* @throws Exception
*/
public SearchResult search(String queryString, Integer page, Integer rows) throws Exception;
}

5.4.3.  service接口实现类  SearchServiceImpl :

@Service
public class SearchServiceImpl implements SearchService { @Autowired
private SearchDao searchDao; @Override
public SearchResult search(String queryString, Integer page, Integer rows)
throws Exception { //1.创建solrQuery对象
SolrQuery query = new SolrQuery(); //2.设置主查询条件
if(StringUtils.isNotBlank(queryString)){
query.setQuery(queryString);
}else {
query.setQuery("*:*");
}
//2.1 设置过滤条件 设置分页
if(page == null) page = 1;
if(rows == null) rows = 60;
query.setStart((page - 1) * rows);
query.setRows(rows);
//2.2 设置默认的搜索域
query.set("df", "item_keywords");
//2.3 设置高亮
query.setHighlight(true);//开启高亮
query.addHighlightField("item_title");//设置高亮显示的域
query.setHighlightSimplePre("<em style=\"color:red\">");
query.setHighlightSimplePost("</em>"); //3.利用dao方法返回的SearchResult只包含了总记录数和商品列表
SearchResult result = searchDao.search(query); //4.设置SearchResult的总页数
long recordCount = result.getRecordCount();
long pageCount = recordCount / rows;
if(recordCount % rows > 0)
pageCount++;
result.setPageCount(pageCount); //5.返回
return result;
}
}

5.4.4.   在taotao-search-service中发布服务

  <!-- 使用dubbo发布服务 -->
<!-- 提供方应用信息,用于计算依赖关系 -->
<dubbo:application name="taotao-search" />
<dubbo:registry protocol="zookeeper" address="192.168.25.131:2181" />
<!-- 用dubbo协议在20880端口暴露服务 -->
<dubbo:protocol name="dubbo" port="20882" />
<!-- 声明需要暴露的服务接口 -->
<dubbo:service interface="com.taotao.search.service.SearchService" ref="searchServiceImpl" timeout="300000"/>

5.4. 表现层

功能在 taotao-search-web 中实现。

5.4.1.   引用服务

taotao-search-web的sprinmvc.xml 中引用:

  <!-- 引用dubbo服务 -->
<dubbo:application name="taotao-search-web" />
<dubbo:registry protocol="zookeeper" address="192.168.25.131:2181" />
<dubbo:reference interface="com.taotao.search.service.SearchService" id="searchService" timeout="30000"/>

5.4.2.    Controller

  请求的url:/search

  参数

    1、q 查询条件。

    2、page 页码。默认为1

  返回值:逻辑视图,返回值。String。

  业务逻辑

    1、接收参数

    2、调用服务查询商品列表

    3、把查询结果传递给页面。需要参数回显。

@Controller
public class SearchController { @Value("${ITEM_ROWS}")
private Integer ITEM_ROWS; @Autowired
private SearchService searchService; @RequestMapping("/search")
public String search(@RequestParam("q")String queryString,
@RequestParam(defaultValue="1")Integer page, Model model) throws Exception { SearchResult result = searchService.search(queryString, page, ITEM_ROWS);
//传递给页面
model.addAttribute("query", queryString);
model.addAttribute("totalPages", result.getPageCount());
model.addAttribute("itemList", result.getItemList());
model.addAttribute("page", page); //返回逻辑视图
return "search";
}
}

属性文件中配置行数:(文件存放在taotao-search-web中的resource目录下)

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

还需要配置属性文件加载:在springmvc.xml中

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

5.4.3.    测试

测试发现有乱码,是GET请求乱码,需要对请求参数进行转码处理:

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

翻页处理:在taotao-search-web工程中:修改如下:

商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

5.5. 图片显示处理

  数据库中保存的图片是以逗号分隔的url列表,只需要展示第一张图片即可。

  方法:

    1、向索引库中添加文档时,只取第一张写入索引库

    2、从文档列表转换为商品列表时可以取一张。

    3、在jsp中对列表拆分,只取一张展示。

  可以在SearchItem中添加一个getImages方法:

  商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决

   在search.jsp中取属性:

      商城06——solr索引库搭建&solr搜索功能实现&图片显示问题解决