大数据ELK（十二）Elasticsearch编程（环境准备）
#头条创作挑战赛#
一、环境准备1、准备 IDEA 项目结构创建 elasticsearch_example 项目创建包结构如下所示
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 接口。
参考代码：
/** * 定义JobFullTextService */ 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; } }
