Java注解之Elasticsearch的案例详解
更新时间：2022年10月16日 10:09:21 作者：湘王
学会了技术就要使用，否则很容易忘记，因为自然界压根就不存在什么代码、变量之类的玩意，这都是一些和生活常识格格不入的东西。这篇文章主要介绍了Java中Elasticsearch的案例，感兴趣的可以了解一下
学会了技术就要使用，否则很容易忘记，因为自然界压根就不存在什么代码、变量之类的玩意，这都是一些和生活常识格格不入的东西。只能多用多练，形成肌肉记忆才行。
在一次实际的产品开发中，由于业务需求的缘故，需要使用Elasticsearch搜索引擎。搜索引擎是通过索引和文档检索数据的，索引类似于MySQL的数据库，而文档类似于MySQL的表。要想使用搜索引擎，就必须事先创建索引和文档。
有两种解决方案可以实现：
第一种方案是把创建索引和文档的语句直接集成在代码里，每次启动时都检查相应的索引、文档是否存在，不存在就创建；
第二种方案是通过脚本的形式，把每个索引和文档的创建语句都保存下来，如果有字段改动则删除，再重新创建。
考虑到开发时字段可能会经常变动，此时就必然会导致修改代码，所以采取第二种方案时既要修改代码，又要同时修改脚本，否则会报错，比较费事。而采用第一种方案，只需要删掉索引和文档再重新启动应用就可以了，不必再单独执行脚本，非常方便，也不容易忘记。综合开发进度及其他现实因素，决定采用第一种方案来解决创建索引和文档的问题。
这里不打算创建一个完整的项目，只需要演示用Java创建Elasticsearch索引相关部分就行了。
即使是这么一点内容，代码量也不少，对于初学者来说仍然有些复杂，所以决定分为两部分来讲。
今天先来准备一下「材料」。事先声明：这里的代码都是应用于本地Elasticsearch服务的，而不是云原生服务，否则代码和配置等内容会有很大不同。
首先，引入所需要的依赖：
<!-- Elasticsearch相关依赖 -->
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<exclusions>
<exclusion>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
</exclusion>
<exclusion>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
</dependency>
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
</dependency>
<!-- fastjson -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.68</version>
</dependency>
<!-- apache commons -->
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>然后修改application.properties属性文件：
## ELASTICSEARCH spring.elastic.rhlc.schema=http spring.elastic.rhlc.hosts=127.0.0.1:9200 spring.elastic.rhlc.username=elastic spring.elastic.rhlc.password=123456 spring.elastic.rhlc.connectTimeOut=5000 spring.elastic.rhlc.socketTimeOut=5000 spring.elastic.rhlc.connectionRequestTimeOut=10000 spring.elastic.rhlc.maxConnectNumber=10000 spring.elastic.rhlc.maxConnectPerRoute=8
接着，创建elasticsearch配置类：
/**
* Elasticsearch配置类
*
* @author xiangwang
*/
@Configuration
public class ElasticConfiguration {
@Value("${spring.elastic.rhlc.schema}")
private String schema;
@Value("${spring.elastic.rhlc.hosts}")
private String hosts;
@Value("${spring.elastic.rhlc.username}")
private String username;
@Value("${spring.elastic.rhlc.password}")
private String password;
@Value("${spring.elastic.rhlc.connectTimeOut}")
private int connectTimeOut;
@Value("${spring.elastic.rhlc.socketTimeOut}")
private int socketTimeOut;
@Value("${spring.elastic.rhlc.connectionRequestTimeOut}")
private int connectionRequestTimeOut;
@Bean
public RestHighLevelClient client() {
String[] hosts = this.hosts.split(",");
HttpHost[] httpHosts = new HttpHost[hosts.length];
for (int i = 0; i < hosts.length; i++) {
httpHosts[i] = new HttpHost(hosts[i].split(":")[0], Integer.parseInt(hosts[i].split(":")[1]), schema);
}
final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(username, password));
RestClientBuilder builder = RestClient.builder(httpHosts).setRequestConfigCallback(requestConfigBuilder -> {
requestConfigBuilder.setConnectTimeout(connectTimeOut);
requestConfigBuilder.setSocketTimeout(socketTimeOut);
requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeOut);
return requestConfigBuilder;
}).setHttpClientConfigCallback(httpClientBuilder -> {
httpClientBuilder.disableAuthCaching();
return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
});
return new RestHighLevelClient(builder);
}
}上面这些都属于常规动作，没啥好说明的。
接下来，还是按照昨天的套路进行：
先创建elasticsearch字段类型枚举：
/**
* elastic字段类型枚举
*
* @author xiangwang
*/
public enum FieldType {
Auto("auto"),
Text("text"),
Keyword("keyword"),
Long("long");
public String value;
private FieldType(final String value) {
this.value = value;
}
public static String getValue(final String value) {
for (FieldType field : FieldType.values()) {
if (field.getValue().equalsIgnoreCase(value)) {
return field.value;
}
}
return null;
}
public String getValue() {
return value;
}
public void setValue(final String value) {
this.value = value;
}
}然后创建elasticsearch的字段：
/**
* elastic字段注解，定义每个elasticsearch字段上的属性
*
* @author xiangwang
*/
@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.FIELD)
@Documented
@Inherited
public @interface DocField {
@AliasFor("name")
String value() default "";
@AliasFor("value")
String name() default "";
FieldType type() default FieldType.Auto;
boolean index() default false;
String format() default "";
String pattern() default "";
boolean store() default false;
boolean fielddata() default false;
String searchAnalyzer() default "";
String analyzer() default "";
String normalizer() default "";
}以上就是Java注解之Elasticsearch的案例详解的详细内容，更多关于Java Elasticsearch的资料请关注脚本之家其它相关文章！
相关文章
Servlet+JavaBean+JSP打造Java Web注册与登录功能
比作MVC的话,控制器部分采用Servlet来实现，模型部分采用JavaBean来实现,而大部分的视图采用Jsp页面来实现,接下来我们就来详细看看如何用Servlet+JavaBean+JSP打造Java Web注册与登录功能2016-05-05
在SpringCloud项目中集成Sentinel,可以实现流量控制、熔断降级等功能,提升系统稳定性和可用性,集成步骤包括添加Sentinel依赖、配置控制台地址、启动控制台、配置限流熔断规则、使用注解和集成SpringCloudGateway,这有助于处理高并发场景,保护服务稳定运行2024-10-10
这篇文章主要介绍了Java 执行CMD命令或执行BAT批处理方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-08-08
本文将深入探讨Spring Shell的核心特性、实现方式及应用场景,帮助开发者掌握这一强大工具,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-04-04
本篇文章主要介绍了IDEA添加Java类注释模版的方法，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-12-12
这篇文章主要介绍了MyBatis 参数类型为String时常见问题及解决方法,非常不错，具有参考借鉴价值，需要的朋友可以参考下2017-03-03
这篇文章主要为大家介绍了Mybatis分页插件PageHelper手写实现示例，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-08-08
这篇文章主要介绍了十个常见的Java异常出现原因，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-03-03
最近给⼀个客户部署项⽬,但是客户的安全稽核有点变态,居然说 Eclipse Jetty Server⾼危漏洞,这篇文章主要给大家介绍了关于Eclipse Jetty server漏洞解决的相关资料,需要的朋友可以参考下2023-11-11
这篇文章主要介绍了java调用c程序通信示例，大家参考使用吧2013-12-12
最新评论