全网最详细的大数据ELK文章系列，强烈建议收藏加关注！
新文章都已经列出历史文章目录，帮助大家回顾前面的知识重点。
目录
Elasticsearch编程
一、环境准备
1、准备IDEA项目结构
2、准备POM依赖
3、创建用于保存职位信息的实体类
4、编写接口和实现类
5、创建实现类
Elasticsearch编程
要将搜索的功能与前端对接，我们必须要使用Java代码来实现对Elasticsearch的操作。我们要使用一个JobService类来实现之前我们用RESTFul完成的操作
一、环境准备
1、准备IDEA项目结构
- 创建elasticsearch_example项目
- 创建包结构如下所示
- 创建elasticsearch_example项目
- 创建包结构如下所示
| 包 | 说明 |
| cn.it.elasticsearch.entity | 存放实体类 |
| cn.it.elasticsearch.service | 存放服务接口 |
| cn.it.elasticsearch.service.impl | 存放服务接口实现类 |
2、准备POM依赖
aliyun
http://maven.aliyun.com/nexus/content/groups/public/
true
false
never
org.elasticsearch.client
elasticsearch-rest-high-level-client
7.6.1
org.apache.logging.log4j
log4j-core
2.11.1
com.alibaba
fastjson
1.2.62
junit
junit
4.12
test
org.testng
testng
6.14.3
test
org.apache.maven.plugins
maven-compiler-plugin
3.1
1.8
1.8
3、创建用于保存职位信息的实体类
注意：
在id字段上添加一个 @JSONField注解，并配置注解的serialize为false，表示该字段无需转换为JSON，因为它就是文档的唯一ID。
参考代码：
public class JobDetail {
// 因为此处无需将id序列化为文档中
@JSonField(serialize = false)
private long id; // 唯一标识
private String area; // 职位所在区域
private String exp; // 岗位要求的工作经验
private String edu; // 学历要求
private String salary; // 薪资范围
private String job_type; // 职位类型（全职/兼职）
private String cmp; // 公司名
private String pv; // 浏览量
private String title; // 岗位名称
private String jd; // 职位描述
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public String getArea() {
return area;
}
public void setArea(String area) {
this.area = area;
}
public String getExp() {
return exp;
}
public void setExp(String exp) {
this.exp = exp;
}
public String getEdu() {
return edu;
}
public void setEdu(String edu) {
this.edu = edu;
}
public String getSalary() {
return salary;
}
public void setSalary(String salary) {
this.salary = salary;
}
public String getJob_type() {
return job_type;
}
public void setJob_type(String job_type) {
this.job_type = job_type;
}
public String getCmp() {
return cmp;
}
public void setCmp(String cmp) {
this.cmp = cmp;
}
public String getPv() {
return pv;
}
public void setPv(String pv) {
this.pv = pv;
}
public String getTitle() {
return title;
}
public void setTitle(String title) {
this.title = title;
}
public String getJd() {
return jd;
}
public void setJd(String jd) {
this.jd = jd;
}
@Override
public String toString() {
return "JobDetail{" +
"id=" + id +
", area='" + area + ''' +
", exp='" + exp + ''' +
", edu='" + edu + ''' +
", salary='" + salary + ''' +
", job_type='" + job_type + ''' +
", cmp='" + cmp + ''' +
", pv='" + pv + ''' +
", title='" + title + ''' +
", jd='" + jd + ''' +
'}';
}
}
4、编写接口和实现类
cn.it.elasticsearch.service包中创建JobFullTextService接口，该接口中定义了职位全文检索相关的Java API接口。
参考代码：
public interface JobFullTextService {
// 添加一个职位数据
void add(JobDetail jobDetail);
// 根据ID检索指定职位数据
JobDetail findById(long id) throws IOException;
// 修改职位薪资
void update(JobDetail jobDetail) throws IOException;
// 根据ID删除指定位置数据
void deleteById(long id) throws IOException;
// 根据关键字检索数据
List searchByKeywords(String keywords) throws IOException;
// 分页检索
Map searchByPage(String keywords, int pageNum, int pageSize) throws IOException;
// scroll分页解决深分页问题
Map searchByScrollPage(String keywords, String scrollId, int pageSize) throws IOException;
// 关闭ES连接
void close() throws IOException;
;
}
5、创建实现类
在cn.it.elasticsearch.service.impl包下创建一个实现类：JobFullTextServiceImpl，并实现上面的接口。
参考代码：
public class JobFullTextServiceImpl implements JobFullTextService {
@Override
public void add(JobDetail jobDetail) {
}
@Override
public void update(JobDetail jobDetail) {
}
@Override
public JobDetail findById(long id) {
return null;
}
@Override
public boolean deleteById(long id) {
return false;
}
@Override
public List searchByKeywords(String keywords) {
return null;
}
@Override
public Map searchByPage(String keywords, int pageNum, int pageSize) {
return null;
}
@Override
public Map searchByScrollPage(String keywords, String scrollId, int pageSize) {
return null;
}
}
- 博客主页：https://lansonli.blog.csdn.net
- 欢迎点赞 收藏 ⭐留言 如有错误敬请指正！
- 本文由 Lansonli 原创，首发于 CSDN博客
- 大数据系列文章会每天更新，停下休息的时候不要忘了别人还在奔跑，希望大家抓紧时间学习，全力奔赴更美好的生活✨
