第一章：Solr 介绍

1.1：什么是 solr

Solr 是 Apache 下的一个顶级开源项目，采用 Java 开发，它是基于 Lucene 的全文搜索服务器。Solr 可以独立运行在 Jetty、Tomcat 等这些 Servlet 容器中。

Solr 提供了比 Lucene 更为丰富的查询语言，同时实现了可配置、可扩展，并对索引、搜索性能进行了优化。

使用 Solr 进行创建索引和搜索索引的实现方法很简单，如下：

创建索引：客户端（可以是浏览器可以是 Java 程序）用 POST 方法向 Solr 服务器发送一个描述 Field 及其内容的 XML 文档，Solr 服务器根据 xml 文档添加、删除、更新索引。
搜索索引：客户端（可以是浏览器可以是 Java 程序）用 GET 方法向 Solr 服务器发送请求，然后对 Solr 服务器返回Xml、json 等格式的查询结果进行解析，组织页面布局。Solr 不提供构建页面 UI 的功能，但是Solr 提供了一个管理界面，通过管理界面可以查询 Solr 的配置和运行情况。

1.2Solr 和 Lucene 的区别

Lucene 是一个开放源代码的全文检索引擎工具包，它不是一个完整的全文检索应用。Lucene 仅提供了完整的查询引擎和索引引擎，目的是为软件开发人员提供一个简单易用的工具包，以方便的在目标系统中实现全文检索的功能，或者以 Lucene 为基础构建全文检索应用。

Solr 的目标是打造一款企业级的搜索引擎系统，它是基于 Lucene 一个搜索引擎服务，可以独立运行，通过 Solr 可以非常快速的构建企业的搜索引擎，通过 Solr 也可以高效的完成站内搜索功能。

第二章：Solr 安装配置

2.1 下载 solr

下载并解压

bin：solr 的运行脚本

contrib：solr 的一些扩展 jar 包，用于增强 solr 的功能。

dist：该目录包含 build 过程中产生的 war 和 jar 文件，以及相关的依赖文件。

docs：solr 的 API 文档

example：solr 工程的例子目录：

example/solr：

该目录是一个标准的 SolrHome，它包含一个默认的 SolrCore

example/multicore：

该目录包含了在 Solr 的 multicore 中设置的多个 Core 目录。

example/webapps：

该目录中包括一个 solr.war，该 war 可作为 solr 的运行实例工程。

licenses：solr 相关的一些许可信息

2.2 运行环境

solr 需要运行在一个 Servlet 容器中，Solr4.10.3 要求 jdk 使用 1.7 以上，Solr 默认提供 Jetty（java 写的 Servlet 容器），本教程使用 Tocmat 作为 Servlet 容器，相关环境如下：

Solr：4.10.3
Jdk 环境：1.7.0_72（solr4.10 不能使用 jdk1.7 以下）
Web 服务器（servlet 容器）：Tomcat 7X

2.3SolrCore 配置

2.3.1SolrHome 和 SolrCore

SolrHome 是 Solr 运行的主目录，该目录中包括了多个 SolrCore 目录。SolrCore 目录中包含了运行 Solr 实例所有的配置文件和数据文件，Solr 实例就是 SolrCore。

一个 SolrHome 可以包括多个 SolrCore（Solr 实例），每个 SolrCore 提供单独的搜索和索引服务。

2.3.2 目录结构

SolrHome 目录：

SolrCore 目录：

2.3.3 创建 SolrCore

创建 SolrCore 先要创建 SolrHome。在 solr 解压包下solr-4.10.3\example\solr文件夹就是一个标准的 SolrHome。

拷贝 solr 解压包下solr-4.10.3\example\solr文件夹。

复制该文件夹到本地的一个目录，把文件名称改为 solrhome。

注：改名不是必须的，只是为了便于理解

打开 SolrHome 目录

SolrCore 创建成功。

