本篇文章给大家分享的是有关springboot与elasticsearch有什么区别，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
核心jar：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-elasticsearch</artifactId> </dependency> <dependency> <groupId>net.java.dev.jna</groupId> <artifactId>jna</artifactId> <version>3.0.9</version> </dependency>
为什么用这样的版本，因为springboot相关的es版本就是这样，为了减少之后无法理解的错误出现，最好将es版本与es jar的版本保持一致，具体项目怎么创建这里就不说了，像平时一样，我们首先创建实体层、dao、web：
不需要任何配置，默认集群名称elasticsearch，地址localhost:9300
@Data @Document(indexName="person",type="student",shards=5,replicas=1,refreshInterval="-1") public class Student implements Serializable { @Id private Long id; private String name; private String classNo; private int age; private String sex; @JsonFormat(pattern = "yyyy-MM-dd") private Date birthday; private String grade; private String description; }dao：
@Repository public interface StudentRepository extends ElasticsearchRepository<Student,Long> { }web：
@RestController @RequestMapping("/student") public class StudentController { @Autowired private StudentRepository studentRepository; @GetMapping("/{id}") public Student get(@PathVariable("id") Long id){ Optional<Student> opt = studentRepository.findById(id); return opt.orElseGet(null); } @GetMapping public Iterable<Student> getAll(){ return studentRepository.findAll(); } @PostMapping public Student save(Student student){ return studentRepository.save(student); } @DeleteMapping("/{id}") public void delete(@PathVariable("id") Long id){ studentRepository.deleteById(id); } }就是这样简单。当然是用并非如此，作为数据库主要的还是查询，根据上一篇对es的简单介绍，可以 知道es的查询有很多种，如何快速查询出理想的数据，关键还是对api的使用与熟悉。
现在降低一下版本来测试
springboot 1.5.21 elasticsearch-5.6.16
依赖的核心jar：
<properties> <java.version>1.8</java.version> <elasticsearch.version>5.6.16</elasticsearch.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!--transport client--> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>transport</artifactId> <version>${elasticsearch.version}</version> </dependency> <!--rest client--> <dependency> <groupId>org.elasticsearch.client</groupId> <artifactId>elasticsearch-rest-high-level-client</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>org.elasticsearch</groupId> <artifactId>elasticsearch</artifactId> <version>${elasticsearch.version}</version> </dependency> <dependency> <groupId>com.sun.jna</groupId> <artifactId>jna</artifactId> <version>3.0.9</version> </dependency> </dependencies>首先要知道，连接es有两种客户端，一种是基于transport，一种是rest，我们分别看先如何实现（默认情况下transport端口9300，rest 9200，在es中可以修改，如果是集群环境，且为同一机器，需要配置各个节点地址）
Transport客户端：
@Bean public TransportClient client() throws UnknownHostException { Settings settings = Settings.builder() .put("cluster.name",properties.getClusterName()) .build(); List<String> nodes = properties.getNodes(); List<TransportAddress> addresses = new ArrayList<>(); for(String node : nodes){ String[] addr = node.split(":"); TransportAddress address = new InetSocketTransportAddress(InetAddress.getByName(addr[0]),Integer.valueOf(addr[1])); addresses.add(address); } TransportClient client = new PreBuiltTransportClient(settings) .addTransportAddresses(addresses.toArray(new TransportAddress[addresses.size()])); return client; }其余就是如何调用这个TransportClient，创建index：
private CreateIndexRequestBuilder configIndex(String index){ if(StringUtils.isEmpty(index)){ log.warn("index name can't be empty"); return null; } Map<String,Object> config = new HashMap<>(); if(properties.getProperties()!=null){ config.putAll(properties.getProperties()); } Settings settings = Settings.builder() .put(config) .build(); return client.admin().indices().prepareCreate(index.toLowerCase()) .setSettings(settings); } public void createIndex(String index,String type,XContentBuilder source){ CreateIndexRequestBuilder indexBuilder = configIndex(index); if(indexBuilder!=null){ // indexBuilder.setSettings() if(!StringUtils.isEmpty(type)){ indexBuilder.addMapping(type, source); } CreateIndexResponse response = indexBuilder.execute().actionGet(); boolean ack = response.isAcknowledged(); if(ack){ log.info("index [{}] create successfully!",index); }else{ log.warn("index [{}] create unsuccessfully!",index); } } }创建索引可以不需要type和document属性，当然，如果需要创建index、type，记得构建的是一个完整的json，类似这样：
{ "settings":{ "number_of_shards":5, "number_of_replicas":1 }, "mappings":{ "type1":{ "properties":{ "prop1":{"type":"text"...} ..... } } ..... } }删除索引：
public boolean deleteIndex(String... index) { return client.admin().indices().prepareDelete(index).execute().actionGet().isAcknowledged(); }保存文档：
public void saveDoc(String index, String type,String id, String source){ if(StringUtils.isEmpty(id)){ log.warn("id is empty,and generate id automatically."); id = UUID.randomUUID().toString(); } IndexResponse response = client.prepareIndex(index, type, id).setSource(source,XContentType.JSON).get(); log.debug("save date status:[{}]",response.status().getStatus()); }修改文档：
public void updateDoc(String index, String type, String id,String source){ UpdateResponse response = client.prepareUpdate(index, type, id).setDoc(source,XContentType.JSON).get(); log.debug("update date status:[{}]",response.status().getStatus()); }删除文档：
public void deleteDoc(String index, String type, String id){ client.prepareDelete(index,type,id).execute().actionGet(); }查询：
public List<Map<String, Object>> query(String index, String type,QueryBuilder query){ SearchRequestBuilder builder = client.prepareSearch(); if(!StringUtils.isEmpty(index)){ builder.setIndices(index); } if(!StringUtils.isEmpty(type)){ builder.setTypes(type); } SearchResponse response = builder.setQuery(query).get(); SearchHits hits = response.getHits(); // long total = hits.totalHits; Iterator<SearchHit> hitIt = hits.iterator(); List<Map<String,Object>> result = new ArrayList<>(); while (hitIt.hasNext()){ SearchHit hit = hitIt.next(); result.add(hit.getSourceAsMap()); } return result; }Rest客户端：
@Bean public RestClient client(){ List<String> nodes = properties.getNodes(); List<HttpHost> hosts = null; if(nodes!=null){ hosts = nodes.stream().map(e -> { // match? String[] addr = e.split(":"); return new HttpHost(addr[0], Integer.valueOf(addr[1])); }).collect(Collectors.toList()); } RestClientBuilder restClientBuilder; if(hosts != null){ restClientBuilder = RestClient.builder(hosts.toArray(new HttpHost[hosts.size()])); }else{ log.warn(" no host is configured,user default {}:{} ",DEFAULT_HOST,DEFAULT_PORT); restClientBuilder = RestClient.builder(new HttpHost(DEFAULT_HOST,DEFAULT_PORT)); } // httpConfigure(restClientBuilder); return restClientBuilder.build(); }这个和es原生的调用一样，当然还有一个异步的方法
client.performRequest(String method, String url, Map<String, String> params, HttpEntity entity, HttpAsyncResponseConsumerFactory consumerFactory);
关键是构建HttpEntiy，因为es主要是通过json格式的数据进行通信，所以关键就是如何构建json格式的数据进行传递，当然我们可以借助一些json工具来完成：
public static String builder(){ Map<String,Object> json = new HashMap<>(); Map<String,Object> match_all = new HashMap<>(); match_all.put("match_all", Collections.EMPTY_MAP); json.put("query",match_all); try { return new ObjectMapper().writeValueAsString(json); } catch (JsonProcessingException e) { e.printStackTrace(); } return null; }以上就是springboot与elasticsearch有什么区别，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注亿速云行业资讯频道。
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
