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

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

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

  1. <!--elasticsearch 依赖  -->
  2.   <dependencies>
  3.           <dependency>
  4.             <groupId>org.springframework.boot</groupId>
  5.             <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  6.         </dependency>
  7.   </dependencies>

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

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

  1. package com.zzg.ela.entity;
  3. import org.springframework.beans.factory.annotation.Value;
  4. import org.springframework.stereotype.Component;
  6. /**
  7.  * ElasticSearch 实例化对象
  8.  * @author zzg
  9.  *
  10.  */
  11. @Component
  12. public class ElasticSearchConfigEntity {
  13.     // 集群名称
  14.     @Value("${com.zzg.ela.cluster_name}")
  15.     private String cluster_name;
  18.     // 是否开启本地存储
  19.     @Value("${com.zzg.ela.enable}")
  20.     private String enable;
  22.     // ip地址
  23.     @Value("${com.zzg.ela.ip}")
  24.     private String ip;
  26.     // port 地址
  27.     @Value("${com.zzg.ela.port}")
  28.     private String port;
  30.     // set 和 get
  31.     public String getCluster_name() {
  32.         return cluster_name;
  33.     }
  35.     public void setCluster_name(String cluster_name) {
  36.         this.cluster_name = cluster_name;
  37.     }
  39.     public String getEnable() {
  40.         return enable;
  41.     }
  43.     public void setEnable(String enable) {
  44.         this.enable = enable;
  45.     }
  47.     public String getIp() {
  48.         return ip;
  49.     }
  51.     public void setIp(String ip) {
  52.         this.ip = ip;
  53.     }
  55.     public String getPort() {
  56.         return port;
  57.     }
  59.     public void setPort(String port) {
  60.         this.port = port;
  61.     }
  62. }

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

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70

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

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

  1. package com.zzg.ela.config;
  3. import java.net.InetAddress;
  4. import java.net.UnknownHostException;
  6. import javax.annotation.PostConstruct;
  8. import org.elasticsearch.client.transport.TransportClient;
  9. import org.elasticsearch.common.settings.Settings;
  10. import org.elasticsearch.common.transport.TransportAddress;
  11. import org.elasticsearch.transport.client.PreBuiltTransportClient;
  12. import org.springframework.beans.factory.annotation.Autowired;
  13. import org.springframework.context.annotation.Bean;
  14. import org.springframework.context.annotation.Configuration;
  16. import com.zzg.ela.entity.ElasticSearchConfigEntity;
  18. /**
  19.  * ElasticSearch 配置
  20.  * 
  21.  * @author zzg
  22.  *
  23.  */
  24. @Configuration
  25. public class ElasticSearchConfig {
  26.     @Autowired
  27.     private ElasticSearchConfigEntity entity;
  29.     @PostConstruct
  30.     void init() {
  31.         System.setProperty("es.set.netty.runtime.available.processors", "false");
  32.     }
  34.     /**
  35.      * ela 连接实列化对象
  36.      * 
  37.      * @return
  38.      */
  39.     @Bean
  40.     public TransportClient getTransportClient() {
  41.         // 9300是es的tcp服务端口
  42.         TransportAddress node = null;
  44.         try {
  45.             node = new TransportAddress(InetAddress.getByName(entity.getIp()), Integer.valueOf(entity.getPort()));
  46.         } catch (NumberFormatException e) {
  47.             // TODO Auto-generated catch block
  48.             e.printStackTrace();
  49.         } catch (UnknownHostException e) {
  50.             // TODO Auto-generated catch block
  51.             e.printStackTrace();
  52.         }
  54.         // 设置es节点的配置信息
  55.         Settings settings = Settings.builder().put("cluster.name", entity.getCluster_name()).build();
  57.         // 实例化es的客户端对象
  58.         TransportClient client = new PreBuiltTransportClient(settings);
  59.         client.addTransportAddress(node);
  61.         return client;
  62.     }
  63. }

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

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

  1. @Component
  2. public class ElasticSearchIndexUtil {
  3.     // 引入 Ela 连接实列化对象
  4.     @Autowired
  5.     private TransportClient client;
  7.     /**其他功能待补充**/
  9. }

发表评论

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

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

相关阅读