大数据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;     } }