1. docker 安装ElasticSearch

1. 这里采用单例模式安装

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

2. 进入容器，对elasticsearch进行配置

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地址，既可看到如下图所示，即启动成功

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

1. 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>

2. 添加配置类

@Configuration
public class ElasticConfig {

    // 主机，默认127.0.0.1
    @Value("${elasticsearch.host:127.0.0.1}")
    private String host;

    // 端口，默认9200
    @Value("${elasticsearch.port:9200}")
    private Integer port;

    // 协议，默认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 的对象映射器
        return new RestClientTransport(getRestClient(),
            new JacksonJsonpMapper());
    }

    @Bean
    public ElasticsearchClient getElasticsearchClient() {
        // 创建操作用的 ElasticsearchClient 对象
        return new ElasticsearchClient(getElasticsearchTransport());
    }

}

3. 添加spring配置

elasticsearch:
  host: 192.168.0.197
  port: 9200
  scheme: http

4. 编写测试类

@Autowired
    private ElasticsearchClient elasticsearchClient;

    @Test
    public void sendSingle() {
        try {
            Map<String, String> data = new HashMap<>();
            data.put("测试一下", "测试一下");
            IndexRequest<Object> indexRequest = new IndexRequest.Builder<Object>()
                .index("测试")
                .id("1")
                .document(data)
                .build();
            elasticsearchClient.index(indexRequest);
        } catch (Exception e) {
            log.error("es索引失败", e);
        }
    }

4. 在kibana中查看添加的索引，并建立视图

1. 点击stack management

   
   image.png

2. 点击索引管理，既可看见我们刚刚添加的索引

   
   image.png

3. 点击数据视图，创建数据视图

   
   image.png
   

   4.输入索引名称，创建视图

   
   image.png

4. 点击discover,即可以看到我们创建的测试视图

   
   image.png