1. docker 安裝ElasticSearch
- 這里采用單例模式安裝
docker run -di -e ES_JAVA_OPTS="-Xms512m -Xmx512m" -e "discovery.type=single-node" -p 9200:9200 -p 9300:9300 --name=elasticsearch elasticsearch:8.2.3
- 進(jìn)入容器，對(duì)elasticsearch進(jìn)行配置
docker exec -u root -it elasticsearch bash
apt-get update
apt-get install vim -y
vim config/elasticsearch.yml
將elasticsearch安全性配置修改為false
#
# -------------------------------------------------------------------------------
--
# Enable security features
xpack.security.enabled: false
xpack.security.enrollment.enabled: false
# Enable encryption for HTTP API client connections, such as Kibana, Logstash, aa
nd Agents
xpack.security.http.ssl:
enabled: false
keystore.path: certs/http.p12
# Enable encryption and mutual authentication between cluster nodes
xpack.security.transport.ssl:
enabled: false
verification_mode: certificate
keystore.path: certs/transport.p12
truststore.path: certs/transport.p12
#----------------------- END SECURITY AUTO CONFIGURATION ------------------------
完成后，保存配置文件并重啟
打開9200地址辞州，既可看到如下圖所示阱飘，即啟動(dòng)成功
image.png
2. docker 安裝kibana
docker run -d -p 5601:5601 --link elasticsearch:es -e ELASTICSEARCH_URL=http://es:9200 --name kibana kibana:8.2.3
完成后驹吮，打開5600地址依疼，可以看到kibana首頁
image.png
3. Spring Boot 整合ElasticSearch
- pom添加依賴文件
<dependency>
<groupId>co.elastic.clients</groupId>
<artifactId>elasticsearch-java</artifactId>
<version>8.2.3</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.12.3</version>
</dependency>
- 添加配置類
@Configuration
public class ElasticConfig {
// 主機(jī)剖煌，默認(rèn)127.0.0.1
@Value("${elasticsearch.host:127.0.0.1}")
private String host;
// 端口材鹦，默認(rèn)9200
@Value("${elasticsearch.port:9200}")
private Integer port;
// 協(xié)議，默認(rèn)http
@Value("${elasticsearch.scheme:http}")
private String scheme;
@Bean
public RestClient getRestClient() {
return RestClient.builder(
new HttpHost(host, port, scheme)
).build();
}
@Bean
public ElasticsearchTransport getElasticsearchTransport() {
// 使用 transport 加載 json 的對(duì)象映射器
return new RestClientTransport(getRestClient(),
new JacksonJsonpMapper());
}
@Bean
public ElasticsearchClient getElasticsearchClient() {
// 創(chuàng)建操作用的 ElasticsearchClient 對(duì)象
return new ElasticsearchClient(getElasticsearchTransport());
}
}
- 添加spring配置
elasticsearch:
host: 192.168.0.197
port: 9200
scheme: http
- 編寫測(cè)試類
@Autowired
private ElasticsearchClient elasticsearchClient;
@Test
public void sendSingle() {
try {
Map<String, String> data = new HashMap<>();
data.put("測(cè)試一下", "測(cè)試一下");
IndexRequest<Object> indexRequest = new IndexRequest.Builder<Object>()
.index("測(cè)試")
.id("1")
.document(data)
.build();
elasticsearchClient.index(indexRequest);
} catch (Exception e) {
log.error("es索引失敗", e);
}
}
4. 在kibana中查看添加的索引耕姊，并建立視圖
-
點(diǎn)擊stack management
image.png -
點(diǎn)擊索引管理桶唐，既可看見我們剛剛添加的索引
image.png -
點(diǎn)擊數(shù)據(jù)視圖，創(chuàng)建數(shù)據(jù)視圖
image.png
4.輸入索引名稱茉兰，創(chuàng)建視圖
image.png -
點(diǎn)擊discover,即可以看到我們創(chuàng)建的測(cè)試視圖
image.png
