From 050dcd4178f91edbe483afc2c864c0a9cc207be8 Mon Sep 17 00:00:00 2001 From: zhangxin10 Date: Fri, 13 Nov 2015 14:58:00 +0800 Subject: [PATCH] =?UTF-8?q?1.=20=E4=BF=AE=E6=94=B9=E9=85=8D=E7=BD=AE=202.?= =?UTF-8?q?=20=E4=BF=AE=E6=94=B9=E5=8F=98=E9=87=8F=E8=8C=83=E5=9B=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reciever/persistance/PersistenceThread.java | 14 +++++++++----- .../src/main/resources/config.properties | 2 +- 2 files changed, 10 insertions(+), 6 deletions(-) diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java index 8538ac8a3..011c59444 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java @@ -16,9 +16,13 @@ public class PersistenceThread extends Thread { @Override public void run() { - int length = 0; + int length; + File file1; + BufferedReader bufferedReader; + int offset; + StringBuffer data; while (true) { - File file1 = getDataFiles(); + file1 = getDataFiles(); if (file1 == null) { try { Thread.sleep(SWITCH_FILE_WAIT_TIME); @@ -29,13 +33,13 @@ public class PersistenceThread extends Thread { } try { - BufferedReader bufferedReader = new BufferedReader(new FileReader(file1)); - int offset = moveOffSet(file1, bufferedReader); + bufferedReader = new BufferedReader(new FileReader(file1)); + offset = moveOffSet(file1, bufferedReader); if (logger.isDebugEnabled()) { logger.debug("Get file[{}] offset [{}]", file1.getName(), offset); } char[] chars = new char[OFFSET_FILE_READ_BUFFER_SIZE]; - StringBuilder data = new StringBuilder(2048); + data = new StringBuffer(2048); boolean bool = true; length = 0; while (bool) { diff --git a/skywalking-server/src/main/resources/config.properties b/skywalking-server/src/main/resources/config.properties index 2b1c50d64..4cf655049 100644 --- a/skywalking-server/src/main/resources/config.properties +++ b/skywalking-server/src/main/resources/config.properties @@ -1,5 +1,5 @@ #采集服务器的端口 -server.port=34000 +server.port=35000 #最大数据缓存线程数量 buffer.max_thread_number=1