在es中我们通过查询某个关键字，从而查询到关键字相关的数据。那么他是怎么去找的？
ES默认的支持对英文的分词，因为英文都是以空格分词，而对于中文的分词效果并不太好
也就是对一句话进行分词的叫做分词器。
##1. 将下载好的zip的压缩包拷贝到es的plugins目录下
##2. 在此目录下创建一个ik的目录
##3. 在ik目录下将刚才zip压缩包解压
[root@hadoop plugins]# mkdir ik
[root@hadoop plugins]# yum -y install unzip
[root@hadoop plugins]# mv elasticsearch-analysis-ik-6.5.3.zip ik/
[root@hadoop ik]# unzip elasticsearch-analysis-ik-6.5.3.zip && rm -f elasticsearch-analysis-ik-6.5.3.zip
##4. 如果是全分布式的话，所有的节点都得拷贝
##5. 重启es
创建索引
curl -HContent-Type:application/json -XPUT ‘http://hadoop:9200/chinese?pretty’ -d
’
{
“settgings”:{
“number_of_shards”:3,
“number_of_replicas”:1,
“analysis”:{
“analyzer”:{
“ik”:{
“tokenizer”:“ik_max_word”
}
}
}
},
“mappings”:{
“test”:{
“properties”:{
“content”:{
“type”:“text”,
“analyzer”:“ik_max_word”,
“search_analyzer”:“ik_max_word”
}
}
}
}
}
’
导入数据
curl -HContent-Type:application/json -XPUT ‘http://hadoop:9200/chinese/test/7?pretty’ -d
’
{
“content”:“SSM框架简要介绍_Mr.zhou_Zxy-CSDN博客_简要介绍ssm框架”
}
’
curl -HContent-Type:application/json -XPUT ‘http://hadoop:9200/chinese/test/8?pretty’ -d
’
{
“content”:“Mr.zhou_Zxy-CSDN博客”
}
’
curl -HContent-Type:application/json -XDELETE ‘http://hadoop:9200/chinese/test/10?pretty’ -d
’
{
“content”:“大数据之布隆过滤器学习_Mr.zhou_Zxy-CSDN博客”
}
’
测试
curl -HContent-Type:application/json -XGET ‘http://hadoop:9200/chinese/_search?pretty’ -d
’
{
“query”:{
“match”:{
“content”:“Zxy”
}
}
}
’
org.elasticsearch.client
transport
6.5.3
com.alibaba
fastjson
1.2.71
org.projectlombok
lombok
1.18.8
package com.bigdata.es;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import java.net.InetAddress;
import java.net.UnknownHostException;
public class Demo1_QuickStart {
public static void main(String[] args) throws UnknownHostException {
//1. 获取客户端对象
Settings settings = Settings.builder()
.put("cluster.name", "zxy")
.build();
TransportClient client = new PreBuiltTransportClient(settings);
//2. 设置连接到集群
client.addTransportAddresses(
new TransportAddress(InetAddress.getByName("***.***.***.**"), 9300)
);
//3. 查询
GetResponse getResponse = client.prepareGet("zxy", "doc", "1").get();
String sourceAsString = getResponse.getSourceAsString();
System.out.println(sourceAsString);
//4. 插入
String json = "{"username":"Mr.zhou"}";
IndexResponse indexResponse = client.prepareIndex("zxy", "doc", "5").setSource(json, XContentType.JSON).get();
System.out.println(indexResponse.getIndex());
System.out.println(indexResponse.getId());
System.out.println(indexResponse.getType());
//5. 删除
DeleteResponse deleteResponse = client.prepareDelete("zxy", "doc", "5").get();
}
}
package com.bigdata.es;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import java.net.InetAddress;
import java.net.UnknownHostException;
public class Demo2_Search {
public static void main(String[] args) throws UnknownHostException {
//1. 获取客户端对象
Settings settings = Settings.builder()
.put("cluster.name", "zxy")
.build();
TransportClient client = new PreBuiltTransportClient(settings);
//2. 设置连接到集群
client.addTransportAddresses(
new TransportAddress(InetAddress.getByName("***.***.***.**"), 9300)
);
//3. 模糊查询
/**
* 1. SearchType
* DFS_QUERY_THEN_FETCH:会直接在es所在的节点直接匹配数据
* QUERY_THEN_FETCH:在分布式环境中匹配数据
* QUERY_AND_FETCH(过时)
*
* 2. QueryBuilders
* MatchAllQueryBuilder:select * from
* MatchQueryBuilder:select * from xxx where name like xxx
* CommonTermsQueryBuilder:select * from xxx where name = xxx
*/
SearchResponse searchResponse = client.prepareSearch("chinese")
.setSearchType(SearchType.QUERY_THEN_FETCH) // 检索范围
.setQuery(QueryBuilders.matchQuery("content", "Zxy"))
.get();
//4. 展示
SearchHits hits = searchResponse.getHits(); // 获取到命中的数据集
long totalHits = hits.totalHits; // 总的命中数
float maxScore = hits.getMaxScore(); // 最大的分数
System.out.println("totalHits :" + totalHits);
System.out.println("maxScore :" + maxScore);
SearchHit[] searchHits = hits.getHits(); // 获取命中的数据
for (SearchHit hit : searchHits) {
System.out.println("index :" + hit.getIndex());
System.out.println("type :" + hit.getType());
System.out.println("docId :" + hit.getId());
System.out.println("content :" + hit.getSourceAsString());
}
}
}