Elasticsearch 下载安装及使用总结
官网文档地点：Elasticsearch Guide官网下载地点：Download Elasticsearch
1. 下载安装
1、下载对应体系的版本
这里下载的 Elasticsearch 版本为 8.13.2，Elasticsearch 依赖 Java，因此要先在服务器上安装 JDK，不过高版本的 Elasticsearch 已经内置了 JDK
https://img-blog.csdnimg.cn/img_convert/2f006df9501a5608925b9772e48f6500.png
2、上传到服务器上，解压
tar -xzf elasticsearch-8.13.2-linux-x86_64.tar.gz
3、创建新用户
Elasticsearch 不能在 root 用户下启动，因此需要创建一个新用户或者使用其他非 root 用户来启动，将 Elasticsearch 实行目录的所属更改为该用户
groupadd es && useradd es -g es
chown -R es:es elasticsearch-8.13.2
4、修改内存巨细
默认分配的内存巨细为 4G，服务器内存不敷可以手动调整分配内存巨细，修改 /config/jvm.options 文件
https://img-blog.csdnimg.cn/img_convert/348092be16a807cae1f9a07a743a826d.png
5、修改 /config/elasticsearch.yml 设置文件
[*]cluster.name：集群名称，集群下全部节点保持一致
[*]node.name：节点名称
[*]path.data：数据目录，一样平常可默认，在实行目录下
[*]path.logs：日志目录，一样平常可默认，在实行目录下
[*]network.host：服务器地点，有几个特殊的预设值，详细可见 Networking | Elasticsearch Guide ，默认为 192.168.0.1
[*]http.port：端口，默认 9200
[*]discovery.seed_hosts：服务发现种子主机，用于设置集群中其他节点
[*]cluster.initial_master_nodes：初始主节点
6、修改最大内存限制，修改 /etc/sysctl.conf 文件，这里的值为 Elasticsearch 要求的最小值
vm.max_map_count = 262144
加载设置
sysctl -p
7、使用非 root 用户启动 Elasticsearch，-d 表现背景启动
./bin/elasticsearch -d
一样平常默认会开启安全设置，会自动生成证书文件并在设置文件里自动添加相关设置
https://img-blog.csdnimg.cn/img_convert/d2007f8aed12769decca9b49211e0828.png
8、测试，访问 https://ip:9200，输入用户名密码，在启动时会输出到控制台或者去日志文件检察
Password for the elastic user (reset with `bin/elasticsearch-reset-password -u elastic`):
r3m5YCt8V=OyGourmPYv
或者直接实行 bin/elasticsearch-reset-password -u elastic 生成一个新密码，获取到如下信息即表现乐成
https://img-blog.csdnimg.cn/img_convert/f2f7ae552177f85cbd4fa53dbc9870a2.png
上面默认开启了 ssl，也就是 https 访问，在使用 Java 毗连时默认会去验证证书相关，可以将 xpack.security.http.ssl.enable 设置为 false，使用 http 访问
2. 使用
需要带上用户名密码
https://img-blog.csdnimg.cn/img_convert/1ed4ecf35fee36f80732a5e8000dce0c.png
1、直接检察服务状态
GET https://ip:9200
https://img-blog.csdnimg.cn/img_convert/838883a35572ccf3dab00e9e4cb76fa1.png
2、测试分词
POST https://ip:9200/_analyze
[*]tokenizer：选择使用的分词器
[*]char_filter：过滤
[*]text：需要分词的文本
https://img-blog.csdnimg.cn/img_convert/192849813e03dfb0b1c3c4c82da4acdb.png
内置分词器
分词器描述分词对象结果standard标准分析器是默认的分析器，假如没有指定，则使用该分析器。它提供了基于文法的标记化(基于 Unicode 文本分割算法，如 Unicode 标准附件 # 29 所规定) ，并且对大多数语言都有用。The 2 QUICK Brown-Foxes jumped over the lazy dog’s bone.[ the, 2, quick, brown, foxes, jumped, over, the, lazy, dog’s, bone ]simple简单分析器将文本分解为任何非字母字符的标记，如数字、空格、连字符和撇号、放弃非字母字符，并将大写字母更改为小写字母。The 2 QUICK Brown-Foxes jumped over the lazy dog’s bone.[ the, quick, brown, foxes, jumped, over, the, lazy, dog, s, bone ]whitespace空格分析器在碰到空白字符时将文本分解为术语The 2 QUICK Brown-Foxes jumped over the lazy dog’s bone.[ The, 2, QUICK, Brown-Foxes, jumped, over, the, lazy, dog’s, bone. ]stop停止分析器与简单分析器相同，但增长了删除停止字的支持。默认使用的是_english_ 停止词。The 2 QUICK Brown-Foxes jumped over the lazy dog’s bone.[ quick, brown, foxes, jumped, over, lazy, dog, s, bone ]keyword不分词，把整个字段当做一个整体返回The 2 QUICK Brown-Foxes jumped over the lazy dog’s bone.pattern模式分析器使用正则表达式将文本拆分为术语。正则表达式应该匹配令牌分隔符，而不是令牌本身。正则表达式默认为w+ (或全部非单词字符)。The 2 QUICK Brown-Foxes jumped over the lazy dog’s bone.[ the, 2, quick, brown, foxes, jumped, over, the, lazy, dog, s, bone ] 扩展，中文分词器
分词器描述分词对象结果ik_smartik 分词器中的简单分词器，支持自界说字典，远程字典学如逆水行舟，不进则退[学如逆水行舟,不进则退]ik_max_wordik_分词器的全量分词器，支持自界说字典，远程字典学如逆水行舟，不进则退[学如逆水行舟,学如逆水,逆水行舟,逆水,行舟,不进则退,不进,则,退] 下载地点：Releases · infinilabs/analysis-ik (github.com)
上传到服务器上 /plugins/ik 目录下，解压
unzip elasticsearch-analysis-ik-8.12.2.zip
注意要设置 ik 分词器的 Elasticsearch 版本，修改 /plugins/ik/plugin-descriptor.properties 文件，然后重启服务
https://img-blog.csdnimg.cn/img_convert/d3047588e57f4b477f7ec1d0e5978361.png
1.2.1 索引
相当于数据库表
1、创建索引，indexs 为对应的索引名称
POST https://ip:9200/indexs
https://img-blog.csdnimg.cn/img_convert/b3728b1289542690f01b4a98283aafce.png
重复创建的话会报错
https://img-blog.csdnimg.cn/img_convert/298c7c198b75a7043fd4cb7dd79fd575.png
创建索引时可以指定 mapping，给字段设置类型和分词器等
https://img-blog.csdnimg.cn/img_convert/74160bef1d27939e1a1a872396cd7f23.png
2、查询索引，indexs 为对应的索引名称
GET https://ip:9200
/indexs 这里没有 mapping，在文档写入 Elasticsearch 时，会根据文档字段自动辨认类型，这种机制称之为动态映射
https://img-blog.csdnimg.cn/img_convert/449c95fe651873a380152158423888d4.png
3、删除索引，indexs 为对应的索引名称
DELETE https://ip:9200/indexs
https://img-blog.csdnimg.cn/img_convert/3fc4db230d6bc72b1d78ed2d40e97334.png
1.2.2 文档
1、添加文档，indexs 为对应的索引名称
POST https://ip:9200/indexs
/_doc # 使用体系生成idPOST https://ip:9200/indexs
/_create/1 # 使用指定idPOST https://ip:9200/indexs
/_doc/1 # 使用指定id，不存在创建，存在更新 https://img-blog.csdnimg.cn/img_convert/62d9c072986b38f482eb8d82388ddd93.png
再检察索引可以发现已经有了 mapping
https://img-blog.csdnimg.cn/img_convert/6b2efbf24441fef7910c932c1627cba6.png
2、查询文档，indexs 为对应的索引名称
GET https://ip:9200
/indexs/_doc/1# 查询单个文档GET http://ip:9200/indexs/_search# 查询全部文档 https://img-blog.csdnimg.cn/img_convert/c93427240032b5e0b7ed286965ca1f3a.png
https://img-blog.csdnimg.cn/img_convert/887465db632b24092bf6a42e2b0ddeb7.png
条件查询
GET http://ip:9200/indexs/_search?q=content:test # q=查询属性名:查询属性值
https://img-blog.csdnimg.cn/img_convert/ae15da203ac80cde561c3397d57f3b3b.png
3、删除文档，indexs 为对应的索引名称
DELETE http://ip:9200/indexs/_doc/1
https://img-blog.csdnimg.cn/img_convert/af475fc1104ae8b01bcce798de4a751e.png
4、修改文档，indexs 为对应的索引名称
全量更新，相当于删除了原来的文档然后重新添加
PUT http://ip:9200/indexs/_doc/1
https://img-blog.csdnimg.cn/img_convert/36dcd606098813d420950d957ad985dc.png
部门更新，不对原始文档进行更新，而是对原始文档对象中的 doc 属性中的指定属性更新
POST http://ip:9200/indexs/_update/1
https://img-blog.csdnimg.cn/img_convert/949f46a396d7a796802a8febe13a9c4a.png
3. 整合 Java
有以下几种通过 Java 操作 Elasticsearch 的方式
[*]ElasticsearchRepository：雷同 MyBatis-Plus 的操作
[*]ElasticsearchTemplate/ElasticSearchRestTemplate：雷同 Redistemplate 的操作
[*]RestHighLevelClient：Elasticsearch 官方提供的 Java 客户端，使用 DSL 的格式来操作，新版本已被弃用
[*]Elasticsearch Java API Client：替换 RestHighLevelClient
3.1 ElasticsearchRepository
3.1.1 引入依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
3.1.2 设置文件
设置 Elasticsearch 的服务器地点以及用户名密码
spring:
elasticsearch:
uris: http://127.0.0.1:9200
username: elastic
password: elastic
3.1.3 文档实体类
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
@Data
@Document(indexName = "articles")
public class Article {
@Id
private String id;
private String title;
private String content;
}
[*]@Document(indexName = "articles")：指定文档的索引名称
[*]@Id：指定该字段作为文档 ID
3.1.4 数据访问层
继承 ElasticsearchRepository，它提供了一套标准的方法定名规范，符合规范的方法名在输入的时候就会有提示，好比 findByXxx(T xxx)，会自动为符合定名规范的方法生成对应的 DSL 语句
import fable.entity.Article;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
public interface ArticleRepository extends ElasticsearchRepository<Article, String> {
Article findByContent(String content);
}
3.1.5 Service
import fable.repository.ArticleRepository;
import fable.entity.Article;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class ArticleService {
private final ArticleRepository articleRepository;
@Autowired
public ArticleService(ArticleRepository articleRepository) {
this.articleRepository = articleRepository;
}
public Article findByContent() {
return articleRepository.findByContent("test");
}
public void save() {
Article article = new Article();
article.setId("test");
article.setTitle("test");
article.setContent("test save");
articleRepository.save(article);
}
}
3.1.6 Controller
import fable.entity.Article;
import fable.service.ArticleService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class ArticleController {
private final ArticleService articleService;
@Autowired
public ArticleController(ArticleService articleService) {
this.articleService = articleService;
}
@GetMapping("/findByContent")
public Article findByContent() {
return articleService.findByContent();
}
@GetMapping("/save")
public void save() {
articleService.save();
}
}
3.1.7 启动类
添加 @EnableElasticsearchRepositories 注解，设置包扫描
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
@SpringBootApplication
@EnableElasticsearchRepositories(basePackages = "fable.repository")
public class FableApplication {
public static void main(String[] args) {
SpringApplication.run(FableApplication.class, args);
}
}
3.1.8 测试
访问 /save 接口，可以看到文档信息已经添加了进来
https://img-blog.csdnimg.cn/img_convert/1eabb7807b99ff2492001b0374865cf7.png
访问 /findByContent 接口，可以看到对应的文档信息
https://img-blog.csdnimg.cn/img_convert/2a0b1309151d7dd6d50d1dce12230b4c.png
3.2 ElasticsearchTemplate/ElasticSearchRestTemplate
将 ElasticsearchTemplate/ElasticSearchRestTemplate 注入进来然后使用对应的方法即可，可自行相识
@Service
public class ArticleService {
private final ArticleRepository articleRepository;
private final ElasticsearchTemplate elasticsearchTemplate;
@Autowired
public ArticleService(ArticleRepository articleRepository, ElasticsearchTemplate elasticsearchTemplate) {
this.articleRepository = articleRepository;
this.elasticsearchTemplate = elasticsearchTemplate;
}
}
3.3 RestHighLevelClient
3.3.1 引入依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
</dependency>
</dependencies>
3.3.2 Controller
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.elasticsearch.action.get.GetRequest;
import org.elasticsearch.action.get.GetResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.IOException;
@RestController
public class ArticleController {
@GetMapping("/get")
public GetResponse get() throws IOException {
BasicCredentialsProvider provider = new BasicCredentialsProvider();
provider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "elastic"));
RestClientBuilder builder = RestClient.builder(new HttpHost("127.0.0.1", 9200, "http"))
.setHttpClientConfigCallback(httpAsyncClientBuilder -> httpAsyncClientBuilder.setDefaultCredentialsProvider(provider));
RestHighLevelClient client = new RestHighLevelClient(builder);
GetRequest getRequest = new GetRequest("articles", "test");
return client.get(getRequest, RequestOptions.DEFAULT);
}
}
3.3.3 测试
访问 /get 接口，可以看到对应的文档信息
https://img-blog.csdnimg.cn/img_convert/0364c61e987232dbd0cdc37f71a2b596.png
3.4 Elasticsearch Java API Client
3.4.1 引入依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>co.elastic.clients</groupId>
<artifactId>elasticsearch-java</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>
3.4.2 文档实体类
import lombok.Data;
@Data
public class Article {
private String id;
private String title;
private String content;
}
3.4.3 Controller
需要注意这里的文档实体类必须包含索引的全部字段，否则会报错无法解析
import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch.core.GetResponse;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import fable.entity.Article;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.elasticsearch.client.RestClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.IOException;
@RestController
public class ArticleController {
@GetMapping("/get")
public Article get() throws IOException {
BasicCredentialsProvider provider = new BasicCredentialsProvider();
provider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "UnF8lyv82vJarD=iAbcZ"));
RestClient restClient = RestClient.builder(new HttpHost("124.222.118.90", 9200, "http"))
.setHttpClientConfigCallback(httpAsyncClientBuilder -> httpAsyncClientBuilder.setDefaultCredentialsProvider(provider))
.build();
ElasticsearchTransport transport = new RestClientTransport(
restClient, new JacksonJsonpMapper()
);
ElasticsearchClient elasticsearchClient = new ElasticsearchClient(transport);
GetResponse<Article> response = elasticsearchClient.get(builder -> builder.index("articles").id("test"), Article.class);
System.out.println(response);
return response.source();
}
}
3.4.4 测试
访问 /get 接口，可以看到文档信息如下
https://img-blog.csdnimg.cn/img_convert/5564d6d9bb419baa602e81964444398f.png
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]