資訊專欄INFORMATION COLUMN
摘要：一前言最近有點(diǎn)想弄一個(gè)站內(nèi)搜索的功能，之前學(xué)過了，后來又聽過這個(gè)名詞。接著在了解全文搜索的時(shí)候就發(fā)現(xiàn)了這個(gè)，他也是以為基礎(chǔ)的。僅僅會(huì)一些簡單的命令，等真正去用到的時(shí)候再慢慢啃吧。文章給出的是以的方式打包下載。
一、前言
最近有點(diǎn)想弄一個(gè)站內(nèi)搜索的功能，之前學(xué)過了Lucene，后來又聽過Solr這個(gè)名詞。接著在了解全文搜索的時(shí)候就發(fā)現(xiàn)了Elasticsearch這個(gè)，他也是以Lucene為基礎(chǔ)的。
我去搜了幾篇Elasticsearch教程，發(fā)現(xiàn)很多都是基于linux的，但我linux耍得并不熟，很少用。僅僅會(huì)一些簡單的命令，等真正去用到linux的時(shí)候再慢慢啃吧。
于是發(fā)現(xiàn)了一篇寫得很好的教程：
http://blog.csdn.net/laoyang360/article/details/52244917
首先是對Elasticsearch的安裝，上面那篇教程也有說，并且給出了一鍵安裝的腳本。這里就用來記錄我個(gè)人的安裝歷程吧。
PS：2018年3月22日18:58:12更新：這里我已經(jīng)不建議在Windows下裝Elasticsearch了，因?yàn)檠b起來還是麻煩，也有一堆的小問題~(后面也有在Linux下配置Elasticsearch的過程，建議用linux環(huán)境下學(xué)習(xí)Elasticsearch(要是學(xué)生建議去買個(gè)服務(wù)器，有優(yōu)惠的),實(shí)在不想出錢，用虛擬機(jī)也行~
二、Windows下安裝Elasticsearch(不建議) 2.1安裝Elasticsearch安裝Elasticsearch以window服務(wù)的方式來運(yùn)行，它的給出的版本是2.3.3。于是我也去安裝2.3.3了。
在官網(wǎng)上可以在搜索框中查找對應(yīng)的版本
要以windows服務(wù)的方式運(yùn)行，教程給出的鏈接已經(jīng)掛了。我搜到了一篇
http://www.cnblogs.com/viaiu/p/5715200.html
2.2安裝head安裝head插件就很簡單了，切換到對應(yīng)的目錄下，使用如下命令：
plugin install mobz/elasticsearch-head2.3安裝kibana和Logstash插件以服務(wù)形式運(yùn)行
給出的連接是stackOverFlow下的提問，還有youtobe的視頻。stackOverFlow并不能解決我安裝過程的問題，youtobe我沒聯(lián)外網(wǎng)，也進(jìn)不去。
后來，我又找到了一篇教程，也十分順利：
https://segmentfault.com/a/1190000010741203#articleHeader2
Logstash下載的版本是：2.3.3與Elasticsearch對應(yīng)起來。
下載kibana的版本是：4.5.0
能夠出現(xiàn)下面這種情況，說明安裝成功
2.4安裝Shieldplugin install license plugin install shield
重啟，接著執(zhí)行:
添加管理員
bin/shield/esusers useradd adminName -r admin
為kibana添加用戶
esusers useradd kibanaserver -r kibana4_server
在其配置上(kibana.yml)添加:
kibana_elasticsearch_username: kibanaserver #Kibana服務(wù)將用這個(gè)用戶名訪問ElasticSearch服務(wù)器。 kibana_elasticsearch_password: zhongfucheng #密碼
只有配置了kibanaserver賬戶、才能登陸進(jìn)去
2.5安裝分詞器這次教程給出的連接就用上了，我截圖主要的：
ik分詞器的版本是1.9.3。文章給出的是以mvn的方式打包下載。因此在github中我們下載resouce類型的。
解壓的時(shí)候是在zip解壓到當(dāng)前文件上，把conf的數(shù)據(jù)拿過去是將其源文件拿過去(不包括文件夾!)
2.6拼音分詞器前面下載了中文分詞器，后邊在看教程的時(shí)候也發(fā)現(xiàn)了拼音分詞器，拼音分詞器的安裝和中文分詞器安裝的時(shí)候很類似
對應(yīng)Elasticsearch2.3.3版本的拼音分詞器版本為：1.7.3
Windows下裝Elasticsearch到此就結(jié)束了。
三、Linux下安裝Elasticsearch這是我搭建一個(gè)項(xiàng)目時(shí)候的筆記，
3.1下載ElasticsearchElasticserach的下載還是非常方便的，提供搜索來進(jìn)行下載。這里我就不貼鏈接了。直接去官網(wǎng)找就行了。或者去我的Elasticsearch學(xué)習(xí)記錄中找。
下載了2.3.3版本，因?yàn)槲以趙indows開發(fā)的時(shí)候也是下載2.3.3版本的，就為了保持一致吧。
3.2安裝Elasticsearchtar -xzvf elasticsearch-2.3.3.tar.gz
切換到bin目錄下執(zhí)行就行了...
需要這樣執(zhí)行elasticsearch，如果使用的是root用戶的話
./elasticsearch -d -Des.insecure.allow.root=true
現(xiàn)在使用下面的語句，是可以獲取得到信息的
curl -X GET "http://localhost:9200"
想要通過外網(wǎng)來訪問的話，那么就需要修改配置文件了，參考鏈接http://blog.csdn.net/u012599988/article/details/51767183
還要在ESC服務(wù)器上開放端口才能訪問：
3.2.1下載head插件在下載head插件的時(shí)候，需要修改elasticsearch的用戶和組，否則它就不讓你下載。命令如下
添加用戶和組
groupadd elasticsearch useradd elasticsearch -g elasticsearch -p 123456
修改文件夾權(quán)限
chown -R elasticsearch:elasticsearch elasticsearch-2.3.3
弄完之后就可以執(zhí)行命令下載head插件了。
./plugin install mobz/elasticsearch-head
下載完head插件后，不要立馬下載shield插件，首先在head插件上創(chuàng)建一個(gè)索引!
否則，當(dāng)下載完shield插件、再訪問head插件的話，就無法連接節(jié)點(diǎn)了!
這搞了我好長的時(shí)間才弄好!!!!!網(wǎng)上也有很多人遇到過這種情況，卻沒什么好的回答。都在說配置文件上的事情。
我是通過在github中別人提出的issue中找到答案的。參考:https://github.com/mobz/elast...
記住了，先在head插件中創(chuàng)建索引、再下載shield插件，否則無法連接head插件!
3.2.2下載權(quán)限shield我在windows下開發(fā)是有下載shiled，為了保持一致，我也下載吧。
輸入命令：
plugin install license plugin install shield
下載完就配置一個(gè)管理員用戶
bin/shield/esusers useradd adminName -r admin
如果文章有錯(cuò)的地方歡迎指正，大家互相交流。習(xí)慣在微信看技術(shù)文章，想要獲取更多的Java資源的同學(xué)，可以關(guān)注微信公眾號(hào):Java3y四、REST API
在前面一章中已經(jīng)下載了Elasticsearch和它常用的各種插件了。了解相關(guān)的概念后，我們就應(yīng)該動(dòng)手弄一弄Elasticsearch是怎么用的。
參考鏈接：
http://blog.csdn.net/laoyang360/article/details/52244917
我是跟著這個(gè)教程大致把REST API走了一下，也漸漸了解了Elasticsearch的知識(shí)點(diǎn)了。
http://www.yiibai.com/elasticsearch/elasticsearch_installation.html
五、JAVA API我們畢竟是使用Java的，因此得知道Elasticsearch和Java是怎么連接的。我找了幾篇教程：
http://www.cnblogs.com/wenbronk/p/6383194.html
http://www.cnblogs.com/tutu21ybz/p/6835178.html
后來找到了一篇比較系統(tǒng)的教程，推薦這個(gè)：
http://blog.csdn.net/napoay/article/details/51707023
自己也跟著教程寫了Demo，其中也出了不少錯(cuò)誤。貼上代碼：
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 {
/**
* 創(chuàng)建
* @throws UnknownHostException
*/
@Test
public void CreateIndex() throws UnknownHostException {
//連接客戶端
Client client = TransportClient.builder().build()
.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
//將數(shù)據(jù)轉(zhuǎn)成json字符串，用集合裝載起來
List jsonData = DataFactory.getInitJsonData();
//創(chuàng)建blog索引、article類型、數(shù)據(jù)是上邊的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("創(chuàng)建成功!");
}
}
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關(guān)鍵字的文檔
QueryBuilder qb1 = termQuery("title", "hibernate");
//查詢title字段或content字段中包含git關(guān)鍵字的文檔:
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()+": "+hit.getSource());// .get("title")
}
} else {
System.out.println("搜到0條結(jié)果");
}
}
/**
* 使用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", "學(xué)習(xí)目標(biāo) 掌握java泛型的產(chǎn)生意義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更新， 如果文檔不存在則創(chuàng)建新的索引
* @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", "學(xué)習(xí)目標(biāo) git。。。10").endObject());
UpdateRequest uRequest2 = new UpdateRequest("blog", "article", "10").doc(
jsonBuilder().startObject().field("title", "Git安裝").field("content", "學(xué)習(xí)目標(biāo) 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("刪除失敗");
}
}
/**
* 根據(jù)index名稱 刪除整個(gè)索引庫
* @throws IOException
* @throws ExecutionException
* @throws InterruptedException
*/
@Test
public void deleteIndex() throws IOException, ExecutionException, InterruptedException {
//要?jiǎng)h除索引庫的名字
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);
}
}
}
// 創(chuàng)建索引庫
@Test
public void createIndex() {
//要?jiǎng)?chuàng)建索引庫的名稱
String indexName = "shcool";
try {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("127.0.0.1"), 9300));
// 創(chuàng)建索引庫
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導(dǎo)出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:ElasticsearchDemosrcjavafileulk.txt");
FileWriter fw = new FileWriter(article);
BufferedWriter bfw = new BufferedWriter(fw);
if (resultHits.getHits().length == 0) {
System.out.println("查到0條數(shù)據(jù)!");
} 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("
");
}
}
bfw.close();
fw.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 批量導(dǎo)入到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:ElasticsearchDemosrcjavafileulk.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();
}
}
/**
* 根據(jù)名稱判斷索引是否存在
* @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);
//下面可判斷多個(gè)索引名稱是否存在
//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下的所有文檔
* 也就是類似關(guān)系型數(shù)據(jù)庫中根據(jù)表刪除所有記錄
*
* ps（需要下載插件plugin install delete-by-query）和導(dǎo)入pom包
*
* ps(使用的是windows服務(wù)的方式運(yùn)行Elastic，因此需要在bin目錄下的使用service重啟，不然就會(huì)報(bào)空指針異常！
*/
@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三層嵌套查詢，我感覺是用得很少的。貼個(gè)鏈接把：
* http://blog.csdn.net/napoay/article/details/52060659
*
* 搜索有相同父id的子文檔，我也感覺用得少。貼個(gè)鏈接吧：
* http://blog.csdn.net/napoay/article/details/52118408
*
* 集群配置，現(xiàn)在用不上。貼個(gè)鏈接吧：
* http://blog.csdn.net/napoay/article/details/52202877
*/
//-------------------------------------------------------------------
/**
* 刪除index為blog、類型為article、id為1的索引中的id屬性
* (需要在配置文件中添加以下內(nèi)容），否則會(huì)出現(xiàn)異常
*
* 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的方式就要改變了。
*
* 網(wǎng)站給的maven坐標(biāo)根本找不到，只能下載了個(gè)jar包用了。
*
* 配置了Elasticsearch認(rèn)證以后，kibana也需要配置，不然進(jìn)不去的。
*
* 鏈接：
* http://blog.csdn.net/sd4015700/article/details/50427852
*
* 當(dāng)前配置的Elasticsearch zhongfucheng:zhongfucheng
* 當(dāng)前配置的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());
}
/**
* 關(guān)閉索引
*/
@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("關(guān)閉索引成功");
}
}
/**
* 打開索引
* @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獲取一個(gè)文檔.
注釋2：傳入多個(gè)id，從相同的索引名/類型名中獲取多個(gè)文檔.
注釋3：可以同時(shí)獲取不同索引中的文檔.
注釋4：遍歷結(jié)果集.
注釋5：檢驗(yàn)文檔是否存在.
注釋6：獲取文檔源.
*/
}
/**
* 獲取索引下每個(gè)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 mappings = client.admin().cluster().prepareState().execute()
.actionGet().getState().getMetaData().getIndices().get("blog").getMappings();
for (ObjectObjectCursor cursor : mappings) {
System.out.println(cursor.key); // 索引下的每個(gè)type
System.out.println(cursor.value.getSourceAsMap()); // 每個(gè)type的mapping
}
}
/**
*
* Elasticsearch還有分析聚合這么一個(gè)功能，類似與Mysql中的分組函數(shù)、統(tǒng)計(jì)數(shù)據(jù)。
* 貼個(gè)鏈接：
*
* http://blog.csdn.net/napoay/article/details/53484730
*/
}
上面的代碼是到：http://blog.csdn.net/napoay/article/details/53276758為止的。
在練習(xí)Demo的時(shí)候出現(xiàn)了幾個(gè)問題：
使用shiled認(rèn)證，無法下載maven坐標(biāo)，只能導(dǎo)入jar包(官方給出的maven坐標(biāo)也找不著....shield被廢棄了)
使用shiled認(rèn)證之后，上面博主給出的連接ElasticSearch代碼有錯(cuò)，拋出了異常。上網(wǎng)找了幾篇資料，無法解決我的問題：
http://blog.csdn.net/sd4015700/article/details/50427852
http://blog.csdn.net/lvyuan1234/article/details/78227778
最后在一篇博文中找到了答案：更新連接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));
六、總結(jié)
在我的個(gè)人項(xiàng)目中簡單用到了Elasticsearch，也遇到了不少的坑，比如：當(dāng)創(chuàng)建Elasticsearch的Client的時(shí)候，一定要加入嗅探這么一個(gè)配置：.put("client.transport.sniff", true)，否則Elasticsearch在使用的時(shí)候會(huì)非常非?？ǎ喼绷钊藨岩扇松?。
當(dāng)時(shí)我是用Elasticsearch做自動(dòng)補(bǔ)齊的功能的，也就下面這張圖片：
Elasticsearch有suggest這么一個(gè)自動(dòng)提示(補(bǔ)齊)的功能，參考博文：
http://blog.csdn.net/gumpeng/article/details/50346631
http://www.tcao.net/article/86.html
http://blog.csdn.net/liyantianmin/article/details/60778273
具體的操作：
在建立Mapping的時(shí)候創(chuàng)建自動(dòng)補(bǔ)齊的這么一個(gè)字段，設(shè)置以下的Mapping
//自動(dòng)補(bǔ)全屬性--------
.startObject("suggestName")
.field("type", "completion")
.field("analyzer", "standard")
.field("payloads", "true")
.endObject()
//自動(dòng)補(bǔ)全屬性結(jié)束--------
當(dāng)用戶加入新的索引記錄的時(shí)候，自動(dòng)補(bǔ)齊字段就是我們的關(guān)鍵字段
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])
//自動(dòng)補(bǔ)全字段
.field("suggestName", strings[2])
.endObject();
return builder.string();
}
其他基礎(chǔ)的東西其實(shí)都是Lucene演變過來的，要是沒學(xué)過Lucene可以去看看我另外一篇博文：
Lucene就這么簡單
如果文章有錯(cuò)的地方歡迎指正，大家互相交流。習(xí)慣在微信看技術(shù)文章，想要獲取更多的Java資源的同學(xué)，可以關(guān)注微信公眾號(hào):Java3y
文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址：http://m.specialneedsforspecialkids.com/yun/76352.html
摘要：目前該功能并未完善，敬請期待。反正每次都會(huì)有新的東西補(bǔ)充上去一開始我本來想做的是可以使用微信登陸，也可以使用賬戶郵箱登陸，也可以使用短信登陸的。后來發(fā)現(xiàn)微信登陸要企業(yè)認(rèn)證，做不了。 從零開發(fā)項(xiàng)目概述 最近這一直在復(fù)習(xí)數(shù)據(jù)結(jié)構(gòu)和算法，也就是前面發(fā)出去的排序算法八大基礎(chǔ)排序總結(jié)，Java實(shí)現(xiàn)單向鏈表，棧和隊(duì)列就是這么簡單，十道簡單算法題等等... 被虐得不要不要的，即使是非常簡單有時(shí)候繞半...
閱讀 3331·2019-08-29 16:17
閱讀 1986·2019-08-29 15:31
閱讀 2656·2019-08-29 14:09
閱讀 2556·2019-08-26 13:52
閱讀 753·2019-08-26 12:21
閱讀 2150·2019-08-26 12:08
閱讀 1001·2019-08-23 17:08
閱讀 1934·2019-08-23 16:59
