九、微服务进阶之 ElasticSearch（基础配置）

@ConfigurationProperties(prefix = "spring.elastic")
@Data
public class ElasticValueConfiguration {
    /** * es节点 */
    private List uris;
    /** * 用户名 */
    private String name;
    /** * 密码 */
    private String password;
    /** * 是否开启es连接 */
    private boolean connectEnabled;
    /** * 连接超时时间 */
    private int connectTimeout;
    /** * 会话超时时间 */
    private int socketTimeout;
    /** * 获取连接超时时间 */
    private int requestTimeout;
    /** * 最大连接数 */
    private int maxConnect;
    /** * 最大路由数连接数 */
    private int maxConnectRoute;
}

"spring.elastic.connect-enabled"："是否开启es连接" 
"spring.elastic.connect-timeout"："连接超时时间" 
"spring.elastic.max-connect": "最大连接数" 
"spring.elastic.max-connect-route": "最大路由数连接数" 
"spring.elastic.name": "用户名" 
"spring.elastic.password": "密码" 
"spring.elastic.request-timeout": "获取连接超时时间" 
"spring.elastic.socket-timeout": "会话超时时间" 
"spring.elastic.uris": "es节点，资源路径"

@SpringBootConfiguration
@EnableConfigurationProperties(ElasticValueConfiguration.class)
@Slf4j
public class ElasticSearchConfiguration {
    @Autowired
    private ElasticValueConfiguration elasticValueConfiguration;

    /** * 同名覆盖默认的 RestHighLevelClient */
    @Bean
    RestHighLevelClient restHighLevelClient() {
        log.info("elastic connection begin to set up...");
        if (!elasticValueConfiguration.isConnectEnabled()) {
            return null;
        }
        List httpHosts = new ArrayList<>();
        for (String es : elasticValueConfiguration.getUris()) {
            httpHosts.add(new HttpHost(es));
        }
        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
        // 需要用户名和密码的认证 
        credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials(elasticValueConfiguration.getName(), elasticValueConfiguration.getPassword()));
        RestClientBuilder restClientBuilder = RestClient.builder(httpHosts.toArray(new HttpHost[0]));
        // 异步连接httpclient配置 
        restClientBuilder.setHttpClientConfigCallback(httpAsyncClientBuilder -> {
            httpAsyncClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
            httpAsyncClientBuilder.setMaxConnTotal(elasticValueConfiguration.getMaxConnect());
            httpAsyncClientBuilder.setMaxConnPerRoute(elasticValueConfiguration.getMaxConnectRoute());
            return httpAsyncClientBuilder;
        });
        // 异步连接httpclient延时配置 
        restClientBuilder.setRequestConfigCallback(requestConfigBuilder -> {
            requestConfigBuilder.setConnectTimeout(elasticValueConfiguration.getConnectTimeout());
            requestConfigBuilder.setSocketTimeout(elasticValueConfiguration.getSocketTimeout());
            requestConfigBuilder.setConnectionRequestTimeout(elasticValueConfiguration.getRequestTimeout());
            return requestConfigBuilder;
        });
        // 设置一个监听程序，每次节点发生故障时都会收到通知，这样就可以采取相应的措施。 
        restClientBuilder.setFailureListener(new RestClient.FailureListener() {
            public void onFailure(HttpHost host) {
                log.warn("elastic nodes {} error!!!", host.toHostString());
            }
        });
        log.info("elastic connection set successfully!");
        return new RestHighLevelClient(restClientBuilder);
    }
}

<properties>
    <elasticsearch.version>7.11.2</elasticsearch.version>
</properties>
<dependencies>
    <!-- 自定义配置参数提示 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-configuration-processor</artifactId>
        <optional>true</optional>
        <!-- 不传递依赖，只是一个工具依赖 -->
    </dependency>
    <!-- 取消低版本es -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
        <exclusions>
            <exclusion>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>elasticsearch-rest-high-level-client</artifactId>
            </exclusion>
            <exclusion>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>transport</artifactId>
            </exclusion>
            <exclusion>
                <groupId>org.elasticsearch.plugin</groupId>
                <artifactId>transport-netty4-client</artifactId>
            </exclusion>
        </exclusions>
    </dependency>
    <!-- 更换高版本的es，对应es服务端的版本 -->
    <!-- 版本查看：http://ip:9200?pretty -->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>${elasticsearch.version}</version>
    </dependency>
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>transport</artifactId>
        <version>${elasticsearch.version}</version>
    </dependency>
    <dependency>
        <groupId>org.elasticsearch.plugin</groupId>
        <artifactId>transport-netty4-client</artifactId>
        <version>${elasticsearch.version}</version>
    </dependency>
</dependencies>

# 注入自定义配置类 
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ 
  com.fatcat.elastic.config.ElasticSearchConfiguration,\ 
  com.fatcat.elastic.template.ElasticDocTemplate,\ 
  com.fatcat.elastic.template.ElasticIndexTemplate