refactor: rpc optimize

Author: kevinten10

capa-spi-aws-mesh/src/main/java/group/rxcloud/capa/spi/aws/mesh/AwsCapaRpcProperties.java

@@ -21,6 +21,8 @@
 import group.rxcloud.capa.infrastructure.CapaProperties;
 import group.rxcloud.capa.infrastructure.exceptions.CapaErrorContext;
 import group.rxcloud.capa.infrastructure.exceptions.CapaException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.Properties;
 
@@ -29,6 +31,8 @@
  */
 public interface AwsCapaRpcProperties {
 
+    Logger logger = LoggerFactory.getLogger(AwsCapaRpcProperties.class);
+
     interface AppMeshProperties {
 
         abstract class Settings {
@@ -59,6 +63,9 @@ abstract class Settings {
 
                 // FIXME: 2021/12/15 use trip logic currently
                 rpcAwsAppMeshNamespace = CapaFoundation.getNamespace(FoundationType.TRIP);
+
+                logger.info("[Capa.Rpc.Client.config] [AwsCapaRpcProperties.AppMeshProperties] rpcAwsAppMeshTemplate[{}] rpcAwsAppMeshPort[{}] rpcAwsAppMeshNamespace[{}]",
+                        rpcAwsAppMeshTemplate, rpcAwsAppMeshPort, rpcAwsAppMeshNamespace);
             }
 
             public static Integer getRpcAwsAppMeshPort() {
@@ -90,6 +97,9 @@ abstract class Settings {
                 Properties properties = CapaProperties.COMPONENT_PROPERTIES_SUPPLIER.apply("rpc-aws");
 
                 rpcAwsAppMeshSerializer = properties.getProperty(RPC_AWS_APP_MESH_SERIALIZER, rpcAwsAppMeshSerializer);
+
+                logger.info("[Capa.Rpc.Client.config] [AwsCapaRpcProperties.SerializerProperties] rpcAwsAppMeshSerializer[{}]",
+                        rpcAwsAppMeshSerializer);
             }
 
             public static String getRpcAwsAppMeshSerializer() {

capa-spi-aws-mesh/src/main/java/group/rxcloud/capa/spi/aws/mesh/http/AwsCapaHttp.java

@@ -93,9 +93,11 @@ private void setRequestHeaderOfAccept(Map<String, String> headers, RequestBody b
             accepts.add(userAcceptValue);
         }
         // 2. set accept header same with content-type
-        final String contentType = body.contentType().toString();
-        if (contentType != null && contentType.length() > 0) {
-            accepts.add(contentType);
+        if (body.contentType() != null) {
+            final String contentType = Objects.requireNonNull(body.contentType()).toString();
+            if (contentType.length() > 0) {
+                accepts.add(contentType);
+            }
         }
         // 3. add */* at last
         accepts.add(ACCEPT_ALL);
@@ -199,6 +201,10 @@ private <T> CompletableFuture<HttpResponse<T>> doAsyncInvoke(String method,
 
             if (HttpExtension.GET.getMethod().toString().equals(httpMethod)) {
                 // TODO: 2021/11/30 append urlParameters to url
+                if (logger.isWarnEnabled()) {
+                    logger.warn("[Capa.Rpc.Client.http] [AwsCapaHttp.doAsyncInvoke] GET not supported now, urlParameters[{}]",
+                            urlParameters);
+                }
             }
 
             // async invoke
@@ -210,7 +216,7 @@ private <T> CompletableFuture<HttpResponse<T>> doAsyncInvoke(String method,
                     type);
             asyncInvoke0.exceptionally(throwable -> {
                 if (logger.isWarnEnabled()) {
-                    logger.warn("[AwsCapaHttp] async invoke error", throwable);
+                    logger.warn("[Capa.Rpc.Client.http] [AwsCapaHttp.doAsyncInvoke] async invoke error", throwable);
                 }
                 throw new CapaException(CapaErrorContext.DEPENDENT_SERVICE_ERROR, throwable);
             });
@@ -229,6 +235,11 @@ private <T> CompletableFuture<HttpResponse<T>> invokeHttp(String url,
 
             Headers header = getRequestHeaderWithParams(headers);
 
+            if (logger.isDebugEnabled()) {
+                logger.debug("[Capa.Rpc.Client.http] [AwsCapaHttp.invokeHttp] final request url[{}] header[{}] httpMethod[{}]",
+                        url, header, httpMethod);
+            }
+
             // make http request
             Request request = new Request.Builder()
                     .url(url)