SpringBoot使用原生ElasticSearch client报错 elasticsearch6.6

曾经终败给现在 2024-03-24 14:03 173阅读 0赞

SpringBoot集成原生elasticsearch client创建索引时报错

错误信息:

  1. Description:
  3. An attempt was made to call the method org.elasticsearch.search.fetch.subphase.highlight.HighlightPhase.<init>(Ljava/util/Map;)V but it does not exist. Its class, org.elasticsearch.search.fetch.subphase.highlight.HighlightPhase, is available from the following locations:
  5.     jar:file:/D:/apache-maven-3.5.4/repository/org/elasticsearch/elasticsearch/6.4.3/elasticsearch-6.4.3.jar!/org/elasticsearch/search/fetch/subphase/highlight/HighlightPhase.class
  7. It was loaded from the following location:
  9.     file:/D:/apache-maven-3.5.4/repository/org/elasticsearch/elasticsearch/6.4.3/elasticsearch-6.4.3.jar
  12. Action:
  14. Correct the classpath of your application so that it contains a single, compatible version of org.elasticsearch.search.fetch.subphase.highlight.HighlightPhase

rg.elasticsearch.search.fetch.subphase.highlight.HighlightPhase.(Ljava/util/Map;)V but it does not exist.

大致意思是有一个HighlightPhase方法不存在 方法是从6.4.3中加载,但是本工程中使用的是6.6.0版本的es

最后的解决方案:在pom.xml中额外添加了6.4.3版本的依赖 

  1. <dependency>
  2.             <groupId>org.elasticsearch.client</groupId>
  3.             <artifactId>transport</artifactId>
  4.             <version>6.6.0</version>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>org.elasticsearch.client</groupId>
  8.             <artifactId>transport</artifactId>
  9.             <version>6.4.3</version>
  10.         </dependency>

单独使用elasticsearch client时创建索引

未集成springboot时成功创建了索引,并没有报错

代码:

maven配置 参考自es官网

  1. <dependency>
  2.             <groupId>org.elasticsearch.client</groupId>
  3.             <artifactId>transport</artifactId>
  4.             <version>6.6.0</version>
  5.         </dependency>
  6.         <dependency>
  7.             <groupId>org.elasticsearch.client</groupId>
  8.             <artifactId>transport</artifactId>
  9.             <version>6.4.3</version>
  10.         </dependency>
  11.         <dependency>
  12.             <groupId>org.apache.logging.log4j</groupId>
  13.             <artifactId>log4j-core</artifactId>
  14.             <version>2.11.1</version>
  15.         </dependency>
  16.         <dependency>
  17.             <groupId>org.apache.logging.log4j</groupId>
  18.             <artifactId>log4j-api</artifactId>
  19.             <version>2.11.1</version>
  20.         </dependency>
  21.         <dependency>
  22.             <groupId>org.apache.logging.log4j</groupId>
  23.             <artifactId>log4j-to-slf4j</artifactId>
  24.             <version>2.11.1</version>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.slf4j</groupId>
  28.             <artifactId>slf4j-api</artifactId>
  29.             <version>1.7.24</version>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.slf4j</groupId>
  33.             <artifactId>slf4j-simple</artifactId>
  34.             <version>1.7.21</version>
  35.         </dependency>

