本篇文章將介紹怎樣使用 java 對 ElasticSearch 進行操作。
首先需要建立一個 maven 專案，這裡不再贅述。
1.在maven 的 pom.xml檔案中需要引入以下幾個 jar 包

<dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>transport</artifactId>
        <version>5.6.3</version>
</dependency
 
>
<dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId>log4j-api</artifactId>
        <version>2.9.1</version>
</dependency>
<dependency>
        <groupId>org.apache.logging.log4j</groupId>
        <artifactId
 
>log4j-core</artifactId>
        <version>2.9.1</version>
</dependency>

2.在 resources 目錄下新增log4j2.properties檔案

appender.console.type = Console
appender.console.name = console
appender.console.layout.type = PatternLayout

rootLogger.level = info
rootLogger.appenderRef.console
 
.ref = console

3.使用TransportClient連線 ElasticSearch。

Settings settings = Settings.builder().put("cluster.name", "leo").build();
TransportClient client = new PreBuiltTransportClient(settings). addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("***.***.***.***"), 9300));
//***.***.***.*** 表示 ip 地址，本地的話，可以使用 localhost，9300是預設的 api 訪問介面

4.建立索引
使用 json檔案來建立索引，生成 json 檔案的方式有多種，字串格式、利用 Map、利用jackson 序列化 beans 到 json、使用 ElasticSearch helps生成(我使用的方式，其它方式實現可參看官方文件)

IndexResponse response = client.prepareIndex("books", "book", "1")
                        .setSource(jsonBuilder().
                                startObject()
                                .field("book_name", "ElasticSearch入門")
                                .field("author", "張三")
                                .field("publish_time", "207-09-09")
                               .endObject())
                        .get();

5.獲取索引

GetResponse getResponse = client.prepareGet("books", "book", "1").execute().actionGet();
        System.out.println(getResponse.getSourceAsString());

6.更新索引

UpdateRequest updateRequest = new UpdateRequest();
updateRequest.index("books");
updateRequest.type("book");
updateRequest.id("1");
updateRequest.doc(jsonBuilder().startObject().field("author", "李四").endObject());
try {
    client.update(updateRequest).get();
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    e.printStackTrace();
}

執行後發現作者從“張三”更新為“李四”了。
7.刪除索引

DeleteResponse response = client.prepareDelete("books", "book", "1").get();

索引被刪除。