SpringBoot集成ElasticSearch存取数据实战

前面几篇分析了elk存取日志相关的操作，今天我们持续分享SpringBoot集成ElasticSearch存取数据实战，在项目开发过程中直接使用。而使用SpringBoot整合Elasticsearch，一般都是使用 SpringData 进行封装的，然后再dao层接口继承ElasticsearchRepository 类，该类实现了很多的方法，比如常用的CRUD方法。

1、pom文件引入相关jar:

       
            org.springframework.boot
            spring-boot-starter-web
             2.1.6.RELEASE
        

       
            org.springframework.boot
            spring-boot-starter-data-elasticsearch
        

2、yml配置es:

spring
   data:
    elasticsearch:
      cluster-name: nd-es-1 #集群名。(默认值: elasticsearch)
      #cluster-nodes: es-1.cs-ys2.nandao.io:9300
      cluster-nodes: 127.0.0.1:9300 #集群节点地址列表，用逗号分隔。如果没有指定，就启动一个客户端节点。
      repositories:
        enabled: true #开启 Elasticsearch 仓库。(默认值:true。)

注意: 9300 是 Java 客户端的端口。9200 是支持 Restful HTTP 的接口。

3、客户端取数据配置：

3.1、接收数据的VO实体：

import java.io.Serializable;
import java.util.Date;
import lombok.Data;
import lombok.ToString;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;


@Data
@document(indexName = "userInfoindex", type = "userInfo")
@ToString
public class UserInfoEsDto implements Serializable {

    private static final long serialVersionUID = 9881158963867439519L;

    
    @Id
    private String id;
 
    //关联id
    @Field(type = FieldType.Long)
    private Long jid;
    
    @Field(type = FieldType.Long)
    private Long userId;

    
    @Field(type = FieldType.Text)
    private String name;

    
    @ToString.Exclude
    @Field(type = FieldType.Text)
    private String content;

    
    @Field(type = FieldType.Long)
    private Date publishTime;


}

3.2、mapper层接口：

import com.nandao.service.dto.UserInfoEsDto;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;

 
public interface UserInfoRepository extends ElasticsearchRepository {

}

3.3、业务层保持和查询核心伪代码：

  import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.domain.Sort.Direction;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
 
   @Resource
    private UserInfoRepository userInfoRepository;

   @Override
    public R syncUserInfoByIds(SyncArticleReq req) {
        List list = .......
        if (list != null && !list.isEmpty()) {
            userInfoRepository.saveAll(list);
        }
        return R.ok();
    }


   @Override
    public R listUser(PageParamUtil req,String acceptLanguage)  {
         Sort sort = Sort.by(Direction.DESC, "publishTime");

            Pageable pageable = PageRequest.of(ReqUtil.checkPageNum(req.getPageNum()), 12, sort);

            Page page = userInfoRepository.findAll(pageable);

            int total = page.getTotalPages();
            List list = page.getContent();
            //单个保存和删除接口如下
            // userInfoRepository.save(userInfoEsDto);
            //userInfoRepository.deleteById(String.valueOf(req.getId()));
            ........
    }

    

 到此实战分享结束，推荐参考一篇文章，可以从另外一个角度测试一下：参考

下篇继续分享es原理，敬请期待！