java代码：

  1. import org.elasticsearch.client.transport.TransportClient;
  2. import org.elasticsearch.common.settings.Settings;
  3. import org.elasticsearch.common.transport.TransportAddress;
  4. import org.elasticsearch.common.xcontent.XContentBuilder;
  5. import org.elasticsearch.common.xcontent.XContentFactory;
  6. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  7. import org.junit.Test;
  9. import java.io.IOException;
  10. import java.net.InetAddress;
  12. /**
  13.  * @program: esclienttes
  14.  * @Date: 2019.4.11 下午 2:09
  15.  * @Author: MicoMecy
  16.  */
  17. public class CreateTest {
  18.     @Test
  19.     public void test() throws IOException {
  20.         Settings settings = Settings.builder()
  21.             .put("cluster.name", "my-elasticsearch").build();
  22.         //Add transport addresses and do something with the client...
  23.         // on startup
  24.         TransportClient client = new PreBuiltTransportClient(settings)
  25. //            .addTransportAddress(new TransportAddress(InetAddress.getByName(""), 9300))
  26.             .addTransportAddress(new TransportAddress(InetAddress.getByName("localhost"), 9300));
  27.         //创建索引
  28.         client.admin().indices().prepareCreate("bolg1").get();
  31.         /*
  32.       {
  33.            创建出的索引结构如下
  34.           "article": {
  35.                   "properties": {
  36.                       "id":{
  37.                        "type":"long",
  38.                        "store":true
  39.                       },
  40.                       "title":{
  41.                        "type":"text",
  42.                        "store":true,
  43.                        "index":true,
  44.                        "analyzer":"ik_smart"
  45.                       },
  46.                       "content":{
  47.                        "type":"text",
  48.                        "store":true,
  49.                        "index":true,
  50.                        "analyzer":"ik_smart"
  51.                       }
  52.                   }
  53.               }
  54.         }
  55.  */
  56. //        拼装JSON
  57.         XContentBuilder builder = XContentFactory.jsonBuilder();
  58.         builder.startObject() //{
  59.             .startObject("article") // "article": {
  60.             .startObject("properties")
  61.             .startObject("id")
  62.             .field("type", "long")
  63.             .field("store", true)
  64.             .endObject()//}
  65.             .startObject("title")
  66.             .field("type", "text")
  67.             .field("store", true)
  68.             .field("index", true)
  69.             .field("analyzer", "ik_smart")
  70.             .endObject()
  71.             .startObject("content")
  72.             .field("type", "text")
  73.             .field("store", true)
  74.             .field("index", true)
  75.             .field("analyzer", "ik_smart")
  76.             .endObject()
  77.             .endObject()
  78.             .endObject()
  79.             .endObject();
  81.         //添加映射
  82.         client.admin().indices()
  83.             .preparePutMapping("bolg1") //准备添加映射=>指定映射所在索引名称
  84.             .setType("article")//指定类型名称
  85.             .setSource(builder) //添加映射内容
  86.             .get();
  88.         //删除索引
  89. //        client.admin().indices().prepareDelete("helll").get();
  91.         // on shutdown
  92.         client.close();
  93.     }
  94. }

Springboot集成elasticsearch client

pom.xml 含有mybatis相关依赖,可自行删除

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.1.3.RELEASE</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  12.     <groupId>com.transcend</groupId>
  13.     <artifactId>es</artifactId>
  14.     <version>0.0.1-SNAPSHOT</version>
  15.     <name>es</name>
  16.     <description>Demo project for Spring Boot</description>
  18.     <properties>
  19.         <java.version>1.8</java.version>
  20.     </properties>
  22.     <dependencies>
  23.         <dependency>
  24.             <groupId>org.springframework.boot</groupId>
  25.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.springframework.boot</groupId>
  29.             <artifactId>spring-boot-starter-web</artifactId>
  30.         </dependency>
  31.         <dependency>
  32.             <groupId>org.mybatis.spring.boot</groupId>
  33.             <artifactId>mybatis-spring-boot-starter</artifactId>
  34.             <version>2.0.0</version>
  35.         </dependency>
  37.         <dependency>
  38.             <groupId>org.springframework.boot</groupId>
  39.             <artifactId>spring-boot-starter-jdbc</artifactId>
  40.         </dependency>
  42.         <dependency>
  43.             <groupId>mysql</groupId>
  44.             <artifactId>mysql-connector-java</artifactId>
  45.             <scope>runtime</scope>
  46.         </dependency>
  47.         <dependency>
  48.             <groupId>org.springframework.boot</groupId>
  49.             <artifactId>spring-boot-starter-test</artifactId>
  50.             <scope>test</scope>
  51.         </dependency>
  52.         <dependency>
  53.             <groupId>junit</groupId>
  54.             <artifactId>junit</artifactId>
  55.             <version>4.12</version>
  56.         </dependency>
  58.         <!--原生es java api-->
  59.         <dependency>
  60.             <groupId>org.elasticsearch.client</groupId>
  61.             <artifactId>transport</artifactId>
  62.             <version>6.6.0</version>
  63.         </dependency>
  64.         <dependency>
  65.             <groupId>org.elasticsearch.client</groupId>
  66.             <artifactId>transport</artifactId>
  67.             <version>6.4.3</version>
  68.         </dependency>
  69.         <dependency>
  70.             <groupId>org.apache.logging.log4j</groupId>
  71.             <artifactId>log4j-core</artifactId>
  72.             <version>2.11.1</version>
  73.         </dependency>
  74.         <dependency>
  75.             <groupId>org.apache.logging.log4j</groupId>
  76.             <artifactId>log4j-api</artifactId>
  77.             <version>2.11.1</version>
  78.         </dependency>
  79.         <dependency>
  80.             <groupId>org.apache.logging.log4j</groupId>
  81.             <artifactId>log4j-to-slf4j</artifactId>
  82.             <version>2.11.1</version>
  83.         </dependency>
  84.         <dependency>
  85.             <groupId>org.slf4j</groupId>
  86.             <artifactId>slf4j-api</artifactId>
  87.             <version>1.7.24</version>
  88.         </dependency>
  89.         <dependency>
  90.             <groupId>org.slf4j</groupId>
  91.             <artifactId>slf4j-simple</artifactId>
  92.             <version>1.7.21</version>
  93.         </dependency>
  95.     </dependencies>
  97.     <build>
  98.         <plugins>
  99.             <plugin>
  100.                 <groupId>org.springframework.boot</groupId>
  101.                 <artifactId>spring-boot-maven-plugin</artifactId>
  102.             </plugin>
  103.         </plugins>
  104.     </build>
  106. </project>

