docker、elasticsearch8、springboot3集成備忘

一、背景

二、安裝docker

三、下載安裝elasticsearch

四、下載安裝elasticsearch-head

五、springboot集成elasticsearch

一、背景

前兩年研究了一段時間elasticsearch，當時也是網上找了很多資料，最后解決個各種問題可以在springboot上運行了，本來是想記錄下解決過程，但是由于某些原因就擱置了下來。最近手頭有個項目正好需要用到elasticsearch，再拿起來的時候發現很多地方都不記得了，于是花了2天時間又搞了下，終于可以正常運行了，這次準備花點時間把遇到的一些問題、解決方法以及需要注意的地方記錄下，便于日后需要時查看。

二、安裝docker

2.1、從官網下載docker，好像需要科學上網，如果不行的話就隨便百度個下載吧。

2.2、安裝3個Windows功能，如下圖

2.3、安裝WSL，在命令行窗口執行wsl --install，如果安裝不成功的話可以嘗試從微軟應用商店安裝（好像只有win10可以搜到這個），搜索wsl，如下圖

2.4、安裝docker，這個沒啥需要特別記錄的

2.5、執行wsl --version查看當前使用的是不是wsl2，如果不是wsl2并且docker也確實不能正常啟動的話，可以嘗試切換到wsl2試試，切換命令為：wsl --set-default-version 2

三、下載安裝elasticsearch

3.1、根據springboot版本下載對應的elasticsearch鏡像，對應關系如下表：

Spring Data Release Train	Spring Data Elasticsearch	Elasticsearch	Spring Framework	Spring Boot
2023.1 (Vaughan)	5.2.x	8.11.1	6.1.x	3.2.x
2023.0 (Ullmann)	5.1.x	8.7.1	6.0.x	3.1.x
2022.0 (Turing)	5.0.x[1]	8.5.3	6.0.x	3.0.x
2021.2 (Raj)	4.4.x[1]	7.17.3	5.3.x	2.7.x
2021.1 (Q)	4.3.x[1]	7.15.2	5.3.x	2.6.x
2021.0 (Pascal)	4.2.x[1]	7.12.0	5.3.x	2.5.x
2020.0 (Ockham)	4.1.x[1]	7.9.3	5.3.2	2.4.x
Neumann	4.0.x[1]	7.6.2	5.2.12	2.3.x
Moore	3.2.x[1]	6.8.12	5.2.12	2.2.x
Lovelace	3.1.x[1]	6.2.2	5.1.19	2.1.x
Kay	3.0.x[1]	5.5.0	5.0.13	2.0.x
Ingalls	2.1.x[1]	2.4.0	4.3.25	1.5.x

也可以到spring官網查看最新的對應關系

3.2、下載指定版本的elasticsearch鏡像：

docker pull elasticsearch:8.11.0

3.3、安裝鏡像：

docker run --name?elastic?-p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" -d elasticsearch:8.11.0

3.4、進入鏡像修改配置

? ? ? ? 3.4.1、進入容器控制臺：

docker exec -it elastic?/bin/bash

? ? ? ? 3.4.2、進入bin目錄：cd bin

? ? ? ? 3.4.3、修改密碼：

elasticsearch-setup-passwords interactive

? ? ? ? 3.4.4、下載配置文件到本地修改：

docker cp elastic:/usr/share/elasticsearch/config/elasticsearch.yml d:/

? ? ? ? 3.4.5、在文件末尾添加（不添加的話elasticsearch-head連接時會報跨域錯誤）

????????????????http.cors.enabled: true
????????????????http.cors.allow-origin: "*"
????????????????http.cors.allow-headers: Authorization

? ? ? ? 3.4.6、上傳覆蓋原文件：

docker cp d:\elasticsearch.yml elastic:/usr/share/elasticsearch/config/

3.5、添加IK分詞插件

? ? ? ? 3.5.1、下載IK分詞插件，新建一個IK目錄，解壓到目錄中。

? ? ? ? 3.5.2、上傳IK文件夾

docker cp d:\xxx\ik elastic:\usr\share\elasticsearch\plugins\

????????3.5.3、重啟elastic

docker restart elastic

3.6、JDK導入證書（不是必須）

? ? ? ? 3.6.1、從elasticsearch下載證書

docker cp elastic:/usr/share/elasticsearch/config/certs/http_ca.crt d:\下載目錄

? ? ? ? 3.6.2、打開控制臺，進入JDK證書目錄

cd C:\Program Files\Java\jdk-18.0.2.1\lib\security

????????3.6.3、執行命令導入證書

C:\Program Files\Java\jdk-18.0.2.1\binkeytool -keystore cacerts -importcert -alias "es_http_ca" -file d:/下載目錄/http_ca.crt

四、下載安裝elasticsearch-head

4.1、下載elasticsearch-head

docker pull mobz/elasticsearch-head:5

4.2、安裝容器：

docker run --name elastic-head -p 9100:9100 -d mobz/elasticsearch-head:5

4.3、在地址欄輸入http://localhost:9100/?auth_user=elastic&auth_password=xxxxx，查看連接elastic是否成功，注意：使用https連接elasticsearch：http://localhost:9200

五、springboot集成elasticsearch

5.1、springboot3.2.0集成elasticsearch8.11.0運行正常，不過從官方文檔看3.2.x要求是8.11.1。下面是必須的一些包。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.2.0-SNAPSHOT</version></parent><properties><java.version>17</java.version></properties><dependencies><dependency><groupId>io.github.hakky54</groupId><artifactId>sslcontext-kickstart</artifactId><version>7.4.7</version></dependency><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></dependencies>
</project>

5.2、新建配置類

package com.rwzhang.elastic.elasticsearchdemo.config;import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.ElasticsearchTransport;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import nl.altindag.ssl.SSLFactory;
import org.apache.http.HttpHost;
import org.apache.http.auth.AuthScope;
import org.apache.http.auth.UsernamePasswordCredentials;
import org.apache.http.client.CredentialsProvider;
import org.apache.http.impl.client.BasicCredentialsProvider;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.repository.config.EnableElasticsearchRepositories;
import org.springframework.data.repository.query.QueryLookupStrategy;@Configuration
@EnableElasticsearchRepositories(queryLookupStrategy = QueryLookupStrategy.Key.CREATE_IF_NOT_FOUND,basePackages = "com.elastic.elasticsearchdemo.repository")
public class ElasticsearchConfig {@Beanpublic ElasticsearchClient elasticsearchClient(){SSLFactory sslFactory = SSLFactory.builder().withUnsafeTrustMaterial().withUnsafeHostnameVerifier().build();final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("elastic", "密碼"));RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200, "https"));builder = builder.setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider).setSSLContext(sslFactory.getSslContext()).setSSLHostnameVerifier(sslFactory.getHostnameVerifier()));RestClient restClient = builder.build();ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());return new ElasticsearchClient(transport);}
}

5.3、新建實體類

public class News implements Serializable {@Id@Field(store=true, index = false, type = FieldType.Integer)Integer id;@Field(analyzer="ik_max_word", searchAnalyzer="ik_smart", type = FieldType.Text)String title;@Field(analyzer="ik_max_word", searchAnalyzer="ik_smart", type = FieldType.Text)String content;public News(String title, String content) {this.title = title;this.content = content;}
}

5.4、新建repository

@Repository
public interface NewsRepository extends ElasticsearchRepository<News, Integer> {@Highlight(fields = {@HighlightField(name = "content")},parameters = @HighlightParameters(preTags = {"<span style='color:red'>"},postTags = {"</span>"},numberOfFragments = 10, //片段個數fragmentSize = 100  //片段長度))List<SearchHit<News>> findByContent(String content, Pageable pageable);long countByContent(String content);
}

5.5、新建測試類

@RunWith(SpringRunner.class)
@SpringBootTest
class ElasticsearchDemoApplicationTests {@ResourceNewsRepository newsRepository;@Testvoid countByContent() {long count = newsRepository.countByContent("足球");System.out.println(StrUtil.format("countByContent: {}", count));}
}