眾所周知，elasticsearch簡稱es,它是基於基於Lucene的搜索服務器。它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口。 Elasticsearch是用Java開發的，並作為Apache許可條款下的開放源碼發布，是當前流行的企業級搜索引擎。設計用於雲計算中，能夠達到實時搜索，穩定，可靠，快速，安裝使用方便。
我們建立一個網站或應用程序，並要添加搜索功能，但是想要完成搜索工作的創建是非常困難的。我們希望搜索解決方案要運行速度快，我們希望能有一個零配置和一個完全免費的搜索模式，我們希望能夠簡單地使用JSON通過HTTP來索引數據，我們希望我們的搜索服務器始終可用，我們希望能夠從一台開始並擴展到數百台，我們要實時搜索，我們要簡單的多租戶，我們希望建立一個雲的解決方案。因此我們利用Elasticsearch來解決所有這些問題以及可能出現的更多其它問題。
在java中使用es時，無非想解決的是查詢速度不夠快，效率不夠高問題，單一從數據庫裡查詢數據已經不能拿滿足當前的業務需求，ok！那麼現在我們來講述一下如何在java中使用到es這個神奇的搜索服務器呢，首先，你得要去引用es的依賴包，依賴如下：
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>transport</artifactId><version>5.5.0</version> </dependency><groupId>org.elasticsearch.client</groupId><artifactId>transport</artifactId><version>5.5.0</version> </dependency> <dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>5.5.0</version> </dependency>
好的，添加完依賴之後，進入到es使用階段，對了，有個問題得需要說明一下，要使用es的話需要安裝jdk1.8工具包並且tomcat最好是7.05以上的版本，不然es會不支持，集成到項目裡面可能會報錯！ ，還有es的安裝和下載，這裡附下載地址下載地址：https://www.elastic.co/downloads/elasticsearch
一切準備就緒後接下來進入到我們真正期待的時刻，什麼呢，沒錯，集成es，究竟如何在java裡面搜索查詢es服務器裡面的東西呢，讓我一一來為你揭曉：
首先我們建議一個es的工具類
package com.osa.utils;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.PrintWriter;import java.net.URL;import java.net.URLConnection;import java.net.URLEncoder;import java.util.Iterator;import java.util.List;import java.util.Map;import java.util.Set;import org.apache.http.client.ClientProtocolException;import com.alibaba.fastjson.JSONArray;import com.alibaba.fastjson.JSONException;import com.alibaba.fastjson.JSONObject;public class HTTPSentUtils {/** * 向指定URL發送GET方法的請求* * @param url * 發送請求的URL * @param param * 請求參數，請求參數應該是name1=value1&name2=value2 的形式。 * @return URL 所代表遠程資源的響應結果*/ public static String sendGet(String url, String param) { String result = ""; BufferedReader in = null; try { String urlNameString = url + "?" + param; URL realUrl = new URL(urlNameString); // 打開和URL之間的連接URLConnection connection = realUrl.openConnection(); // 設置通用的請求屬性connection.setRequestProperty("accept", "*/*"); connection.setRequestProperty("connection", "Keep-Alive"); connection.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); // 建立實際的連接connection.connect(); // 獲取所有響應頭字段Map<String, List<String>> map = connection.getHeaderFields(); // 遍歷所有的響應頭字段for (String key : map.keySet()) { System.out.println(key + "--->" + map.get(key)); } // 定義BufferedReader輸入流來讀取URL的響應in = new BufferedReader(new InputStreamReader( connection.getInputStream())); String line; while ((line = in.readLine()) != null) { result += line; } } catch (Exception e) { System.out.println("發送GET請求出現異常！" + e); e.printStackTrace(); } // 使用finally塊來關閉輸入流finally { try { if (in != null) { in.close(); } } catch (Exception e2) { e2.printStackTrace(); } } return result; } /** * 向指定URL 發送POST方法的請求* * @param url * 發送請求的URL * @param param * 請求參數，請求參數應該是name1=value1&name2=value2 的形式。 * @return 所代表遠程資源的響應結果*/ public static String sendPost(String url, String param) { PrintWriter out = null; BufferedReader in = null; String result = ""; try { URL realUrl = new URL(url); // 打開和URL之間的連接URLConnection conn = realUrl.openConnection(); // 設置通用的請求屬性conn.setRequestProperty("accept", "*/*"); conn.setRequestProperty("connection", "Keep-Alive"); conn.setRequestProperty("user-agent", "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)"); // 發送POST請求必須設置如下兩行conn.setDoOutput(true); conn.setDoInput(true); // 獲取URLConnection對像對應的輸出流out = new PrintWriter(conn.getOutputStream()); // 發送請求參數out.print(param); // flush輸出流的緩衝out.flush(); // 定義BufferedReader輸入流來讀取URL的響應in = new BufferedReader( new InputStreamReader(conn.getInputStream())); String line; while ((line = in.readLine()) != null) { result += line; } } catch (Exception e) { System.out.println("發送POST 請求出現異常！"+e); e.printStackTrace(); } //使用finally塊來關閉輸出流、輸入流finally{ try{ if(out!=null){ out.close(); } if(in!=null){ in.close(); } } catch(IOException ex){ ex.printStackTrace(); } } return result; } }工具類有了之後，可以看到裡面有兩個發送請求的方法，一個是sendGet和sendPost方法，兩個方法可以基於自己的選擇選用，當然這只是個發送請求的方法，如何調用？在這裡的話，我們既然是從es裡面查詢，就沒有必要使用mybatis或者hibernate框架了，可以在數據層中，自己定義sql，然後將sql將拼好的sql通過前面的工具類調用sendGet/sendPost方法，如下：
String sql=URLEncoder.encode(" select * from table");encode方法主要是去除sql裡面的一些空格
String result=HTTPSentUtils.sendGet("http://221.124.71.8:9200/_sql", "sql="+sql);ip加端口自己可以在安裝的時候配置
OK！一般到這個時候的發送可以成功的話，就能取到es裡面的數據，因為es裡面返回的都是json數據，所以我們格式化一下json字符串
net.sf.json.JSONObject jsonObject =net.sf.json.JSONObject.fromObject(result); //取出hits標籤net.sf.json.JSONObject hitsjsonObject = jsonObject.getJSONObject("hits");數據拿到之後，結下來就是業務操作了。到這裡也差不多結束了。
以上是查詢的一些操作，那麼如果我們需要將數據批量插入到es裡面該如何操作？舉個例子吧
package com.sojson.core.elasticsearch.manager;import java.util.ArrayList;import java.util.HashMap;import java.util.List;import java.util.Map;import net.sf.json.JSONObject;import org.elasticsearch.action.bulk.BulkRequestBuilder;import org.elasticsearch.action.bulk.BulkResponse;import org.elasticsearch.action.index.IndexRequestBuilder;import com.sojson.common.utils.StringUtils;import com.sojson.core.elasticsearch.utils.ESTools;publicclassInsertManager{/*** 添加數據到Elasticsearch*@param index 索引*@param type 類型*@param idName Id字段名稱*@param json 存儲的JSON，可以接受Map*@return*/publicstaticMapsave(String index,String type,String idName,JSONObject json){List list =newArrayList();list.add(json);return save(index, type, idName, list);}通過傳來的參數進行處理調用save方法執行插入es操作
/*** 添加數據到Elasticsearch*@param index 索引*@param type 類型*@param idName Id字段名稱*@param listData 一個對象集合*@return*/@SuppressWarnings("unchecked")publicstaticMapsave(String index,String type,String idName,List listData){BulkRequestBuilder bulkRequest =ESTools.client.prepareBulk().setRefresh(true);Map resultMap =newHashMap();for(Object object: listData){JSONObject json =JSONObject.fromObject(object);//沒有指定idName 那就讓Elasticsearch自動生成，if(StringUtils.isBlank(idName)){IndexRequestBuilder lrb =ElasticsearchUtils.client .prepareIndex(index, type) .setSource(json);bulkRequest.add(lrb);//ElasticsearchUtils是工具類，裡面配置的是一些es配置信息}else{String idValue = json.optString(idName);IndexRequestBuilder lrb =ESTools.client.prepareIndex(index, type,idValue).setSource(json);bulkRequest.add(lrb);}}BulkResponse bulkResponse = bulkRequest.execute().actionGet();if(bulkResponse.hasFailures()){// process failures by iterating through each bulk response itemSystem.out.println(bulkResponse.getItems().toString());resultMap.put("500","保存ES失敗!");return resultMap;}bulkRequest=ESTools.client.prepareBulk();resultMap.put("200","保存ES成功!");return resultMap;}} ElasticsearchUtils工具類
public class ElasticsearchUtils {private static final String CLUSTER_NAME = "cluster.name";private static final String ES_IP="es.ip";private static final String ES_PORT="es.port";private static Settings settings;private static TransportClient client;public static TransportClient getESClient() throws UnknownHostException{settings = Settings.builder().put(CLUSTER_NAME,ConfigUtils.getConfig(CLUSTER_NAME)).build();if(client != null){client = new PreBuiltTransportClient(settings).addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(ConfigUtils.getConfig(ES_IP)), Integer.parseInt(ConfigUtils.getConfig(ES_PORT))));}return client;}以上是插入es操作，好了，今天的總結就到這裡吧，希望可以給大家帶來一些小小的幫助，也希望大家多多支持武林網。