java操作ElasticSearch（es）进行增删查改操作

2017-10-26 539

ElasticSearch(名称太长，后面简称ES)作为一个搜索引擎，目前可谓是如日中天，几乎和solr齐驾并驱。关于他能做什么，跟云计算有什么关系，在此不再描述。但是ES的官方文档，特别是关于java的客户端文档，真是少的可怜，甚至连个完整的增删改的示例都没有。在此，我就献丑了。

在开始讲解之前，还是先做个铺垫，为了能够有一个可以索引的模型，我们自定义了一个模型，暂时起个名称叫LogModel吧，这个模型有各种数据类型，int,long,String,list，但千万不要认为这是跟记录日志有关的一个模型。作为索引的一个最简单模型。代码如下：

    Java代码  
     
   
 import java.util.ArrayList;   
 import java.util.List;   
 import java.util.Random;   
 import java.util.UUID;   
 /**  
  * 瞎编的一个模型，跟日志基本没有关系  
  * @author donlian  
  */   
 public class LogModel {   
     //主ID   
     private long id;   
     //次ID   
     private int subId;   
     /**  
      * 系统名称  
      */   
     private String systemName;   
     private String host;   
        
     //日志描述   
     private String desc;   
     private List<Integer> catIds;   
     public LogModel(){   
         Random random = new Random();   
         this.id = Math.abs(random.nextLong());   
         int subId = Math.abs(random.nextInt());   
         this.subId = subId;   
         List<Integer> list = new ArrayList<Integer>(5);   
         for(int i=0;i<5;i++){   
             list.add(Math.abs(random.nextInt()));   
         }   
         this.catIds = list;   
         this.systemName = subId%1 == 0?"oa":"cms";   
         this.host = subId%1 == 0?"10.0.0.1":"10.2.0.1";   
         this.desc = "中文" + UUID.randomUUID().toString();   
     }   
     public LogModel(long id,int subId,String sysName,String host,String desc,List<Integer> catIds){   
         this.id = id;   
         this.subId = subId;   
         this.systemName = sysName;   
         this.host = host;   
         this.desc = desc;   
         this.catIds = catIds;   
     }   
 ...//省去get,set方法   
 }   

同时，因为ES在索引的时候，一般都用json格式，因此，使用jackson定义了一个将对象转化成json的工具类，也很简单，代码：

    Java代码  
     
   
 public class ESUtils {   
     private static ObjectMapper objectMapper = new ObjectMapper();   
     public static String toJson(Object o){   
         try {   
             return objectMapper.writeValueAsString(o);   
         } catch (JsonProcessingException e) {   
             e.printStackTrace();   
         }   
         return "";   
     }   
 }   

在开始进行操作ES服务器之前，我们必须得获得ES的API，简单介绍一下ES操作服务器的两种方式，一种是使用Node方式，即本机也启动一个ES，然后跟服务器的ES进行通信，这个node甚至还能存储（奇怪，一般需要这样的方式吗？），另一种，就是下面我介绍的这一种，通过一个对象使用http协议跟服务器进行交互。

获得一个ES客户端API的代码如下：

    Java代码  
     
   
 Settings settings = ImmutableSettings.settingsBuilder()   
                 //指定集群名称   
                 .put("cluster.name", "elasticsearch")   
                 //探测集群中机器状态   
                 .put("client.transport.sniff", true).build();   
         /*  
          * 创建客户端，所有的操作都由客户端开始，这个就好像是JDBC的Connection对象  
          * 用完记得要关闭  
          */   
         Client client = new TransportClient(settings)   
         .addTransportAddress(new InetSocketTransportAddress("192.168.1.106", 9300));   

Client对象，可以理解为数据库的Connection对象。好了，准备工作完成，下面就开始增删改查。

