华为云云耀云服务器L实例评测｜Elasticsearch的springboot整合 & Kibana进行全查询和模糊查询

àì夳堔傛蜴生んèń 2023-10-16 17:18 1阅读 0赞

![在这里插入图片描述][8b9aa4230a9f4f0da89d5541ffed9f4a.png]

## 前言 ##

最近华为云云耀云服务器L实例上新，也搞了一台来玩，期间遇到各种问题，在解决问题的过程中学到不少和运维相关的知识。

在前几期的博客中，介绍了Elasticsearch的Docker版本的安装，Elasticsearch的可视化Kibana工具安装，以及IK分词器的安装。

本篇博客介绍Elasticsearch的springboot整合，以及Kibana进行全查询和模糊查询。

其他相关的Elasticsearch的文章列表如下：

*  [Elasticsearch的Docker版本的安装和参数设置 & 端口开放和浏览器访问][Elasticsearch_Docker_ _]
 *  [Elasticsearch的可视化Kibana工具安装 & IK分词器的安装和使用][Elasticsearch_Kibana_ _ IK]

![在这里插入图片描述][73c346f5cd924016949305ae5dbcfa15.png]

其他相关的华为云云耀云服务器L实例评测文章列表如下：

*  [初始化配置SSH连接 & 安装MySQL的docker镜像 & 安装redis以及主从搭建 & 7.2版本redis.conf配置文件][SSH_ _ _MySQL_docker_ _ _redis_ _ 7.2_redis.conf]
 *  [安装Java8环境 & 配置环境变量 & spring项目部署 &【!】存在问题未解决][Java8_ _ _ _ spring_]
 *  [部署spring项目端口开放问题的解决 & 服务器项目环境搭建MySQL，Redis，Minio…指南][spring_ _ _MySQL_Redis_Minio]
 *  [由于自己原因导致MySQL数据库被攻击 & MySQL的binlog日志文件的理解][MySQL_ _ MySQL_binlog]
 *  [认识redis未授权访问漏洞 & 漏洞的部分复现 & 设置连接密码 & redis其他命令学习][redis_ _ _ _ _ _ redis]
 *  [拉取创建canal镜像配置相关参数 & 搭建canal连接MySQL数据库 & spring项目应用canal初步][canal_ _ _canal_MySQL_ _ spring_canal]
 *  [Docker版的Minio安装 & Springboot项目中的使用 & 结合vue进行图片的存取][Docker_Minio_ _ Springboot_ _ _vue]
 *  [在Redis的Docker容器中安装BloomFilter & 在Spring中使用Redis插件版的布隆过滤器][Elasticsearch_Docker_ _]

#### 文章目录 ####

*  前言
 *  引出
 *  springBoot整合elasticsearch
 *   *  1.引入依赖
     *  2.配置yml文件
     *   *  写配置类
     *  3.创建doc的实体类
     *  4.写实体类对应的mapper
     *  5.存取数据的测试
 *  Kibana进行查询
 *   *  1.全查询
     *  2.进行模糊查询
     *  附录：Kibana报错解决
 *  总结

## 引出 ##

--------------------

1.Elasticsearch的springboot整合；  
2.Kibana进行全查询和模糊查询；

## springBoot整合elasticsearch ##

![在这里插入图片描述][aa7b6f5802804633bc6f35f9f6d0a2ae.png]

### 1.引入依赖 ###

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
            </dependency>

### 2.配置yml文件 ###

![在这里插入图片描述][02248a0284de4c859ac17104283ad3c2.png]

server:
      port: 9090
    
    spring:
      application:
        # 给这个项目起个名称
        name: book-mall
      datasource:
        druid:
          url: jdbc:mysql://127.0.0.1:3306/book_db?useSSL=false&serverTimezone=Asia/Shanghai&allowPublicKeyRetrieval=true
          username: root
          password: 123
          driver-class-name: com.mysql.cj.jdbc.Driver
    
      # es的相关配置
      data:
        elasticsearch:
          repositories:
            enabled: true
      # es的ip+端口
      elasticsearch:
        uris: 124.70.138.34:9200
    
    
    mybatis-plus:
      configuration:
        log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    
    # 单元测试配置
    knife4j:
      enable: true
    
    # 日志级别配置
    logging:
      level:
        com.tinaju.bm: debug

#### 写配置类 ####

![在这里插入图片描述][3164b5d549554984a1901cbb784d63d0.png]

package com.tinaju.bm.config;
    
    
    import org.elasticsearch.client.RestHighLevelClient;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.data.elasticsearch.client.ClientConfiguration;
    import org.springframework.data.elasticsearch.client.RestClients;
    import org.springframework.data.elasticsearch.config.AbstractElasticsearchConfiguration;
    
    /**
     * Elasticsearch的配置类
     */
    @Configuration
    public class ElasticsearchConfig extends AbstractElasticsearchConfiguration {
        
        @Value("${spring.elasticsearch.uris}")
        private String uris;
        @Bean
        @Override
        public RestHighLevelClient elasticsearchClient() {
        
            ClientConfiguration configuration =
                    ClientConfiguration.builder()
                            .connectedTo(uris)
                            .build();
            return RestClients.create(configuration).rest();
        }
    }

