zoukankan      html  css  js  c++  java
  • java api 调用es集群(1.7版本)

    public static void main(String[] args) {
    Settings settings = ImmutableSettings.settingsBuilder()
    // client.transport.sniff=true
    // 客户端嗅探整个集群的状态,把集群中其它机器的ip地址自动添加到客户端中,并且自动发现新加入集群的机器
    .put("client.transport.sniff", true).put("client", true)// 仅作为客户端连接
    .put("data", false).put("cluster.name", "elasticsearch")// 集群名称
    .build();
    TransportClient client = new TransportClient(settings).addTransportAddress(new InetSocketTransportAddress("192.168.10.140", 9300))// TCP
    // 连接地址
    .addTransportAddress(new InetSocketTransportAddress("192.168.10.124", 9300));

    List<String> jsonData = BlogController.initData();
    String json = "{" + ""user":"金旭东"," + ""postDate":"2013-01-30"," + ""message":"测试elsaticsearch"" + "}";
    for (int i = 0; i < 1; i++) {
    IndexResponse response = client.prepareIndex("blog", "article").setSource(json).get();
    if (response.isCreated()) {
    System.out.println("创建成功!");
    }
    }
    client.close();
    }

  • 相关阅读:
    阅读笔记(四)——《代码整洁之道》1
    阅读笔记(一)——《需求工程——软件建模与分析》一
    数据提取
    HIVE数据清洗练习
    第八周hadoop-MapReduce
    小程序新增页面导航栏
    个人课程总结
    第十六周总结

    排序
  • 原文地址:https://www.cnblogs.com/coderdxj/p/6547154.html
Copyright © 2011-2022 走看看