Index(增加）

ES里面的增加对象不叫什么add,save等，叫index。但无论叫什么名称，反正就是向ES服务器里面加数据。上面说过一个对象转json的工具类，其实ES的API中，是自带构建json的工具类的。

    Java代码  
     
   
 import org.elasticsearch.action.index.IndexResponse;   
 import org.elasticsearch.client.Client;   
 import org.elasticsearch.client.transport.TransportClient;   
 import org.elasticsearch.common.settings.ImmutableSettings;   
 import org.elasticsearch.common.settings.Settings;   
 import org.elasticsearch.common.transport.InetSocketTransportAddress;   
    
 import com.donlianli.es.ESUtils;   
 import com.donlianli.es.model.LogModel;   
 /**  
  * 向ES添加索引对象  
  * @author donlian  
  */   
 public class IndexTest {   
     public static void main(String[] argv){   
         Settings settings = ImmutableSettings.settingsBuilder()   
                 //指定集群名称   
                 .put("cluster.name", "elasticsearch")   
                 //探测集群中机器状态   
                 .put("client.transport.sniff", true).build();   
         /*  
          * 创建客户端，所有的操作都由客户端开始，这个就好像是JDBC的Connection对象  
          * 用完记得要关闭  
          */   
         Client client = new TransportClient(settings)   
         .addTransportAddress(new InetSocketTransportAddress("192.168.1.106", 9300));   
         String json = ESUtils.toJson(new LogModel());   
         //在这里创建我们要索引的对象   
         IndexResponse response = client.prepareIndex("twitter", "tweet")   
                 //必须为对象单独指定ID   
                 .setId("1")   
                 .setSource(json)   
                 .execute()   
                 .actionGet();   
         //多次index这个版本号会变   
         System.out.println("response.version():"+response.version());   
         client.close();   
     }   
 }   

运行这个代码，就向ES插入了一条数据，你运行两遍，还是一条。ES根据你设置的ID来设置对象，如果没有则插入，有则更新。每更新一次，对应的version加1.

好了，在次，使用以下命令，应该能够查询到一条记录了。

    Java代码  
     
 curl -XGET 'http://localhost:9200/twitter/tweet/1'

delete(删除）

有了增加的例子，删除的例子也就好写了。增加是prepareIndex，删除是prepareDelete,查询就是PrepareGet。

代码如下：

    Java代码  
     
   
 import org.elasticsearch.action.delete.DeleteResponse;   
 import org.elasticsearch.client.Client;   
 import org.elasticsearch.client.transport.TransportClient;   
 import org.elasticsearch.common.settings.ImmutableSettings;   
 import org.elasticsearch.common.settings.Settings;   
 import org.elasticsearch.common.transport.InetSocketTransportAddress;   
    
 import com.donlianli.es.ESUtils;   
    
 public class DeleteTest {   
     public static void main(String[] argv){   
         Settings settings = ImmutableSettings.settingsBuilder()   
                 //指定集群名称   
                 .put("cluster.name", "elasticsearch")   
                 //探测集群中机器状态   
                 .put("client.transport.sniff", true).build();   
         /*  
          * 创建客户端，所有的操作都由客户端开始，这个就好像是JDBC的Connection对象  
          * 用完记得要关闭  
          */   
         Client client = new TransportClient(settings)   
         .addTransportAddress(new InetSocketTransportAddress("192.168.1.106", 9300));   
         //在这里创建我们要索引的对象   
         DeleteResponse response = client.prepareDelete("twitter", "tweet", "1")   
                 .execute().actionGet();   
         System.out.println(response.getId());   
         System.out.println(ESUtils.toJson(response.getHeaders()));   
     }   
 }   

GET(查询）

    Java代码  
     
   
 import org.elasticsearch.action.get.GetResponse;   
 import org.elasticsearch.client.Client;   
 import org.elasticsearch.client.transport.TransportClient;   
 import org.elasticsearch.common.settings.ImmutableSettings;   
 import org.elasticsearch.common.settings.Settings;   
 import org.elasticsearch.common.transport.InetSocketTransportAddress;   
    
 public class GetTest {   
     public static void main(String[] argv){   
         Settings settings = ImmutableSettings.settingsBuilder()   
                 //指定集群名称   
                 .put("cluster.name", "elasticsearch")   
                 //探测集群中机器状态   
                 .put("client.transport.sniff", true).build();   
         /*  
          * 创建客户端，所有的操作都由客户端开始，这个就好像是JDBC的Connection对象  
          * 用完记得要关闭  
          */   
         Client client = new TransportClient(settings)   
         .addTransportAddress(new InetSocketTransportAddress("192.168.1.106", 9300));   
         //在这里创建我们要索引的对象   
         GetResponse response = client.prepareGet("twitter", "tweet", "1")   
                 .execute().actionGet();   
         System.out.println("response.getId():"+response.getId());   
         System.out.println("response.getSourceAsString():"+response.getSourceAsString());   
     }   
 }   

好了，增删改查的代码写完。至于搜索，那是一个比较深入的话题，我也在慢慢探索。我时间我会继续写下去。

原文网址：http://donlianli.iteye.com/blog/1902238

微信关注我们

原文链接：https://yq.aliyun.com/articles/662177

转载内容版权归作者及来源网站所有！

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

开源大数据周刊-第70期

资讯：推动云基础设施创新，英特尔与阿里云的“软硬合唱” 对于一家云服务厂商来说，实现软件、服务与硬件基础设施的完美整合，是在激烈市场竞争中的关键点。微软开源用于Spark的深度学习库MMLSpark微软开源了MMLSpark，用于Apache Spark的的深度学习库。MMLSpark可以与微软认知工具包和OpenCV完美整合。微软发现，虽然SparkML可以建立可扩展的机器学习平台，绝大多数开发者的精力都耗在了调用底层API上。MMLSpark 旨在简化 PySpark 中的重复性工作。 CRI-O 1.0 正式发布CRI-O让你可以直接从Kubernetes来运行容器，无需任何不必要的代码或工具。只要容器符合OCI，CRI-O就可以运行它，摈弃了非必要的工具，让容器一心处理它最擅长的方面：运行下一代云原生应用程序。技术利用

2017-10-27

598

Hbase 配置流程

配置Hbase之前需要先配置一下ZooKeeper.在每台服务器的hosts文件中添加192.168.111.200 master192.168.111.199 slave1192.168.111.198 slave2如果在之前装集群的时候已经配置过了那么就不用再配置了随便在某一台上解压zookeeper文件zoopeeker文件可在官网上下载下载好将压缩文件上传到任意一台linux系统上tar -zxvf zookeeper-3.4.8.tar.gz解压完之后配置/etc/profile文件(我是将文件解压到了/opt/SofteWare文件下) #zookeeper export ZOOKEEPER=/opt/SoftWare/zookeeper/zookeeper-3.4.8 export PATH=$PATH:$ZOOKEEPER/bin 然后执行source /etc/profile指令更新进入刚解压完的文件下的conf目录下mkdir zoo.cfg文件然后 cp zoo_sample.cfg zoo.cfg修改里面的dataDir =//opt/SoftWare/zoo...

2017-10-28

552

发表评论

资源下载

更多资源

优质分享App

近一个月的开发和优化，本站点的第一个app全新上线。该app采用极致压缩，本体才4.36MB。系统里面做了大量数据访问、缓存优化。方便用户在手机上查看文章。后续会推出HarmonyOS的适配版本。

Oracle

Oracle Database，又名Oracle RDBMS，或简称Oracle。是甲骨文公司的一款关系数据库管理系统。它是在数据库领域一直处于领先地位的产品。可以说Oracle数据库系统是目前世界上流行的关系数据库管理系统，系统可移植性好、使用方便、功能强，适用于各类大、中、小、微机环境。它是一种高效率、可靠性好的、适应高吞吐量的数据库方案。

Apache Tomcat

Tomcat是Apache 软件基金会（Apache Software Foundation）的Jakarta 项目中的一个核心项目，由Apache、Sun 和其他一些公司及个人共同开发而成。因为Tomcat 技术先进、性能稳定，而且免费，因而深受Java 爱好者的喜爱并得到了部分软件开发商的认可，成为目前比较流行的Web 应用服务器。

Sublime Text

Sublime Text具有漂亮的用户界面和强大的功能，例如代码缩略图，Python的插件，代码段等。还可自定义键绑定，菜单和工具栏。Sublime Text 的主要功能包括：拼写检查，书签，完整的 Python API ， Goto 功能，即时项目切换，多选择，多窗口等等。Sublime Text 是一个跨平台的编辑器，同时支持Windows、Linux、Mac OS X等操作系统。