当前位置 : 主页 > 编程语言 > java >

elasticsearch transportclient

来源:互联网 收集:自由互联 发布时间:2021-06-28
gistfile1.txt @Configurationpublic class ESConfiguration { private TransportClient client; @Bean public TransportClient esTransportClient() throws UnknownHostException { Settings settings = Settings.builder() .put("client.transport.nodes_sa
gistfile1.txt
@Configuration
public class ESConfiguration {

    private TransportClient client;

    @Bean
    public TransportClient esTransportClient() throws UnknownHostException {

        Settings settings = Settings.builder()
                .put("client.transport.nodes_sampler_interval", "5s")
                .put("client.transport.sniff", false)
                .put("transport.tcp.compress", true)
                .put("cluster.name", "elasticsearch")
                .build();

        client = new PreBuiltTransportClient(settings);

        client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getLocalHost(), 9300));

        return client;
    }
}
网友评论