新增es 配置

527515025 · 527515025 · commit 2449a6e1b41b · 2019-04-02T14:51:38.000+08:00
diff --git a/springboot-elasticsearch/pom.xml b/springboot-elasticsearch/pom.xml
@@ -46,12 +46,30 @@
             <artifactId>mysql-connector-java</artifactId>
             <version>5.1.40</version>
         </dependency>
-
         <dependency>
             <groupId>org.apache.commons</groupId>
             <artifactId>commons-lang3</artifactId>
             <version>3.4</version>
         </dependency>
+        <!--es-->
+        <dependency>
+            <groupId>com.sun.jna</groupId>
+            <artifactId>jna</artifactId>
+            <version>3.0.9</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.elasticsearch.client</groupId>
+            <artifactId>rest</artifactId>
+            <version>5.5.3</version>
+        </dependency>
+
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.40</version>
+        </dependency>
+
     </dependencies>
 
 </project>
diff --git a/springboot-elasticsearch/src/main/java/cn/abel/config/ESRestClientConfig.java b/springboot-elasticsearch/src/main/java/cn/abel/config/ESRestClientConfig.java
@@ -0,0 +1,45 @@
+package cn.abel.config;
+
+import org.apache.http.HttpHost;
+import org.apache.http.auth.AuthScope;
+import org.apache.http.auth.UsernamePasswordCredentials;
+import org.apache.http.client.CredentialsProvider;
+import org.apache.http.impl.client.BasicCredentialsProvider;
+import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
+import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestClientBuilder;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author yangyibo
+ * @time 2019/4/2
+ */
+@Configuration
+public class ESRestClientConfig {
+    @Value("${elasticsearch.userName}")
+    private String userName;
+    @Value("${elasticsearch.password}")
+    private String password;
+    @Value("${elasticsearch.rest.hostNames}")
+    private String hostName;
+    @Value("${elasticsearch.rest.port}")
+    private Integer port;
+
+    @Bean(destroyMethod = "close")
+    public RestClient getRestClient() {
+        final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();
+        credentialsProvider.setCredentials(AuthScope.ANY,
+                new UsernamePasswordCredentials(userName, password));
+        RestClientBuilder restClientBuilder = RestClient.builder(new HttpHost(hostName, port));
+        //配置身份验证
+        restClientBuilder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback() {
+            @Override
+            public HttpAsyncClientBuilder customizeHttpClient(HttpAsyncClientBuilder httpClientBuilder) {
+                return httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider);
+            }
+        });
+        return restClientBuilder.build();
+    }
+}
diff --git a/springboot-elasticsearch/src/main/resources/local/application.properties b/springboot-elasticsearch/src/main/resources/local/application.properties
@@ -56,4 +56,8 @@ pagehelper.reasonable=true
 pagehelper.supportMethodsArguments=true
 pagehelper.params=count=countSql
 
-
+#es\u670D\u52A1\u5668\u5730\u5740\u914D\u7F6E
+elasticsearch.new.userName=
+elasticsearch.new.password=
+elasticsearch.rest.new.hostNames=127.0.0.1
+elasticsearch.rest.new.port=9200
