fix(recommend-server): align recommend-feature grpc client with ad-engine

recommend-server-service/pom.xml

@@ -180,7 +180,7 @@
         <dependency>
             <groupId>com.tzld.piaoquan</groupId>
             <artifactId>recommend-feature-client</artifactId>
-            <version>1.1.20</version>
+            <version>1.1.35</version>
         </dependency>
         <dependency>
             <groupId>com.google.protobuf</groupId>
@@ -304,4 +304,4 @@
         </plugins>
     </build>
 
-</project>
+</project>

recommend-server-service/src/main/java/com/tzld/piaoquan/recommend/server/remote/FeatureV2RemoteService.java

@@ -26,8 +26,16 @@ public class FeatureV2RemoteService {
         if (CollectionUtils.isEmpty(protos)) {
             return Collections.emptyMap();
         }
-        Map<String, String> result = client.multiGetFeature(protos);
-        return result;
+        try {
+            long start = System.currentTimeMillis();
+            Map<String, String> result = client.multiGetFeature(protos);
+            log.debug("FeatureV2RemoteService.getFeature: protos.size={}, result.size={}, costTime={}",
+                    protos.size(), result != null ? result.size() : 0, System.currentTimeMillis() - start);
+            return result != null ? result : Collections.emptyMap();
+        } catch (Exception e) {
+            log.error("FeatureV2RemoteService.getFeature: unexpected exception, protos.size={}", protos.size(), e);
+            return Collections.emptyMap();
+        }
     }
 
 

recommend-server-service/src/main/resources/application.yml

@@ -24,6 +24,12 @@ grpc:
   client:
     recommend-feature:
       negotiationType: PLAINTEXT
+      enable-keep-alive: true
+      keep-alive-time: 20s
+      keep-alive-timeout: 5s
+      keep-alive-without-calls: true
+      max-inbound-message-size: 20MB
+      negotiation-type: plaintext
     abtest:
       negotiationType: PLAINTEXT
 
@@ -61,4 +67,4 @@ feign:
         readTimeout: 10000
 model:
   xgboost:
-    path: xgboost
+    path: xgboost