java使用es查詢的示例代碼

更新時間：2018年01月03日 09:19:51 作者：浪子一枚

本篇文章主要介紹了java使用es查詢的示例代碼，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

眾所周知，elasticsearch簡稱es,它是基于基于Lucene的搜索服務(wù)器。它提供了一個分布式多用戶能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java開發(fā)的，并作為Apache許可條款下的開放源碼發(fā)布，是當(dāng)前流行的企業(yè)級搜索引擎。設(shè)計用于云計算中，能夠達(dá)到實時搜索，穩(wěn)定，可靠，快速，安裝使用方便。

我們建立一個網(wǎng)站或應(yīng)用程序，并要添加搜索功能，但是想要完成搜索工作的創(chuàng)建是非常困難的。我們希望搜索解決方案要運(yùn)行速度快，我們希望能有一個零配置和一個完全免費(fèi)的搜索模式，我們希望能夠簡單地使用JSON通過HTTP來索引數(shù)據(jù)，我們希望我們的搜索服務(wù)器始終可用，我們希望能夠從一臺開始并擴(kuò)展到數(shù)百臺，我們要實時搜索，我們要簡單的多租戶，我們希望建立一個云的解決方案。因此我們利用Elasticsearch來解決所有這些問題以及可能出現(xiàn)的更多其它問題。

在java中使用es時，無非想解決的是查詢速度不夠快，效率不夠高問題，單一從數(shù)據(jù)庫里查詢數(shù)據(jù)已經(jīng)不能拿滿足當(dāng)前的業(yè)務(wù)需求，ok！那么現(xiàn)在我們來講述一下如何在java中使用到es這個神奇的搜索服務(wù)器呢，首先，你得要去引用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>

好的，添加完依賴之后，進(jìn)入到es使用階段，對了，有個問題得需要說明一下，要使用es的話需要安裝jdk1.8工具包并且tomcat最好是7.05以上的版本，不然es會不支持，集成到項目里面可能會報錯！，還有es的安裝和下載，這里附下載地址下載地址：https://www.elastic.co/downloads/elasticsearch

一切準(zhǔn)備就緒后接下來進(jìn)入到我們真正期待的時刻，什么呢，沒錯，集成es，究竟如何在java里面搜索查詢es服務(wù)器里面的東西呢，讓我一一來為你揭曉：

首先我們建議一個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發(fā)送GET方法的請求
  * 
  * @param url
  *   發(fā)送請求的URL
  * @param param
  *   請求參數(shù)，請求參數(shù)應(yīng)該是 name1=value1&name2=value2 的形式。
  * @return URL 所代表遠(yuǎn)程資源的響應(yīng)結(jié)果
  */
 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();
   // 設(shè)置通用的請求屬性
   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();
   // 獲取所有響應(yīng)頭字段
   Map<String, List<String>> map = connection.getHeaderFields();
   // 遍歷所有的響應(yīng)頭字段
   for (String key : map.keySet()) {
    System.out.println(key + "--->" + map.get(key));
   }
   // 定義 BufferedReader輸入流來讀取URL的響應(yīng)
   in = new BufferedReader(new InputStreamReader(
     connection.getInputStream()));
   String line;
   while ((line = in.readLine()) != null) {
    result += line;
   }
  } catch (Exception e) {
   System.out.println("發(fā)送GET請求出現(xiàn)異常！" + e);
   e.printStackTrace();
  }
  // 使用finally塊來關(guān)閉輸入流
  finally {
   try {
    if (in != null) {
     in.close();
    }
   } catch (Exception e2) {
    e2.printStackTrace();
   }
  }
  return result;
 }
 /**
  * 向指定 URL 發(fā)送POST方法的請求
  * 
  * @param url
  *   發(fā)送請求的 URL
  * @param param
  *   請求參數(shù)，請求參數(shù)應(yīng)該是 name1=value1&name2=value2 的形式。
  * @return 所代表遠(yuǎn)程資源的響應(yīng)結(jié)果
  */
 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();
   // 設(shè)置通用的請求屬性
   conn.setRequestProperty("accept", "*/*");
   conn.setRequestProperty("connection", "Keep-Alive");
   conn.setRequestProperty("user-agent",
     "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
   // 發(fā)送POST請求必須設(shè)置如下兩行
   conn.setDoOutput(true);
   conn.setDoInput(true);
   // 獲取URLConnection對象對應(yīng)的輸出流
   out = new PrintWriter(conn.getOutputStream());
   // 發(fā)送請求參數(shù)
   out.print(param);
   // flush輸出流的緩沖
   out.flush();
   // 定義BufferedReader輸入流來讀取URL的響應(yīng)
   in = new BufferedReader(
     new InputStreamReader(conn.getInputStream()));
   String line;
   while ((line = in.readLine()) != null) {
    result += line;
   }
  } catch (Exception e) {
   System.out.println("發(fā)送 POST 請求出現(xiàn)異常！"+e);
   e.printStackTrace();
  }
  //使用finally塊來關(guān)閉輸出流、輸入流
  finally{
   try{
    if(out!=null){
     out.close();
    }
    if(in!=null){
     in.close();
    }
   }
   catch(IOException ex){
    ex.printStackTrace();
   }
  }
  return result;
 } 
}

工具類有了之后，可以看到里面有兩個發(fā)送請求的方法，一個是sendGet和sendPost方法，兩個方法可以基于自己的選擇選用，當(dāng)然這只是個發(fā)送請求的方法，如何調(diào)用？在這里的話，我們既然是從es里面查詢，就沒有必要使用mybatis或者h(yuǎn)ibernate框架了，可以在數(shù)據(jù)層中，自己定義sql，然后將sql將拼好的sql通過前面的工具類調(diào)用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！一般到這個時候的發(fā)送可以成功的話，就能取到es里面的數(shù)據(jù)，因為es里面返回的都是json數(shù)據(jù)，所以我們
格式化一下json字符串

net.sf.json.JSONObject jsonObject =net.sf.json.JSONObject.fromObject(result); 
//取出hits標(biāo)簽
net.sf.json.JSONObject hitsjsonObject = jsonObject.getJSONObject("hits");

數(shù)據(jù)拿到之后，結(jié)下來就是業(yè)務(wù)操作了。到這里也差不多結(jié)束了。

以上是查詢的一些操作，那么如果我們需要將數(shù)據(jù)批量插入到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{
/**
* 添加數(shù)據(jù)到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);
}

通過傳來的參數(shù)進(jìn)行處理調(diào)用save方法執(zhí)行插入es操作

/**
* 添加數(shù)據(jù)到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 item
System.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操作，好了，今天的總結(jié)就到這里吧，希望可以給大家?guī)硪恍┬⌒〉膸椭蚕Ｍ蠹叶喽嘀С帜_本之家。

您可能感興趣的文章: