java jest,elasticsearch 基于 jest 的http客户端封装

目前 elasticsearch java 客户端中有两种使用方式，一种是使用TransportClient，一种是使用 http client。

关于TransportClient，elastic计划在Elasticsearch 7.0中弃用TransportClient，并在8.0中完全删除它。后面，应该使用Java高级REST客户端，它执行HTTP请求而不是序列化的Java请求。

spring boot 包引用

com.zhuanche.es.jest

sq-es-spring-boot-starter

0.0.1-SNAPSHOT

配置

es.url: http://dev-es01-a.es.01zhuanche.com:9200

es.max-total: 100

es.per-total: 100

代码

//注入 service

@Autowired

private ElasticSearchService searchService;

//创建索引

String mapping="{\"worksheet\": {\"properties\": {\"call_record_id\": {\"type\": \"long\"}, \"city_id\": {\"type\": \"long\"}, \"commit_user_id\": {\"type\": \"keyword\"}, \"commit_user_name\": {\"type\": \"keyword\"}, \"confirm_sheet_type_four\": {\"type\": \"long\"}, \"confirm_sheet_type_one\": {\"type\": \"long\"}, \"confirm_sheet_type_three\": {\"type\": \"long\"}, \"confirm_sheet_type_two\": {\"type\": \"long\"}, \"contact\": {\"type\": \"keyword\"}, \"create_date\": {\"type\": \"date\"}, \"current_deal_user_id\": {\"type\": \"keyword\"}, \"current_deal_user_name\": {\"type\": \"keyword\"}, \"current_status\": {\"type\": \"long\"}, \"dept_id\": {\"type\": \"long\"}, \"driver_id\": {\"type\": \"long\"}, \"driver_name\": {\"type\": \"keyword\"}, \"driver_phone\": {\"type\": \"keyword\"}, \"duty_dept\": {\"type\": \"long\"}, \"handle_time\": {\"type\": \"long\"}, \"id\": {\"type\": \"long\"}, \"license_plates\": {\"type\": \"keyword\"}, \"memo\": {\"type\": \"keyword\"}, \"order_no\": {\"type\": \"keyword\"}, \"order_type\": {\"type\": \"long\"}, \"reopen_times\": {\"type\": \"long\"}, \"rider_name\": {\"type\": \"keyword\"}, \"rider_phone\": {\"type\": \"keyword\"}, \"service_type_id\": {\"type\": \"long\"}, \"sheet_classify\": {\"type\": \"long\"}, \"sheet_priority\": {\"type\": \"long\"}, \"sheet_source\": {\"type\": \"long\"}, \"sheet_tag\": {\"type\": \"long\"}, \"sheet_tag_sort\": {\"type\": \"long\"}, \"sheet_type_four\": {\"type\": \"long\"}, \"sheet_type_one\": {\"type\": \"long\"}, \"sheet_type_three\": {\"type\": \"long\"}, \"sheet_type_two\": {\"type\": \"long\"}, \"update_date\": {\"type\": \"date\"}, \"urge_times\": {\"type\": \"long\"}, \"weight\": {\"type\": \"long\"}, \"work_sheet_no\": {\"type\": \"keyword\"} } } } ";

this.searchService.createIndex(index);

this.searchService.createIndex(index, type, mapping);

//创建别名

List list = Arrays.asList(index);

this.searchService.addAlias(list , "index-alias");

//写入数据

List dataList = new ArrayList<>();

list.forEach(item ->{

WorkSheet entity = new WorkSheet();

entity.setId(Long.valueOf(item.get("id").toString()));

dataList.add(entity);

});

searchService.bulkInsertData(index, type, dataList);

//异步写入数据

searchService.bulkInsertDataAsync(index, type, dataList);

搜索代码

@Test

public void testSearch(){

Page page = new Page<>();

ESQueryBuilderConstructor constructor = new ESQueryBuilderConstructor();

//constructor.must(new ESQueryBuilders().term("sheetSource", "3"));//单个值匹配 OK

//constructor.must(new ESQueryBuilders().terms("sheetSource", Arrays.asList(3,6,4)));//多值匹配 OK

//constructor.must(new ESQueryBuilders().queryString("高德"));// ok

//constructor.must(new ESQueryBuilders().fuzzy("commitUserName", "张*")); // OK

//constructor.must(new ESQueryBuilders().term("commitUserName", "***")); 精确匹配

//constructor.must(new ESQueryBuilders().range("sheet_source", 0, 6 ));

//constructor.must(new ESQueryBuilders().terms("deptId", Arrays.asList(14, 9)));

constructor.setFrom((page.getPageNo()-1) * page.getPageSize());

constructor.setSize(page.getPageSize());

page = this.searchService.search(index, type, WorkSheet.class, constructor);

System.out.println("查询返回结果：" + JSON.toJSONString(page));

}

使用基础 jar 包

com.zhuanche.es.jest

es-jest-service

0.0.2-SNAPSHOT

io.searchbox

jest

org.elasticsearch

elasticsearch

使用 spring配置