本文只是一个springboot整合es的案例，es在版本控制上极差，每个大版本之间兼容性很差，api也很多不一样，所以我这里只是一个简单的demo。
项目结构：
1. 导入依赖
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.7.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <dependencies> <!--web--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--elasticsearch 整合 springboot两个依赖--> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>7.2.1</version> </dependency> <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>7.2.1</version> </dependency> <!--添加fastjson依赖--> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.7</version> </dependency> </dependencies>
2. es配置类
import org.apache.http.HttpHost; import org.elasticsearch.client.RestClient; import org.elasticsearch.client.RestHighLevelClient; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class EsConfig { @Bean(destroyMethod = "close") public RestHighLevelClient client() { return new RestHighLevelClient(RestClient.builder( new HttpHost("192.168.209.100", 9200, "http") )); } }
3. 没有整合mysql，这里直接准备好需要操作的数据
import java.text.SimpleDateFormat; import java.util.ArrayList; import java.util.Calendar; import java.util.Date; import java.util.List; import java.util.Random; public class User { private int id; private int age; private String name; private Date startTime; private Date endTime; public static List<User> getAll() { List<User> list = new ArrayList<User>(); try { Calendar no = Calendar.getInstance(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String time = "2019-09-25 19:12:32"; User user = null; for(int i=1;i<11;i++) { no.setTime(format.parse(time)); no.set(Calendar.DATE, no.get(Calendar.DATE) -new Random().nextInt(15)); Date startTime = no.getTime(); no.set(Calendar.DATE, no.get(Calendar.DATE) +new Random().nextInt(30)); Date endTime = no.getTime(); user = new User(i, new Random().nextInt(100), "吴磊"+i, startTime, endTime); list.add(user); } } catch (Exception e) { } return list; } public int getId() { return id; } public void setId(int id) { this.id = id; } public int getAge() { return age; } public void setAge(int age) { this.age = age; } public String getName() { return name; } public void setName(String name) { this.name = name; } public Date getStartTime() { return startTime; } public void setStartTime(Date startTime) { this.startTime = startTime; } public Date getEndTime() { return endTime; } public void setEndTime(Date endTime) { this.endTime = endTime; } public User(int id, int age, String name, Date startTime, Date endTime) { super(); this.id = id; this.age = age; this.name = name; this.startTime = startTime; this.endTime = endTime; } public User() { super(); } @Override public String toString() { return "User [id=" + id + ", age=" + age + ", name=" + name + ", startTime=" + startTime + ", endTime=" + endTime + "]"; } }
4. 编写操作es的javaApi
import java.io.IOException; import java.util.HashMap; import java.util.LinkedList; import java.util.List; import java.util.Map; import org.elasticsearch.action.delete.DeleteRequest; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.GetRequest; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexRequest; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.action.update.UpdateRequest; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.RequestOptions; import org.elasticsearch.client.RestHighLevelClient; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.builder.SearchSourceBuilder; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cglib.beans.BeanMap; import org.springframework.stereotype.Service; import com.alibaba.fastjson.JSONObject; import com.wulei.entity.User; @Service public class ESService { // 索引名称 (可以理解成数据库的表名) private static final String index_name = "user"; // es对象 @Autowired private RestHighLevelClient client; public int add() { int count = 0; try { // 从数据库拿到数据 List<User> list = User.getAll(); for(User u : list) { addIndex(u, String.valueOf(u.getId())); count += 1; } } catch (Exception e) { // TODO: handle exception } return count; } /** * 添加索引 * @param user * @param id * @throws IOException */ public void addIndex(User user, String id) throws IOException{ // 创建一个索引，指定文档id，source是文档内容 IndexRequest request = new IndexRequest(index_name).id(id).source(beanToMap(user)); IndexResponse response = client.index(request, RequestOptions.DEFAULT); System.out.println(response); } /** * 查询 * @param id * @return * @throws IOException */ public Object get(String id) throws IOException{ GetRequest getRequest = new GetRequest(index_name,id); GetResponse response = client.get(getRequest,RequestOptions.DEFAULT); Map<String, Object> source = response.getSource(); System.out.println(response); return JSONObject.toJSON(source); } /** * 删除 * @param id * @return * @throws IOException */ public boolean del(String id) throws IOException{ DeleteRequest request = new DeleteRequest(index_name,id); DeleteResponse res = client.delete(request, RequestOptions.DEFAULT); System.out.println(res); return true; } /** * 改 * @param id * @return * @throws IOException */ public boolean edit(User user,String id) throws IOException{ UpdateRequest request = new UpdateRequest(index_name,id).doc(beanToMap(user)); UpdateResponse name = client.update(request,RequestOptions.DEFAULT); System.out.println(name); return true; } /** * 条件搜索 * @param key * @param value * @return * @throws IOException */ public List<User> select(String key,String value,int start, int end,int type) throws IOException { // 指定索引，类似于数据库的表 SearchRequest searchRequest = new SearchRequest(index_name); // 创建查询对象，相当于写查询sql SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); if(type==1) { // matchQuery是模糊查询，会对key进行分词 searchSourceBuilder.query(QueryBuilders.matchQuery(key,value)); }else if(type==2) { // termQuery是精准查询 searchSourceBuilder.query(QueryBuilders.termQuery(key,value)); } // 指定从哪条开始查询 searchSourceBuilder.from(start); // 需要查出的总记录条数 searchSourceBuilder.size(end); searchRequest.source(searchSourceBuilder); SearchResponse response = client.search(searchRequest,RequestOptions.DEFAULT); System.out.println(JSONObject.toJSON(response)); SearchHit[] hits = response.getHits().getHits(); List<User> list = new LinkedList<>(); for(SearchHit hit: hits){ User user = JSONObject.parseObject(hit.getSourceAsString(),User.class); list.add(user); } return list; } /** * 对象转map * @param bean * @param <T> * @return */ public <T> Map<String, Object> beanToMap(T bean) { Map<String, Object> map = new HashMap<>(); if (bean != null) { BeanMap beanMap = BeanMap.create(bean); for (Object key : beanMap.keySet()) { if(beanMap.get(key) != null){ map.put(key + "", beanMap.get(key)); } } } return map; } }
5. 写测试接口
@RestController public class ESController { @Autowired private ESService service; @RequestMapping("/add") public int add() { return service.add(); } @RequestMapping("/get") public Object get(String id) throws IOException{ return service.get(id); } @RequestMapping("/getAll") public List<User> getAll() throws IOException{ List<User> list = new ArrayList<User>(); for(int i=1;i<11;i++) { Object json = service.get(String.valueOf(i)); list.add(JSONObject.parseObject(json.toString(), User.class)); } return list; } @RequestMapping("/del") public boolean del(String id) throws IOException{ return service.del(id); } @RequestMapping("/edit") public boolean edit(User user,String id) throws IOException{ return service.edit(user, id); } @RequestMapping("/select") public List<User> select(String key,String value,int start, int end,int type) throws IOException { return service.select(key, value, start, end, type); } }