分佈式搜索ElasticSearch構建集羣與簡單搜索實例應用

關於ElasticSearch不介紹了,直接說應用.

分佈式ElasticSearch集羣構建的方法.

1.經過在程序中建立一個嵌入es節點（Node），使之成爲es集羣的一部分，而後經過這個節點來與es集羣通訊.

/**在運行該測試實例時,已經在本地創建了對應的索引庫datum*/
    public static void main(String[] args) { //當你啓動一個節點,它會自動加入同網段的es集羣,一個前提就是es的集羣名(cluster.name)這個參數要設置一致。
        String clusterName = "elasticsearch_pudp"; //集羣結點名稱
        
        /** * 默認的話啓動一個節點,es集羣會自動給它分配一些索引的分片,若是你想這個節點僅僅做爲一個客戶端而不去保存數據, * 你就能夠設置把node.data設置成false或 node.client設置成true。 */ Node node = NodeBuilder.nodeBuilder().clusterName(clusterName).client(true).node(); //啓動結點,加入到指定集羣
 node.start(); //獲取節點搜索端,使用prepareGet搜索datum索引庫中 索引類型爲datum,的索引記錄惟一id值爲150得記錄
        GetResponse response = node.client().prepareGet("datum", "datum", ""+150).execute().actionGet(); //對象映射模型
        ObjectMapper mapper = new ObjectMapper(); //將搜索結果response中的值轉換成指定的對象模型,Datum是本身創建的一個諮詢Model對象
        Datum datum= mapper.convertValue(response.getSource(), Datum.class); //打印檢索結果中獲取的對象相應的屬性
        System.out.println("資訊標題:"+datum.getTitle() ); //關閉結點
 node.close(); }

程序運行結果:

資訊標題:波立維與泰嘉片哪一個治療血栓病效果更好呢

還有一種狀況是你並不想把節點加入集羣，只想用它進行單元測試時，就要啓動一個」本地」的es，這裏「本地」指的是在jvm的級別下運行，即兩個不一樣的es節點運行在同一個JVM中時會組成一個集羣。它須要把節點的local參數設置成true

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

  

2.用TransportClient這個接口和es集羣通訊.

集羣中綁定結點

經過TransportClient這個接口，咱們能夠不啓動節點就能夠和es集羣進行通訊，它須要指定es集羣中其中一臺或多臺機的ip地址和端口

        Client client = new TransportClient() .addTransportAddress(new InetSocketTransportAddress("192.168.0.149", 9300)) .addTransportAddress(new InetSocketTransportAddress("192.168.0.162", 9300)); client.close(); 

集羣名稱若是咱們不更改,默認的爲elasticsearch,在ElasticSearch對應的目錄elasticsearch\config\下的elasticsearch.yml文件中.以下位置 

################################### Cluster ################################### # Cluster name identifies your cluster for auto-discovery. If you're running
# multiple clusters on the same network, make sure you're using unique names.
# cluster.name: elasticsearch

 

程序中自定義集羣結點名稱

    /**在運行該測試實例時,已經在本地創建了對應的索引庫datum*/
    public static void main(String[] args) { //自定義集羣結點名稱
        String clusterName = "elasticsearch_pudongping"; //程序中更改集羣結點名稱
        Settings settings = ImmutableSettings.settingsBuilder() .put("cluster.name", clusterName).build(); //建立集羣,綁定集羣內的機器
        TransportClient client = new TransportClient(settings); client.addTransportAddress(new InetSocketTransportAddress("192.168.0.149", 9300)); client.addTransportAddress(new InetSocketTransportAddress("192.168.0.162", 9300)); //搜索
        GetResponse response = client.prepareGet("datum", "datum", ""+130) .execute() .actionGet(); ObjectMapper mapper = new ObjectMapper(); Datum datum= mapper.convertValue(response.getSource(), Datum.class); System.out.println("資訊標題:"+datum.getTitle() ); //關閉結點
 client.close(); }

程序運行結果：

資訊標題:捷諾維主要成份有哪些 療效怎麼樣

設置屬性使客戶端去嗅探整個集羣的狀態

能夠設置client.transport.sniff爲true來使客戶端去嗅探整個集羣的狀態

        /** * 能夠設置client.transport.sniff爲true來使客戶端去嗅探整個集羣的狀態， * 把集羣中其它機器的ip地址加到客戶端中,這樣作的好處是通常你不用手動設置集羣裏全部集羣的ip到鏈接客戶端, * 它會自動幫你添加，而且自動發現新加入集羣的機器。 */ Settings settings = ImmutableSettings.settingsBuilder() .put("client.transport.sniff", true).build(); TransportClient client = new TransportClient(settings);

 

