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

2017-10-26 556

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

616

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

569

发表评论

资源下载

更多资源

Mario

马里奥是站在游戏界顶峰的超人气多面角色。马里奥靠吃蘑菇成长，特征是大鼻子、头戴帽子、身穿背带裤，还留着胡子。与他的双胞胎兄弟路易基一起，长年担任任天堂的招牌角色。

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题，腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构，目前腾讯云软件源站支持公网访问和内网访问。

Spring

Spring框架（Spring Framework）是由Rod Johnson于2002年提出的开源Java企业级应用框架，旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念，提供核心容器、应用上下文、数据访问集成等模块，支持整合Hibernate、Struts等第三方框架，其适用范围不仅限于服务器端开发，绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux（中文名：洛基）是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版，作为CentOS稳定版停止维护后与RHEL（Red Hat Enterprise Linux）完全兼容的开源替代方案，由社区拥有并管理，支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性，采用模块化包装和SELinux安全架构，默认包含GNOME桌面环境及XFS文件系统，支持十年生命周期更新。