springboot java 项目连接es
springboot java 项目连接es
介绍
小项目，没有引用es客户端，直接使用的http的方式进行连接的，方式比较简单，但是依赖较少，一个比较小的项目，部署方便
业务也很简单就是把数据库中的数据读到es中，然后在做几个接口读es中的数据
版本
es版本 6.8.11
springboot 2.6.3
java 8
依赖
只有web和mysql的依赖，别的不需要
这里就不作介绍了，如果有需要可以私信我
开始
配置
这个是放到yml文件中的配置 就是es的地址
es:url: http://127.0.0.1:9200/name: elasticpassword: 1234567890index: es_indexsearchSize: 1000version: 6.8.11
连接es
使用了这个类
RestTemplate restTemplate;
header
其中name和password就是配置中的
public HttpHeaders header() {HttpHeaders httpHeaders = new HttpHeaders();httpHeaders.setContentType(MediaType.APPLICATION_JSON);httpHeaders.set("authorization", "Basic " + (new BASE64Encoder().encode((name + ":" + password).getBytes()).replaceAll("\n", "")));return httpHeaders;
}
查询
esUrl 是es的地址
index 就是索引
param 就是参数
response.getBody() 返回的是一个json对象 自己根据内容解析一下即可
public JSONObject search(JSONObject param) {String url = esUrl + "/" + index + "/_search";HttpEntity httpEntity = new HttpEntity(param.toJSONString(), header());ResponseEntity<JSONObject> response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, JSONObject.class);return response.getBody();
}
删除
public void deleteById(String id) {String url = esUrl + "/" + index + "/_doc/" + id;restTemplate.delete(url);
}
更新
public JSONObject updateEsById(String id, JSONObject param) {String url = esUrl + "/" + index + "/_doc/" + id + "/_update";HttpEntity httpEntity = new HttpEntity(param.toJSONString(), header());ResponseEntity<JSONObject> response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, JSONObject.class);return response.getBody();}
保存
public void saveById(String id, JSONObject json) {String url = esUrl + "/" + index + "/_doc/" + id;HttpEntity httpEntity = new HttpEntity(json.toJSONString(), header());ResponseEntity<JSONObject> response = restTemplate.exchange(url, HttpMethod.POST, httpEntity, JSONObject.class);JSONObject ret = response.getBody();
}
补充
不同的版本是有差异的，具体可以在使用中根据报错进行调整
举例
es6.*版本的更新语句是这样的
esUrl + "/" + index + "/_doc/" + id + "/_update";
es7.*的是这样的
esUrl + "/" + index + "/_update/" + id + "?refresh=true"
最后
整体的就是这样，其实主要是是restTemplate的使用，相对于es客户端使用比较简单一下（个人认为,主要是es用的不是很多)
如果大家有疑问和需要我可以后期就行补充