add unit test(#9708)

alibaba · Dec 28, 2022 · 939905c · 939905c
1 parent bafd6ef
commit 939905c
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 1 deletion.
diff --git a/naming/src/main/java/com/alibaba/nacos/naming/misc/HttpClientManager.java b/naming/src/main/java/com/alibaba/nacos/naming/misc/HttpClientManager.java
@@ -161,7 +161,7 @@ protected Logger assignLogger() {
         }
     }
 
-    private static class ProcessorHttpClientFactory extends AbstractHttpClientFactory {
+    public static class ProcessorHttpClientFactory extends AbstractHttpClientFactory {
 
         @Override
         protected HttpClientConfig buildHttpClientConfig() {

diff --git a/.../core-test/src/test/java/com/alibaba/nacos/test/common/NacosAsyncRestTemplate_ITCase.java b/.../core-test/src/test/java/com/alibaba/nacos/test/common/NacosAsyncRestTemplate_ITCase.java
@@ -20,11 +20,14 @@
 import com.alibaba.nacos.api.exception.NacosException;
 import com.alibaba.nacos.common.http.Callback;
 import com.alibaba.nacos.common.http.HttpClientBeanHolder;
+import com.alibaba.nacos.common.http.HttpClientFactory;
 import com.alibaba.nacos.common.http.HttpRestResult;
 import com.alibaba.nacos.common.http.client.NacosAsyncRestTemplate;
 import com.alibaba.nacos.common.http.param.Header;
 import com.alibaba.nacos.common.http.param.Query;
 import com.alibaba.nacos.common.model.RestResult;
+import com.alibaba.nacos.naming.misc.HttpClientManager.ProcessorHttpClientFactory;
+
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.FixMethodOrder;
@@ -57,6 +60,11 @@ public class NacosAsyncRestTemplate_ITCase {
     private NacosAsyncRestTemplate nacosRestTemplate = HttpClientBeanHolder
             .getNacosAsyncRestTemplate(LoggerFactory.getLogger(NacosAsyncRestTemplate_ITCase.class));
 
+    private static final HttpClientFactory PROCESSOR_ASYNC_HTTP_CLIENT_FACTORY = new ProcessorHttpClientFactory();
+
+    private NacosAsyncRestTemplate processorRestTemplate = HttpClientBeanHolder
+            .getNacosAsyncRestTemplate(PROCESSOR_ASYNC_HTTP_CLIENT_FACTORY);
+
     private final String CONFIG_INSTANCE_PATH = "/nacos/v1/ns";
 
     private String IP = null;
@@ -112,6 +120,22 @@ public void test_url_post_form() throws Exception {
         Assert.assertTrue(restResult.ok());
     }
 
+    @Test
+    public void test_url_post_form_by_processor() throws Exception {
+        String url = IP + CONFIG_INSTANCE_PATH + "/instance";
+        Map<String, String> param = new HashMap<>();
+        param.put("serviceName", "app-test");
+        param.put("port", "8080");
+        param.put("ip", "11.11.11.11");
+        CallbackMap<String> callbackMap = new CallbackMap<>();
+        processorRestTemplate.postForm(url, Header.newInstance(), Query.newInstance(), param, String.class, callbackMap);
+        Thread.sleep(2000);
+        HttpRestResult<String> restResult = callbackMap.getRestResult();
+        System.out.println(restResult.getData());
+        System.out.println(restResult.getHeader());
+        Assert.assertTrue(restResult.ok());
+    }
+
     @Test
     public void test_url_put_form() throws Exception {
         String url = IP + CONFIG_INSTANCE_PATH + "/instance";