### 3.创建doc的实体类 ###

![在这里插入图片描述][ff00e7ab56f447deb438ee2cb9bcb2d8.png]

package com.tinaju.bm.entity.es;
    
    
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.NoArgsConstructor;
    import org.springframework.data.annotation.Id;
    import org.springframework.data.elasticsearch.annotations.DateFormat;
    import org.springframework.data.elasticsearch.annotations.Document;
    import org.springframework.data.elasticsearch.annotations.Field;
    import org.springframework.data.elasticsearch.annotations.FieldType;
    
    import java.math.BigDecimal;
    import java.util.Date;
    
    /**
     * 和es相关的映射类doc文档
     */
    @Data
    @NoArgsConstructor
    @AllArgsConstructor
    
    @Document(indexName = "book_index",createIndex = true)
    public class BookDoc {
        
    
        @Id
        @Field(type = FieldType.Text)
        private String id;
        
        @Field(type = FieldType.Text)
        private String title;
        
        @Field(type = FieldType.Text)
        private String author;
        
        @Field(type = FieldType.Text)
        private String isbn;
        
        @Field(type = FieldType.Double) // 是double类型
        private BigDecimal price;
        
        @Field(type = FieldType.Integer)
        private Integer version;
        
        @Field(type = FieldType.Date,format = DateFormat.basic_date_time)
        private Date pubDate; // 出版日期
        
        @Field(type = FieldType.Integer)
        private Integer store; // 库存
        
        @Field(type = FieldType.Text)
        private String imgUrl; // 封面图片地址
        
        @Field(type = FieldType.Double) // 是double类型
        private BigDecimal weight; // 重量
        
        @Field(type = FieldType.Integer)
        private Integer sold; // 卖出数量；
        
        @Field(type = FieldType.Text)
        private String introduction; // 简介
        
        @Field(type = FieldType.Integer)
        private Integer pages; // 图书页数
        
        @Field(type = FieldType.Date,format = DateFormat.basic_date_time)
        private Date createTime;
        
        @Field(type = FieldType.Date,format = DateFormat.basic_date_time)
        private Date updateTime;
        
        @Field(type = FieldType.Text)
        private String createBy; // 数据记录人
        
        @Field(type = FieldType.Text)
        private Long publisherName; // 出版社
        
        @Field(type = FieldType.Text)
        private Long typeName; // 类型
    
    }

### 4.写实体类对应的mapper ###

![在这里插入图片描述][9d5ab6f2028a4bb9a433f63ccfb084d9.png]

package com.tinaju.bm.dao.es;
    
    import com.tinaju.bm.entity.es.BookDoc;
    import org.apache.ibatis.annotations.Mapper;
    import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
    
    /**
     * es的dao，实体类类型，和主键的类型
     */
    @Mapper
    public interface IBookDocDao extends ElasticsearchRepository<BookDoc,String> {
        
    }

### 5.存取数据的测试 ###

![在这里插入图片描述][fa69358892c748a6a913fc89ccc68ed3.png]

@Autowired
        private IBookDocDao bookDocDao;
    
        @Override
        public void addToES() {
        
            List<Book> books = bookMapper.selectList(null);
            books.forEach(book -> {
        
                BookDoc bookDoc = new BookDoc();
                bookDoc.setId(book.getId()+"");
                bookDoc.setAuthor(book.getAuthor());
                bookDoc.setIntroduction(book.getIntroduction());
                bookDoc.setTitle(book.getTitle());
                bookDoc.setPrice(book.getPrice());
                bookDocDao.save(bookDoc);
            });
        }

![在这里插入图片描述][019f6fdeccba44ca8c446825994f5416.png]

> 进行es的查询

![在这里插入图片描述][762e53f345474ddc9375f434bc18e00e.png]

@Autowired
        private IBookDocDao bookDocDao;
    
        @Test
        public void findES() {
        
            Iterable<BookDoc> all = bookDocDao.findAll();
            System.out.println(all);
            all.forEach(bookDoc -> {
        
                System.out.println(bookDoc);
            });
    
            System.out.println("###############");
            Optional<BookDoc> byId = bookDocDao.findById("4");
            System.out.println(byId.get());
        }

## Kibana进行查询 ##

### 1.全查询 ###

> GET /book\_index/\_search
> 
> 全查询，耗时比Navicat多，可能是我的数据量较少，并且es是在服务器上，网络可能也有延迟；
> 
> 而我的mysql是本地的数据库；

![在这里插入图片描述][6cc8f67cf56349c48d2cdb5e326b09d5.png]

> Navicat进行查询

![在这里插入图片描述][fff8f9cc7d1c4d8994254b05e68e1c25.png]

### 2.进行模糊查询 ###

