ES提供了多种编程语言的链接方式，有Java API，PHP API，.NET API

官网可以详细了解

https://www.elastic.co/guide/en/elasticsearch/client/index.html

下面阐述ES支持的客户端链接方式：

1：REST API

可以通过浏览器请求get方法进行链接；

利用Postman等工具发起REST请求；

Java发起HttpClient请求；

2：Transport链接

通过socket链接,用官网一个的TransPort客户端，底层是netty

特别提示：

ES在7.0版本开始将废弃TransportClient，8.0版本开始将完全移除TransportClient

取而代之的是High Level REST Client。

Java High Level REST Client 为高级别的Rest客户端，基于低级别的REST客户端，增加了编组请求JSON串，解析响应JSON串等相关API，使用的版本需要和ES服务端的版本保持一致，否则会有版本问题。

首先在使用Java REST Client的时候引入maven的Jar包依赖：

<dependency>

   <groupId>org.elasticsearch.client</groupId>

   <artifactId>elasticsearch-rest-high-level-client</artifactId>

   <version>6.2.4</version>

</dependency>

　　

将log4j2.xml编译到classes路径下

<?xml version="1.0" encoding="UTF-8"?>

<configuration status="OFF">

   <appenders>

       <Console name="Console" target="SYSTEM_OUT">

           <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/>

       </Console>

   </appenders>

   <loggers>

       <root level="info">

           <appender-ref ref="Console"/>

       </root>

   </loggers>

</configuration>

　　

Java High Level REST Client 初始化以及增加修改，批量操作使用示例：

package com.herbert.test;

import org.apache.commons.lang3.StringUtils;

import org.apache.http.HttpHost;

import org.elasticsearch.ElasticsearchException;

import org.elasticsearch.action.DocWriteRequest;

import org.elasticsearch.action.DocWriteResponse;

import org.elasticsearch.action.bulk.BulkItemResponse;

import org.elasticsearch.action.bulk.BulkRequest;

import org.elasticsearch.action.bulk.BulkResponse;

import org.elasticsearch.action.delete.DeleteResponse;

import org.elasticsearch.action.index.IndexRequest;

import org.elasticsearch.action.index.IndexResponse;

import org.elasticsearch.action.support.replication.ReplicationResponse;

import org.elasticsearch.action.update.UpdateResponse;

import org.elasticsearch.client.RestClient;

import org.elasticsearch.client.RestHighLevelClient;

import org.elasticsearch.common.xcontent.XContentType;

import org.elasticsearch.rest.RestStatus;

import java.io.IOException;

import java.util.*;

/**

* Created by Herbert on 2019/1/28.

*/

public class ESUtil {

   protected RestHighLevelClient client;

   /**

    * Java High Level REST Client  初始化

    */

   public ESUtil (){

       client = new RestHighLevelClient(

               RestClient.builder(

                       new HttpHost("localhost", 9200, "http")));

   }

   /**

    *  新增，修改文档

    * @param indexName  索引

    * @param type mapping type

    * @param id 文档id

    * @param jsonStr 文档数据

    */

   public void addData(String indexName,String type ,String id,String jsonStr) {

       try {

           // 1、创建索引请求  //索引  // mapping type  //文档id

           IndexRequest request = new IndexRequest(indexName, type, id);     //文档id

           // 2、准备文档数据

           // 直接给JSON串

           request.source(jsonStr, XContentType.JSON);

           //4、发送请求

           IndexResponse indexResponse = null;

           try {

               // 同步方式

               indexResponse = client.index(request);

           } catch (ElasticsearchException e) {

               // 捕获，并处理异常

               //判断是否版本冲突、create但文档已存在冲突

               if (e.status() == RestStatus.CONFLICT) {

                   System.out.println("冲突了，请在此写冲突处理逻辑！" + e.getDetailedMessage());

               }

           }

           //5、处理响应

           if (indexResponse != null) {

               String index1 = indexResponse.getIndex();

               String type1 = indexResponse.getType();

               String id1 = indexResponse.getId();

               long version1 = indexResponse.getVersion();

               if (indexResponse.getResult() == DocWriteResponse.Result.CREATED) {

                   System.out.println("新增文档成功!" + index1 + type1 + id1 + version1);

               } else if (indexResponse.getResult() == DocWriteResponse.Result.UPDATED) {

                   System.out.println("修改文档成功!");

               }

               // 分片处理信息

               ReplicationResponse.ShardInfo shardInfo = indexResponse.getShardInfo();

               if (shardInfo.getTotal() != shardInfo.getSuccessful()) {

                   System.out.println("分片处理信息.....");

               }

               // 如果有分片副本失败，可以获得失败原因信息

               if (shardInfo.getFailed() > 0) {

                   for (ReplicationResponse.ShardInfo.Failure failure : shardInfo.getFailures()) {

                       String reason = failure.reason();

                       System.out.println("副本失败原因：" + reason);

                   }

               }

           }

       } catch (Exception e) {

           e.printStackTrace();

       }

   }

   /**

    *  批量插入ES

    * @param indexName 索引

    * @param type 类型

    * @param idName id名称

    * @param list 数据集合

    */

