脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → SpringBoot2集成Elasticsearch6.x

SpringBoot2如何集成Elasticsearch6.x(TransportClient方式)

 更新时间：2024年05月11日 09:48:38   作者：终遇你..  
这篇文章主要介绍了SpringBoot2如何集成Elasticsearch6.x(TransportClient方式)问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

技术架构

  • Spring Boot 2.6.3
  • Elasticsearch6.6.2
  • JDK1.8

依赖POM

   <properties>
        <java.version>1.8</java.version>
        <elasticSearch.version>6.4.3</elasticSearch.version>
    </properties>
 
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.4</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.59</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>${elasticSearch.version}</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>transport</artifactId>
            <version>${elasticSearch.version}</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>${elasticSearch.version}</version>
        </dependency>
        <dependency>
            <groupId>org.elasticsearch.plugin</groupId>
            <artifactId>transport-netty4-client</artifactId>
            <version>${elasticSearch.version}</version>
        </dependency>

application.yml配置

elasticsearch:
  cluster-name: test-es
  # 多台机器用,分割
  cluster-nodes: 192.168.116.200:9300

ESConfig 配置类

package com.example.link.config;
 
import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.StringUtils;
 
import java.net.InetAddress;
 
/**
 * @author lanx
 * @date 2022/3/13
 */
@Configuration
@Slf4j
public class ESConfig {
    private static final String CLUSTER_NODES_SPLIT_SYMBOL = ",";
    private static final String HOST_PORT_SPLIT_SYMBOL = ":";
 
 
    @Value("${elasticsearch.cluster-name}")
    String clusterName;
    @Value("${elasticsearch.cluster-nodes}")
    String clusterNodes;
 
    @Bean
    public TransportClient getTransportClient() {
        log.info("elasticsearch init.");
        if (StringUtils.isEmpty(clusterName)) {
            throw new RuntimeException("elasticsearch.cluster-name is empty.");
        }
        if (StringUtils.isEmpty(clusterNodes)) {
            throw new RuntimeException("elasticsearch.cluster-nodes is empty.");
        }
        try {
            Settings settings = Settings.builder().put("cluster.name", clusterName.trim())
                    .put("client.transport.sniff", true).build();
            TransportClient transportClient = new PreBuiltTransportClient(settings);
            String[] clusterNodeArray = clusterNodes.trim().split(CLUSTER_NODES_SPLIT_SYMBOL);
            for (String clusterNode : clusterNodeArray) {
                String[] clusterNodeInfoArray = clusterNode.trim().split(HOST_PORT_SPLIT_SYMBOL);
                TransportAddress transportAddress = new TransportAddress(InetAddress.getByName(clusterNodeInfoArray[0]),
                        Integer.parseInt(clusterNodeInfoArray[1]));
                transportClient.addTransportAddress(transportAddress);
            }
            log.info("elasticsearch init success.");
            return transportClient;
        } catch (Exception e) {
            throw new RuntimeException("elasticsearch init fail.");
        }
    }
}

LinkWebAApplicationTests 测试类

package com.example.link;
 
import com.alibaba.fastjson.JSON;
import com.example.link.domain.Student;
import lombok.extern.slf4j.Slf4j;
import org.elasticsearch.action.bulk.BulkRequestBuilder;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.delete.DeleteResponse;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.action.search.SearchRequestBuilder;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.search.SearchType;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.BoolQueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.index.query.functionscore.FunctionScoreQueryBuilder;
import org.elasticsearch.index.reindex.BulkByScrollResponse;
import org.elasticsearch.index.reindex.DeleteByQueryAction;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
 
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
 
 
@RunWith(SpringRunner.class)
@SpringBootTest
@Slf4j
class LinkWebAApplicationTests {
 
    private Student student;
 
    @Autowired
    private TransportClient transportClient;
 
 
    /**
     * ES 插入数据，指定id
     */
    @Test
    void test() {
        student = new Student();
        student.setName("test2");
        student.setAge(20);
       IndexResponse response =  transportClient.prepareIndex("school","student","1").setSource(JSON.toJSONString(student), XContentType.JSON)
                .get();
        log.info("status:{}",response.status().getStatus());
    }
    /**
     * ES 插入数据，不指定id
     */
    @Test
    void test2() {
        student = new Student();
        student.setName("test2");
        student.setAge(20);
        IndexResponse response =  transportClient.prepareIndex("school","student").setSource(JSON.toJSONString(student), XContentType.JSON)
                .get();
        log.info("status:{}",response.status().getStatus());
    }
 
    /**
     * ES p批量插入数据，不指定id
     */
    @Test
    void test3() {
 
        //建立批量提交类
        BulkRequestBuilder bulkRequest =transportClient.prepareBulk();
        for (int i = 0; i<= 10 ;i++){
            student = new Student();
            student.setName("lx"+i);
            student.setAge(i);
            bulkRequest.add(transportClient.prepareIndex("school","student").setSource(JSON.toJSONString(student), XContentType.JSON));
        }
        BulkResponse bulkResponse=bulkRequest.execute().actionGet();
        //提交过程是否产生错误
        if(bulkResponse.hasFailures()){
            log.info("buildFailureMessage:{}",bulkResponse.buildFailureMessage());
        }else {
            log.info("bulkRequest success !");
        }
 
    }
 
