zoukankan      html  css  js  c++  java
  • 使用java如何操作elasticsearch?简单示例。

    在线API:
    https://www.elastic.co/guide/en/elasticsearch/client/java-api/2.4/transport-client.html
    教程:
    http://blog.java1234.com/blog/articles/345.html
    注意:
    不同版本的ES API差别较大,引入jar包版本一定要和生产保持一致。工具类及使用方法可以参考备件系统项目:源码见GitHub
    工具类及使用方法可以参考备件系统项目:源码见GitHub

     

    引入jar包:

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

    写测试类:

    package com.sxt.es.test;
    
    import java.net.InetAddress;
    import java.util.Date;
    
    import org.elasticsearch.action.index.IndexResponse;
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.transport.InetSocketTransportAddress;
    import org.elasticsearch.common.xcontent.XContentFactory;
    
    
    public class Testes {
        
        private static String host="192.168.136.131"; // 服务器地址
        private static int port=9300; // 端口
        
        public static void main(String[] args) throws Exception {
            
            TransportClient client = TransportClient.builder().build()
                    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(Testes.host), Testes.port));
            IndexResponse response =client.prepareIndex("twitter", "tweet", "1")
                    .setSource(XContentFactory.jsonBuilder()
                            .startObject()
                            .field("user", "kimchy")
                            .field("postDate", new Date())
                            .field("message", "trying out Elasticsearch")
                        .endObject()
                            )
                    .get();
                System.out.println("索引名称:"+response.getIndex());
                System.out.println("类型:"+response.getType());
                System.out.println("文档ID:"+response.getId()); // 第一次使用是1
            client.close();
        }
    }
  • 相关阅读:
    Joomla 3.9.13 二次注入分析(CVE-2019-19846)
    Wordpress未授权查看私密内容漏洞 分析(CVE-2019-17671)
    Thinkphp 5.1.24 parseKey缺陷导致聚合注入 分析
    Thinkphp 5.1.7 parseData缺陷导致insert/update注入 分析
    Oracle笔记2
    Oracle笔记1
    k8s之helm入门
    k8s之自定义指标API部署prometheus
    k8s之资源指标API部署metrics-server
    k8s之调度器、预选策略及优选函数
  • 原文地址:https://www.cnblogs.com/xyhero/p/9339189.html
Copyright © 2011-2022 走看看