如何在Spring中注入ElasticSearch实例

在企业级项目开发中,大多数公司都会集成Spring来简化开发成本,要使用Spring自然少不了一大堆需要依赖注入的Bean,通常情况下,我们会选择在spring的xml中,配置一些类的实例,比如连接池,或者配置文件初始化类,或者集成duboo时配置一些Service的引用等等。 有些类的实例生成比较复杂,直接在xml中,是没法进行配置的,比如我想在Spring注入ElasticSearch的Client实例,注意(这里并不是使用的spring-data-elasticsearch项目),而是使用原始的ElasticSearch的API。 我们先看下,在非Spring的项目中,如何初始化ElasticSearch的Client实例:

Java代码

  1. //es的客户端实例
  2. static Client client=null;
  3. static {
  4. //设置集群名字
  5. Settings settings = ImmutableSettings.settingsBuilder()
  6. .put("cluster.name", "search")
  7. .put("client.transport.sniff", true)
  8. . build();
  9. //连接单台机器,注意ip和端口号,不能写错
  10. client=new TransportClient(settings)
  11. .addTransportAddress(new InetSocketTransportAddress("192.168.1.187", 9300))
  12. .addTransportAddress(new InetSocketTransportAddress("192.168.1.121", 9300))
  13. .addTransportAddress(new InetSocketTransportAddress("192.168.1.122", 9300));
  14. }

由于ElasticSearch的Client实例是通过各种组装加工而成,并没法直接在Spring的xml中使用Bean标签进行初始化,这时候我们可以使用@Configuration注解,来在Java类中,生成bean实例,这个注解和使用spring的xml进行注入功能大致相同,只不过能直接在Java类生成一个类实例,比较灵活而已。最终的代码如下:

Java代码

  1. package cn.bizbook.product.elk.config;
  2. import org.elasticsearch.client.Client;
  3. import org.elasticsearch.client.transport.TransportClient;
  4. import org.elasticsearch.common.settings.ImmutableSettings;
  5. import org.elasticsearch.common.settings.Settings;
  6. import org.elasticsearch.common.transport.InetSocketTransportAddress;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.context.annotation.Configuration;
  10. /**
  11. * Created by qindongliang on 2016/4/6.
  12. */
  13. @Configuration
  14. public class FactoryBean {
  15. //配置文件工具类
  16. @Autowired
  17. private ESConf esConf;
  18. //注入的ElasticSearch实例
  19. @Bean(name = "client")
  20. public Client getESClient(){
  21. //设置集群名字
  22. Settings settings = ImmutableSettings.settingsBuilder()
  23. .put("cluster.name", esConf.getClusterName())
  24. .build();
  25. Client client=new TransportClient(settings);
  26. //读取的ip列表是以逗号分隔的
  27. for(String ip:esConf.getIps().split(",")){
  28. ((TransportClient)client).addTransportAddress(new InetSocketTransportAddress(ip,esConf.getPort()));
  29. }
  30. return client;
  31. }
  32. }

最后来看下,如何在DAO层,引用client实例,非常easy:

Java代码

  1. @Resource(name = "client")
  2. private Client client;

原文发布于微信公众号 - 我是攻城师(woshigcs)

原文发表时间:2016-04-06

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏玩转JavaEE

初识Spring Boot框架

按:最近公众号文章主要是整理一些老文章,主要是个人CSDN上的博客,也会穿插一些新的技术点。 ---- 前面的铺垫文章已经连着写了六篇了,主要是介绍了Sprin...

39750
来自专栏云计算

使用 Spring Boot 2.0,Eureka 和 Spring Cloud 的微服务快速指南

原文地址:https://dzone.com/articles/quick-guide-to-microservices-with-spring-boot-20...

5.4K30
来自专栏Java 源码分析

SpringBoot 笔记 ( 一 ):启动流程

SpringBoot 笔记(一): 启动流程 1. 配置开发环境 1. 创建 Maven 项目 然后我们首先在项目里面加上编译环境,防止每一次更新 Maven ...

31540
来自专栏一个会写诗的程序员的博客

第9章 Spring Boot开发者工具第9章 Spring Boot开发者工具

Spring Boot Maven Plugin,提供了使用Maven构建Spring Boot 工程的支持。我们可以用这个插件完成打包功能。支持打可执行jar...

23520
来自专栏cloudskyme

查看linux版本命令

1. 查看内核版本命令: 1) [root@q1test01 ~]# cat /proc/version Linux version 2.6....

441110
来自专栏懒人开发

AndroidStudio简单使用(一):基础面板

用android studio也比较长时间了 一直没有怎么总结过, 看了 徐宜生 的 android群英传: 神兵利器 后,才感觉到, 其实 除了代码以外...

87410
来自专栏微信公众号:Java团长

初识Spring Boot框架

前面的铺垫文章已经写了几篇了,主要是介绍了Spring和SpringMVC框架,小伙伴们在学习的过程中大概也发现了这两个框架需要我们手动配置的地方非常多,不过做...

11840
来自专栏从零开始的linux

安装docker

查看版本 # uname -a Linux huawei 2.6.32-642.13.1.el6.x86_64 #1 SMP Wed Jan 11 20:56:...

46480
来自专栏技术总结

python

13640
来自专栏熊二哥

Spring快速入门

Spring源码剖析一书,非常细致,但对于个人来说,意义不算特别的大,因此选其可用部分做个记录就好。 ? 功能 示例 配置文件的解析...

188100

扫码关注云+社区

领取腾讯云代金券