zoukankan      html  css  js  c++  java
  • transport方式连接Elasticsearch6.2.3

     连接ES有3中方式:

    ①transport方式

    ②rest方式

    ③JEST方式(第三方)

    我自己项目使用第一种方式,代码和配置如下: 

    1、引入依赖

    <dependency>
      <groupId>org.elasticsearch</groupId>
      <artifactId>elasticsearch</artifactId>
      <version>6.2.3</version>
    </dependency>

    <dependency>
      <groupId>org.elasticsearch.client</groupId>
      <artifactId>transport</artifactId>
      <version>6.2.3</version>
      <exclusions>
        <exclusion>
        <groupId>org.elasticsearch</groupId>
        <artifactId>elasticsearch</artifactId>
        </exclusion>
      </exclusions>
    </dependency>

    2、配置

    es.cluster-name=csmses
    es.ip=30.23.8.172,30.23.8.173,30.23.8.174,30.23.8.175,30.23.8.176
    es.port=9300
    es.pool=5

    3、代码

    /**
    * TransportClient方式连接ES
    * @author wangymd
    *
    */
    @Configuration
    public class EsConfig {

    private Log log = LogFactory.getLog(EsConfig.class);

    @Autowired
    private Environment env;

    @Bean
    public TransportClient transportClient() throws UnknownHostException{
      Settings settings = Settings.builder()
      .put("cluster.name", env.getProperty("es.cluster-name"))
      .put("client.transport.sniff", true)
      .put("thread_pool.search.size", Integer.valueOf(env.getProperty("es.pool")))
      .build();
      TransportClient esClient = new PreBuiltTransportClient(settings);
      String ipStr = env.getProperty("es.ip");//多个IP
      String port = env.getProperty("es.port");//端口一致9300
      log.info("@@@@@@@@TransportClient方式连接ES@@@@@@@@。IP:" + ipStr + ", PORT:" + port);
      String[] ips = ipStr.split(",");
      for (String ip : ips) {
        if(StringUtils.isNotEmpty(ip) && RegExpValidatorUtils.isIP(ip)){
          TransportAddress transportAddress = new TransportAddress(InetAddress.getByName(ip), Integer.valueOf(port));
          esClient.addTransportAddress(transportAddress);
        }
      }
      return esClient;
      }
    }

  • 相关阅读:
    Python中的除法
    使用Windows Live Writer 2012和Office Word 2013 发布文章到博客园全面总结
    单例模式(Singleton)的6种实现
    Linux关机命令总结
    Java中构造函数执行顺序的问题
    SVN四部曲之SVN命令精通
    SVN四部曲之SVN简单使用教程入门
    SVN四部曲之SVN使用详解进阶
    用正则表达式判断一个二进制数是否能被3整除
    栈帧%ebp,%esp详解
  • 原文地址:https://www.cnblogs.com/wangymd/p/11264172.html
Copyright © 2011-2022 走看看