elasticsearch 初學入門

ElasticSearch是一個基於Lucene的搜索伺服器。它提供了一個分散式多用戶能力的全文搜索引擎，基於RESTful web介面。Elasticsearch是用Java開發的，並作為Apache許可條款下的開放源碼發布，是當前流行的企業級搜索引擎。設計用於雲計算中，能夠達到實時搜索，穩定，可靠，快速，安裝使用方便。官網:https://www.elastic.co/

初學elasticsearch，查閱無數資料終得運行成功，本文環境基於Java、Windows。

1. elasticsearch版本：5.0.1，下載ZIP包，地址：https://www.elastic.co/downloads/elasticsearch。

   

2. 下載後解壓到C:elasticsearch-5.0.1

   

3. 運行elasticsearch.bat，就在本機開啟一個elasticsearch節點

   

4. 瀏覽器訪問 http://localhost:9200/ ，如果能夠正常訪問，說明該節點配置成功。

   

5. Java Maven 項目調用 elasticsearch API，直接貼代碼

pom.xml文件詳見 pom.xml

public static void main(String[] args) throws UnknownHostException {

@SuppressWarnings("resource")

TransportClient client = new PreBuiltTransportClient(Settings.EMPTY)

.addTransportAddress(new InetSocketTransportAddress(

InetAddress.getByName("127.0.0.1"), 9300));

Map<String, Object> json = new HashMap<String, Object>();

json.put("user", "jack k");

json.put("postDate", "2016-11-23");

json.put("message", "es demo");

client.prepareIndex("twitter", "tweet", "1").setType("muti_field")

.setSource(json).execute().actionGet();

GetResponse response = client.prepareGet("twrite", "tweet", "1")

.execute().actionGet();

Map<String, Object> map = response.getSource();

Iterator<Entry<String, Object>> iter = map.entrySet().iterator();

while (iter.hasNext()) {

Entry<String, Object> ent = iter.next();

System.out.println(ent.getKey() + "=" + ent.getValue());

}

QueryBuilder qb = QueryBuilders.matchQuery("user", "jack");

SearchResponse scrollResp = client.prepareSearch("twitter")

.setSearchType(SearchType.DEFAULT)

.setScroll(new TimeValue(60000)).setQuery(qb).setSize(100)

.execute().actionGet();

System.out.println("通過user欄位查詢:" + scrollResp);

System.out.println(

"通過user欄位查詢信息數量:" + scrollResp.getHits().getTotalHits());

for (SearchHit hit : scrollResp.getHits()) {

Iterator<Entry<String, Object>> rpItor = hit.getSource().entrySet()

.iterator();

while (rpItor.hasNext()) {

Entry<String, Object> rpEnt = rpItor.next();

System.out.println(rpEnt.getKey() + " : " + rpEnt.getValue());

}

}

client.close();

}

第一次寫文章，如果問題敬請諒解指出，謝謝。小弟再此拜上。

推薦閱讀：