ElasticSearch6.x 基于SpringBoot 实现ElasticSearch连接功能封装

怼烎@ 2023-10-18 22:21 86阅读 0赞

第一步：基于SpringBoot2.1.2,依赖ElasticSearch jar 包

<dependencies>
      		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    		</dependency>
      </dependencies>

第二步：封装ElasticSearch 连接参数实体对象(ElasticSearchConfigEntity.java)

功能描述：声明ElasticSearchConfigEntity.java 为组件，实现读取application.properties 配置文件中涉及elasticsearch 服务器连接参数。

package com.zzg.ela.entity;
    
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
    
    /**
     * ElasticSearch 实例化对象
     * @author zzg
     *
     */
    @Component
    public class ElasticSearchConfigEntity {
    	// 集群名称
    	@Value("${com.zzg.ela.cluster_name}")
    	private String cluster_name;
    
    	
    	// 是否开启本地存储
    	@Value("${com.zzg.ela.enable}")
    	private String enable;
    	
    	// ip地址
    	@Value("${com.zzg.ela.ip}")
    	private String ip;
    	
    	// port 地址
    	@Value("${com.zzg.ela.port}")
    	private String port;
    	
    	// set 和 get
    	public String getCluster_name() {
    		return cluster_name;
    	}
    
    	public void setCluster_name(String cluster_name) {
    		this.cluster_name = cluster_name;
    	}
    
    	public String getEnable() {
    		return enable;
    	}
    
    	public void setEnable(String enable) {
    		this.enable = enable;
    	}
    
    	public String getIp() {
    		return ip;
    	}
    
    	public void setIp(String ip) {
    		this.ip = ip;
    	}
    
    	public String getPort() {
    		return port;
    	}
    
    	public void setPort(String port) {
    		this.port = port;
    	}
    }

第三步：application.properties 配置涉及elasticsearch 服务器相关配置参数，截图如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70][]

第四步：编写ElasticSearch 配置参数对象（ElasticSearchConfig.java）

功能说明：注入ElasticSearchConfigEntity对象，实例化TransportClient对象。

package com.zzg.ela.config;
    
    import java.net.InetAddress;
    import java.net.UnknownHostException;
    
    import javax.annotation.PostConstruct;
    
    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.Autowired;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import com.zzg.ela.entity.ElasticSearchConfigEntity;
    
    /**
     * ElasticSearch 配置
     * 
     * @author zzg
     *
     */
    @Configuration
    public class ElasticSearchConfig {
    	@Autowired
    	private ElasticSearchConfigEntity entity;
    
    	@PostConstruct
    	void init() {
    		System.setProperty("es.set.netty.runtime.available.processors", "false");
    	}
    
    	/**
    	 * ela 连接实列化对象
    	 * 
    	 * @return
    	 */
    	@Bean
    	public TransportClient getTransportClient() {
    		// 9300是es的tcp服务端口
    		TransportAddress node = null;
    
    		try {
    			node = new TransportAddress(InetAddress.getByName(entity.getIp()), Integer.valueOf(entity.getPort()));
    		} catch (NumberFormatException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		} catch (UnknownHostException e) {
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    
    		// 设置es节点的配置信息
    		Settings settings = Settings.builder().put("cluster.name", entity.getCluster_name()).build();
    
    		// 实例化es的客户端对象
    		TransportClient client = new PreBuiltTransportClient(settings);
    		client.addTransportAddress(node);
    
    		return client;
    	}
    }

第五步：编写ElasticSearchUtil工具类对象

功能说明：注入TransportClient, 封装elasticsearch 搜索引擎的通用操作。

@Component
    public class ElasticSearchIndexUtil {
    	// 引入 Ela 连接实列化对象
    	@Autowired
    	private TransportClient client;
    
        /**其他功能待补充**/
    
    }

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20190725162215256.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n,size_16,color_FFFFFF,t_70