節(jié)點客戶端(node client):
節(jié)點客戶端本身也是一個ES節(jié)點(一般不保存數(shù)據(jù)菜职,不能成為主節(jié)點),它能以無數(shù)據(jù)節(jié)點身份加入到集群中旗闽。因為它是集群環(huán)境中的一個節(jié)點酬核,所以它知道整個集群狀態(tài)(所有節(jié)點駐留,分片分布在哪些節(jié)點等等)适室, 可以把需要執(zhí)行的操作自動路由到節(jié)點上嫡意,而少一個網(wǎng)絡躍點。
Node node = NodeBuilder.nodeBuilder().local(true).node() ;
Client client = node.client();
GetResponse getResponse = client.prepareGet(index,type,"2").get();
System.out.println(JSONObject.toJSONString(getResponse));
當你啟動node時捣辆,你可以在你的項目/src/main/resources/elasticsearch.yml文件中定義簡單的設置cluster.name或者明確地使用clusterName
方法來加入到指定的集群中蔬螟。
使用elasticsearch.yml的方式: cluster.name: yourclustername
通過Java的方式:
Node node = NodeBuilder.nodeBuilder().clusterName("elasticsearch").local(true).node() ;
使用節(jié)點客戶端的好處是,操作可以自動地路由到這些操作被執(zhí)行的節(jié)點汽畴,而不需要執(zhí)行雙跳(double hop)旧巾。例如,索引操作將會在該操作最終存在的分片上執(zhí)行忍些。
當你啟動了一個節(jié)點鲁猩,最重要的決定是它是否將保有數(shù)據(jù)。大多數(shù)情況下坐昙,我們僅僅需要用到clients绳匀,而不需要分片分配給它們。這可以通過設置node.data
為false
或者設置node.local
為true
來簡單實現(xiàn)炸客。
Node node = NodeBuilder.nodeBuilder().local(true).node() ;
Client client = node.client();
傳輸客戶端(Transport Client)
作為更輕量的傳輸客戶端能夠請求到遠程集群疾棵。它自己不加入集群,只是簡單的獲得一個或者多個初始化的transport
地址痹仙,并以輪詢的方式與這些地址進行通信是尔。比較像傳統(tǒng)的CS程序的架構,比如數(shù)據(jù)庫連接开仰。
Settings settings = Settings.builder()
.put("cluster.name","my-application") .build();
TransportClient client = TransportClient.builder()
.settings(settings).build()
.addTransportAddress(newInetSocketTransportAddress(InetAddress.getByName("ip"),9300));
傳輸客戶端可以嗅到集群的其他部分拟枚,并將它們加入到機器列表薪铜。為了開啟該功能,可以設置client.transport.sniff
為true
恩溅。
其他的transfersport客戶端設置有如下幾個:
client.transport.ignore_cluster_name
:true
:忽略連接節(jié)點的集群名驗證
client.transport.ping_timeout
一個節(jié)點的響應時間隔箍,默認是5s
client.transport.nodes_sampler_intervalsample/ping
節(jié)點的時間間隔,默認是5s
節(jié)點客戶端與傳輸客戶端的區(qū)別
- 第一種方式脚乡,相當于額外啟動了一個ES的
node
節(jié)點蜒滩,這個節(jié)點和集群中的其他節(jié)點沒有任何區(qū)別。只是這個node
是由我們編碼控制的奶稠,可以設置這個node
是不存數(shù)據(jù)的節(jié)點(沒有特殊原因你就應該這個設置)俯艰。
- 第二種方法,相當于獲取了所有
node
節(jié)點的client
锌订,發(fā)送請求的時候遍歷當前可用的client
(這里可用指的是可以連接竹握,但是node
本身不一定可用,比如node
正在恢復中啦辐,還沒有加入到集群,這就會產(chǎn)生問題昧甘。)跟方法一相比战得,方法二會產(chǎn)生雙跳(double hop)庸推,即當前遍歷到node1,但訪問的數(shù)據(jù)在node2聋亡,請求先轉發(fā)到node1际乘,又由node1轉發(fā)到node2。
遍歷方式:每次請求通過AtomicInteger
進行原子加1(超過最大值后設置為0)脖含,按當前可用client
數(shù)取模养葵。
獲取當前可用client的方法:使用線程池,遍歷當前可用client
关拒,如果client
未連接庸娱,嘗試進行一次連接谐算,連接成功加入可用client
中,如果client
已經(jīng)連接直接加入可用client
臣樱。
可以通過設置client.transport.sniff
是否為true
腮考,來設置是使用SimpleNodeSampler
還是SniffNOdesSampler
,默認是false
棚放,就是使用SimpleNodeSampler
馅闽。具體實現(xiàn)在org.elasticsearch.client.transport.TransportClientNodesService
中。
簡單的說福也,SimpleNodeSampler
會限制當前可用client
一定是在配置中設置的節(jié)點暴凑。而SniffNodesSampler
會使用所有發(fā)現(xiàn)的client
,即使這個client
的node
现喳,不在配置中嗦篱。
當集群中某個node
掛掉之后,重新加入的時候灸促,因為是通過判斷client
是否可以連接浴栽,而不是node
是否可用,這會導致這個時候使用這個client
發(fā)送請求的時候產(chǎn)生異常甩挫。而方法一不會椿每,因為還沒加入集群的node
英遭,對于自己創(chuàng)建的node
來說是不可見的亦渗。
使用情況
如果要將應用程序和Elasticsearch集群進行解耦法精,傳輸客戶端是一個理想的選擇。例如 如果你的應用程序需要快速的創(chuàng)建和銷毀到集群的鏈接狼荞,傳輸客戶端比節(jié)點客戶端更"輕"帮碰,因為它不是集群的