2.3.4 配置 SolrCore

在 conf 文件夹下有一个 solrconfig.xml。这个文件是来配置 SolrCore 实例的相关信息。如果使用默认配置可以不用做任何修改。它里面包含了不少标签，但是我们关注的标签为：lib 标签、datadir 标签、requestHandler 标签。

lib 标签

在 solrconfig.xml 中可以加载一些扩展的 jar，solr.install.dir 表示 solrCore 的目录位置，需要如下修改：

然后将 contrib 和 dist 两个目录拷贝到 E:\12-solr\0505 下

datadir 标签

每个 SolrCore 都有自己的索引文件目录，默认在 SolrCore 目录下的 data 中。

$C:\Users\ADMINI~1\AppData\Local\Temp\SNAGHTML2806a34.PNG$

data 数据目录下包括了 index 索引目录和 tlog 日志文件目录。

如果不想使用默认的目录也可以通过 solrConfig.xml 更改索引目录，如下：

requestHandler 标签

requestHandler 请求处理器，定义了索引和搜索的访问方式。

通过/update 维护索引，可以完成索引的添加、修改、删除操作。

提交 xml、json 数据完成索引维护，索引维护小节详细介绍。

通过/select 搜索索引。

设置搜索参数完成搜索，搜索参数也可以设置一些默认值，如下：

\

\explicit\</str>

\10\</int>\

\json\</str>\

\text\</str>\

\</lst>

\</requestHandler>

Solr 工程部署

由于在项目中用到的 web 服务器大多数是用的 Tomcat，所以就讲 solr 和 Tomcat 的整合。

安装 Tomcat

把 solr.war 部署到 Tomcat 中

从 solr 解压包下的solr-4.10.3\example\webapps目录中拷贝 solr.war
复制到 tomcat 安装目录的webapps文件夹下

解压缩 solr.war

使用压缩工具解压或者启动 tomcat 自动解压。解压之后删除 solr.war

添加 solr 服务的扩展依赖包（日志包）

把 solr 解压包下的solr-4.10.3\example\lib\ext目录下的所有 jar 包拷贝。
复制到解压缩后的 solr 工程的WEB-INF\lib目录

添加 log4j.properties

把 solr 解压包下solr-4.10.3\example\resources\log4j.properties文件进行拷贝
在解压缩后的 solr 工程中的WEB-INF目录中创建 classes 文件夹
复制 log4j.properties 文件到刚创建的 classes 目录

在 solr 应用的 web.xml 文件中，加载 SolrHome

修改 web.xml 使用 jndi 的方式告诉 solr 服务器。

Solr/home 名称必须是固定的。

启动 Tomcat 进行访问

访问http://localhost:8080/solr/

出现以下界面则说明 solr 安装成功！！！

管理界面功能介绍

Dashboard

仪表盘，显示了该 Solr 实例开始启动运行的时间、版本、系统资源、jvm 等信息。

Logging

Solr 运行日志信息

Cloud

Cloud 即 SolrCloud，即 Solr 云（集群），当使用 Solr Cloud 模式运行时会显示此菜单，该部分功能在第二个项目，即电商项目会讲解。

Core Admin

Solr Core 的管理界面。在这里可以添加 SolrCore 实例。

java properties

Solr 在 JVM 运行环境中的属性信息，包括类路径、文件编码、jvm 内存设置等信息。

Tread Dump

显示 Solr Server 中当前活跃线程信息，同时也可以跟踪线程运行栈信息。

Core selector（重点）

选择一个 SolrCore 进行详细操作，如下：

Analysis（重点）

通过此界面可以测试索引分析器和搜索分析器的执行情况。

注：solr 中，分析器是绑定在域的类型中的。

dataimport

可以定义数据导入处理器，从关系数据库将数据导入到 Solr 索引库中。

默认没有配置，需要手工配置。

Document（重点）

