From b39f00a58071d4f14234420193e3673ad8e9f012 Mon Sep 17 00:00:00 2001 From: ascrutae Date: Thu, 18 Aug 2016 07:56:05 +0800 Subject: [PATCH] =?UTF-8?q?=E5=B0=86=E6=89=80=E6=9C=89=E7=9A=84=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=94=B9=E4=B8=BA=E5=AE=88=E6=8A=A4=E7=BA=BF=E7=A8=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../alarm/AlarmMessageProcessThread.java | 1 + .../skywalking/alarm/UserInfoCoordinator.java | 1 + .../alarm/UsersChangedDetectionThread.java | 4 + .../a/eye/skywalking/buffer/BufferGroup.java | 1 + .../selfexamination/SDKHealthCollector.java | 1 + .../sender/DataSenderFactoryWithBalance.java | 1 + .../reciever/buffer/AppendEOFFlagThread.java | 1 + .../reciever/buffer/DataBufferThread.java | 1 + .../peresistent/PersistenceThread.java | 1 + .../RegisterPersistenceThread.java | 1 + .../ackspan/alarm/AlarmRedisConnector.java | 1 + .../ServerHealthCollector.java | 117 +++++++++--------- 12 files changed, 73 insertions(+), 58 deletions(-) diff --git a/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/AlarmMessageProcessThread.java b/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/AlarmMessageProcessThread.java index 449d441bc..8761d9835 100644 --- a/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/AlarmMessageProcessThread.java +++ b/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/AlarmMessageProcessThread.java @@ -37,6 +37,7 @@ public class AlarmMessageProcessThread extends Thread { public AlarmMessageProcessThread() { // 初始化生成ThreadId threadId = UUID.randomUUID().toString(); + this.setDaemon(true); } @Override diff --git a/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UserInfoCoordinator.java b/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UserInfoCoordinator.java index 7b658ae78..03dd491d9 100644 --- a/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UserInfoCoordinator.java +++ b/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UserInfoCoordinator.java @@ -31,6 +31,7 @@ public class UserInfoCoordinator extends Thread { private boolean isCoordinator = false; public UserInfoCoordinator() { + this.setDaemon(true); } @Override diff --git a/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UsersChangedDetectionThread.java b/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UsersChangedDetectionThread.java index 6fb1a6d28..e2f71f123 100644 --- a/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UsersChangedDetectionThread.java +++ b/skywalking-alarm/src/main/java/com/a/eye/skywalking/alarm/UsersChangedDetectionThread.java @@ -19,6 +19,10 @@ public class UsersChangedDetectionThread extends Thread { private String userIdsEncryptedStr; private Logger logger = LogManager.getLogger(UsersChangedDetectionThread.class); + public UsersChangedDetectionThread() { + this.setDaemon(true); + } + public void run() { while (true) { try { diff --git a/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/buffer/BufferGroup.java b/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/buffer/BufferGroup.java index aef25a12e..2f286450a 100644 --- a/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/buffer/BufferGroup.java +++ b/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/buffer/BufferGroup.java @@ -61,6 +61,7 @@ public class BufferGroup { super("ConsumerWorker"); this.start = start; this.end = end; + this.setDaemon(true); } @Override diff --git a/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/selfexamination/SDKHealthCollector.java b/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/selfexamination/SDKHealthCollector.java index 6e38bf66f..ac91bc648 100644 --- a/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/selfexamination/SDKHealthCollector.java +++ b/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/selfexamination/SDKHealthCollector.java @@ -18,6 +18,7 @@ public class SDKHealthCollector extends Thread { private SDKHealthCollector() { super("HealthCollector"); + this.setDaemon(true); } public static void init() { diff --git a/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/sender/DataSenderFactoryWithBalance.java b/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/sender/DataSenderFactoryWithBalance.java index ba09daf2b..c35001e71 100644 --- a/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/sender/DataSenderFactoryWithBalance.java +++ b/skywalking-collector/skywalking-api/src/main/java/com/a/eye/skywalking/sender/DataSenderFactoryWithBalance.java @@ -102,6 +102,7 @@ public class DataSenderFactoryWithBalance { public static class DataSenderChecker extends Thread { public DataSenderChecker() { super("Data-Sender-Checker"); + this.setDaemon(true); } @Override diff --git a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/AppendEOFFlagThread.java b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/AppendEOFFlagThread.java index 7f87645eb..738da1052 100644 --- a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/AppendEOFFlagThread.java +++ b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/AppendEOFFlagThread.java @@ -19,6 +19,7 @@ class AppendEOFFlagThread extends Thread { super("AppendEOFFlagThread"); this.dataBufferFiles = dataBufferFiles; this.countDownLatch = countDownLatch; + this.setDaemon(true); } @Override diff --git a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/DataBufferThread.java b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/DataBufferThread.java index 9e8a54825..9cab70f4f 100644 --- a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/DataBufferThread.java +++ b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/buffer/DataBufferThread.java @@ -26,6 +26,7 @@ public class DataBufferThread extends Thread { public DataBufferThread(int threadIdx) { super("DataBufferThread_" + threadIdx); + this.setDaemon(true); } @Override diff --git a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/PersistenceThread.java b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/PersistenceThread.java index 1eb4db18f..37bd733ee 100644 --- a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/PersistenceThread.java +++ b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/PersistenceThread.java @@ -24,6 +24,7 @@ public class PersistenceThread extends Thread { public PersistenceThread(int trdIndex) { super("PersistentThread" + trdIndex); + this.setDaemon(true); } @Override diff --git a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/RegisterPersistenceThread.java b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/RegisterPersistenceThread.java index 61a186fb0..b630b78c0 100644 --- a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/RegisterPersistenceThread.java +++ b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/peresistent/RegisterPersistenceThread.java @@ -30,6 +30,7 @@ public class RegisterPersistenceThread extends Thread { Config.RegisterPersistence.REGISTER_FILE_PARENT_DIRECTORY, Config.RegisterPersistence.REGISTER_FILE_NAME); bakOffsetFile = new File( Config.RegisterPersistence.REGISTER_FILE_PARENT_DIRECTORY, Config.RegisterPersistence.REGISTER_BAK_FILE_NAME); + this.setDaemon(true); } @Override diff --git a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/processor/ackspan/alarm/AlarmRedisConnector.java b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/processor/ackspan/alarm/AlarmRedisConnector.java index ebf237038..a08512d23 100644 --- a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/processor/ackspan/alarm/AlarmRedisConnector.java +++ b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/processor/ackspan/alarm/AlarmRedisConnector.java @@ -57,6 +57,7 @@ public class AlarmRedisConnector { Config.Alarm.ALARM_OFF_FLAG = true; } } + this.setDaemon(true); } private RedisInspector connect() { diff --git a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/selfexamination/ServerHealthCollector.java b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/selfexamination/ServerHealthCollector.java index c9ba49ecf..f73f8c95e 100644 --- a/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/selfexamination/ServerHealthCollector.java +++ b/skywalking-server/src/main/java/com/a/eye/skywalking/reciever/selfexamination/ServerHealthCollector.java @@ -10,66 +10,67 @@ import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.Logger; public class ServerHealthCollector extends Thread { - private Logger logger = LogManager.getLogger(ServerHealthCollector.class); + private Logger logger = LogManager.getLogger(ServerHealthCollector.class); - private static Map heathReadings = new ConcurrentHashMap(); + private static Map heathReadings = new ConcurrentHashMap(); - private ServerHealthCollector(){ - super("ServerHealthCollector"); - } - - public static void init(){ - new ServerHealthCollector().start(); - } - - public static ServerHeathReading getCurrentHeathReading(String extraId) { - String id = getId(extraId); - if (!heathReadings.containsKey(id)) { - synchronized (heathReadings) { - if (!heathReadings.containsKey(id)) { - if(heathReadings.keySet().size() > 5000){ - throw new RuntimeException("use ServerHealthCollector illegal. There is an overflow trend of Server Health Collector Report Data."); - } - heathReadings.put(id, new ServerHeathReading(id)); - } - } - } - return heathReadings.get(id); - } + private ServerHealthCollector() { + super("ServerHealthCollector"); + this.setDaemon(true); + } - private static String getId(String extraId) { - return "SkyWalkingServer,M:" + MachineUtil.getHostDesc() + ",P:" - + MachineUtil.getProcessNo() + ",T:" - + Thread.currentThread().getName() + "(" - + Thread.currentThread().getId() + ")" - + (extraId == null ? "" : ",extra:" + extraId); - } + public static void init() { + new ServerHealthCollector().start(); + } - @Override - public void run() { - while (true) { - try { - Map heathReadingsSnapshot = heathReadings; - heathReadings = new ConcurrentHashMap(); - String[] keyList = heathReadingsSnapshot.keySet().toArray(new String[0]); - Arrays.sort(keyList); - StringBuilder log = new StringBuilder(); - log.append("\n---------Server Health Collector Report---------\n"); - for(String key : keyList){ - log.append(heathReadingsSnapshot.get(key)).append("\n"); - } - log.append("------------------------------------------------\n"); - - logger.info(log); - - try { - Thread.sleep(Config.HealthCollector.REPORT_INTERVAL); - } catch (InterruptedException e) { - logger.warn("sleep error.", e); - } - } catch (Throwable t) { - logger.error("ServerHealthCollector report error.", t); - } - } - } + public static ServerHeathReading getCurrentHeathReading(String extraId) { + String id = getId(extraId); + if (!heathReadings.containsKey(id)) { + synchronized (heathReadings) { + if (!heathReadings.containsKey(id)) { + if (heathReadings.keySet().size() > 5000) { + throw new RuntimeException( + "use ServerHealthCollector illegal. There is an overflow trend of Server Health Collector Report Data."); + } + heathReadings.put(id, new ServerHeathReading(id)); + } + } + } + return heathReadings.get(id); + } + + private static String getId(String extraId) { + return "SkyWalkingServer,M:" + MachineUtil.getHostDesc() + ",P:" + MachineUtil.getProcessNo() + ",T:" + Thread + .currentThread().getName() + "(" + Thread.currentThread().getId() + ")" + (extraId == null ? + "" : + ",extra:" + extraId); + } + + @Override + public void run() { + while (true) { + try { + Map heathReadingsSnapshot = heathReadings; + heathReadings = new ConcurrentHashMap(); + String[] keyList = heathReadingsSnapshot.keySet().toArray(new String[0]); + Arrays.sort(keyList); + StringBuilder log = new StringBuilder(); + log.append("\n---------Server Health Collector Report---------\n"); + for (String key : keyList) { + log.append(heathReadingsSnapshot.get(key)).append("\n"); + } + log.append("------------------------------------------------\n"); + + logger.info(log); + + try { + Thread.sleep(Config.HealthCollector.REPORT_INTERVAL); + } catch (InterruptedException e) { + logger.warn("sleep error.", e); + } + } catch (Throwable t) { + logger.error("ServerHealthCollector report error.", t); + } + } + } }