java使用es查詢的示例代碼
眾所周知，elasticsearch簡稱es,它是基于基于Lucene的搜索服務(wù)器。它提供了一個分布式多用戶能力的全文搜索引擎，基于RESTful web接口。Elasticsearch是用Java開發(fā)的，并作為Apache許可條款下的開放源碼發(fā)布，是當前流行的企業(yè)級搜索引擎。設(shè)計用于云計算中，能夠達到實時搜索，穩(wěn)定，可靠，快速，安裝使用方便。
我們建立一個網(wǎng)站或應(yīng)用程序，并要添加搜索功能，但是想要完成搜索工作的創(chuàng)建是非常困難的。我們希望搜索解決方案要運行速度快，我們希望能有一個零配置和一個完全免費的搜索模式，我們希望能夠簡單地使用JSON通過HTTP來索引數(shù)據(jù)，我們希望我們的搜索服務(wù)器始終可用，我們希望能夠從一臺開始并擴展到數(shù)百臺，我們要實時搜索，我們要簡單的多租戶，我們希望建立一個云的解決方案。因此我們利用Elasticsearch來解決所有這些問題以及可能出現(xiàn)的更多其它問題。
在java中使用es時，無非想解決的是查詢速度不夠快，效率不夠高問題，單一從數(shù)據(jù)庫里查詢數(shù)據(jù)已經(jī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>
好的，添加完依賴之后，進入到es使用階段，對了，有個問題得需要說明一下，要使用es的話需要安裝jdk1.8工具包并且tomcat最好是7.05以上的版本，不然es會不支持，集成到項目里面可能會報錯！，還有es的安裝和下載，這里附下載地址下載地址：https://www.elastic.co/downloads/elasticsearch
一切準備就緒后接下來進入到我們真正期待的時刻，什么呢，沒錯，集成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 所代表遠程資源的響應(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 所代表遠程資源的響應(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方法，兩個方法可以基于自己的選擇選用，當然這只是個發(fā)送請求的方法，如何調(diào)用？在這里的話，我們既然是從es里面查詢，就沒有必要使用mybatis或者hibernate框架了，可以在數(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標簽
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ù)進行處理調(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ī)硪恍┬⌒〉膸椭蚕Ｍ蠹叶喽嘀С帜_本之家。
相關(guān)文章
這篇文章主要給大家介紹了關(guān)于Java解壓RAR文件的三種方式,Java自身并不支持解壓RAR文件,需要使用第三方庫來實現(xiàn),文中給出了詳細的示例代碼,需要的朋友可以參考下2023-07-07
Mybatis mapper接口動態(tài)代理開發(fā)步驟解析
這篇文章主要介紹了Mybatis mapper接口動態(tài)代理開發(fā)步驟解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-07-07
java樹結(jié)構(gòu)stream工具類的示例代碼詳解
Stream 作為 Java 8 的一大亮點，它與 java.io 包里的 InputStream 和 OutputStream 是完全不同的概念。今天通過本文重點給大家介紹java樹結(jié)構(gòu)stream工具類的示例代碼，感興趣的朋友一起看看吧2022-03-03
SSH框架網(wǎng)上商城項目第28戰(zhàn)之使用Ajax技術(shù)局部更新商品數(shù)量和總價
這篇文章主要為大家詳細介紹了SSH框架網(wǎng)上商城項目第28戰(zhàn)之使用Ajax技術(shù)局部更新商品數(shù)量和總價，感興趣的小伙伴們可以參考一下2016-06-06
詳解自定義SpringMVC的Http信息轉(zhuǎn)換器的使用
這篇文章主要介紹了詳解自定義SpringMVC的Http信息轉(zhuǎn)換器的使用,小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2017-11-11
這篇文章主要為大家詳細介紹了java實現(xiàn)學生信息錄入界面，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2022-04-04
解決MyBatis Mapper的XML文件SQL語句無法自動提示問題(親測有效)
這篇文章主要給大家介紹了如何解決MyBatis Mapper的XML文件SQL語句無法自動提示的問題,文中有詳細的原因分析,以及通過圖文介紹的解決方案,需要的朋友可以參考下2023-10-10
這篇文章主要介紹了Java開啟線程的四種方法,本文結(jié)合實例代碼給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-02-02
SpringBoot使用Filters實現(xiàn)請求過濾和預處理
過濾器（Filter）是一種在Web應(yīng)用中用于攔截和處理HTTP請求和響應(yīng)的對象,在Java Web開發(fā)中,過濾器是實現(xiàn)特定功能,如認證、日志記錄和字符編碼處理的重要工具,本文主要介紹了SpringBoot使用Filters實現(xiàn)請求過濾和預處理,需要的朋友可以參考下2024-08-08
SpringBoot?Security權(quán)限控制自定義failureHandler實例
這篇文章主要為大家介紹了SpringBoot?Security權(quán)限控制自定義failureHandler實例，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2022-11-11