通过/update 表示更新索引，solr 默认根据 id（唯一约束）域来更新 Document 的内容，如果根据 id 值搜索不到 id 域则会执行添加操作，如果找到则更新。

通过此菜单可以创建索引、更新索引、删除索引等操作，界面如下：

overwrite="true" ： solr 在做索引的时候，如果文档已经存在，就用 xml 中的文档进行替换
commitWithin="1000" ： solr 在做索引的时候，每个 1000（1 秒）毫秒，做一次文档提交。为了方便测试也可以在 Document 中立即提交，\</doc>后添加“\”

Query（重点）

通过/select 执行搜索索引，必须指定“q”查询条件方可搜索。

多 solrcore 配置

配置多 SolrCore 的好处：

一个 solr 工程对外通过 SorlCore 提供服务，每个 SolrCore 相当于一个数据库，这个功能就相当于一个 mysql 可以运行多个数据库。
将索引数据分 SolrCore 存储，方便对索引数据管理维护。
SolrCloud 集群需要使用多 core。

复制原来的 core 目录为 collection2，目录结构如下：

修改 collection2 下的 core.properties，如下：

演示多 core 的使用，在 collection1 和 collection2 中分别创建索引、搜索索引。

solr 基本使用

schema.xml

schema.xml 文件在 SolrCore 的 conf 目录下，它是 Solr 数据表配置文件，在此配置文件中定义了域以及域的类型还有其他一些配置，在 solr 中域必须先定义后使用。

field

Name：域的名称
Type：域的类型
Indexed：是否索引
Stored：是否存储
Required：是否必须
multiValued：是否是多值，存储多个值时设置为 true，solr 允许一个 Field 存储多个值，比如存储一个用户的好友 id（多个），商品的图片（多个，大图和小图）

fieldType（域类型）

| \ \ \ \ \ \ \</analyzer> \ \ \ \ \ \</analyzer> \</fieldType>

name：域类型的名称
class：指定域类型的 solr 类型。
analyzer：指定分词器。在 FieldType 定义的时候最重要的就是定义这个类型的数据在建立索引和进行查询的时候要使用的分析器 analyzer，包括分词和过滤。
type：index 和 query。Index 是创建索引，query 是查询索引。
tokenizer：指定分词器
filter：指定过滤器

uniqueKey

\id\</uniqueKey>

相当于主键，每个文档中必须有一个 id 域。

copyField（复制域）

\

可以将多个 Field 复制到一个 Field 中，以便进行统一的检索。当创建索引时，solr 服务器会自动的将源域的内容复制到目标域中。

source：源域
dest：目标域，搜索时，指定目标域为默认搜索域，可以提供查询效率。

定义目标域：

必须要使用：multiValued="true"

dynamicField（动态域）

\

Name：动态域的名称，是一个表达式，*匹配任意字符，只要域的名称和表达式的规则能够匹配就可以使用。

例如：搜索时查询条件【product_i：钻石】就可以匹配这个动态域，可以直接使用，不用单独再定义一个 product_i 域。

配置中文分析器

使用 IKAnalyzer 中文分析器。

第一步：把 IKAnalyzer2012FF_u1.jar 添加到 solr/WEB-INF/lib 目录下。

第二步：复制 IKAnalyzer 的配置文件和自定义词典和停用词词典到 solr 的 classpath 下。

第三步：在 schema.xml 中添加一个自定义的 fieldType，使用中文分析器。

\<!-- IKAnalyzer--> \ \ \</fieldType>

第四步：定义 field，指定 field 的 type 属性为 text_ik

\<!--IKAnalyzer Field--> \ \

第五步：重启 tomcat

测试：

配置业务 field

需求

要使用 solr 实现电商网站中商品搜索。

电商中商品信息在 mysql 数据库中存储了，将 mysql 数据库中数据在 solr 中创建索引。

需要在 solr 的 schema.xml 文件定义商品 Field。

定义步骤

