TransportClient 使用传输模块来远程连接一个elasticsearch集群;
区别与 node client模式,transportClient是不会加入集群中的。
// on startupClient client = new TransportClient() .addTransportAddress(new InetSocketTransportAddress("host1", 9300)) .addTransportAddress(new InetSocketTransportAddress("host2", 9300));// on shutdownclient.close();
或者你可以指定一个集群的名称:
Settings settings = ImmutableSettings.settingsBuilder() .put("cluster.name", "myClusterName").build();Client client = new TransportClient(settings);
或者使用配置文件的方式(参考nodeClient方式)定义集群的名称。
如果设置client.transport.sniff为true,则表示客户端去嗅探整个cluster的状态,把集群中其它机器的ip地址加到客户端中,这样做的好处是一般你不用手动设置集群里所有集群的ip到连接客户端,它会自动帮你添加,并且自动发现新加入集群的机器。Settings settings = ImmutableSettings.settingsBuilder() .put("client.transport.sniff", true).build();TransportClient client = new TransportClient(settings);
但是至少添加一个InetSocketTransportAddress,否则会出现异常:org.elasticsearch.client.transport.NoNodeAvailableException: No node
available。