分布式搜索elasticsearch java API 之(一)------与集群交互 - 云端分布式搜索技术 - 博客频道 - CSDN.NET
2014-11-04 22:14
741 查看
这是关于elasticsearch java api的第一篇教程,陆续会把es的一些心得写出来。
可以通过两种方式来连接到elasticsearch(简称es)集群,第一种是通过在你的程序中创建一个嵌入es节点(Node),使之成为es集群的一部分,然后通过这个节点来与es集群通信。第二种方式是用TransportClient这个接口和es集群通信。
Node方式
创建嵌入节点的方式如下:
[java]
view plaincopy
import static org.elasticsearch.node.NodeBuilder.*;
//启动节点
Node node = nodeBuilder().node();
Client client = node.client();
//关闭节点
node.close();
当你启动一个节点,它会自动加入同网段的es集群,一个前提就是es的集群名(cluster.name)这个参数要设置一致。
默认的话启动一个节点,es集群会自动给它分配一些索引的分片,如果你想这个节点仅仅作为一个客户端而不去保存数据,你就可以设置把node.data设置成false或 node.client设置成true。下面是例子:
[java]
view plaincopy
Node node = nodeBuilder().clusterName(clusterName).client(true).node();
还有一种情况是你并不想把节点加入集群,只想用它进行单元测试时,就要启动一个“本地”的es,这里“本地”指的是在jvm的级别下运行,即两个不同的es节点运行在同一个JVM中时会组成一个集群。它需要把节点的local参数设置成true,下面是例子:
[java]
view plaincopy
Node node = nodeBuilder().local(true).node();
TransportClient方式
参考:http://www.searchtech.pro/elasticsearch-glossary-explain
通过TransportClient这个接口,我们可以不启动节点就可以和es集群进行通信,它需要指定es集群中其中一台或多台机的ip地址和端口,例子如下:
[java]
view plaincopy
Client client = new TransportClient()
.addTransportAddress(new InetSocketTransportAddress("host1", 9300))
.addTransportAddress(new InetSocketTransportAddress("host2", 9300));
client.close();
如果你需要更改集群名(默认是elasticsearch),需要如下设置:
[java]
view plaincopy
Settings settings = ImmutableSettings.settingsBuilder()
.put("cluster.name", "myClusterName").build();
Client client = new TransportClient(settings);
你可以设置client.transport.sniff为true来使客户端去嗅探整个集群的状态,把集群中其它机器的ip地址加到客户端中,这样做的好处是一般你不用手动设置集群里所有集群的ip到连接客户端,它会自动帮你添加,并且自动发现新加入集群的机器。代码实例如下:
[java]
view plaincopy
Settings settings = ImmutableSettings.settingsBuilder()
.put("client.transport.sniff", true).build();
TransportClient client = new TransportClient(settings);
参考资料:http://www.searchtech.pro/articles/2013/02/18/1361194853254.html
可以通过两种方式来连接到elasticsearch(简称es)集群,第一种是通过在你的程序中创建一个嵌入es节点(Node),使之成为es集群的一部分,然后通过这个节点来与es集群通信。第二种方式是用TransportClient这个接口和es集群通信。
Node方式
创建嵌入节点的方式如下:
[java]
view plaincopy
import static org.elasticsearch.node.NodeBuilder.*;
//启动节点
Node node = nodeBuilder().node();
Client client = node.client();
//关闭节点
node.close();
当你启动一个节点,它会自动加入同网段的es集群,一个前提就是es的集群名(cluster.name)这个参数要设置一致。
默认的话启动一个节点,es集群会自动给它分配一些索引的分片,如果你想这个节点仅仅作为一个客户端而不去保存数据,你就可以设置把node.data设置成false或 node.client设置成true。下面是例子:
[java]
view plaincopy
Node node = nodeBuilder().clusterName(clusterName).client(true).node();
还有一种情况是你并不想把节点加入集群,只想用它进行单元测试时,就要启动一个“本地”的es,这里“本地”指的是在jvm的级别下运行,即两个不同的es节点运行在同一个JVM中时会组成一个集群。它需要把节点的local参数设置成true,下面是例子:
[java]
view plaincopy
Node node = nodeBuilder().local(true).node();
TransportClient方式
参考:http://www.searchtech.pro/elasticsearch-glossary-explain
通过TransportClient这个接口,我们可以不启动节点就可以和es集群进行通信,它需要指定es集群中其中一台或多台机的ip地址和端口,例子如下:
[java]
view plaincopy
Client client = new TransportClient()
.addTransportAddress(new InetSocketTransportAddress("host1", 9300))
.addTransportAddress(new InetSocketTransportAddress("host2", 9300));
client.close();
如果你需要更改集群名(默认是elasticsearch),需要如下设置:
[java]
view plaincopy
Settings settings = ImmutableSettings.settingsBuilder()
.put("cluster.name", "myClusterName").build();
Client client = new TransportClient(settings);
你可以设置client.transport.sniff为true来使客户端去嗅探整个集群的状态,把集群中其它机器的ip地址加到客户端中,这样做的好处是一般你不用手动设置集群里所有集群的ip到连接客户端,它会自动帮你添加,并且自动发现新加入集群的机器。代码实例如下:
[java]
view plaincopy
Settings settings = ImmutableSettings.settingsBuilder()
.put("client.transport.sniff", true).build();
TransportClient client = new TransportClient(settings);
参考资料:http://www.searchtech.pro/articles/2013/02/18/1361194853254.html
相关文章推荐
- 分布式搜索elasticsearch java API 之(一)------与集群交互
- 分布式搜索elasticsearch java API 之(一)------与集群交互
- 分布式搜索elasticsearch java API 之(一)------与集群交互
- 分布式搜索elasticsearch java API 之(一)------与集群交互
- AlteraFPGA使用通用SPIFlash - 张亚群的技术专栏 - 博客频道 - CSDN.NET
- android常用技术网站收藏过的网址 给 Android 开发者的 RxJava 详解 Android设备标识-没有完美的解决方案-只有取舍 - 小彼得的专栏 - 博客频道 - CSDN.NET
- CentOS安装python2.6 - 子剑灵学技术 - 博客频道 - CSDN.NET
- Ubuntu 16.04安装使用Docker - mickjoust 的 技术小屋 - 博客频道 - CSDN.NET
- 编写字符串反转函数 - 小小外星人的技术博客 - 博客频道 - CSDN.NET
- 网易视频云技术干货:分布式搜索elasticsearch集群监控工具bigdesk
- 分布式系统全链路监控方案设计 - chenglinhust的专栏 - 博客频道 - CSDN.NET
- clover分布式任务调度系统 - stark_summer的专栏 - 博客频道 - CSDN.NET
- 一个实际的Lisp项目开发心得 - albert_lee的产品技术空间 - 博客频道 - CSDN.NET
- [Hadoop] 实际应用场景之 - 百度 - Zhu_Julian's Notes (朱显杰的技术博客) - 博客频道 - CSDN.NET
- Redis Primer(1)基于JedisPool的Redis hset并发性能测试 - @钟超 · 技术博客专栏 - 博客频道 - CSDN.NET
- Python实现批量执行ArcGIS版本的协调和提交 - ArcGIS技术研究 - 博客频道 - CSDN.NET
- 技术积累-1( C技巧/GLib数据结构 ) - LeoWL的专栏 - 博客频道 - CSDN.NET
- 分布式搜索elasticsearch java API 之(六)------批量添加删除索引
- QTextCodec中的setCodecForTr等终于消失了 (Qt5) - 1+1=2 - 博客频道 - CSDN.NET
- 为 setuptools 开路搭桥 - 赖勇浩的编程私伙局 - 博客频道 - CSDN.NET