實例應用: 

使用TransportClient初始化客戶端並執行簡單搜索:

package com.bbf.client; import java.util.ArrayList; import java.util.List; import org.codehaus.jackson.map.ObjectMapper; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.search.SearchResponse; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.ImmutableSettings; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.index.query.QueryBuilder; import org.elasticsearch.index.query.QueryBuilders; import org.elasticsearch.search.SearchHit; import org.elasticsearch.search.SearchHits; import com.bbf.search.model.Datum; /** * description: * * @author <a href='mailto:dennisit@163.com'> Cn.pudp (En.dennisit)</a> Copy Right since 2013-9-29 * * com.bbf.client.ESClient.java * */

public class ESClient { /**在運行該測試實例時,已經在本地創建了對應的索引庫datum*/
    public static void main(String[] args) { //自定義集羣結點名稱
        String clusterName = "elasticsearch_pudongping"; //程序中更改集羣結點名稱 而且設置client.transport.sniff爲true來使客戶端去嗅探整個集羣的狀態
        Settings settings = ImmutableSettings.settingsBuilder() .put("cluster.name", clusterName).put("client.transport.sniff", true).build(); //建立客戶端對象
        TransportClient client = new TransportClient(settings); //客戶端對象初始化集羣內結點,綁定多個ip //client.addTransportAddress(new InetSocketTransportAddress("192.168.0.149", 9300));
        client.addTransportAddress(new InetSocketTransportAddress("192.168.0.162", 9300)); //搜索,根據Id查詢
        GetResponse response = client.prepareGet("datum", "datum", ""+130) .execute() .actionGet(); //查詢結果映射成對象類
        ObjectMapper mapper = new ObjectMapper(); Datum datum= mapper.convertValue(response.getSource(), Datum.class); System.out.println("資訊編號:" + datum.getId() +"\t資訊標題:"+datum.getTitle() ); //構造查詢器查詢,第一個參數爲要查詢的關鍵字,第二個參數爲要檢索的索引庫中的對應索引類型的域
        QueryBuilder query = QueryBuilders.multiMatchQuery("恩必普", "keyword"); //第一個參數datum表示索引庫,第二個參數datum表示索引類型,from表示開始的位置 size表示查詢的條數 ,相似mysql中的limit3,5
        SearchResponse searchResponse = client.prepareSearch("datum").setTypes("datum").setQuery(query).setFrom(3).setSize(5).execute().actionGet(); //將搜索結果轉換爲list集合對象
        List<Datum> lists  = getBeans(searchResponse); System.out.println("查詢出來的結果數:" + lists.size()); for(Datum dtm: lists){ System.out.println("資訊編號:" + dtm.getId() +"\t資訊標題:"+dtm.getTitle()); } //關閉客戶端
 client.close(); } /** * 從查詢到的記錄中獲取json串值,轉換成<code>Datum</code>對象 * * @author <a href='mailto:dennisit@163.com'> Cn.pudp (En.dennisit)</a> Copy Right since 2013-9-24 下午09:24:29 * * @param response * 查詢結果集<code>GetResponse</code> * @return * 返回<code>Datum</code>對象 */
    public static Datum getResponseToObject(GetResponse response){ ObjectMapper mapper = new ObjectMapper(); return mapper.convertValue(response.getSource(), Datum.class); } /** * 將查詢到的對象集合封裝成List集合 * * @author <a href='mailto:dennisit@163.com'>Cn.pudp(En.dennisit)</a> Copy Right since 2013-9-27 下午02:31:26 * * @param response * @return
     */
    public static List<Datum> getBeans(SearchResponse response) { SearchHits hits = response.getHits(); ObjectMapper mapper = new ObjectMapper(); List<Datum> datumList = new ArrayList<Datum>(); for (SearchHit hit : hits) { String json = hit.getSourceAsString(); Datum dtm = new Datum(); try { dtm = mapper.readValue(json, Datum.class); datumList.add(dtm); } catch (Exception e) { e.printStackTrace(); } } return datumList; } }

 程序運行結果:

資訊編號:130 資訊標題:捷諾維主要成份有哪些 療效怎麼樣 查詢出來的結果數:5 資訊編號:16 資訊標題:恩必普是否是醫保藥 能夠報銷嗎 資訊編號:11 資訊標題:恩必普的治療範圍 有什麼優點 資訊編號:17 資訊標題:恩必普的做用機制是什麼 資訊編號:12 資訊標題:恩必普服用有什麼禁忌 注意事項哪些 資訊編號:20    資訊標題:中風能夠用恩必普嗎

 

 轉載請註明出處:[http://www.cnblogs.com/dennisit/p/3346228.html]