Skip to content

Commit

Permalink
Polish alibaba#104
Browse files Browse the repository at this point in the history
  • Loading branch information
@mercyblitz
mercyblitz committed Oct 1, 2018
1 parent b0b7146 commit a718c84
Show file tree
Hide file tree
Showing 13 changed files with 59 additions and 251 deletions.
3 changes: 0 additions & 3 deletions client/src/main/java/com/alibaba/nacos/client/naming/cache/ConcurrentDiskUtil.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -229,9 +229,6 @@ private static void sleep(int time) {
}
}

public static void main(String[] args) {
}

static final public Logger log = LogUtils.LOG;
static final int RETRY_COUNT = 10;
static final int SLEEP_BASETIME = 10;
Expand Down
6 changes: 0 additions & 6 deletions client/src/main/java/com/alibaba/nacos/client/naming/net/HttpClient.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -175,12 +175,6 @@ private static String encodingParams(Map<String, String> params, String encoding
return sb.toString();
}

public static void main(String[] args) throws UnsupportedEncodingException {
Map<String, String> params = new HashMap<String, String>(2);
params.put("s", "Wms+rkGG8jlaBBbpl8FIDxxNQGA=");
System.out.println(encodingParams(params, "utf-8"));
}

public static class HttpResult {
final public int code;
final public String content;
Expand Down
7 changes: 0 additions & 7 deletions common/src/main/java/com/alibaba/nacos/common/util/IoUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -162,12 +162,5 @@ public static byte[] tryDecompress(InputStream raw) throws Exception {
return null;
}

public static void main(String[] args) throws IOException {

// String path = "/Users/zhupengfei/test_write.txt";

// writeStringToFile(new File(path), "hello2222", "utf-8");
}

}

4 changes: 0 additions & 4 deletions common/src/main/java/com/alibaba/nacos/common/util/SystemUtil.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -45,10 +45,6 @@ public static String getSystemEnv(String key) {
return env;
}

public static void main(String[] args) throws SQLException {
System.out.println(Boolean.parseBoolean("Tfue"));
}

public static float getLoad() {
return (float) operatingSystemMXBean.getSystemLoadAverage();
}
Expand Down
68 changes: 0 additions & 68 deletions config/src/main/java/LogbackInitTest.java
View file

This file was deleted.

123 changes: 53 additions & 70 deletions config/src/main/java/com/alibaba/nacos/config/server/monitor/ResponseMonitor.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,78 +20,61 @@

/**
* Response Monitory
*
* @author Nacos
*
* @author Nacos
*/
public class ResponseMonitor {
static AtomicLong[] getConfigCountDetail = new AtomicLong[8];
static AtomicLong getConfigCount = new AtomicLong();
private static final int MS_50 = 50;
private static final int MS_100 = 100;
private static final int MS_200 = 200;
private static final int MS_500 = 500;
private static final int MS_1000 = 1000;
private static final int MS_2000 = 2000;
private static final int MS_3000 = 3000;
static AtomicLong[] getConfigCountDetail = new AtomicLong[8];
static AtomicLong getConfigCount = new AtomicLong();
private static final int MS_50 = 50;
private static final int MS_100 = 100;
private static final int MS_200 = 200;
private static final int MS_500 = 500;
private static final int MS_1000 = 1000;
private static final int MS_2000 = 2000;
private static final int MS_3000 = 3000;

static {
refresh();
}

public static void refresh() {
for (int i = 0; i < getConfigCountDetail.length; i++) {
getConfigCountDetail[i] = new AtomicLong();
}
}

public static void addConfigTime(long time) {
getConfigCount.incrementAndGet();
if (time < MS_50) {
getConfigCountDetail[0].incrementAndGet();
} else if (time < MS_100) {
getConfigCountDetail[1].incrementAndGet();
} else if (time < MS_200) {
getConfigCountDetail[2].incrementAndGet();
} else if (time < MS_500) {
getConfigCountDetail[3].incrementAndGet();
} else if (time < MS_1000) {
getConfigCountDetail[4].incrementAndGet();
} else if (time < MS_2000) {
getConfigCountDetail[5].incrementAndGet();
} else if (time < MS_3000) {
getConfigCountDetail[6].incrementAndGet();
} else {
getConfigCountDetail[7].incrementAndGet();
}
}

static{
refresh();
}

public static void refresh(){
for(int i = 0; i< getConfigCountDetail.length;i++){
getConfigCountDetail[i] = new AtomicLong();
}
}

public static void addConfigTime(long time){
getConfigCount.incrementAndGet();
if(time < MS_50){
getConfigCountDetail[0].incrementAndGet();
} else if(time < MS_100) {
getConfigCountDetail[1].incrementAndGet();
} else if (time < MS_200){
getConfigCountDetail[2].incrementAndGet();
} else if(time < MS_500){
getConfigCountDetail[3].incrementAndGet();
} else if(time < MS_1000){
getConfigCountDetail[4].incrementAndGet();
} else if(time < MS_2000){
getConfigCountDetail[5].incrementAndGet();
} else if(time < MS_3000){
getConfigCountDetail[6].incrementAndGet();
} else {
getConfigCountDetail[7].incrementAndGet();
}
}

public static String getStringForPrint(){
DecimalFormat df = new DecimalFormat("##.0");
StringBuilder s = new StringBuilder("getConfig monitor:\r\n");
s.append("0-50ms:" + df.format(getConfigCountDetail[0].getAndSet(0)*100/ getConfigCount.get())).append("%\r\n");
s.append("100-200ms:" + df.format(getConfigCountDetail[2].getAndSet(0)*100/ getConfigCount.get())).append("%\r\n");
s.append("200-500ms:" + df.format(getConfigCountDetail[3].getAndSet(0)*100/ getConfigCount.get())).append("%\r\n");
s.append("500-1000ms:" + df.format(getConfigCountDetail[4].getAndSet(0)*100/ getConfigCount.get())).append("%\r\n");
s.append("1000-2000ms:" + df.format(getConfigCountDetail[5].getAndSet(0)*100/ getConfigCount.get())).append("%\r\n");
s.append("2000-3000ms:" + df.format(getConfigCountDetail[6].getAndSet(0)*100/ getConfigCount.get())).append("%\r\n");
s.append("3000以上ms:" + df.format(getConfigCountDetail[7].getAndSet(0)*100/ getConfigCount.getAndSet(0))).append("%\r\n");
return s.toString();
}

public static void main(String[] args) {
ResponseMonitor.addConfigTime(10);
ResponseMonitor.addConfigTime(10);
ResponseMonitor.addConfigTime(10);
ResponseMonitor.addConfigTime(10);
ResponseMonitor.addConfigTime(100);
ResponseMonitor.addConfigTime(150);
ResponseMonitor.addConfigTime(250);
ResponseMonitor.addConfigTime(350);
ResponseMonitor.addConfigTime(750);
ResponseMonitor.addConfigTime(15000);
System.out.println(ResponseMonitor.getStringForPrint());
System.out.println(ResponseMonitor.getStringForPrint());

}
public static String getStringForPrint() {
DecimalFormat df = new DecimalFormat("##.0");
StringBuilder s = new StringBuilder("getConfig monitor:\r\n");
s.append("0-50ms:" + df.format(getConfigCountDetail[0].getAndSet(0) * 100 / getConfigCount.get())).append("%\r\n");
s.append("100-200ms:" + df.format(getConfigCountDetail[2].getAndSet(0) * 100 / getConfigCount.get())).append("%\r\n");
s.append("200-500ms:" + df.format(getConfigCountDetail[3].getAndSet(0) * 100 / getConfigCount.get())).append("%\r\n");
s.append("500-1000ms:" + df.format(getConfigCountDetail[4].getAndSet(0) * 100 / getConfigCount.get())).append("%\r\n");
s.append("1000-2000ms:" + df.format(getConfigCountDetail[5].getAndSet(0) * 100 / getConfigCount.get())).append("%\r\n");
s.append("2000-3000ms:" + df.format(getConfigCountDetail[6].getAndSet(0) * 100 / getConfigCount.get())).append("%\r\n");
s.append("3000以上ms:" + df.format(getConfigCountDetail[7].getAndSet(0) * 100 / getConfigCount.getAndSet(0))).append("%\r\n");
return s.toString();
}
}
4 changes: 0 additions & 4 deletions config/src/main/java/com/alibaba/nacos/config/server/utils/RegexParser.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -75,8 +75,4 @@ static public boolean containsWildcard(String regex) {
return (regex.contains("?") || regex.contains("*"));
}

public static void main(String[] args) {
String str = "com.taobao.uic.*";
System.out.println(str + " -> " + regexFormat(str));
}
}
14 changes: 6 additions & 8 deletions config/src/main/java/com/alibaba/nacos/config/server/utils/TimeUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,27 +15,25 @@
*/
package com.alibaba.nacos.config.server.utils;

import org.apache.commons.lang.time.FastDateFormat;

import java.sql.Timestamp;
import java.util.Calendar;
import java.util.Date;

import org.apache.commons.lang.time.FastDateFormat;
/**
* Time util
* @author Nacos
*
* @author Nacos
*/
public class TimeUtils {

public static Timestamp getCurrentTime() {
public static Timestamp getCurrentTime() {
Date date = new Date();
return new Timestamp(date.getTime());
}
public static void main(String[] args) {
System.out.println(getCurrentTime().toString());
}

static public String getCurrentTimeStr() {

static public String getCurrentTimeStr() {
Calendar c = Calendar.getInstance();
c.setTime(new Date());
c.get(Calendar.HOUR);
Expand Down
28 changes: 0 additions & 28 deletions core/src/main/java/com/alibaba/nacos/core/App.java
View file

This file was deleted.

7 changes: 0 additions & 7 deletions naming/src/main/java/com/alibaba/nacos/naming/core/Cluster.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -451,11 +451,4 @@ public void valid() {
}
}
}

public static void main(String[] args) {
String v1 = "nesttest";
if (v1.matches(CLUSTER_NAME_SYNTAX)) {
System.out.print("");
}
}
}
3 changes: 0 additions & 3 deletions naming/src/main/java/com/alibaba/nacos/naming/monitor/PerformanceLoggerThread.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -136,7 +136,4 @@ private long getAvgPushCost() {
}
return avgCost;
}

public static void main(String[] args) {
}
}
28 changes: 0 additions & 28 deletions test/src/main/java/com/alibaba/nacos/test/App.java
View file

This file was deleted.

15 changes: 0 additions & 15 deletions test/src/test/java/com/alibaba/nacos/test/naming/RandomUtils.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -263,21 +263,6 @@ public static boolean getBoolean() {
return getIntegerMoreThanZeroLessThan(3) == 1;
}

public static void main(String[] args) {
for(int t = 0; t < 20; ++t) {
Collection<Integer> arrs = getRandomCollection(1, 5, 5);
Iterator var3 = arrs.iterator();

while(var3.hasNext()) {
int i = (Integer)var3.next();
System.out.println(i);
}

System.out.println("----");
}

}

public static String getStringByUUID() {
return UUID.randomUUID().toString();
}
Expand Down

0 comments on commit a718c84

Please sign in to comment.