From 2e8425117c483160acdf6728fb72db1be58aa644 Mon Sep 17 00:00:00 2001 From: ascrutae Date: Wed, 24 Feb 2016 19:35:03 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E4=BF=AE=E5=A4=8DunusedServerAddresses?= =?UTF-8?q?=E7=9A=84=E6=95=B0=E9=87=8F=E5=B0=8F=E4=BA=8E=E7=AD=89=E4=BA=8E?= =?UTF-8?q?1=E7=9A=84=E6=83=85=E5=86=B5=EF=BC=8C=E4=BD=BF=E7=94=A8ThreadLo?= =?UTF-8?q?calRandom=E4=BC=9A=E6=8A=9B=E5=87=BA=E5=BC=82=E5=B8=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sender/DataSenderFactoryWithBalance.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) 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 d37ffe440..5a2662c2c 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 @@ -197,8 +197,14 @@ public class DataSenderFactoryWithBalance { private static DataSender findReadySender() { DataSender result = null; - int index = ThreadLocalRandom.current().nextInt(0, - unusedServerAddresses.size()); + + int index = 0; + + if (unusedServerAddresses.size() > 1){ + index = ThreadLocalRandom.current().nextInt(0, + unusedServerAddresses.size()); + } + for (int i = 0; i < unusedServerAddresses.size(); i++, index++) { if (index == unusedServerAddresses.size()) {