设为首页 收藏本站
查看: 980|回复: 0

[经验分享] elasticsearch java api

[复制链接]

尚未签到

发表于 2019-1-29 07:15:28 | 显示全部楼层 |阅读模式
  一、获取elasticsearch Client是简单的,最普遍的方法是创建连接cluster 的TransportClient。
  注意:这个client 的版本和你在电脑上打开的服务器的主要的版本是一样的(e.g. 2.x, or 5.x)

  The client must have the same major version (e.g. 2.x, or 5.x) as the nodes in the cluster. Clients may connect to clusters which have a different minor version (e.g.2.3.x) but it is possible that new functionality may not be supported.>  二、transportclient 创建
TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)  
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host1"), 9300))
  
        .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("host2"), 9300));
  

  
// on shutdown
  

  
client.close();
  Note that you have to set the cluster name if you use one different than "elasticsearch":
Settings settings = Settings.builder()  
        .put("cluster.name", "myClusterName").build();
  
TransportClient client = new PreBuiltTransportClient(settings);
  
//Add transport addresses and do something with the client...
  三、Document  APIS
  这部分描述的是增删改查。
  单个文档的APIS有Index API ,GET API, DELETE API,DELETE BY QUERY API,UPDATE API。
  多个文档APIS 有:Multi Get API ,Bulk API
  注意:All CRUD APIs are single-index APIs. The index parameter accepts a single index name, or an alias(别名) which points to a single index.
  Index API
  Index API 在特定的index中索引一个Json类型的文档。
  创建json文件有四种方式:

  •   Manually (手工)(aka do it yourself) using native byte[] or as a String
  •   Using a Map that will be automatically converted to its JSON equivalent(相等的)
  •   Using a third party library to serialize your beans such as Jackson
  •   Using built-in helpers XContentFactory.jsonBuilder()
  在内部,每种类型都转换为byte [](所以一个String被转换成一个byte [])。 因此,如果对象已经是这种形式,那么使用它。 jsonBuilder是高度优化的JSON生成器,它直接构造一个byte []。
  Using Map
edit
  Map is a key:values pair collection. It represents a JSON structure:
Map json = new HashMap();json.put("user","kimchy");json.put("postDate",new Date());json.put("message","trying out Elasticsearch");Use Elasticsearch helpersedit
  Elasticsearch provides built-in helpers to generate JSON content.
import static org.elasticsearch.common.xcontent.XContentFactory.*;XContentBuilder builder = jsonBuilder()  
    .startObject()
  
        .field("user", "kimchy")
  
        .field("postDate", new Date())
  
        .field("message", "trying out Elasticsearch")
  
    .endObject()
Index documentedit

  The following example indexes a JSON document into an index called twitter, under a type called tweet, with>import static org.elasticsearch.common.xcontent.XContentFactory.*;IndexResponse response = client.prepareIndex("twitter", "tweet", "1")  
        .setSource(jsonBuilder()
  
                    .startObject()
  
                        .field("user", "kimchy")
  
                        .field("postDate", new Date())
  
                        .field("message", "trying out Elasticsearch")
  
                    .endObject()
  
                  )
  
        .get();

  Note that you can also index your documents as JSON String and that you don’t have to give an>String json = "{" +  
        "\"user\":\"kimchy\"," +
  
        "\"postDate\":\"2013-01-30\"," +
  
        "\"message\":\"trying out Elasticsearch\"" +
  
    "}";IndexResponse response = client.prepareIndex("twitter", "tweet")
  
        .setSource(json)
  
        .get();
  IndexResponse object will give you a report:
// Index nameString _index = response.getIndex();// Type nameString _type = response.getType();// Document ID (generated or not)String _id = response.getId();// Version (if it's the first time you index this document, you will get: 1)long _version = response.getVersion();// status has stored current instance statement.RestStatus status = response.status();


运维网声明 1、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-668881-1-1.html 上篇帖子: Elasticsearch入门 下篇帖子: Elasticsearch 修改内存配置
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表