From 9e67f8a8001dc3a7bf206877c9e57b173da4b9ba Mon Sep 17 00:00:00 2001
From: zhangxin10 <curtain.xin@gmail.com>
Date: Mon, 14 Dec 2015 16:06:38 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9C=80=E5=A4=A7=E8=BF=9E=E6=8E=A5=E6=B6=88?=
 =?UTF-8?q?=E8=B4=B9=E7=BA=BF=E7=A8=8B=E5=B0=8F=E4=BA=8E=E4=BF=9D=E6=8C=81?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5=E7=9A=84Sender=E7=9A=84=E6=95=B0=E9=87=8F?=
 =?UTF-8?q?=EF=BC=8C=E5=B0=B1=E4=B8=8D=E9=9C=80=E8=A6=81=E4=BF=9D=E6=8C=81?=
 =?UTF-8?q?=E9=82=A3=E4=B9=88=E5=A4=9A=E7=9A=84=E4=BF=9D=E6=8C=81=E8=BF=9E?=
 =?UTF-8?q?=E6=8E=A5=E7=9A=84Sender=E7=9A=84=E6=95=B0=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cloud/skywalking/sender/DataSenderFactoryWithBalance.java | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java
index 3397f9729b..9e7f0105ad 100644
--- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java
+++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/sender/DataSenderFactoryWithBalance.java
@@ -55,6 +55,10 @@ public class DataSenderFactoryWithBalance {
         // 根据配置的服务器集群的地址，来计算保持连接的Sender的数量
         maxKeepConnectingSenderSize = calculateMaxKeeperConnectingSenderSize(tmpInetSocketAddress
                 .size());
+        //最大连接消费线程小于保持连接的Sender的数量，就不需要保持那么多的保持连接的Sender的数量
+        if (maxKeepConnectingSenderSize > Config.Consumer.MAX_CONSUMER * Config.Buffer.POOL_SIZE) {
+            maxKeepConnectingSenderSize = Config.Consumer.MAX_CONSUMER * Config.Buffer.POOL_SIZE;
+        }
 
         // 初始化的发送程序
         int index = 0;
-- 
GitLab