转载

Spring Boot 连接 Elasticsearch 备忘

以下备忘 Spring Boot 项目使用 transport client 连接 Elasticsearch 的方式。

1. Pom.xml

添加如下依赖：

<dependency>
    <groupId>org.elasticsearch</groupId>
    <artifactId>elasticsearch</artifactId>
    <version>5.4.1</version>
</dependency>
<dependency>
    <groupId>org.elasticsearch.client</groupId>
    <artifactId>transport</artifactId>
    <version>5.4.1</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-api</artifactId>
    <version>2.11.1</version>
</dependency>
<dependency>
    <groupId>org.apache.logging.log4j</groupId>
    <artifactId>log4j-core</artifactId>
    <version>2.11.1</version>
</dependency>

注意，这里对 log4j 的依赖引用，是为了解决以下报错：

NoClassDefFoundError: org/apache/logging/log4j/Logger

2. 添加 Client Bean

@Slf4j
@Configuration
public class ESClientConfiguration {

    @Bean
    public Client client() {
        TransportClient client = null;
        try {
            Settings settings = Settings.builder()
                    .put("client.transport.sniff", true)
                    .put("cluster.name", "xxxx")
                    .put("client.transport.ping_timeout", "3s")
                    .build();
            client = new PreBuiltTransportClient(settings)
                    .addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress("xxx.xxx.xxx.xxx", 9300)))
                    .addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress("xxx.xxx.xxx.xxx", 9300)))
                    .addTransportAddress(new InetSocketTransportAddress(new InetSocketAddress("xxx.xxx.xxx.xxx", 9300)));
            return client;
        } catch (Throwable e) {
            log.error("@@@@", e);
        }
        return client;
    }
}

注：Elasticsearch Http 端口和 TCP 端口不同，切勿写错。

3. 使用

@Autowired
private Client client;

SearchResponse searchResponse = client.prepareSearch("index").setQuery(
        QueryBuilders.boolQuery().should(xxx).should(xxx)
).get();
SearchHit[] hits = searchResponse.getHits().getHits();

参考连接

elasticsearch bool query combine must with OR - Stack Overflow
How to query for null values? - Elasticsearch - Grafana Community
elasticsearch - How to connect Elastic search 5.4 to tcp in java? - Stack Overflow
Issue with elastic search 5.0.0 - NoClassDefFoundError: org/apache/logging/log4j/Logger - Elasticsearch - Discuss the Elastic Stack
How to use Java API to build a nested query with filter query combination in 5.6.x? - Elasticsearch - Discuss the Elastic Stack
Combining bool and range queries - Elasticsearch - Discuss the Elastic Stack
[]( https://blog.csdn.net/qq_3216...
[]( https://blog.csdn.net/c511362...

原文 https://segmentfault.com/a/1190000020095485

正文到此结束