ES Java 客戶端

節(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.datafalse或者設置node.localtrue來簡單實現(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.snifftrue恩溅。

其他的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,即使這個clientnode现喳,不在配置中嗦篱。
當集群中某個node掛掉之后,重新加入的時候灸促,因為是通過判斷client是否可以連接浴栽,而不是node是否可用,這會導致這個時候使用這個client發(fā)送請求的時候產(chǎn)生異常甩挫。而方法一不會椿每,因為還沒加入集群的node英遭,對于自己創(chuàng)建的node來說是不可見的亦渗。

使用情況
如果要將應用程序和Elasticsearch集群進行解耦法精,傳輸客戶端是一個理想的選擇。例如 如果你的應用程序需要快速的創(chuàng)建和銷毀到集群的鏈接狼荞,傳輸客戶端比節(jié)點客戶端更"輕"帮碰,因為它不是集群的

轉載自ES Java 客戶端 - 做個有夢想的咸魚 - 博客園

最后編輯于
?著作權歸作者所有,轉載或內(nèi)容合作請聯(lián)系作者
  • 序言:七十年代末殉挽,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子斯碌,更是在濱河造成了極大的恐慌傻唾,老刑警劉巖,帶你破解...
    沈念sama閱讀 211,743評論 6 492
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件逛裤,死亡現(xiàn)場離奇詭異猴抹,居然都是意外死亡锁荔,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 90,296評論 3 385
  • 文/潘曉璐 我一進店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來恬总,“玉大人壹堰,你說我怎么就攤上這事骡湖【瘢” “怎么了?”我有些...
    開封第一講書人閱讀 157,285評論 0 348
  • 文/不壞的土叔 我叫張陵,是天一觀的道長辜王。 經(jīng)常有香客問我呐馆,道長,這世上最難降的妖魔是什么摹恰? 我笑而不...
    開封第一講書人閱讀 56,485評論 1 283
  • 正文 為了忘掉前任俗慈,我火速辦了婚禮闺阱,結果婚禮上,老公的妹妹穿的比我還像新娘瘦穆。我一直安慰自己赊豌,他們只是感情好,可當我...
    茶點故事閱讀 65,581評論 6 386
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著艾恼,像睡著了一般钠绍。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上媳握,一...
    開封第一講書人閱讀 49,821評論 1 290
  • 那天毙芜,我揣著相機與錄音,去河邊找鬼晦雨。 笑死隘冲,一個胖子當著我的面吹牛,可吹牛的內(nèi)容都是我干的奥邮。 我是一名探鬼主播洽腺,決...
    沈念sama閱讀 38,960評論 3 408
  • 文/蒼蘭香墨 我猛地睜開眼蘸朋,長吁一口氣:“原來是場噩夢啊……” “哼扣唱!你這毒婦竟也來了噪沙?” 一聲冷哼從身側響起,我...
    開封第一講書人閱讀 37,719評論 0 266
  • 序言:老撾萬榮一對情侶失蹤辐马,失蹤者是張志新(化名)和其女友劉穎齐疙,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體穷绵,經(jīng)...
    沈念sama閱讀 44,186評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡仲墨,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 36,516評論 2 327
  • 正文 我和宋清朗相戀三年目养,在試婚紗的時候發(fā)現(xiàn)自己被綠了癌蚁。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
    茶點故事閱讀 38,650評論 1 340
  • 序言:一個原本活蹦亂跳的男人離奇死亡,死狀恐怖煞躬,靈堂內(nèi)的尸體忽然破棺而出恩沛,到底是詐尸還是另有隱情雷客,我是刑警寧澤烛卧,帶...
    沈念sama閱讀 34,329評論 4 330
  • 正文 年R本政府宣布总放,位于F島的核電站呈宇,受9級特大地震影響,放射性物質(zhì)發(fā)生泄漏局雄。R本人自食惡果不足惜甥啄,卻給世界環(huán)境...
    茶點故事閱讀 39,936評論 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望炬搭。 院中可真熱鬧蜈漓,春花似錦、人聲如沸宫盔。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,757評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽灼芭。三九已至有额,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背巍佑。 一陣腳步聲響...
    開封第一講書人閱讀 31,991評論 1 266
  • 我被黑心中介騙來泰國打工茴迁, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留,地道東北人萤衰。 一個月前我還...
    沈念sama閱讀 46,370評論 2 360
  • 正文 我出身青樓堕义,卻偏偏與公主長得像,于是被迫代替她去往敵國和親脆栋。 傳聞我的和親對象是個殘疾皇子倦卖,可洞房花燭夜當晚...
    茶點故事閱讀 43,527評論 2 349

推薦閱讀更多精彩內(nèi)容