SpringBoot整合ElasticSearch详细过程

￡神魔★判官ぃ 2022-05-11 11:08 176阅读 0赞

##### 首先呢 在整合之前我们需要安装ElasticSearch 可以参照之前博主的文章 #####

[Windows环境下安装ES][Windows_ES]

> ## 一、创建工程 ##

##### 使用IntelliJ创建SpringBoot工程 SpringBoot版本为2.0.4 ElasticSearch为5.6.10 #####

![image][]  
![image][image 1]  
![image][image 2]  
![image][image 3]  
![image][image 4]  
![image][image 5]

##### 删掉蓝框中的文件(如上) 最后我们的目录结构(如下) #####

![image][image 6]

##### 下面pom文件主要修改的是把spring boot从IntelliJ默认的版本换成2.0.4以及添加netty3的客户端 否则启动会报错 #####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    
    	<groupId>net.conn</groupId>
    	<artifactId>elasticsearch</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>war</packaging>
    
    	<name>elasticsearch</name>
    	<description>Demo project for Spring Boot</description>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.0.4.RELEASE</version>
    		<relativePath/> 
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    		</dependency>
    		
    		<dependency>
                <groupId>org.elasticsearch.plugin</groupId>
                <artifactId>transport-netty3-client</artifactId>
                <version>5.6.10</version>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-tomcat</artifactId>
    			<scope>provided</scope>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    
    
    </project>

> ## 二、配置代码 ##

##### 在resources下新建config文件夹 然后创建elasticsearch.properties #####

![image][image 7]

#Es地址
    es.hostName=localhost
    
    #Es端口号
    es.transport=9300
    
    #配置es的集群名称，默认是elasticsearch，es会自动发现在同一网段下的es，如果在同一网段下有多个集群，就可以用这个属性来区分不同的集群
    es.cluster.name=elasticsearch

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

##### 在Java工程下创建config文件夹 然后创建ElasticSearchConfig.java #####

![image][image 8]

package net.conn.elasticsearch.config;
    
    import org.elasticsearch.client.transport.TransportClient;
    import org.elasticsearch.common.settings.Settings;
    import org.elasticsearch.common.transport.InetSocketTransportAddress;
    import org.elasticsearch.common.transport.TransportAddress;
    import org.elasticsearch.transport.client.PreBuiltTransportClient;
    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.PropertySource;
    
    import java.net.InetAddress;
    import java.net.UnknownHostException;
    
    /**
     * @Author Conn
     * @Date 2018/10/15
     */
    @Configuration
    @PropertySource(value = "classpath:config/elasticsearch.properties")
    public class ElasticSearchConfig {
        private static final Logger logger = LoggerFactory.getLogger(ElasticSearchConfig.class);
    
        @Value("${es.hostName}")
        private String hostName;
    
        @Value("${es.transport}")
        private Integer transport;
    
        @Value("${es.cluster.name}")
        private String clusterName;
    
        @Bean
        public TransportClient transportClient() {
            logger.info("ElasticSearch初始化开始");
    
            TransportClient transportClient = null;
    
            try {
                TransportAddress transportAddress = new InetSocketTransportAddress(InetAddress.getByName(hostName), Integer.valueOf(transport));
    
                //配置信息
                Settings es = Settings.builder().put("cluster.name", clusterName).build();
    
                //配置信息Settings自定义
                transportClient = new PreBuiltTransportClient(es);
    
                transportClient.addTransportAddress(transportAddress);
            } catch (UnknownHostException e) {
                logger.error("ES创建错误", e);
            }
            return transportClient;
        }
    }

> ## 三、启动项目 ##

##### 这时候我们通过springboot启动器启动项目会发现控制台报以下的错误 #####

2018-10-19 15:48:05.189  INFO 44964 --- [       Thread-8] s.c.a.AnnotationConfigApplicationContext : Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@418c5a9c: startup date [Fri Oct 19 15:48:02 CST 2018]; root of context hierarchy
    2018-10-19 15:48:05.190  INFO 44964 --- [       Thread-8] o.s.j.e.a.AnnotationMBeanExporter        : Unregistering JMX-exposed beans on shutdown
    Disconnected from the target VM, address: '127.0.0.1:60159', transport: 'socket'

##### 解决方法是 pom文件里注释掉provided #####

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

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

# 后记 #

##### OK 项目启动了 我们的整合也就成功了 接下来博主会带来部分elastic search的Java API的使用方法。 #####

[Windows_ES]: https://blog.csdn.net/tzconn/article/details/83016494
[image]: /images/20220505/5fdd5edd1ce24537a6b2a075b0e16673.png
[image 1]: /images/20220505/e24e00c57e3646e48f596bca0e5c3bb6.png
[image 2]: /images/20220505/be234b94b5644f8fb79d569e04e6b110.png
[image 3]: /images/20220505/14e46faf627642b89b13339a336b25c3.png
[image 4]: /images/20220505/c7ee9a9580f34db9a252cd8a50d460df.png
[image 5]: /images/20220505/e9e38df24cac48e889aeae8fb34083d2.png
[image 6]: /images/20220505/c66bbdd5e36c403787d421cde69aa018.png
[image 7]: /images/20220505/0d7678b525104480ac34d89910831801.png
[image 8]: /images/20220505/9893bf3b80e741aab68fd5260b20fd5b.png