es 7.2.0 support

Author: shi-yuan

pom.xml

@@ -4,7 +4,7 @@
 
 	<groupId>org.ansj</groupId>
 	<artifactId>elasticsearch-analysis-ansj</artifactId>
-	<version>7.1.1.0</version>
+	<version>7.2.0.0</version>
 	<description>elasticsearch analysis by ansj</description>
 	<name>elasticsearch-analysis-ansj</name>
 	<url>http://maven.nlpcn.org</url>
@@ -21,7 +21,7 @@
 		<runSuite>**/MainTestSuite.class</runSuite>
 		<elasticsearch.plugin.name>elasticsearch-analysis-ansj</elasticsearch.plugin.name>
         <elasticsearch.plugin.java.version>1.8</elasticsearch.plugin.java.version>
-		<elasticsearch.version>7.1.1</elasticsearch.version>
+		<elasticsearch.version>7.2.0</elasticsearch.version>
 		<elasticsearch.plugin.classname>org.ansj.elasticsearch.plugin.AnalysisAnsjPlugin</elasticsearch.plugin.classname>
 	</properties>
 

src/main/java/org/ansj/elasticsearch/action/AnsjAction.java

@@ -22,10 +22,6 @@ public AnsjResponse newResponse() {
 
     @Override
     public Writeable.Reader<AnsjResponse> getResponseReader() {
-        return in -> {
-            AnsjResponse response = new AnsjResponse();
-            response.readFrom(in);
-            return response;
-        };
+        return AnsjResponse::new;
     }
 }

src/main/java/org/ansj/elasticsearch/action/AnsjResponse.java

@@ -26,6 +26,10 @@ public AnsjResponse(Map<String, ?> map) {
         this.map.putAll(map);
     }
 
+    public AnsjResponse(StreamInput in) throws IOException {
+        readFrom(in);
+    }
+
     public AnsjResponse put(String key, Object value) {
         map.put(key, value);
         return this;

src/main/java/org/ansj/elasticsearch/action/TransportAnsjAction.java

@@ -33,6 +33,7 @@
 import org.elasticsearch.cluster.service.ClusterService;
 import org.elasticsearch.common.inject.Inject;
 import org.elasticsearch.common.io.stream.StreamInput;
+import org.elasticsearch.common.io.stream.Writeable;
 import org.elasticsearch.index.shard.ShardId;
 import org.elasticsearch.threadpool.ThreadPool;
 import org.elasticsearch.transport.TransportException;
@@ -245,7 +246,8 @@ private AnsjResponse flushConfigAll() {
 
         final CountDownLatch countDownLatch = new CountDownLatch(nodes.getSize());
 
-        final Map<String, String> result = new HashMap<>();
+        final Map<String, String> result = new HashMap<>(16);
+        final Writeable.Reader<AnsjResponse> reader = getResponseReader();
 
         for (final DiscoveryNode node : nodes) {
 
@@ -254,9 +256,7 @@ private AnsjResponse flushConfigAll() {
             TransportResponseHandler<AnsjResponse> rep = new TransportResponseHandler<AnsjResponse>() {
                 @Override
                 public AnsjResponse read(StreamInput in) throws IOException {
-                    AnsjResponse instance = newResponse();
-                    instance.readFrom(in);
-                    return instance;
+                    return reader.read(in);
                 }
 
                 @Override
@@ -315,7 +315,8 @@ private AnsjResponse flushDicAll(AnsjRequest request) {
 
         final CountDownLatch countDownLatch = new CountDownLatch(nodes.getSize());
 
-        final Map<String, String> result = new HashMap<>();
+        final Map<String, String> result = new HashMap<>(16);
+        final Writeable.Reader<AnsjResponse> reader = getResponseReader();
 
         for (final DiscoveryNode node : nodes) {
 
@@ -324,9 +325,7 @@ private AnsjResponse flushDicAll(AnsjRequest request) {
             transportService.sendRequest(node, AnsjAction.NAME, req, new TransportResponseHandler<AnsjResponse>() {
                 @Override
                 public AnsjResponse read(StreamInput in) throws IOException {
-                    AnsjResponse instance = newResponse();
-                    instance.readFrom(in);
-                    return instance;
+                    return reader.read(in);
                 }
 
                 @Override
@@ -398,7 +397,7 @@ private AnsjResponse flushDic(AnsjRequest request) {
                     CrfLibrary.reload(key);
                     return null;
                 });
-            } else if (key.equals("ansj_config")) {
+            } else if ("ansj_config".equals(key)) {
                 this.cfg.reloadConfig();
             } else {
                 return new AnsjResponse().put("status", "not find any by " + key);
@@ -414,8 +413,8 @@ private AnsjResponse flushDic(AnsjRequest request) {
     }
 
     @Override
-    protected AnsjResponse newResponse() {
-        return new AnsjResponse();
+    protected Writeable.Reader<AnsjResponse> getResponseReader() {
+        return AnsjResponse::new;
     }
 
     @Override