From 490e9baecef84f79d5d4dd1607fc830ad5835afe Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=B8=89=E4=B8=99?= <10604541+sanbing-os@user.noreply.gitee.com> Date: Fri, 25 Oct 2024 09:49:24 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4kafka=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- docker/start.sh | 2 +- .../sanbing/jcpp/app/service/grpc/DownlinkGrpcClient.java | 5 ++++- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/docker/start.sh b/docker/start.sh index 33ea7fa..d16c041 100644 --- a/docker/start.sh +++ b/docker/start.sh @@ -12,7 +12,7 @@ export JAVA_APP_OPTS="-XX:+UseContainerSupport -XX:InitialRAMPercentage=10 -XX:M -XX:HeapDumpPath=/var/log/sanbing/heapdump/ \ -XX:+UseTLAB -XX:+ResizeTLAB -XX:+PerfDisableSharedMem -XX:+UseCondCardMark \ -XX:+UseG1GC -XX:MaxGCPauseMillis=500 -XX:+UseStringDeduplication -XX:+ParallelRefProcEnabled -XX:MaxTenuringThreshold=10 \ - -Xss512k -XX:MaxDirectMemorySize=128M -XX:G1ReservePercent=20 \ + -Xss512k -XX:MaxDirectMemorySize=256M -XX:G1ReservePercent=20 \ -XX:-OmitStackTraceInFastThrow \ -Dlogging.config=/app/config/log4j2.xml" diff --git a/jcpp-app/src/main/java/sanbing/jcpp/app/service/grpc/DownlinkGrpcClient.java b/jcpp-app/src/main/java/sanbing/jcpp/app/service/grpc/DownlinkGrpcClient.java index dee6bc3..445093b 100644 --- a/jcpp-app/src/main/java/sanbing/jcpp/app/service/grpc/DownlinkGrpcClient.java +++ b/jcpp-app/src/main/java/sanbing/jcpp/app/service/grpc/DownlinkGrpcClient.java @@ -261,7 +261,10 @@ public class DownlinkGrpcClient { } if (connectErrTimesMap.computeIfAbsent(hostAndPort, k -> new AtomicInteger()).incrementAndGet() >= maxReconnectTimes) { - queueMap.remove(hostAndPort); + LinkedBlockingQueue queue = queueMap.remove(hostAndPort); + if (queue != null) { + queue.clear(); + } connectErrTimesMap.remove(hostAndPort); log.info("[{}] Grpc 客户端重连异常超过{}次，不再重连", hostAndPort, maxReconnectTimes); }