一、案例pom依赖
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.kingseok</groupId>
<artifactId>zhq_test_es</artifactId>
<version>1.0-SNAPSHOT</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath /> <!-- lookup parent from repository -->
</parent>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
<!-- springboot整合freemarker -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-freemarker</artifactId>
</dependency>
</dependencies>
</project>
二、Elasticsearch生成案例数据
在kibana中执行下面的脚本:
PUT /clouddisk
POST /clouddisk/_mapping/disk
{
"disk": {
"properties": {
"baiduaddres": {
"type": "keyword"
},
"browsetimes": {
"type": "long"
},
"collectiontime": {
"type": "date"
},
"describe": {
"type": "text",
"analyzer": "ik_smart"
},
"filesize": {
"type": "float"
},
"name": {
"type": "text",
"analyzer": "ik_smart"
},
"sharpeople": {
"type": "keyword"
},
"shartime": {
"type": "date"
},
"source": {
"type": "keyword"
}
}
}
}
POST /clouddisk/disk
{
"name":"2020世上最全SpringCloud",
"source":"百度云盘",
"describe":"该资料由独角兽百度收集",
"shartime":"2020-05-05",
"browsetimes":100000,
"filesize":3.65,
"sharpeople":"独角兽",
"collectiontime": "2020-05-05",
"baiduaddres":"https:pan.baidu.com"
}
POST /clouddisk/disk
{
"name":"腾讯课堂SpringCloud和SpringBoot",
"source":"百度云盘",
"describe":"该资料由腾讯课堂出品",
"shartime":"2020-05-05",
"browsetimes":100000,
"filesize":3.65,
"sharpeople":"独角兽",
"collectiontime": "2020-05-05",
"baiduaddres":"https:pan.baidu.com"
}
POST /clouddisk/disk
{
"name":"腾讯课堂SpringBoot整合SSM案例",
"source":"百度云盘",
"describe":"该资料由腾讯课堂出品",
"shartime":"2020-05-05",
"browsetimes":100000,
"filesize":3.65,
"sharpeople":"独角兽",
"collectiontime": "2020-05-05",
"baiduaddres":"https:pan.baidu.com"
}
POST /clouddisk/disk
{
"name":"网易课堂SpringBoot整合SSM案例",
"source":"百度云盘",
"describe":"该资料由网易课堂出品",
"shartime":"2020-05-05",
"browsetimes":100000,
"filesize":3.65,
"sharpeople":"独角兽",
"collectiontime": "2020-05-05",
"baiduaddres":"https:pan.baidu.com"
}
POST /clouddisk/disk
{
"name":"阿里巴巴课堂SpringBoot整合SSM案例",
"source":"百度云盘",
"describe":"该资料由阿里巴巴课堂出品",
"shartime":"2020-05-05",
"browsetimes":100000,
"filesize":3.65,
"sharpeople":"独角兽",
"collectiontime": "2020-05-05",
"baiduaddres":"https:pan.baidu.com"
}
image.png
三、案例Demo代码
1)、全局配置文件
spring:
data:
elasticsearch:
####集群名称
cluster-name: myes
####地址
cluster-nodes: 192.168.43.104:9300
freemarker:
# 设置模板后缀名
suffix: .ftl
# 设置文档类型
content-type: text/html
# 设置页面编码格式
charset: UTF-8
# 设置页面缓存
cache: false
# 设置ftl文件路径
template-loader-path:
- classpath:/templates
# 设置静态文件路径,js,css等
mvc:
static-path-pattern: /static/**
2)、实体类层
@Data
@Document(indexName = "clouddisk", type = "disk")
public class CloudDiskEntity {
@Id
private String id;
// 名称
private String name;
// 来源
private String source;
// 描述
private String describe;
// 分享时间
private Date shartime;
// 浏览次数
private Long browsetimes;
// 文件大小
private Double filesize;
// 分享人
private String sharpeople;
// 收录时间
private String collectiontime;
// 地址
private String baiduaddres;
}
3)、Repository层
public interface CloudDiskDao extends ElasticsearchRepository<CloudDiskEntity, String> {
}
4)、控制层
@Controller
public class SearchController {
@Autowired
private CloudDiskDao cloudDiskDao;
@RequestMapping("/search")
public String search(String keyword,
String describe,
@PageableDefault(page = 0, value = 5) Pageable pageable,
HttpServletRequest req) {
//开始时间
long startTime = System.currentTimeMillis();
// 创建查询对象
BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();
if (!StringUtils.isEmpty(keyword)) {
// 模糊查询 一定要ik中文
MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("name", keyword);
boolQuery.must(matchQuery);
}
if (!StringUtils.isEmpty(describe)) {
MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("describe", describe);
boolQuery.must(matchQuery);
}
// 调用查询接口
Page<CloudDiskEntity> page = cloudDiskDao.search(boolQuery, pageable);
req.setAttribute("page", page);
// 记录总数
req.setAttribute("total", page.getTotalElements());
req.setAttribute("keyword", keyword);
// 计算分页总数
int totalPage = (int) ((page.getTotalElements() - 1) / pageable.getPageSize() + 1);
// 分页总数
req.setAttribute("totalPage", totalPage);
Long emdTime = System.currentTimeMillis();
req.setAttribute("time", emdTime - startTime);
return "search";
}
}
5)、启动类
@SpringBootApplication
@EnableElasticsearchRepositories(basePackages = "com.zhq.repository")
public class AppElasticsearch {
public static void main(String[] args) {
SpringApplication.run(AppElasticsearch.class,args);
}
}
6)、页面实现
<!DOCTYPE html>
<html xmlns="http://www.w3.org/1999/xhtml" xmlns:th="http://www.thymeleaf.org">
<head>
<meta charset="UTF-8">
<title>独角兽码农网盘搜索引擎</title>
<!-- 新 Bootstrap 核心 CSS 文件 -->
<link href="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap.min.css" rel="stylesheet">
<!-- 可选的Bootstrap主题文件(一般不使用) -->
<script src="https://cdn.bootcss.com/bootstrap/3.3.7/css/bootstrap-theme.min.css"></script>
<!-- jQuery文件。务必在bootstrap.min.js 之前引入 -->
<script src="https://cdn.bootcss.com/jquery/2.1.1/jquery.min.js"></script>
<!-- 最新的 Bootstrap 核心 JavaScript 文件 -->
<script src="https://cdn.bootcss.com/bootstrap/3.3.7/js/bootstrap.min.js"></script>
</head>
<body style="display: block; margin: 0 auto; width: 50%; " >
<div style="width:100%;height:60px;" align="center">
<h2 style="color:#985f0d;">独角兽码农网盘搜索引擎</h2>
</div>
<br/>
<div align="center">
<span style="font-size: 18px;" >检索出${total}条数据,耗时:${time}毫秒</span>
</div>
<br/>
<br/>
<div class="bs-example" data-example-id="striped-table">
<table class="table table-bordered table-hover">
<thead>
<tr>
<th style="text-align:center;" scope="row">链接名称</th>
<th style="text-align:center;">文件大小GB</th>
<th style="text-align:center;">分享人</th>
<th style="text-align:center;">云盘地址</th>
</tr>
</thead>
<tbody>
<#list page.content as p>
<tr >
<th style="text-align: left;" >
<#if keyword??>
${p.name?replace(keyword, '<span style="color: red">${keyword}</span>')}
<#else>
${p.name}
</#if>
</th>
<th style="text-align: center;">${p.filesize}</th>
<th style="text-align: center;">${p.sharpeople}</th>
<th style="text-align: center;"><a href="${p.baiduaddres}">云盘地址</a> </th>
</tr>
</#list>
</tbody>
</table>
<div style="font-size: 21px;">
<#list 1..totalPage as i>
<#if keyword??>
<a href="/search?keyword=${keyword}&page=${i-1}" >${i}</a>
<#else>
<a href="/search?page=${i-1}" >${i}</a>
</#if>
</#list>
页
</div>
</div>
</body>
</html>