Feat: Adapting the new version of GatewayClient routing

Author: Jzow

trpc-spring-support/trpc-spring-cloud-gateway/src/main/java/com/tencent/trpc/spring/cloud/gateway/filter/TrpcRoutingFilter.java

@@ -83,7 +83,13 @@ public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
         ServerHttpRequest request = exchange.getRequest();
         return DataBufferUtils.join(request.getBody())
                 .map(body -> requestRewriter.resolver(exchange, route, body))
-                .map(body -> client.asyncInvoke(request, route, body.asByteBuffer().array()))
+                .map(body -> {
+                    java.nio.ByteBuffer byteBuffer = body.asByteBuffer();
+                    byte[] bytes = new byte[byteBuffer.remaining()];
+                    byteBuffer.get(bytes);
+                    byteBuffer.rewind();
+                    return client.asyncInvoke(request, route, bytes);
+                })
                 .flatMap(result -> this.responseRewriter.write(exchange, route.getMetadata(), result));
     }
 

trpc-spring-support/trpc-spring-cloud-gateway/src/main/java/com/tencent/trpc/spring/cloud/gateway/rewriter/DefaultTrpcResponseRewriter.java

@@ -30,11 +30,13 @@ public Mono<Void> write(ServerWebExchange exchange,
             Mono<byte[]> result) {
         ServerHttpResponse response = exchange.getResponse();
         if (result != null) {
-            DataBuffer dataBuffer = response.bufferFactory().wrap(result.block());
-            logger.info("dataBuffer :{}", dataBuffer.toString(StandardCharsets.UTF_8));
-            // Content-Type uses application/json by default
-            response.getHeaders().add("Content-Type", MimeTypeUtils.APPLICATION_JSON_VALUE);
-            return response.writeWith(Mono.justOrEmpty(dataBuffer));
+            return result.flatMap(bytes -> {
+                DataBuffer dataBuffer = response.bufferFactory().wrap(bytes);
+                logger.info("dataBuffer :{}", dataBuffer.toString(StandardCharsets.UTF_8));
+                // Content-Type uses application/json by default
+                response.getHeaders().add("Content-Type", MimeTypeUtils.APPLICATION_JSON_VALUE);
+                return response.writeWith(Mono.just(dataBuffer));
+            });
         }
         return Mono.empty();
     }