先确定定义的商品 document 的 field 有哪些？

可以根据 mysql 数据库中商品表的字段来确定：

products 商品表：

商品 document 的 field 包括：pid、name、catalog、catalog_name、price、description、picture

先定义 Fieldtype：

solr 本身提供的 fieldtype 类型够用了不用定义新的了。

再定义 Field：

pid：商品 id 主键

使用 solr 本身提供的：

name：商品名称

catalog：商品分类

catalog_name：商品分类名称

price：商品价格

description：商品描述

picture：商品图片

\<!--product--> \ \ \ \ \ \ \

dataimportHandler 插件

第一步：添加 jar 包

Dataimport 的 jar

从 solr-4.10.3\dist 目录下拷贝 solr-dataimporthandler-4.10.3.jar，复制到以下目录：

修改 schema.xml 如下：
数据库驱动包

把 mysql 数据库驱动包，拷贝到以下目录：

修改 schema.xml，如下：

第二步：配置 solrconfig.xml，添加一个 requestHandler

\ \ \data-config.xml\</str> \</lst> \</requestHandler>

第三步：创建一个 data-config.xml

在 collection1\conf\目录下创建 data-config.xml 文件

\<?xml version="1.0" encoding="UTF-8" ?> \ \ \ \ \ \ \ \ \ \ \ \</entity> \</document> \</dataConfig>

第四步：重启 tomcat

第五步：点击“execute”按钮导入数据

注意：到入数据前会先清空索引库，然后再导入。

Solrj 的使用

什么是 solrj

solrj 是访问 Solr 服务的 java 客户端，提供索引和搜索的请求方法，SolrJ 通常在嵌入在业务系统中，通过 SolrJ 的 API 接口操作 Solr 服务，如下图：

Solrj 和图形界面操作的区别就类似于数据库中你使用 jdbc 和 mysql 客户端的区别一样。

需求

使用 solrj 调用 solr 服务实现对索引库的增删改查操作。

环境准备

Solr：4.10.3
Jdk 环境：1.7.0_72（solr4.10 不能使用 jdk1.7 以下）
Ide 环境：eclipse indigo

工程搭建

第一步：创建 java 工程

第二步：添加 jar

Solrj 的包
Solr 服务的依赖包

代码实现

添加\修改索引

步骤

创建 HttpSolrServer 对象，通过它和 Solr 服务器建立连接。
创建 SolrInputDocument 对象，然后通过它来添加域。
通过 HttpSolrServer 对象将 SolrInputDocument 添加到索引库。
提交。

代码

说明：根据 id（唯一约束）域来更新 Document 的内容，如果根据 id 值搜索不到 id 域则会执行添加操作，如果找到则更新。

