绥中做网站,网站建设上市,企业制作小程序,外贸营销网站下载 ES
相当于安装 MySQL, 可以在官网上下载 (链接在后面). 要注意安装的 ES 的版本要和项目中用的 Springboot 的版本对应.
比如我用的 Springboot 版本是 2.6, 所以ES要下载7.15 版本的. 官网链接: https://www.elastic.co/cn/downloads/elasticsearch
点右边这个查看更多…下载 ES
相当于安装 MySQL, 可以在官网上下载 (链接在后面). 要注意安装的 ES 的版本要和项目中用的 Springboot 的版本对应.
比如我用的 Springboot 版本是 2.6, 所以ES要下载7.15 版本的. 官网链接: https://www.elastic.co/cn/downloads/elasticsearch
点右边这个查看更多版本, 然后找到对应的版本下载就可以了.
这里我点了以后网页怎么都打不开, 找不到对应的版本下载, 然后我就直接把url改成这样下载到的 (把版本换成了7.15.2, 后缀换成了zip): https://artifacts.elastic.co/downloads/elasticsearch/elasticsearch-7.15.2-windows-x86_64.zip 安装
下载到安装包以后, 解压这个安装包, 然后点击这个 bat 文件运行就可以了. (看别的文章说, 项目运行的时候这个命令框要开着.)
看到 successfully 以后去 localhost:9200 (这个端口默认是9200) 看一下有没有成功. 像下面这个图一样的结果就是成功了.
localhost:9200依赖
pom.xml中引入es依赖: !-- es --dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-elasticsearch/artifactId/dependency说明: spring-boot-starter-data-elasticsearch 这个依赖是 springboot 重新整合了 ES 的一个依赖, 并不是 ES 本身的依赖.
有些文章中会提到, 安装依赖的时候安装的是 elasticsearch, elasticsearch-rest-high-level-client 之类的 , 这才是 es 本身的依赖 ( 另一篇文章: pringboot 整合 ElasticSearch 方法(二) 中用的就是这种方法).
配置
ES 的配置有两种方式: 一种是把配置信息写在 application.yml 文件中; 另一种是写一个配置类. 两种方法都可以, 写配置类的方法更加灵活.
配置类
新建一个 config 文件夹, 然后把测试类写在这里: package com.example.demo.config;import lombok.Data;
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;Data
Configuration
public class ElasticConfig extends AbstractElasticsearchConfiguration {BeanOverridepublic RestHighLevelClient elasticsearchClient() {final ClientConfiguration clientConfiguration ClientConfiguration.builder().connectedTo(localhost:9200)
// .withSocketTimeout(600000).build();return RestClients.create(clientConfiguration).rest();}
}使用
实体类
package com.example.demo.pojo;import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;import java.util.Date;Data
Document(indexName log) // 索引的名称
public class Log {Idprivate String id;private String content;private Date time;}说明
实体类中的 id 是必须有的, 不管是String 还是Integer形式的都不影响, 但是要有这个字段. 不然创建mapper这个bean的时候会报错的.
实体类有id这个字段, 存数据的时候, id不是必传的, 不传也不会报错, 不传ES会自动生成id, 下面就是把 id 设置为 String 类型, 存储的时候不传id得到的数据: Mapper / Repository
好多文章里写的是新建一个 Repository 文件夹.
mapper 中 extends 了一个方法, 这样就在 LogMapper 中提供了一些基本的增删改查方法, 就不需要再在 mapper 里再自己手动写这些方法了.
extends ElasticsearchRepository 后面第一个参数是实体类的名称(这里是Log), 第二个参数是实体类id的类型(这里Log实体类中id为Integer)
提供的这些方法在测试类里面 Autowired 注入 logMapper 以后, 输入 logMapper. 也会有提示的.
但是这个依赖提供的 extends ElasticsearchRepository 好像有些 springboot 的版本是不支持的, 就会报各种错以及各种标红 (我试了出错的版本是 springboot 2.10, 处理方法在另一篇文章: pringboot 整合 ElasticSearch 方法(二) 中). package com.example.demo.mapper;import com.example.demo.pojo.Log;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;Repository
public interface LogMapper extends ElasticsearchRepositoryLog,Integer {
}
( 这个里面可以不写方法的, 默认会使用一些自带的方法, 没有漏粘代码. )
测试类
这个测试类可以直接写在这个默认的里面就好了. 反正只是测试一下, 真实项目也要改的.
如果新建了测试类, 不要忘记加 RunWith(SpringRunner.class) 注解(因为配置类是写在config文件夹下面的, 需要 Autowired 注入一起启动)
注入一下 logMapper, 然后就可以开始写不同的测试类了. 一些简单的方法:
package com.example.demo;import com.example.demo.mapper.LogMapper;
import com.example.demo.pojo.Log;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.Date;
import java.util.Optional;SpringBootTest
class DemoApplicationTests {Autowiredprivate LogMapper logMapper;Testvoid add() {for(int i1;i11;i) {Log log new Log();Date currentDate new Date();log.setId(i);log.setContent(this is contenti);log.setTime(currentDate);logMapper.save(log);}}Testvoid delete(){Integer id 1;logMapper.deleteById(id);}Testvoid update() {Log updateLog new Log();Date currentDate new Date();updateLog.setId(2);updateLog.setContent(update message);updateLog.setTime(currentDate);logMapper.save(updateLog);}Testvoid find() {IterableLog all logMapper.findAll(); // 查找全部的文档数据, 返回结果是没有顺序的ArrayListLog list new ArrayList(); // 利用list给返回的结果排序for(Log log:all){list.add(log);System.out.println(log);}// 使用list的方法实现排序}Testvoid findById() {OptionalLog byId logMapper.findById(4);System.out.println(byId);}Testvoid findByIdAll() {ArrayListInteger ids new ArrayList();ids.add(1);ids.add(2);IterableLog allById logMapper.findAllById(ids);// 打印结果for(Log log:allById){System.out.println(log); // 如果给的id在索引里没有, 就不会输出(这里不会报错的)}}}
如果不传id, 不会报错, es会自动生成id的, 如下:
