Elasticsearch就這麼簡單
1、前言
最近有點想弄一個站內搜索的功能，以前學過了Lucene，後來又聽過Solr這個名詞。接着在瞭解全文搜索的時候就發現了Elasticsearch這個，他也是以Lucene爲基礎的。html
我去搜了幾篇Elasticsearch教程，發現不少都是基於linux的，但我linux耍得並不熟，不多用。僅僅會一些簡單的命令，等真正去用到linux的時候再慢慢啃吧。java
因而發現了一篇寫得很好的教程：linux
首先是對Elasticsearch的安裝，上面那篇教程也有說，而且給出了一鍵安裝的腳本。這裏就用來記錄我我的的安裝歷程吧。github
PS：2018年3月22日18:58:12更新：這裏我已經不建議在Windows下裝Elasticsearch了，由於裝起來仍是麻煩，也有一堆的小問題~(後面也有在Linux下配置Elasticsearch的過程，建議用linux環境下學習Elasticsearch(要是學生建議去買個服務器，有優惠的),實在不想出錢，用虛擬機也行~web
2、Windows下安裝Elasticsearch(不建議)
2.1安裝Elasticsearch
安裝Elasticsearch以window服務的方式來運行，它的給出的版本是2.3.3。因而我也去安裝2.3.3了。sql
在官網上能夠在搜索框中查找對應的版本數據庫
要以windows服務的方式運行，教程給出的連接已經掛了。我搜到了一篇json
www.cnblogs.com/viaiu/p/571…segmentfault
2.2安裝head
安裝head插件就很簡單了，切換到對應的目錄下，使用以下命令：
plugin install mobz/elasticsearch-head
2.3安裝kibana和Logstash插件以服務形式運行
給出的鏈接是stackOverFlow下的提問，還有youtobe的視頻。stackOverFlow並不能解決我安裝過程的問題，youtobe我沒聯外網，也進不去。
後來，我又找到了一篇教程，也十分順利：
Logstash下載的版本是：2.3.3與Elasticsearch對應起來。
下載kibana的版本是：4.5.0
可以出現下面這種狀況，說明安裝成功
2.4安裝Shield
plugin install license plugin install shield
重啓，接着執行:
添加管理員
bin/shield/esusers useradd adminName -r admin
爲kibana添加用戶
esusers useradd kibanaserver -r kibana4_server
在其配置上(kibana.yml)添加:
kibana_elasticsearch_username: kibanaserver #Kibana服務將用這個用戶名訪問ElasticSearch服務器。 kibana_elasticsearch_password: zhongfucheng #密碼
只有配置了kibanaserver帳戶、才能登錄進去
2.5安裝分詞器
此次教程給出的鏈接就用上了，我截圖主要的：
ik分詞器的版本是1.9.3。文章給出的是以mvn的方式打包下載。所以在github中咱們下載resouce類型的。
解壓的時候是在zip解壓到當前文件上，把conf的數據拿過去是將其源文件拿過去(不包括文件夾!)
2.6拼音分詞器
前面下載了中文分詞器，後邊在看教程的時候也發現了拼音分詞器，拼音分詞器的安裝和中文分詞器安裝的時候很相似
對應Elasticsearch2.3.3版本的拼音分詞器版本爲：1.7.3
Windows下裝Elasticsearch到此就結束了。
3、Linux下安裝Elasticsearch
這是我搭建一個項目時候的筆記，
3.1下載Elasticsearch
Elasticserach的下載仍是很是方便的，提供搜索來進行下載。這裏我就不貼連接了。直接去官網找就好了。或者去個人Elasticsearch學習記錄中找。
下載了2.3.3版本，由於我在windows開發的時候也是下載2.3.3版本的，就爲了保持一致吧。
3.2安裝Elasticsearch
tar -xzvf elasticsearch-2.3.3.tar.gz
切換到bin目錄下執行就好了...
須要這樣執行elasticsearch，若是使用的是root用戶的話
./elasticsearch -d -Des.insecure.allow.root=true
如今使用下面的語句，是能夠獲取獲得信息的
curl -X GET 'http://localhost:9200'
想要經過外網來訪問的話，那麼就須要修改配置文件了，參考連接blog.csdn.net/u012599988/…
還要在ESC服務器上開放端口才能訪問：
3.2.1下載head插件
在下載head插件的時候，須要修改elasticsearch的用戶和組，不然它就不讓你下載。命令以下
添加用戶和組
groupadd elasticsearch useradd elasticsearch -g elasticsearch -p 123456
修改文件夾權限
chown -R elasticsearch:elasticsearch elasticsearch-2.3.3
弄完以後就能夠執行命令下載head插件了。
./plugin install mobz/elasticsearch-head
下載完head插件後，不要立馬下載shield插件，首先在head插件上建立一個索引!
不然，當下載完shield插件、再訪問head插件的話，就沒法鏈接節點了!
這搞了我好長的時間才弄好!!!!!網上也有不少人遇到過這種狀況，卻沒什麼好的回答。都在說配置文件上的事情。
我是經過在github中別人提出的issue中找到答案的。參考:https://github.com/mobz/elasticsearch-head/issues/191#issuecomment-132636493
記住了，先在head插件中建立索引、再下載shield插件，不然沒法鏈接head插件!
3.2.2下載權限shield
我在windows下開發是有下載shiled，爲了保持一致，我也下載吧。
輸入命令：
plugin install license plugin install shield
下載完就配置一個管理員用戶
bin/shield/esusers useradd adminName -r admin
若是文章有錯的地方歡迎指正，你們互相交流。習慣在微信看技術文章，想要獲取更多的Java資源的同窗，能夠關注微信公衆號:Java3y
4、REST API
在前面一章中已經下載了Elasticsearch和它經常使用的各類插件了。瞭解相關的概念後，咱們就應該動手弄一弄Elasticsearch是怎麼用的。
參考連接：
我是跟着這個教程大體把REST API走了一下，也漸漸瞭解了Elasticsearch的知識點了。
5、JAVA API
咱們畢竟是使用Java的，所以得知道Elasticsearch和Java是怎麼鏈接的。我找了幾篇教程：
後來找到了一篇比較系統的教程，推薦這個：
本身也跟着教程寫了Demo，其中也出了很多錯誤。貼上代碼：
import com.carrotsearch.hppc.cursors.ObjectObjectCursor;
import org.elasticsearch.action.admin.indices.close.CloseIndexResponse;
import org.elasticsearch.action.admin.indices.create.CreateIndexRequest;
import org.elasticsearch.action.admin.indices.create.CreateIndexResponse;
import org.elasticsearch.action.admin.indices.delete.DeleteIndexResponse;
import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequest;
import org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse;
import org.elasticsearch.action.admin.indices.exists.types.TypesExistsResponse;
import org.elasticsearch.action.admin.indices.open.OpenIndexResponse;
import org.elasticsearch.action.bulk.BulkRequestBuilder;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.deletebyquery.DeleteByQueryAction;
import org.elasticsearch.action.deletebyquery.DeleteByQueryRequestBuilder;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.get.MultiGetItemResponse;
import org.elasticsearch.action.get.MultiGetResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.cluster.metadata.MappingMetaData;
import org.elasticsearch.common.collect.ImmutableOpenMap;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.script.Script;
import org.elasticsearch.script.ScriptService;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.shield.ShieldPlugin;
import org.junit.Test;
import java.io.*;
import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.List;
import java.util.concurrent.ExecutionException;
import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;
import static org.elasticsearch.index.query.QueryBuilders.termQuery;
import org.elasticsearch.client.transport.TransportClient;
/**
* Created by ozc on 2017/11/5.
*/
public class ElasticsearchDemo {
/**
* 建立
* @throws UnknownHostException
*/
@Test
public void CreateIndex() throws UnknownHostException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
//將數據轉成json字符串，用集合裝載起來
List<String> jsonData = DataFactory.getInitJsonData();
//建立blog索引、article類型、數據是上邊的json字符串
for (int i = 0; i < jsonData.size(); i++) {
IndexResponse response = client.prepareIndex("blog", "article","1").setSource(jsonData.get(i)).get();
if (response.isCreated()) {
System.out.println("建立成功!");
}
}
client.close();
}
/**
* 查詢
* @throws UnknownHostException
*/
@Test
public void selectIndex() throws UnknownHostException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
//查詢title字段中包含hibernate關鍵字的文檔
QueryBuilder qb1 = termQuery("title", "hibernate");
//查詢title字段或content字段中包含git關鍵字的文檔:
QueryBuilder qb2= QueryBuilders.multiMatchQuery("git", "title","content");
SearchResponse response = client.prepareSearch("blog").setTypes("article").setQuery(qb2).execute()
.actionGet();
SearchHits hits = response.getHits();
if (hits.totalHits() > 0) {
for (SearchHit hit : hits) {
System.out.println("score:"+hit.getScore()+":\t"+hit.getSource());// .get("title")
}
} else {
System.out.println("搜到0條結果");
}
}
/**
* 使用updateRequest更新
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void update1() throws IOException, ExecutionException, InterruptedException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
UpdateRequest uRequest = new UpdateRequest();
uRequest.index("blog");
uRequest.type("article");
uRequest.id("1");
uRequest.doc(jsonBuilder().startObject().field("content", "學習目標 掌握java泛型的產生意義ssss").endObject());
client.update(uRequest).get();
}
/**
* 使用腳本更新，須要更改配置文件【我不喜歡用】
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void update2() throws IOException, ExecutionException, InterruptedException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
client.prepareUpdate("blog", "article", "1")
.setScript(new Script("ctx._source.title = \"git入門\"", ScriptService.ScriptType.INLINE, null, null))
.get();
}
/**
* 使用doc更新
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void update3() throws IOException, ExecutionException, InterruptedException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
client.prepareUpdate("blog", "article", "1")
.setDoc(jsonBuilder().startObject().field("content", "SVN與Git對比222222。。。").endObject()).get();
}
/**
* 使用updateRequest更新、可以新增新字段
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void update4() throws IOException, ExecutionException, InterruptedException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
UpdateRequest updateRequest = new UpdateRequest("blog", "article", "1")
.doc(jsonBuilder().startObject().field("commet", "0").endObject());
client.update(updateRequest).get();
}
/**
* 使用UpdateRequest更新， 若是文檔不存在則建立新的索引
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void update5() throws IOException, ExecutionException, InterruptedException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
IndexRequest indexRequest = new IndexRequest("blog", "article", "10").source(jsonBuilder().startObject()
.field("title", "Git安裝10").field("content", "學習目標 git。。。10").endObject());
UpdateRequest uRequest2 = new UpdateRequest("blog", "article", "10").doc(
jsonBuilder().startObject().field("title", "Git安裝").field("content", "學習目標 git。。。").endObject())
.upsert(indexRequest);
client.update(uRequest2).get();
}
/**
* 刪除具體的索引值
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void deleteSpecificIndex() throws IOException, ExecutionException, InterruptedException {
//鏈接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
DeleteResponse dResponse = client.prepareDelete("blog", "article", "10").execute()
.actionGet();
if (dResponse.isFound()) {
System.out.println("刪除成功");
} else {
System.out.println("刪除失敗");
}
}
/**
* 根據index名稱 刪除整個索引庫
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void deleteIndex() throws IOException, ExecutionException, InterruptedException {
//要刪除索引庫的名字
String indexName = "zhognfucheng";
if (!isIndexExists(indexName)) {
System.out.println(indexName + " not exists");
} else {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"),
9300));
DeleteIndexResponse dResponse = client.admin().indices().prepareDelete(indexName)
.execute().actionGet();
if (dResponse.isAcknowledged()) {
System.out.println("delete index "+indexName+" successfully!");
}else{
System.out.println("Fail to delete index "+indexName);
}
}
}
// 建立索引庫
@Test
public void createIndex() {
//要建立索引庫的名稱
String indexName = "shcool";
try {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
// 建立索引庫
if (isIndexExists(indexName)) {
System.out.println("Index " + indexName + " already exits!");
} else {
CreateIndexRequest cIndexRequest = new CreateIndexRequest(indexName);
CreateIndexResponse cIndexResponse = client.admin().indices().create(cIndexRequest)
.actionGet();
if (cIndexResponse.isAcknowledged()) {
System.out.println("create index successfully！");
} else {
System.out.println("Fail to create index!");
}
}
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
/**
* 批量從Elasticsearch導出json到文件中
*/
@Test
public void ElasticSearchBulkOut() {
try {
//初始化
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch").build();// cluster.name在elasticsearch.yml
//鏈接客戶端
Client client = TransportClient.builder().settings(settings).build()
.addTransportAddress(new InetSocketTransportAddress(
InetAddress.getByName("127.0.0.1"), 9300));
//匹配全部查詢
QueryBuilder qb = QueryBuilders.matchAllQuery();
SearchResponse response = client.prepareSearch("blog")
.setTypes("article").setQuery(qb)
.execute().actionGet();
//獲取命中記錄
SearchHits resultHits = response.getHits();
//遍歷命中記錄，寫到文件中
File article = new File("C:\\ElasticsearchDemo\\src\\java\\file\\bulk.txt");
FileWriter fw = new FileWriter(article);
BufferedWriter bfw = new BufferedWriter(fw);
if (resultHits.getHits().length == 0) {
System.out.println("查到0條數據!");
} else {
for (int i = 0; i < resultHits.getHits().length; i++) {
String jsonStr = resultHits.getHits()[i]
.getSourceAsString();
System.out.println(jsonStr);
bfw.write(jsonStr);
bfw.write("\n");
}
}
bfw.close();
fw.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 批量導入到Elasticsearch中
*/
@Test
public void ElasticSearchBulkInput() {
try {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch").build();// cluster.name在elasticsearch.yml中配置
Client client = TransportClient.builder().settings(settings).build()
.addTransportAddress(new InetSocketTransportAddress(
InetAddress.getByName("127.0.0.1"), 9300));
File article = new File("C:\\ElasticsearchDemo\\src\\java\\file\\bulk.txt");
FileReader fr=new FileReader(article);
BufferedReader bfr=new BufferedReader(fr);
String line = null;
BulkRequestBuilder bulkRequest=client.prepareBulk();
int count=0;
while((line=bfr.readLine())!=null){
bulkRequest.add(client.prepareIndex("test","article").setSource(line));
if (count%10==0) {
bulkRequest.execute().actionGet();
}
count++;
//System.out.println(line);
}
bulkRequest.execute().actionGet();
bfr.close();
fr.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 根據名稱判斷索引是否存在
* @param indexName
* @return
*/
public boolean isIndexExists(String indexName) {
boolean flag = false;
try {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
IndicesExistsRequest inExistsRequest = new IndicesExistsRequest(indexName);
//下面可判斷多個索引名稱是否存在
//IndicesExistsResponse indexResponse = client.admin().indices().prepareExists("blog","blog1").execute().actionGet();
IndicesExistsResponse inExistsResponse = client.admin().indices()
.exists(inExistsRequest).actionGet();
if (inExistsResponse.isExists()) {
flag = true;
} else {
flag = false;
}
} catch (UnknownHostException e) {
e.printStackTrace();
}
return flag;
}
/**
* 刪除type下的全部文檔
* 也就是相似關係型數據庫中根據表刪除全部記錄
*
* ps（須要下載插件plugin install delete-by-query）和導入pom包
*
* ps(使用的是windows服務的方式運行Elastic，所以須要在bin目錄下的使用service重啓，否則就會報空指針異常！
*/
@Test
public void deleteByQuery() throws UnknownHostException {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
String deletebyquery = "{\"query\": {\"match_all\": {}}}";
DeleteByQueryRequestBuilder response = new DeleteByQueryRequestBuilder(client,DeleteByQueryAction.INSTANCE);
response.setIndices("blog").setTypes("article").setSource(deletebyquery)
.execute()
.actionGet();
}
//-------------------------------------------------------------------
/**
* Java三層嵌套查詢，我感受是用得不多的。貼個連接把：
* http://blog.csdn.net/napoay/article/details/52060659
* <p>
* 搜索有相同父id的子文檔，我也感受用得少。貼個連接吧：
* http://blog.csdn.net/napoay/article/details/52118408
*
* 集羣配置，如今用不上。貼個連接吧：
* http://blog.csdn.net/napoay/article/details/52202877
*/
//-------------------------------------------------------------------
/**
* 刪除index爲blog、類型爲article、id爲1的索引中的id屬性
* (須要在配置文件中添加如下內容），不然會出現異常
*
* script.inline: on
script.indexed: on
script.engine.groovy.inline.aggs: on
*
* @throws UnknownHostException
*/
@Test
public void deleteField() throws UnknownHostException {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
client.prepareUpdate("blog", "article", "1").setScript(new Script("ctx._source.remove(\"title\")",ScriptService.ScriptType.INLINE, null, null)).get();
//刪除屬性中的屬性
//client.prepareUpdate("test", "document", "1").setScript(new Script( "ctx._source.processInstance.remove(\"id\")",ScriptService.ScriptType.INLINE, null, null)).get();
}
/**
* 添加了Elasticsearch安全插件之後，鏈接cliet的方式就要改變了。
*
* 網站給的maven座標根本找不到，只能下載了個jar包用了。
*
* 配置了Elasticsearch認證之後，kibana也須要配置，否則進不去的。
*
* 連接：
* http://blog.csdn.net/sd4015700/article/details/50427852
*
* 當前配置的Elasticsearch zhongfucheng:zhongfucheng
* 當前配置的kibana kibanaserver:zhongfucheng (ps:此部分還須要修改配置文件，詳情看上邊的鏈接)
*
*/
@Test
public void changeClient() throws UnknownHostException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
System.out.println(client);
}
/**
* 判斷類型是否存在
* @throws UnknownHostException
*/
@Test
public void isTypeExists() throws UnknownHostException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
// bolg是index、article是類型
TypesExistsResponse typeResponse = client.admin().indices()
.prepareTypesExists("blog").setTypes("article")
.execute().actionGet();
System.out.println(typeResponse.isExists());
}
/**
* 關閉索引
*/
@Test
public void closeIndex() throws UnknownHostException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
CloseIndexResponse cIndexResponse = client.admin().indices().prepareClose("shcool")
.execute().actionGet();
if (cIndexResponse.isAcknowledged()) {
System.out.println("關閉索引成功");
}
}
/**
* 打開索引
* @throws UnknownHostException
*/
@Test
public void openIndex() throws UnknownHostException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
OpenIndexResponse oIndexResponse = client.admin().indices()
.prepareOpen("shcool")
.execute().actionGet();
System.out.println(oIndexResponse.isAcknowledged());
}
/**
* 獲取文檔的集合
* 能夠獲取同一索引、同一類型、不一樣id的文檔集合
* 也能夠獲取不一樣索引、不一樣類型、不一樣id的文檔集合
*/
@Test
public void getDocCollection() throws UnknownHostException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
MultiGetResponse multiGetItemResponses = client.prepareMultiGet()
.add("blog", "article", "1") //註釋1
//.add("twitter", "tweet", "2", "3", "4") //註釋2
.add("test", "article", "AV-K5x1NAQtVzQCf247Q") //註釋3
.get();
for (MultiGetItemResponse itemResponse : multiGetItemResponses) { //註釋4
GetResponse response = itemResponse.getResponse();
if (response.isExists()) { //註釋5
String json = response.getSourceAsString(); //註釋6
System.out.println(json);
}
}
/**
註釋1: 經過單一的ID獲取一個文檔.
註釋2：傳入多個id，從相同的索引名/類型名中獲取多個文檔.
註釋3：能夠同時獲取不一樣索引中的文檔.
註釋4：遍歷結果集.
註釋5：檢驗文檔是否存在.
註釋6：獲取文檔源.
*/
}
/**
* 獲取索引下每一個Type和Mapping
* @throws IOException
*/
@Test
public void getIndexTypeAndMapping() throws IOException {
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
ImmutableOpenMap<String, MappingMetaData> mappings = client.admin().cluster().prepareState().execute()
.actionGet().getState().getMetaData().getIndices().get("blog").getMappings();
for (ObjectObjectCursor<String, MappingMetaData> cursor : mappings) {
System.out.println(cursor.key); // 索引下的每一個type
System.out.println(cursor.value.getSourceAsMap()); // 每一個type的mapping
}
}
/**
*
* Elasticsearch還有分析聚合這麼一個功能，相似與Mysql中的分組函數、統計數據。
* 貼個連接：
*
* http://blog.csdn.net/napoay/article/details/53484730
*/
}
上面的代碼是到：blog.csdn.net/napoay/arti…爲止的。
在練習Demo的時候出現了幾個問題：
- 使用shiled認證，沒法下載maven座標，只能導入jar包(官方給出的maven座標也找不着....shield被廢棄了)
- 使用shiled認證以後，**上面博主給出的鏈接ElasticSearch代碼有錯，拋出了異常。**上網找了幾篇資料，沒法解決個人問題：
- blog.csdn.net/sd4015700/a…
- blog.csdn.net/lvyuan1234/…
- 最後在一篇博文中找到了答案：更新鏈接Elasticsearch的代碼
Settings settings = Settings.settingsBuilder()
.put("cluster.name", "elasticsearch")
.put("shield.user", "zhongfucheng:zhongfucheng")
.build();
TransportClient client = TransportClient.builder()
.addPlugin(ShieldPlugin.class)
.settings(settings).build();
client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
6、總結
在個人我的項目中簡單用到了Elasticsearch，也遇到了很多的坑，好比：當建立Elasticsearch的Client的時候，必定要加入嗅探這麼一個配置：.put("client.transport.sniff", true)，不然Elasticsearch在使用的時候會很是很是卡，簡直使人懷疑人生。
當時我是用Elasticsearch作自動補齊的功能的，也就下面這張圖片：
Elasticsearch有suggest這麼一個自動提示(補齊)的功能，參考博文：
具體的操做：
- 在創建Mapping的時候建立自動補齊的這麼一個字段，設置如下的Mapping
//自動補全屬性--------
.startObject("suggestName")
.field("type", "completion")
.field("analyzer", "standard")
.field("payloads", "true")
.endObject()
//自動補全屬性結束--------
當用戶加入新的索引記錄的時候，自動補齊字段就是咱們的關鍵字段
public static String String2JSON(String... strings) throws IOException {
String suggestName = strings[2];
if (suggestName.length() > 0) {
}
XContentBuilder builder = jsonBuilder()
.startObject()
.field("userId", strings[0])
.field("webSiteAddr", strings[1])
.field("webSiteName", strings[2])
//自動補全字段
.field("suggestName", strings[2])
.endObject();
return builder.string();
}
其餘基礎的東西其實都是Lucene演變過來的，要是沒學過Lucene能夠去看看我另一篇博文：
若是文章有錯的地方歡迎指正，你們互相交流。習慣在微信看技術文章，想要獲取更多的Java資源的同窗，能夠關注微信公衆號:Java3y
相關文章
- 1. Elasticsearch就這麼簡單
- 2. Jquery就是這麼簡單
- 3. WebService就是這麼簡單
- 4. WebSocket就是這麼簡單
- 5. Maven就是這麼簡單
- 6. Tomcat就是這麼簡單
- 7. HTTP就是這麼簡單
- 8. XML就是這麼簡單
- 9. Activiti就是這麼簡單
- 10. ThreadLocal就是這麼簡單
- 更多相關文章...
- • Thymeleaf簡單格式化輸出 - Thymeleaf 教程
- • jQuery Mobile 表單 - jQuery Mobile 教程
- • Github 簡明教程
- • 再有人問你分佈式事務，把這篇扔給他
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. Duang!超快Wi-Fi來襲
- 2. 機器學習-補充03 神經網絡之**函數(Activation Function)
- 3. git上開源maven項目部署 多module maven項目（多module maven+redis+tomcat+mysql）後臺部署流程學習記錄
- 4. ecliple-tomcat部署maven項目方式之一
- 5. eclipse新導入的項目經常可以看到「XX cannot be resolved to a type」的報錯信息
- 6. Spark RDD的依賴於DAG的工作原理
- 7. VMware安裝CentOS-8教程詳解
- 8. YDOOK：Java 項目 Spring 項目導入基本四大 jar 包 導入依賴，怎樣在 IDEA 的項目結構中導入 jar 包 導入依賴
- 9. 簡單方法使得putty（windows10上）可以免密登錄樹莓派
- 10. idea怎麼用本地maven
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. Elasticsearch就這麼簡單
- 2. Jquery就是這麼簡單
- 3. WebService就是這麼簡單
- 4. WebSocket就是這麼簡單
- 5. Maven就是這麼簡單
- 6. Tomcat就是這麼簡單
- 7. HTTP就是這麼簡單
- 8. XML就是這麼簡單
- 9. Activiti就是這麼簡單
- 10. ThreadLocal就是這麼簡單