| \@Test public void addDocument() throws Exception { // 1、创建 HttpSolrServer 对象，通过它和 Solr 服务器建立连接。 // 参数：solr 服务器的访问地址 HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/"); // 2、创建 SolrInputDocument 对象，然后通过它来添加域。 SolrInputDocument document = new SolrInputDocument(); // 第一个参数：域的名称，域的名称必须是在 schema.xml 中定义的 // 第二个参数：域的值 // 注意：id 的域不能少 document.addField("id", "c0001"); document.addField("title_ik", "使用 solrJ 添加的文档"); document.addField("content_ik", "文档的内容"); document.addField("product_name", "商品名称"); // 3、通过 HttpSolrServer 对象将 SolrInputDocument 添加到索引库。 server.add(document); // 4、提交。 server.commit(); }

查询测试

删除索引

根据 ID 删除

代码

\@Test public void deleteDocument() throws Exception { // 1、创建 HttpSolrServer 对象，通过它和 Solr 服务器建立连接。 // 参数：solr 服务器的访问地址 HttpSolrServer server = new HttpSolrServer( "http://localhost:8080/solr/"); // 根据 ID 删除 server.deleteById("c0001"); // 提交 server.commit(); }

查询测试

根据条件删除

\@Test public void deleteDocumentByQuery() throws Exception { // 1、创建 HttpSolrServer 对象，通过它和 Solr 服务器建立连接。 // 参数：solr 服务器的访问地址 HttpSolrServer server = new HttpSolrServer( "http://localhost:8080/solr/"); // 根据 ID 删除 server.deleteByQuery("id:c0001"); // 全部删除 // server.deleteByQuery("*:*"); // 提交 server.commit(); }

查询索引

solr 的查询语法

q - 查询关键字，必须的，如果查询所有使用*:*。

请求的 q 是字符串

fq - （filter query）过虑查询，作用：在 q 查询符合结果中同时是 fq 查询符合的，例如：：

请求 fq 是一个数组（多个值）

过滤查询价格从 1 到 20 的记录。

也可以在“q”查询条件中使用 product_price:[1 TO 20]，如下：

也可以使用“*”表示无限，例如：

20 以上：product_price:[20 TO *]

20 以下：product_price:[* TO 20]

sort - 排序，格式：sort=\+\[,\+\]… 。示例：

按价格降序

start - 分页显示使用，开始记录下标，从 0 开始
rows - 指定返回结果最多有多少条记录，配合 start 来实现分页。

实际开发时，知道当前页码和每页显示的个数最后求出开始下标。

fl - 指定返回那些字段内容，用逗号或空格分隔多个。

显示商品图片、商品名称、商品价格

df-指定一个搜索 Field

也可以在 SolrCore 目录中 conf/solrconfig.xml 文件中指定默认搜索 Field，指定后就可以直接在“q”查询条件中输入关键字。

wt - (writer type)指定输出格式，可以有 xml, json, php, phps, 后面 solr 1.3 增加的，要用通知我们，因为默认没有打开。
hl 是否高亮 ,设置高亮 Field，设置格式前缀和后缀。

简单查询

\@Test public void queryIndex() throws Exception { // 创建 HttpSolrServer 对象，通过它和 Solr 服务器建立连接。 // 参数：solr 服务器的访问地址 HttpSolrServer server = new HttpSolrServer( "http://localhost:8080/solr/"); // 创建 SolrQuery 对象 SolrQuery query = new SolrQuery(); // 设置查询条件,名称“q”是固定的且必须的 query.set("q", "id:2"); // 调用 server 的查询方法，查询索引库 QueryResponse response = server.query(query); // 查询结果 SolrDocumentList results = response.getResults(); // 查询结果总数 long cnt = results.getNumFound(); System.out.println("查询结果总数:" + cnt); for (SolrDocument solrDocument : results) { System.out.println(solrDocument.get("id")); System.out.println(solrDocument.get("productname")); System._out.println(solrDocument.get("productprice")); System._out.println(solrDocument.get("productcatalog_name")); System._out.println(solrDocument.get("product_picture")); } }

复杂查询

复杂查询中包括高亮的处理

\@Test public void queryIndex2() throws Exception { // 创建 HttpSolrServer 对象，通过它和 Solr 服务器建立连接。 // 参数：solr 服务器的访问地址 HttpSolrServer server = new HttpSolrServer("http://localhost:8080/solr/"); // 创建 SolrQuery 对象 SolrQuery query = new SolrQuery(); // 设置查询条件 query.setQuery("钻石"); // 设置过滤条件 query.setFilterQueries("productcatalog_name:幽默杂货"); // 设置排序 query.setSort("product_price", ORDER._desc); // 设置分页信息 query.setStart(0); query.setRows(10); // 设置显得的域的列表 query.setFields("id", "productname", "product_price", "product_catalog_name", "product_picture"); // 设置默认搜索域 query.set("df", "product_name"); // 设置高亮 query.setHighlight(true); query.addHighlightField("product_name"); query.setHighlightSimplePre("\"); query.setHighlightSimplePost("\</em>"); // 调用 server 的查询方法，查询索引库 QueryResponse response = server.query(query); // 查询结果 SolrDocumentList results = response.getResults(); // 查询结果总数 long cnt = results.getNumFound(); System._out.println("查询结果总数:" + cnt); for (SolrDocument solrDocument : results) { System.out.println(solrDocument.get("id")); String productName = (String) solrDocument.get("productname"); //获取高亮列表 Map\>> highlighting = response .getHighlighting(); //获得本文档的高亮信息 List\ list = highlighting.get(solrDocument.get("id")).get( "product_name"); //如果有高亮，则把商品名称赋值为有高亮的那个名称 if (list != null) { productName = list.get(0); } System._out.println(productName); System.out.println(solrDocument.get("productprice")); System._out.println(solrDocument.get("productcatalog_name")); System._out.println(solrDocument.get("product_picture")); } }

案例

需求

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

界面如下：

分析

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

UI 分析

架构分析

架构分为：

solr 服务器
1. 自己开发的应用（重点）
2. 数据库 mysql

自己开发的应用

Controller

和前端页面进行请求和响应的交互
1. Service
  
  使用 solrj 来调用 solr 的服务进行索引和搜索
  
  Service 调用 dao 进行商品数据的维护时，要同步更新索引库
2. Dao
  
  对商品数据进行维护和查询

环境准备

Solr：4.10.3
Jdk 环境：1.7.0_72（solr4.10 不能使用 jdk1.7 以下）
Ide 环境：eclipse indigo
Web 服务器（servlet 容器）：Tomcat 7X

工程搭建

第一步：创建 web 工程

第二步：添加 jar 包

Solrj 的包
Solr 服务的日志包
Spring 的包（包含 springmvc）
Jstl 包
Commons 日志包

代码实现

Pojo

分析

索引查询结果

通过分析得出：

需要一个商品的 pojo（Product），存放商品信息
还需要一个包装 pojo（ResultModel），它包括商品列表信息、商品分页信息

代码

Product.java

public class Product { // 商品编号 private String pid; // 商品名称 private String name; // 商品分类名称 private String catalog_name; // 价格 private float price; // 商品描述 private String description; // 图片名称 private String picture; }

ResultModel.java

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

Dao

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

public interface ProductDao { //查询商品信息，包括分页信息 public ResultModel queryProduct(SolrQuery query) throws Exception; }
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\ productList = new ArrayList\<>(); Product product = null; // 高亮信息 Map\>> highlighting = response .getHighlighting(); for (SolrDocument solrDocument : documentList) { product = new Product(); product.setPid((String) solrDocument.get("id")); String prodName = (String) solrDocument.get("product_name"); List\ 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; } }

public interface ProductDao { //查询商品信息，包括分页信息 public ResultModel queryProduct(SolrQuery query) throws Exception; }

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\ productList = new ArrayList\<>(); Product product = null; // 高亮信息 Map\>> highlighting = response .getHighlighting(); for (SolrDocument solrDocument : documentList) { product = new Product(); product.setPid((String) solrDocument.get("id")); String prodName = (String) solrDocument.get("product_name"); List\ 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; } }

Service

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

public interface ProductService { public ResultModel queryProduct(String queryString, String cataName, String price, String sort, Integer curPage) throws Exception; }
\@Service public class ProductServiceImpl implements ProductService { \@Autowired private ProductDao dao; \@Override public ResultModel queryProduct(String queryString, String cataName, String price, String sort, Integer curPage) throws Exception { // 封装 SolrQuery SolrQuery query = new SolrQuery(); // 设置查询条件 if (queryString != null && !"".equals(queryString)) { query.setQuery(queryString); }else{ query.setQuery(":"); } // 设置过滤条件 if (cataName != null && !"".equals(cataName)) { query.addFilterQuery("productcatalog_name:" + cataName); } if (price != null && !"".equals(price)) { String[] strings = price.split("-"); if (strings.length == 2) { query.addFilterQuery("product_price:[" + strings[0] + " TO " + strings[1] + "]"); } } // 设置排序（1：降序 0：升序） if ("1".equals(sort)) { query.setSort("product_price", ORDER._desc); } else { query.setSort("productprice", ORDER._asc); } // 设置分页信息 if (curPage == null) curPage = 1; query.setStart((curPage - 1) * Constants.rows); query.setRows(Constants.rows); // 设置默认搜索域 query.set("df", "product_name"); // 设置高亮 query.setHighlight(true); query.addHighlightField("product_name"); query.setHighlightSimplePre("\"); query.setHighlightSimplePost("\</font>"); ResultModel resultModel = dao.queryProduct(query); resultModel.setCurPage(curPage); return resultModel; } }

public interface ProductService { public ResultModel queryProduct(String queryString, String cataName, String price, String sort, Integer curPage) throws Exception; }

\@Service public class ProductServiceImpl implements ProductService { \@Autowired private ProductDao dao; \@Override public ResultModel queryProduct(String queryString, String cataName, String price, String sort, Integer curPage) throws Exception { // 封装 SolrQuery SolrQuery query = new SolrQuery(); // 设置查询条件 if (queryString != null && !"".equals(queryString)) { query.setQuery(queryString); }else{ query.setQuery("*:*"); } // 设置过滤条件 if (cataName != null && !"".equals(cataName)) { query.addFilterQuery("productcatalog_name:" + cataName); } if (price != null && !"".equals(price)) { String[] strings = price.split("-"); if (strings.length == 2) { query.addFilterQuery("product_price:[" + strings[0] + " TO " + strings[1] + "]"); } } // 设置排序（1：降序 0：升序） if ("1".equals(sort)) { query.setSort("product_price", ORDER._desc); } else { query.setSort("productprice", ORDER._asc); } // 设置分页信息 if (curPage == null) curPage = 1; query.setStart((curPage - 1) * Constants.rows); query.setRows(Constants.rows); // 设置默认搜索域 query.set("df", "product_name"); // 设置高亮 query.setHighlight(true); query.addHighlightField("product_name"); query.setHighlightSimplePre("\"); query.setHighlightSimplePost("\</font>"); ResultModel resultModel = dao.queryProduct(query); resultModel.setCurPage(curPage); return resultModel; } }

Controller

代码

\@Controller public class ProductController { \@Autowired private ProductService service; \@RequestMapping("/list") public String queryProduct(String queryString, String catalog_name, String price, String sort, Integer page, Model model) throws Exception { ResultModel resultModel = service.queryProduct(queryString, catalog_name, price, sort, page); 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"; } }

配置

Web.xml

\<?xml version="1.0" encoding="UTF-8"?> \ \jd0723\</display-name> \ \ \springmvc\</servlet-name> \org.springframework.web.servlet.DispatcherServlet\</servlet-class> \ \contextConfigLocation\</param-name> \classpath:springmvc.xml\</param-value> \</init-param> \</servlet> \ \springmvc\</servlet-name> \*.action\</url-pattern> \</servlet-mapping> \ \Character Encoding\</filter-name> \org.springframework.web.filter.CharacterEncodingFilter\</filter-class> \ \encoding\</param-name> \UTF-8\</param-value> \</init-param> \</filter> \ \Character Encoding\</filter-name> \/*\</url-pattern> \</filter-mapping> \</web-app>

Springmvc.xml

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

\<?xml version="1.0" encoding="UTF-8"?> \ \<!-- 配置扫描包 --> \ \<!-- 配置注解驱动 --> \ \<!-- jsp 视图解析器 --> \ \<!-- 前缀 --> \\</property> \<!-- 后缀 --> \\</property> \</bean> \ \\</constructor-arg> \</bean> \</beans>