   public void bulkDate(String indexName,String type ,String idName ,List<Map<String,Object>> list ){

       try {

           if(null == list || list.size()<=0){

               return;

           }

           if(StringUtils.isBlank(indexName) || StringUtils.isBlank(idName)  || StringUtils.isBlank(type)){

               return;

           }

           BulkRequest request = new BulkRequest();

           for(Map<String,Object> map : list){

               if(map.get(idName)!=null){

                   request.add(new IndexRequest(indexName, type, String.valueOf(map.get(idName)))

                           .source(map,XContentType.JSON));

               }

           }

           // 2、可选的设置

           /*

           request.timeout("2m");

           request.setRefreshPolicy("wait_for");

           request.waitForActiveShards(2);

           */

           //3、发送请求

           // 同步请求

           BulkResponse bulkResponse = client.bulk(request);

           //4、处理响应

           if(bulkResponse != null) {

               for (BulkItemResponse bulkItemResponse : bulkResponse) {

                   DocWriteResponse itemResponse = bulkItemResponse.getResponse();

                   if (bulkItemResponse.getOpType() == DocWriteRequest.OpType.INDEX

                           || bulkItemResponse.getOpType() == DocWriteRequest.OpType.CREATE) {

                       IndexResponse indexResponse = (IndexResponse) itemResponse;

                       //TODO 新增成功的处理

                       System.out.println("新增成功,{}"+ indexResponse.toString());

                   } else if (bulkItemResponse.getOpType() == DocWriteRequest.OpType.UPDATE) {

                       UpdateResponse updateResponse = (UpdateResponse) itemResponse;

                       //TODO 修改成功的处理

                       System.out.println("修改成功,{}"+ updateResponse.toString());

                   } else if (bulkItemResponse.getOpType() == DocWriteRequest.OpType.DELETE) {

                       DeleteResponse deleteResponse = (DeleteResponse) itemResponse;

                       //TODO 删除成功的处理

                       System.out.println("删除成功,{}"+ deleteResponse.toString());

                   }

               }

           }

       } catch (IOException e) {

           e.printStackTrace();

       }

   }

   public static void main(String ags[]){

       Map<String,Object> map1 = new HashMap<String, Object>();

       map1.put("id","2");

       map1.put("user1","bbherbert1");

       map1.put("postDate","2018-08-30");

       map1.put("username","aa");

       map1.put("message","message");

       Map<String,Object> map2 = new HashMap<String, Object>();

       map2.put("id","3");

       map2.put("user2","bbherbert1");

       map2.put("postDate","2018-08-30");

       map2.put("username","aa");

       map2.put("message","message");

       Map<String,Object> map = new HashMap<String, Object>();

       map.put("id","1");

       map.put("user","bbherbert1");

       map.put("postDate","2018-08-30");

       map.put("username","aa");

       map.put("message","message");

       List<Map<String,Object>> list = new ArrayList<Map<String, Object>>();

       list.add(map);

       list.add(map1);

       list.add(map2);

       ESUtil esUtil= new ESUtil();

       esUtil.bulkDate("book15","boo","id",list);

//        Map<String,Object> map = new HashMap<String, Object>();

//        map.put("user","herbert1");

//        map.put("postDate","2018-08-30");

//        map.put("username","aa");

//        map.put("message","message");

//        String jsonString = JSON.toJSONString(map);

//        esUtil.addData("hh","d","4",jsonString);

//        esUtil.addData("hh","d","4","{" +

//                "\"user\":\"kimchy\"," +

//                "\"postDate\":\"2013-01-30\"," +

//                "\"username\":\"zhangsan\"," +

//                "\"message\":\"trying out Elasticsearch\"" +

//                "}");

   }

}

上述简单的介绍了增加文档的操作示例。详情可参照官方API

最新文章

  1. L2 Population 原理 - 每天5分钟玩转 OpenStack（113）
  2. Linux命令（22）find的使用
  3. Geolocation
  4. struts2视频学习笔记 29-30（Struts 2常用标签，防止表单重复提交）
  5. Javascript模块化编程（三）：require.js的用法 （转）
  6. The Aggregate Magic Algorithms
  7. Linux Shell 脚本
  8. Razor视图引擎布局
  9. c# winfrom 委托实现窗体相互传值
  10. build.prop各种优化代码
  11. 常用LINUX脚本汇总（1）
  12. array_multisort 关联（string）键名保持不变，但数字键名会被重新索引。
  13. 两种设计模式和XML解析
  14. MySQL中间件之ProxySQL(8)：SQL语句的重写规则
  15. vue问题大全
  16. 最大似然估计实例 | Fitting a Model by Maximum Likelihood (MLE)
  17. 20 约束 异常处理 MD5 日志
  18. 认识hasLayout——IE浏览器css bug的一大罪恶根源
  19. HTTP 基础术语
  20. 基于kcp，consul的service mesh实现

热门文章

  1. Spring 插件安装
  2. Spring Boot中application.properties和application.yml文件
  3. （七）spring+druid多数据源配置
  4. CHI 2015大会：着眼于更加个性化的人机交互
  5. POJ 3522 用不同的排序方式
  6. Java 去掉字符串中的重复数据
  7. 算法设计与分析-Week12
  8. Hexo博客maupassant主题添加Google Adsense广告
  9. SGD与Adam识别MNIST数据集
  10. 做直播能有多赚钱，Python告诉你