java操作ElasticSearch（es）進(jìn)行增刪查改操作x

本文格式為Word版，下載可任意編輯——java操作ElasticSearch（es）進(jìn)行增刪查改操作xjava操作ElasticSearch（es）舉行增刪查改操作ElasticSearch(名稱太長，后面簡稱ES)作為一個(gè)探尋引擎，目前可謂是如日中天，幾乎和solr齊駕并驅(qū)。關(guān)于他能做什么，跟云計(jì)算有什么關(guān)系，在此不再描述。但是ES的官方文檔，更加是關(guān)于java的客戶端文檔，真是少的可憐，甚至連個(gè)完整的增刪改的例如都沒有。在此，我就獻(xiàn)丑了。

在開頭講解之前，還是先做個(gè)鋪墊，為了能夠有一個(gè)可以索引的模型，我們自定義了一個(gè)模型，暫時(shí)起個(gè)名稱叫LogModel吧，這個(gè)模型有各種數(shù)據(jù)類型，int,long,String,list，但千萬不要認(rèn)為這是跟記錄日志有關(guān)的一個(gè)模型。作為索引的一個(gè)最簡樸模型。代碼如下：

Java代碼

1ArrayList;

2List;

3Random;

4importjava.util.UUID;

5/**

6

瞎編的一個(gè)模型，跟日志根本沒有關(guān)系

7

*@authordonlian

8

*/

9.publicclassLogModel{

10//主ID

11privatelongid;

12//次ID

13privateintsubId;

14/**

15系統(tǒng)名稱

16*/

17systemName;

18privateStringhost;

19

20//日志描述

21Stringdesc;

22rivateListIntegercatIds;

23publicLogModel(){

24Randomrandom=newRandom();

25this.id=Math.abs(random.nextLong());

26.

intsubId=Math.abs(random.nextInt());

27this.subId=subId;

28ListIntegerlist=newArrayListInteger(5);

29for(inti=0;i5;i++){

30

list.add(Math.abs(random.nextInt()));

31}

32catIds=list;

33systemName=subId%1==0?oa:cms;

34host=subId%1==0?:;

35

this.desc=中文+UUID.randomUUID().toString();

36}

37.

publicLogModel(longid,intsubId,StringsysName,Stringhost,Stringdesc,ListIntegercatIds){

38id=id;

39ubId=subId;

40systemName=sysName;

41host=host;

42desc=desc;

43

this.catIds=catIds;

44

}

45...//省去get,set方法

46.}

同時(shí)，由于ES在索引的時(shí)候，一般都用json格式，因此，使用jackson定義了一個(gè)將對象轉(zhuǎn)化成json的工具類，也很簡樸，代碼：

Java代碼

1publicclassESUtils{

2

privatestaticObjectMapperobjectMapper=newObjectMapper();

3

publicstaticStringtoJson(Objecto){

4

try{

5

returnobjectMapper.writeValueAsString(o);

6

}catch(JsonProcessingExceptione){

7

e.printStackTrace();

8

}

9.

return;

10

}

11.}

在開頭舉行操作ES服務(wù)器之前，我們務(wù)必得獲得ES的API，簡樸介紹一下ES操作服務(wù)器的兩種方式，一種是使用Node方式，即本機(jī)也啟動(dòng)一個(gè)ES，然后跟服務(wù)器的ES舉行通信，這個(gè)node甚至還能存儲(chǔ)（古怪，一般需要這樣的方式

嗎？），另一種，就是下面我介紹的這一種，通過一個(gè)對象使用http協(xié)議跟服務(wù)器舉行交互。

獲得一個(gè)ES客戶端API的代碼如下：

Java代碼

1Settingssettings=ImmutableSettings.settingsBuilder()

2

//指定集群名稱

3

.put(,elasticsearch)

4

//探測集群中機(jī)器狀態(tài)

5

.put(client.transport.sniff,true).build();

6

/*

7.

*創(chuàng)造客戶端，全體的操作都由客戶端開頭，這個(gè)就猶如是JDBC的Connection對象

8

*用完記得要關(guān)閉

9.

*/

10Clientclient=newTransportClient(stings)

11.

.addTransportAddress(newInetSocketTransportAddress(06,9300));

Client對象，可以理解為數(shù)據(jù)庫的Connection對象。好了，打定工作完成，下面就開頭增刪改查。

Index(增加）

ES里面的增加對象不叫什么add,save等，叫index。但無論叫什么名稱，反正就是向ES服務(wù)器里面加數(shù)據(jù)。上面說過一個(gè)對象轉(zhuǎn)json的工具類，其實(shí)ES的API中，是自帶構(gòu)建json的工具類的。

Java代碼

1action.index.IndexResponse;

2Client;

3lient.transport.TransportClient;

4ImmutableSettings;

5settings.Settings;

6importmon.transport.InetSocketTransportAddress;

7

8ESUtils;

9.importcom.donlianli.es.model.LogModel;

10/**

11.

*向ES添加索引對象

12@authordonlian

13*/

14publicclassIndexTest{

15publicstaticvoidmain(String[]argv){

16Settingssettings=ImmutableSettings.settingsBuilder()

17//指定集群名稱

18.put(,elasticsearch)

19//探測集群中機(jī)器狀態(tài)

20

.put(client.transport.sniff,true).build();

21/*

22.

*創(chuàng)造客戶端，全體的操作都由客戶端開頭，這個(gè)就猶如是JDBC的Connection對象

23用完記得要關(guān)閉

24*/

25Clientclient=newTransportClient(stings)

26.

.addTransportAddress(newInetSocketTransportAddress(06,9300));

27Stringjson=ESUtils.toJson(newLogModel());

28//在這里創(chuàng)造我們要索引的對象

29IndexResponseresponse=client.prepareIndex(twitter,tweet)

30//務(wù)必為對象單獨(dú)指定ID

31Id(1)

32setSource(json)

33execute()

34

.actionGet();

35//屢屢index這個(gè)版本號會(huì)變

36System.out.println(response.version():+response.version());

37

client.close();

38

}

39.}

運(yùn)行這個(gè)代碼，就向ES插入了一條數(shù)據(jù)，你運(yùn)行兩遍，還是一條。ES根據(jù)你設(shè)置的ID來設(shè)置對象，假設(shè)沒有那么插入，有那么更新。每更新一次，對應(yīng)的version加1.好了，在次，使用以下命令，理應(yīng)能夠查詢到一條記錄了。

Java代碼

1.curl-XGET"http://localhost:9200/twitter/tweet/1"

delete(刪除）

有了增加的例子，刪除的例子也就好寫了。增加是prepareIndex，刪除是prepareDelete,查詢就是PrepareGet。

代碼如下：

Java代碼

1action.delete.DeleteResponse;

2Client;

3lient.transport.TransportClient;

4ImmutableSettings;

5settings.Settings;

6importmon.transport.InetSocketTransportAddress;

7

8importcom.donlianli.es.ESUtils;

9.

10publicclassDeleteTest{

11publicstaticvoidmain(String[]argv){

12Settingssettings=ImmutableSettings.settingsBuilder()

13//指定集群名稱

14.put(,elasticsearch)

15//探測集群中機(jī)器狀態(tài)

16

.put(client.transport.sniff,true).build();

17/*

18.

*創(chuàng)造客戶端，全體的操作都由客戶端開頭，這個(gè)就猶如是JDBC的Connection對象

19用完記得要關(guān)閉

20*/

21Clientclient=newTransportClient(stings)

22.

.addTransportAddress(newInetSocketTransportAddress(06,9300));

23//在這里創(chuàng)造我們要索引的對象

24DeleteResponseresponse=client.prepareDelete(twitter,tweet,1)

25

.execte().actionGet();

26response.getId());

27

System.out.println(ESUtils.toJson(response.getHeaders()));

28

}

29.}

GET(查詢）

Java代碼

1action.get.GetResponse;

2Client;

3lient.transport.TransportClient;

4ImmutableSettings;

5settings.Settings;

6importmon.transport.InetSocketTransportAddress;

7

8publicclassGetTest{

9.

publicstaticvoidmain(String[]argv){

10Settingssettings=ImmutableSettings.settingsBuilder()

11//指定集群名稱

12.put(