    /*
     * 查询分页数据
     */
    @Test
    void test4(){
        SearchRequestBuilder builder = transportClient.prepareSearch("school");
        builder.setTypes("student");
        builder.setSearchType(SearchType.DFS_QUERY_THEN_FETCH);
        builder.setFrom(0);
        builder.setSize(20);
        //explain为true表示根据数据相关度排序，和关键字匹配最高的排在前面
        builder.setExplain(true);
 
        BoolQueryBuilder queryBuilder = QueryBuilders.boolQuery();
        // 搜索 name 字段包含test2的数据
         queryBuilder.must(QueryBuilders.matchQuery("name", "lx0"));
        queryBuilder.must(QueryBuilders.matchQuery("age", "0"));
        //多个字段查询一个文本
        queryBuilder.must(QueryBuilders.multiMatchQuery("0", "name","age"));
 
        // 多条件查询 FunctionScore
        FunctionScoreQueryBuilder query = QueryBuilders.functionScoreQuery(queryBuilder);
        builder.setQuery(query);
 
 
        SearchResponse response = builder.execute().actionGet();
        SearchHits hits = response.getHits();
        List<Map<String,Object>> result = new ArrayList<Map<String, Object>>();
        for (SearchHit hit:hits){
            result.add(hit.getSourceAsMap());
        }
 
        log.info("result List : {}",JSON.toJSONString(result));
 
    }
 
    /**
     * 更新数据
     * @throws Exception
     */
    @Test
    public void test5() throws Exception{
        student = new Student();
        student.setName("lx");
        student.setAge(30);
        UpdateRequest updateRequest = new UpdateRequest();
        UpdateRequest doc = updateRequest
                .index("school")
                .type("student")
                .id("1")
                .doc(JSON.toJSONString(student), XContentType.JSON);
        UpdateResponse response = transportClient.update(doc).get();
      log.info("status : {}",response.status().toString());
    }
 
    /**
     * 根据id删除数据
     */
    @Test
    public void test6(){
        DeleteResponse response = transportClient.prepareDelete("school", "student", "1").get();
        log.info("status : {}",response.status());
    }
 
    /**
     * 根据条件删除数据
     */
    @Test
    public void test8() {
        BulkByScrollResponse response = DeleteByQueryAction.INSTANCE
                .newRequestBuilder(transportClient)
                .filter(QueryBuilders.matchQuery("name", "test2"))
                .source("school") //index
                .get();
        log.info("status : {}",response.getDeleted());
 
    }
 
}

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • idea如何为java程序添加启动参数

    idea如何为java程序添加启动参数

    文章介绍了如何在Java程序中添加启动参数,包括program arguments、VM arguments和Environment variables,并解释了如何在代码中使用System类获取这些参数
    2025-01-01
  • Spring Boot 2.7.8 原生 SSE 服务端开发实战指南

    Spring Boot 2.7.8 原生 SSE 服务端开发实战指南

    在Spring Boot 2.7.8版本中,我们可以利用其原生支持,轻松实现SSE服务,从而为应用提供实时数据推送能力,本文给大家介绍Spring Boot 2.7.8 原生 SSE 服务端开发实战指南,感兴趣的朋友一起看看吧
    2026-04-04
  • Java使用正则表达式(regex)匹配中文实例代码

    Java使用正则表达式(regex)匹配中文实例代码

    本文给大家分享java使用正则表达式匹配中文的实例代码，以及java中要匹配中文的正则表达式两种写法，感兴趣的朋友通过本文一起看看吧
    2016-12-12
  • Java集合框架之List ArrayList LinkedList使用详解刨析

    Java集合框架之List ArrayList LinkedList使用详解刨析

    早在 Java 2 中之前，Java 就提供了特设类。比如：Dictionary, Vector, Stack, 和 Properties 这些类用来存储和操作对象组。虽然这些类都非常有用，但是它们缺少一个核心的，统一的主题。由于这个原因，使用 Vector 类的方式和使用 Properties 类的方式有着很大不同
    2021-10-10
  • Spring Boot 中的横切逻辑统一治理方案

    Spring Boot 中的横切逻辑统一治理方案

    拦截器是Spring框架提供的核心功能之一,核心用于统一拦截用户的请求,文章主要介绍了Spring框架中的拦截器、统一数据返回格式和统一异常处理,本文给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧
    2026-02-02
  • java使用EasyExcel导入导出excel

    java使用EasyExcel导入导出excel

    导入导出excel数据是常见的需求，今天就来看一下Java基于EasyExcel实现这个功能，感兴趣的朋友可以了解下
    2021-05-05
  • MyBatis中如何获取Oracle序列

    MyBatis中如何获取Oracle序列

    文章介绍了在使用MyBatis时,如何通过获取序列的下一个值来完成某些功能操作,并在之后进行数据的添加操作,文中特别强调了在获取序列值后不能单独执行插入操作,否则会报错
    2024-12-12
  • 基于Mybatis Plus实现多表分页查询的示例代码

    基于Mybatis Plus实现多表分页查询的示例代码

    这篇文章主要介绍了基于Mybatis Plus实现多表分页查询的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2020-12-12
  • 很详细的Log4j配置步骤

    很详细的Log4j配置步骤

    Log4J的配置文件(Configuration File)就是用来设置记录器的级别、存放器和布局的，它可接key=value格式的设置或xml格式的设置信息。通过配置，可以创建出Log4J的运行环境。
    2008-11-11
  • Java 进阶必备之ssm框架全面整合

    Java 进阶必备之ssm框架全面整合

    SSM框架是spring MVC ，spring和mybatis框架的整合，是标准的MVC模式，将整个系统划分为表现层，controller层，service层，DAO层四层，使用spring MVC负责请求的转发和视图管理，spring实现业务对象管理，mybatis作为数据对象的持久化引擎
    2021-10-10

最新评论