ElasticSearch 集群连接方法 Java

蔚落 2022-05-21 11:29 178阅读 0赞

package com.ctpsp.custominfo.api.configuration;
    
    
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.network.InetAddresses;
    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.UnknownHostException;
    
    @Configuration
    public class ElasticSearchConfiguration {
        @Value("${elastic.esServerIps}")
        private String esServerIps;
        @Value("${elastic.port}")
        private int port;
    
        private static TransportClient  transPort = null;
    
        @Bean
        public TransportClient client() throws UnknownHostException {
    
            try {
    
                Settings settings = Settings.builder()
                        .put("cluster.name", "leon")
                        .build();
    
                transPort = new PreBuiltTransportClient(settings);
    
                String esIps[] = esServerIps.split(",");
                for (String esIp : esIps) {//添加集群IP列表
                    TransportAddress transportAddress =  new InetSocketTransportAddress(
                            InetAddresses.forString(esIp),
                            9300);
                    transPort.addTransportAddresses(transportAddress);
                }
    
                return transPort;
            }catch (Exception e){
                e.printStackTrace();
                if (transPort != null){
                    transPort.close();
                }
            }
            return null;
        }
    
    }

properties

elastic.esServerIps=192.168.1.21,192.168.1.21
    elastic.port= 9300