> MySQL进行模糊查询

![在这里插入图片描述][ce5d5f9287b548359535abdbd9da3183.png]

> es进行模糊查询

![在这里插入图片描述][2937ce3f244f4572bbedd3bd958c4ae6.png]

GET /book_index/_search
    {
        
      "query": {
        
        "bool": {
        
          "should": [
            {
        
              "fuzzy": {
        
                "title": {
        
                  "value": "中"
                }
              }
            },
            {
        
              "wildcard": {
        
                "author": {
        
                  "value": "中"
                }
              }
            },
            {
        
              "wildcard": {
        
                "introduction": {
        
                  "value": "中"
                }
              }
            }
          ]
        }
      }
    }

### 附录：Kibana报错解决 ###

> 打开kibana网页后报错

![在这里插入图片描述][4b01c90ec1354fd68b0a29e1d5aed82d.png]

> 在配置文件里面设置server.name解决问题

![在这里插入图片描述][8df96bdd8e7f45b08c40c7af21f86773.png]

--------------------

## 总结 ##

1.Elasticsearch的springboot整合；  
2.Kibana进行全查询和模糊查询；

[8b9aa4230a9f4f0da89d5541ffed9f4a.png]: https://img-blog.csdnimg.cn/8b9aa4230a9f4f0da89d5541ffed9f4a.png
[Elasticsearch_Docker_ _]: https://blog.csdn.net/Pireley/article/details/133268762
[Elasticsearch_Kibana_ _ IK]: https://blog.csdn.net/Pireley/article/details/133485501
[73c346f5cd924016949305ae5dbcfa15.png]: https://img-blog.csdnimg.cn/73c346f5cd924016949305ae5dbcfa15.png
[SSH_ _ _MySQL_docker_ _ _redis_ _ 7.2_redis.conf]: https://blog.csdn.net/Pireley/article/details/132694836
[Java8_ _ _ _ spring_]: https://blog.csdn.net/Pireley/article/details/132724077
[spring_ _ _MySQL_Redis_Minio]: https://blog.csdn.net/Pireley/article/details/132757602
[MySQL_ _ MySQL_binlog]: https://blog.csdn.net/Pireley/article/details/132818521
[redis_ _ _ _ _ _ redis]: https://blog.csdn.net/Pireley/article/details/132918794
[canal_ _ _canal_MySQL_ _ spring_canal]: https://blog.csdn.net/Pireley/article/details/132900906
[Docker_Minio_ _ Springboot_ _ _vue]: https://blog.csdn.net/Pireley/article/details/133200908
[aa7b6f5802804633bc6f35f9f6d0a2ae.png]: https://img-blog.csdnimg.cn/aa7b6f5802804633bc6f35f9f6d0a2ae.png
[02248a0284de4c859ac17104283ad3c2.png]: https://img-blog.csdnimg.cn/02248a0284de4c859ac17104283ad3c2.png
[3164b5d549554984a1901cbb784d63d0.png]: https://img-blog.csdnimg.cn/3164b5d549554984a1901cbb784d63d0.png
[ff00e7ab56f447deb438ee2cb9bcb2d8.png]: https://img-blog.csdnimg.cn/ff00e7ab56f447deb438ee2cb9bcb2d8.png
[9d5ab6f2028a4bb9a433f63ccfb084d9.png]: https://img-blog.csdnimg.cn/9d5ab6f2028a4bb9a433f63ccfb084d9.png
[fa69358892c748a6a913fc89ccc68ed3.png]: https://img-blog.csdnimg.cn/fa69358892c748a6a913fc89ccc68ed3.png
[019f6fdeccba44ca8c446825994f5416.png]: https://img-blog.csdnimg.cn/019f6fdeccba44ca8c446825994f5416.png
[762e53f345474ddc9375f434bc18e00e.png]: https://img-blog.csdnimg.cn/762e53f345474ddc9375f434bc18e00e.png
[6cc8f67cf56349c48d2cdb5e326b09d5.png]: https://img-blog.csdnimg.cn/6cc8f67cf56349c48d2cdb5e326b09d5.png
[fff8f9cc7d1c4d8994254b05e68e1c25.png]: https://img-blog.csdnimg.cn/fff8f9cc7d1c4d8994254b05e68e1c25.png
[ce5d5f9287b548359535abdbd9da3183.png]: https://img-blog.csdnimg.cn/ce5d5f9287b548359535abdbd9da3183.png
[2937ce3f244f4572bbedd3bd958c4ae6.png]: https://img-blog.csdnimg.cn/2937ce3f244f4572bbedd3bd958c4ae6.png
[4b01c90ec1354fd68b0a29e1d5aed82d.png]: https://img-blog.csdnimg.cn/4b01c90ec1354fd68b0a29e1d5aed82d.png
[8df96bdd8e7f45b08c40c7af21f86773.png]: https://img-blog.csdnimg.cn/8df96bdd8e7f45b08c40c7af21f86773.png