Spring Boot 使用docker整合ElasticSearch

ElasticSearch是我们经常用到的搜索引擎之一,本篇博客从零开始使用docker安装elasticsearch,elasticsearch-head然后整合Spring Boot数据进行新增和查询。由于篇幅原因,后面会分两篇blog实战使用分词器以及拼音搜索功能。

准备工作

新建Spring Boot项目

添加我们需要使用的依赖,除了 elasticsearch 其他两个非必要, web 是为了方便调试,如果没有使用过 lombok 的需要安装 IDEA/Eclipse 插件

<!-- elasticsearch -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
<!-- web方便调试 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- lombok -->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
复制代码

安装ElasticSearch

因为我的电脑是Windows10,所以这里我们选择使用docker来安装elasticsearch,操作简单。没有安装docker的可以试一下。 docker win10安装教学 。

  1. 首先我们访问 dockerhub 找到 elasticsearch下载自己需要的版本,我这边就下载最新版。
    Spring Boot 使用docker整合ElasticSearch
  2. 打开shell命令,拉取镜像
    Spring Boot 使用docker整合ElasticSearch
  3. 启动elasticsearch,我们按照 dockerhub description 启动开发配置的elasticsearch。
// shell命令
docker network create somenetwork

docker run -d --name elasticsearch --net somenetwork -p 9200:9200 -p 9300:9300 -e "discovery.type=single-node" elasticsearch:tag
复制代码
Spring Boot 使用docker整合ElasticSearch

灰色有些命令看不清楚,所以换个背景颜色,启动完成之后
docker ps

看一下容器是否启动成功。

Spring Boot 使用docker整合ElasticSearch

浏览器访问
127.0.0.1:9200

,查看是否启动成功。

Spring Boot 使用docker整合ElasticSearch

安装elasticsearch-head

  1. 同样使用docker安装,但是访问 dockerhub 的时候发现 elasticsearch-head 404了,执行 docker pull mobz/elasticsearch-head 也不可以,但是好在 docker pull mobz/elasticsearch-head:5 是可以拉取的,安装并启动。
// shell命令
docker pull mobz/elasticsearch-head:5

docker run -d --name es_admin -p 9100:9100 mobz/elasticsearch-head:5
复制代码
Spring Boot 使用docker整合ElasticSearch
  1. 访问 http://127.0.0.1:9100/ ,检查head是否启动成功,发现head是启动成功了,但是没有连接上elasticsearch,因为我们自定义了网络,所以需要配置一下elasticsearch支持跨域访问。
    Spring Boot 使用docker整合ElasticSearch
  2. 配置elasticsearch.yml支持跨域。
// shell命令
// 进入容器
docker exec -it elasticsearch /bin/bash

// 修改配置文件
vi ./config/elasticsearch.yml

// 添加以下配置
http.cors.enabled: true
http.cors.allow-origin: "*"

// ctrl + c,:wq!保存配置
// 退出容器
exit

// 重启elasticsearch
docker restart elasticsearch
复制代码

再重新访问一下 http://127.0.0.1:9100/ ,连接成功了。

Spring Boot 使用docker整合ElasticSearch

使用Spring Boot访问ElasticSearch

添加application.yml配置

# application.yml
server:
  port: 8080

spring:
  application:
    name: elasticsearch-demo
  elasticsearch:
    rest:
      uris: http://127.0.0.1:9200
      connection-timeout: 1s
      read-timeout: 30s
复制代码

启动Spring Boot project

Spring Boot 使用docker整合ElasticSearch

使用ElasticSearchRepository存取数据

Spring Boot 使用docker整合ElasticSearch
// UserEntity 
package com.example.elasticsearch.entity;

import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;

import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;

@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
@Document(indexName = "user")
public class UserEntity {

    @Id
    private Long userId;

    private String userName;

    private Integer age;

    private Integer sex;

}

// UserRepository 
package com.example.elasticsearch.repository;

import com.example.elasticsearch.entity.UserEntity;

import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

public interface UserRepository extends ElasticsearchRepository<UserEntity, Long> {

}

// ElasticSearchService 
package com.example.elasticsearch.service;

import com.example.elasticsearch.entity.UserEntity;

import java.util.List;

public interface ElasticSearchService {

    void saveUser( UserEntity userEntity );

    void saveUser( List<UserEntity> userEntity );

    UserEntity findById(Long id);

}

// ElasticSearchServiceImpl 
package com.example.elasticsearch.service.impl;

import com.example.elasticsearch.entity.UserEntity;
import com.example.elasticsearch.repository.UserRepository;
import com.example.elasticsearch.service.ElasticSearchService;

import org.springframework.stereotype.Service;

import java.util.List;

import javax.annotation.Resource;

@Service
public class ElasticSearchServiceImpl implements ElasticSearchService {

    @Resource
    private UserRepository userRepository;

    @Override
    public void saveUser( UserEntity userEntity ) {
        userRepository.save(userEntity);
    }

    @Override
    public void saveUser( List<UserEntity> userEntity ) {
        userEntity.containsAll(userEntity);
    }

    @Override
    public UserEntity findById( Long id ) {
        return userRepository.findById(id).get();
    }
}

// Test
package com.example.elasticsearch;

import com.example.elasticsearch.entity.UserEntity;
import com.example.elasticsearch.service.ElasticSearchService;

import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

import javax.annotation.Resource;

@SpringBootTest
class ElasticsearchApplicationTests {

    @Resource
    private ElasticSearchService elasticSearchService;

    @Test
    void save() {
        elasticSearchService.saveUser(UserEntity.builder()
                .userId(1L).userName("David").age(18).sex(1)
                .build());
    }

    @Test
    void findById() {
        UserEntity byId = elasticSearchService.findById(1L);
        System.out.println(byId);
    }

}
复制代码

数据插入成功后,head无法查看,因为我们使用的head是5,但是es是7,解析格式不同,所以我们需要修改 vendor.js 文件。

// 将vendor.js拷贝至本地
docker cp es_admin:/usr/src/app/_site/vendor.js ./

// 修改6886和7573行 application/x-www-form-urlencoded修改为application/json;charset=UTF-8
// 将vendor.js拷贝到es_admines_admin原处
docker cp vendor.js es_admin:/usr/src/app/_site
复制代码

操作完成后直接刷新页面即可。

Spring Boot 使用docker整合ElasticSearch

原文 

https://juejin.im/post/5f028685e51d4534a2087814

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » Spring Boot 使用docker整合ElasticSearch

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址