ElasticSearch 之 Client

在使用ElasticSearch的时候,我们需要与Cluster通信,Java版本的API提供了几种方式来构造Client,进而通过Client操作Cluster。

1)使用Node与clustor通信

原理:通过在程序中创建一个嵌入es节点(Node),使之成为ElasticSearch集群的一部分,然后通过这个节点来与ElasticSearch集群通信。

最简单的方式:

Node node = NodeBuilder.nodeBuilder().node();

Client client = node.client();

配置cluster集群名称的方式:

(1)配置文件里边配置:/src/main/resources/elasticsearch.yml
 添加:cluster.name=yourclustername

(2)代码里边设置: Node node =
NodeBuilder.nodeBuilder().clusterName("yourclustername").node();

默认的话启动一个节点,es集群会自动给它分配一些索引的分片,
此时可能会出现一些问题,例如:如果初始化Map的时候,需要分词插件,而本地又没有,就会报错。如果你想这个节点仅仅作为一个客户端而不去保存数据,
你就可以设置把node.data设置成false或node.client设置成true。如:NodeBuilder.nodeBuilder().client(true).node();    此时,就不会出现上面的错误。

还有一种情况是你并不想把节点加入集群,只想用它进行单元测试时,就要启动一个”本地”的es,这里“本地”指的是在jvm的级别下运行,即两个不同的es节点运行在同一个JVM中时会组成一个集群。它需要把节点的local参数设置成true

Node node = NodeBuilder.nodeBuilder().local(true).node();      ???

2)使用TransportClient 与cluster通信

Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name",
"xg-elasticsearch").put("client.transport.sniff", true).build();

TransportClient transportClient = new
TransportClient(settings);

transportClient.addTransportAddress(new
InetSocketTransportAddress("192.168.1.16", 9300));

cluster.name
表示:集群的名称,默认为 elasticsearch,可以在ElasticSearch对应的目录elasticsearch\config\下的elasticsearch.yml文件中修改。

如果设置client.transport.sniff为true,则表示客户端去嗅探整个cluster的状态,把集群中其它机器的ip地址加到客户端中,这样做的好处是一般你不用手动设置集群里所有集群的ip到连接客户端,它会自动帮你添加,并且自动发现新加入集群的机器。

但是至少添加一个InetSocketTransportAddress,否则会出现异常:org.elasticsearch.client.transport.NoNodeAvailableException:
No node
available。这里给出了解释:https://groups.google.com/forum/#!topic/elasticsearch/TkEm068KJyo

意思就是至少手动添加一个节点,而 当client.transport.sniff
设置为true的时候,其做的是会把其它的在同一cluster中的其它的node添加进来。据说:同一cluster下的所有node需要在同一网段下面,待证实。


要注意的是:客户端和集群的cluster的版本需要一致。否则会出现不兼容的问题。

在使用过程中,不要重复构造Client对象,应该使用单例复用。

关于Client的官方文档:http://www.elasticsearch.org/guide/en/elasticsearch/client/java-api/current/client.html

ElasticSearch 之 Client,码迷,mamicode.com

时间: 2024-11-03 21:28:50

ElasticSearch 之 Client的相关文章

Elasticsearch .net client NEST使用说明 2.x

Elasticsearch .net client NEST使用说明 2.x 引用 Install-Package NEST Connection链接 //单node Var node = new Uri(“……”); var settings = new ConnectionSettings(node); //多node Var nodes = new Uri [] { new Uri(“……”), new Uri(“……”) }; //多node Var nodes = new Node [

elasticsearch系列七:ES Java客户端-Elasticsearch Java client(ES Client 简介、Java REST Client、Java Client、Spring Data Elasticsearch)

一.ES Client 简介 1. ES是一个服务,采用C/S结构 2. 回顾 ES的架构 3. ES支持的客户端连接方式 3.1 REST API ,端口 9200 这种连接方式对应于架构图中的RESTful style API这一层,这种客户端的连接方式是RESTful风格的,使用http的方式进行连接 3.2 Transport 连接 端口 9300 这种连接方式对应于架构图中的Transport这一层,这种客户端连接方式是直接连接ES的节点,使用TCP的方式进行连接 4. ES提供了多种

(转)Elasticsearch .net client NEST使用说明 2.x

Elasticsearch.Net与NEST是Elasticsearch为C#提供的一套客户端驱动,方便C#调用Elasticsearch服务接口.Elasticsearch.Net是较基层的对Elasticsearch服务接口请求响应的实现,NEST是在前者基础之上进行的封装.本文是针对NEST的使用的总结. 引用 Install-Package NEST 包含以下dll NEST.dll Elasticsearch.Net.dll   Newtonsoft.Json.dll 概念 存储结构:

Elasticsearch之client源码简要分析

问题 让我们带着问题去学习,效率会更高 1  es集群只配置一个节点,client是否能够自动发现集群中的所有节点?是如何发现的? 2  es client如何做到负载均衡? 3  一个es node挂掉之后,es client如何摘掉该节点? 4  es client node检测分为两种模式(SimpleNodeSampler和SniffNodesSampler),有什么不同? 核心类 TransportClient    es client对外API类 TransportClientNod

写个Elasticsearch的client库简化操作

[TestMethod] public void Analyze() { string[] d = mIndex.Analyze("c# socket", "ik"); } [TestMethod] public void match() { IList<Blog> items = mIndex.Query<Blog>(q => q.Match(new SearchMatch { field = "title", q

自定义Flume Sink:ElasticSearch Sink

Flume Sink的目的是从Flume Channel中获取数据然后输出到存储或者其他Flume Source中.Flume Agent启动的时候,它会为每一个Sink都启动一个SinkRunner的对象,SinkRunner.start()方法会启动一个新的线程去管理每一个Sink的生命周期.每一个Sink需要实现start().Stop()和process()方法.你可以在start方法中去初始化Sink的参数和状态,在stop方法中清理Sink的资源.最关键的是process方法,它将处

ElasticSearch Index API &amp;&amp; Mapping

ElasticSearch  NEST Client 操作Index var indexName="twitter"; var deleteIndexResponse = client.DeleteIndex(indexName);                var createIndexResponse = client.CreateIndex(indexName);                var getIndexResponse = client.GetIndex(in

elasticsearch java 客户端之action简介

上一篇介绍了elasticsearch的client结构,client只是一个门面,在每个方法后面都有一个action来承接相应的功能.但是action也并非是真正的功能实现者,它只是一个代理,它的真正实现者是transportAction.本篇就对action及transportAction的实现做一个简单的分析, elasticsearch中的绝大部分操作都是通过相应的action,这些action在action包中.它的结构如下图所示: 上图是action包的部分截图,这里面对应着各个功能

Spring Boot + Elasticsearch

spring data elasticsearch elasticsearch 2.0.0.RELEASE 2.2.0 1.4.0.M1 1.7.3 1.3.0.RELEASE 1.5.2 1.2.0.RELEASE 1.4.4 1.1.0.RELEASE 1.3.2 1.0.0.RELEASE https://github.com/helloworldtang/spring-data-elasticsearch 1.None of the configured nodes are availa