修复自动创建ES索引模版失败问题

Author: zengqiao

km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/ESOpClient.java

@@ -392,10 +392,7 @@ public boolean createIndex(String indexName) {
         return false;
     }
 
-    /**
-     * 创建索引模板
-     */
-    public boolean createIndexTemplateIfNotExist(String indexTemplateName, String config) {
+    public boolean templateExist(String indexTemplateName){
         ESClient esClient = null;
 
         try {
@@ -410,15 +407,37 @@ public boolean createIndexTemplateIfNotExist(String indexTemplateName, String co
             if (null != templateConfig) {
                 return true;
             }
+        } catch (Exception e) {
+            LOGGER.warn( "method=templateExist||indexTemplateName={}||msg=exception!",
+                    indexTemplateName, e);
+        } finally {
+            if (esClient != null) {
+                this.returnESClientToPool(esClient);
+            }
+        }
+
+        return false;
+    }
+
+    /**
+     * 创建索引模板
+     */
+    public boolean createIndexTemplateIfNotExist(String indexTemplateName, String config) {
+        ESClient esClient = null;
+
+        try {
+            esClient = this.getESClientFromPool();
+
+            //存在模板就返回，不存在就创建
+            if(templateExist(indexTemplateName)){return true;}
 
             // 创建新的模板
             ESIndicesPutTemplateResponse response = esClient.admin().indices().preparePutTemplate( indexTemplateName )
                     .setTemplateConfig( config ).execute().actionGet( 30, TimeUnit.SECONDS );
 
             return response.getAcknowledged();
         } catch (Exception e) {
-            LOGGER.warn(
-                    "class=ESOpClient||method=createIndexTemplateIfNotExist||indexTemplateName={}||config={}||msg=exception!",
+            LOGGER.warn( "method=createIndexTemplateIfNotExist||indexTemplateName={}||config={}||msg=exception!",
                     indexTemplateName, config, e
             );
         } finally {