From ed849142f590f216e157157b9700f3493ecda8c8 Mon Sep 17 00:00:00 2001
From: Lobo Xu <317307889@qq.com>
Date: Mon, 27 Feb 2023 13:59:29 +0800
Subject: [PATCH] proxy some optimization (#6175)

Co-authored-by: loboxu <loboxu@tencent.com>
---
 .../main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java | 5 +++--
 .../rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java   | 3 ++-
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
index 4e9dfbcfa6..66ab71712c 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
@@ -18,6 +18,7 @@
 package org.apache.rocketmq.proxy.grpc;
 
 import java.util.concurrent.TimeUnit;
+import io.grpc.Server;
 import org.apache.rocketmq.common.constant.LoggerName;
 import org.apache.rocketmq.logging.org.slf4j.Logger;
 import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
@@ -26,9 +27,9 @@ import org.apache.rocketmq.proxy.common.StartAndShutdown;
 public class GrpcServer implements StartAndShutdown {
     private static final Logger log = LoggerFactory.getLogger(LoggerName.PROXY_LOGGER_NAME);
 
-    private final io.grpc.Server server;
+    private final Server server;
 
-    protected GrpcServer(io.grpc.Server server) {
+    protected GrpcServer(Server server) {
         this.server = server;
     }
 
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
index fb6df25627..799775412e 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
@@ -50,12 +50,13 @@ public class GrpcChannelManager implements StartAndShutdown {
     public GrpcChannelManager(ProxyRelayService proxyRelayService, GrpcClientSettingsManager grpcClientSettingsManager) {
         this.proxyRelayService = proxyRelayService;
         this.grpcClientSettingsManager = grpcClientSettingsManager;
+        this.init();
     }
 
     protected void init() {
         this.scheduledExecutorService.scheduleAtFixedRate(
             this::scanExpireResultFuture,
-            10, 10, TimeUnit.SECONDS
+            10, 1, TimeUnit.SECONDS
         );
     }