From d379cf65467c9ed59476ad06e6e6d54018a90f74 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?F=E5=98=89=E9=98=B3?= Date: Sat, 19 May 2018 12:39:26 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B7=A5=E7=A8=8B=E5=9F=BA=E7=A1=80=E9=85=8D?= =?UTF-8?q?=E7=BD=AE=E5=AE=8C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../configeration/ElasticSearchConfiger.java | 32 +++++++++++++++++++ 1 file changed, 32 insertions(+) diff --git a/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java b/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java index d5b0957..1f8fd7d 100644 --- a/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java +++ b/src/main/java/top/fjy8018/elasticsearch/configeration/ElasticSearchConfiger.java @@ -1,9 +1,41 @@ package top.fjy8018.elasticsearch.configeration; +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.context.annotation.Bean; +import org.springframework.context.annotation.Configuration; + +import java.net.InetAddress; +import java.net.UnknownHostException; + /** * @author F嘉阳 * @date 2018-05-19 12:22 */ +@Configuration public class ElasticSearchConfiger { + /** + * 创建连接客户端 + * @return + * @throws UnknownHostException + */ + @Bean + public TransportClient client() throws UnknownHostException { + // 构造连接地址,TCP地址和端口 + TransportAddress node = new TransportAddress(InetAddress.getByName("192.168.79.138"), 9300); + + // 初始化自定义配置,若和主节点名字不一致则会无法连接 + Settings settings = Settings.builder().put("cluster.name", "Fjiayang").build(); + + // 构造连接实例 + TransportClient client = new PreBuiltTransportClient(settings); + + client.addTransportAddress(node); + + return client; + + } }