From 1018981f7348e463ed4e326a0524387fa871d91e Mon Sep 17 00:00:00 2001
From: ascrutae <ascrutae@gmail.com>
Date: Thu, 2 Jun 2016 10:28:00 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9key?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../reciever/handler/CollectionServerDataHandler.java          | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
index 8492a3510..6775f92e4 100644
--- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
+++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/handler/CollectionServerDataHandler.java
@@ -29,7 +29,7 @@ public class CollectionServerDataHandler extends SimpleChannelInboundHandler<byt
                 DataBufferThreadContainer.getDataBufferThread().saveTemporarily(data.getBytes());
             } else {
                 InetSocketAddress socketAddress = (InetSocketAddress) ctx.channel().localAddress();
-                String key = socketAddress.getHostName() + ":" + socketAddress.getPort();
+                String key = ctx.name() + "-" + socketAddress.getHostName() + ":" + socketAddress.getPort();
                 Jedis jedis = AlarmRedisConnector.getJedis();
                 // 如果不存在，则置为0，并且设置生失效时间
                 if (jedis.setnx(key, 0 + "") == 1) {
@@ -44,7 +44,6 @@ public class CollectionServerDataHandler extends SimpleChannelInboundHandler<byt
         }
     }
 
-
     /**
      * 生成校验和参数
      *
-- 
GitLab