ElasticSearch学习（二）客户端TransportClient简单检索

拼搏现实的明天。 2022-01-28 08:39 391阅读 0赞

1、添加依赖

<dependency>
                <groupId>org.elasticsearch</groupId>
                <artifactId>elasticsearch</artifactId>
                <version>5.5.2</version>
            </dependency>
            <dependency>
                <groupId>org.elasticsearch.client</groupId>
                <artifactId>transport</artifactId>
                <version>5.5.2</version>
            </dependency>

2、application.properties配置文件

# es 配置
    spring.es.host=172.16.8.221
    spring.es.transport.port=9300
    spring.es.port=9200
    spring.es.cluster.name=application
    spring.es.index.auto.create=true

3、添加连接配置类

package com.scistor.elasticsearch;
    
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.transport.InetSocketTransportAddress;
    import org.elasticsearch.common.transport.TransportAddress;
    import org.elasticsearch.transport.client.PreBuiltTransportClient;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.net.InetAddress;
    import java.net.UnknownHostException;
    
    /**
     * @author lc
     * @description es 配置
     * @date 2019/3/26
     */
    @Configuration
    public class TransportClientConfig {
        // id地址
        @Value("${spring.es.host}")
        private String host;
        // 端口号
        @Value("${spring.es.transport.port}")
        private int transportPort;
        // 集群名字
        @Value("${spring.es.cluster.name}")
        private String clusterName;
        @Value("${spring.es.index.auto.create}")
        private boolean indexAutoCreate;
    
        @Bean
        public TransportClient getClient() throws UnknownHostException {
            TransportAddress node = new InetSocketTransportAddress(
                    InetAddress.getByName(host), transportPort    //ip
            );
            Settings setttings = Settings.builder()
                    .put("client.transport.sniff", indexAutoCreate)
                    .put("cluster.name", clusterName).build();
    
            TransportClient client = new PreBuiltTransportClient(setttings);
            client.addTransportAddress(node);
            return client;
        }
    
    }

4、简单检索

@Autowired
                private TransportClient transportClient;
    
    
                // 时间范围的设定
                RangeQueryBuilder rangequerybuilder = QueryBuilders.rangeQuery(createTime).from(startTime).to(endTime);
    
                // 根据事件名查询
                TermQueryBuilder termQuery = QueryBuilders.termQuery("c_event_id.keyword", eventId);
    
    
                // 查询条件封装
                BoolQueryBuilder boolBuilder = QueryBuilders.boolQuery();
                boolBuilder.must(rangequerybuilder);
                boolBuilder.must(termQuery);
    
    
                // 请求参数封装
                SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
                sourceBuilder.sort("c_time", SortOrder.DESC); // 按时间倒序排序
                sourceBuilder.query(boolBuilder);
                // 如果不指定查询量范围，ES默认只返回10条，这两个参数可以根据分页情况设定
                // sourceBuilder.from(0);
                // sourceBuilder.size(9);
    
    
                // 请求查询
                SearchRequest searchRequest = new SearchRequest("index_org_info");
                searchRequest.types("type001");
                searchRequest.source(sourceBuilder);
                SearchResponse response = transportClient.search(searchRequest).get();
    
    
                // 获取数据
                SearchHits hits = response.getHits();
                Map aptIdMap = jedisCluster.hgetAll(redis_aptid_key);
                for (SearchHit searchHit : hits.getHits()) {
                    String json = searchHit.getSourceAsString();
                }