将TransportClient交由spring管理

  1. ElasticSearchConfig.java
  3. package com.transcend.config;
  5. import org.elasticsearch.client.transport.TransportClient;
  6. import org.elasticsearch.common.settings.Settings;
  7. import org.elasticsearch.common.transport.TransportAddress;
  8. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  9. import org.springframework.context.annotation.Bean;
  10. import org.springframework.context.annotation.Configuration;
  12. import java.net.InetAddress;
  13. import java.net.UnknownHostException;
  15. /**
  16.  * @program: es
  17.  * @Date: 2019.4.12 下午 3:24
  18.  * @Author: MicoMecy
  19.  */
  20. @Configuration
  21. public class ElasticSearchConfig {
  22.     @Bean(name = "client")
  23.     public TransportClient getClient() {
  24.         TransportAddress node = null;
  25.         try {
  26.             node = new TransportAddress(InetAddress.getByName("localhost"),9300);
  27.         } catch (UnknownHostException e) {
  28.             e.printStackTrace();
  29.         }
  30.         Settings settings = Settings.builder().put("cluster.name", "my-elasticsearch").build();
  32.         TransportClient client = new PreBuiltTransportClient(settings)
  33.             .addTransportAddress(node);
  34.         return client;
  35.     }
  36. }

SpringBootTest

  1. package com.transcend.createindex;
  3. import com.transcend.db.dao.CstableMapper;
  4. import com.transcend.db.entity.Cstable;
  5. import org.elasticsearch.client.transport.TransportClient;
  6. import org.elasticsearch.common.xcontent.XContentBuilder;
  7. import org.elasticsearch.common.xcontent.XContentFactory;
  8. import org.junit.Test;
  9. import org.junit.runner.RunWith;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.boot.test.context.SpringBootTest;
  12. import org.springframework.test.context.junit4.SpringRunner;
  14. import java.io.IOException;
  15. import java.util.List;
  17. /**
  18.  * @program: es
  19.  * @Date: 2019.4.11 下午 3:47
  20.  * @Author: Haeyden
  21.  * 创建索引分级
  22.  */
  23. @RunWith(SpringRunner.class)
  24. @SpringBootTest
  25. public class CreaetIndexGrading {
  27.     @Autowired
  28.     private TransportClient client;
  29.     @Test
  30.     public void createIndexUseClient() throws IOException {
  31.         client.admin().indices().prepareCreate("bolg1").get();
  33. //        拼装JSON
  34.         XContentBuilder builder = XContentFactory.jsonBuilder();
  35.         builder.startObject() //{
  36.             .startObject("article") // "article": {
  37.             .startObject("properties")
  38.             .startObject("id")
  39.             .field("type", "long")
  40.             .field("store", true)
  41.             .endObject()//}
  42.             .startObject("title")
  43.             .field("type", "text")
  44.             .field("store", true)
  45.             .field("index", true)
  46.             .field("analyzer", "ik_smart")
  47.             .endObject()
  48.             .startObject("content")
  49.             .field("type", "text")
  50.             .field("store", true)
  51.             .field("index", true)
  52.             .field("analyzer", "ik_smart")
  53.             .endObject()
  54.             .endObject()
  55.             .endObject()
  56.             .endObject();
  58.         //添加映射
  59.         client.admin().indices()
  60.             .preparePutMapping("bolg1") //准备添加映射=>指定映射所在索引名称
  61.             .setType("article")//指定类型名称
  62.             .setSource(builder) //添加映射内容
  63.             .get();
  65.         //删除索引
  66. //        client.admin().indices().prepareDelete("helll").get();
  68.         // on shutdown
  69.         client.close();
  70.     }
  72. }

发表评论

表情：
评论列表 （有 0 条评论，173人围观）

还没有评论，来说两句吧...

相关阅读