blob: 4cf8ec0240bbdb915823445e7e53033e9c046fdf (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
package cn.ac.iie.common;
import java.io.Serializable;
import org.apache.log4j.Logger;
import cn.ac.iie.bean.ConfigCompile;;
public class CommonService implements Serializable{
private static final long serialVersionUID = 6106510579752162633L;
private static Logger logger = Logger.getLogger(CommonService.class);
private static final Integer COMPILE_OPTION_NUMBER = 9;
public String[] splitMessageWithLogType(String message,String logType) {
Integer ZiYong_LOG_LENGTH = RealtimeCountConfig.LOG_COMMON_FIELD_NUM + HashTableConfig.LOG_SUB_OPTION_NUM_MAP.get(logType);
if(message!=null && !message.isEmpty()) {
String[] values = message.split(RealtimeCountConfig.LOG_STRING_SPLITTER);//分割符"\t"
if(values.length == ZiYong_LOG_LENGTH) {
return values;
} else {
logger.error(logType+"--->message length = " + values.length + " is illegal");//测试用
return null;
}
}
return null;
}
public ConfigCompile checkReplyFromRedis(String redisReply){
if(redisReply == null){
return null;
}
String[] str = redisReply.split("\t");
if(str.length == COMPILE_OPTION_NUMBER){
try{
ConfigCompile cc = new ConfigCompile(str);
if(cc.getSERVICE().equals(RealtimeCountConfig.EMPTY_OPTION_CHARACTER)){
logger.error("私有标签为空, 配置id为: "+ cc.getCOMPILE_ID());
return null;
}
return cc;
} catch (Exception e){
e.printStackTrace();
return null;
}
}else{
return null;
}
}
public ConfigCompile checkPz(String pzStr){
String[] str = pzStr.split("\t");
if(str.length == COMPILE_OPTION_NUMBER){
try{
ConfigCompile cc = new ConfigCompile(str);
if(cc.getSERVICE().equals(RealtimeCountConfig.EMPTY_OPTION_CHARACTER)){
logger.error("私有标签为空, 配置id为: "+ cc.getCOMPILE_ID());
return null;
}
return cc;
} catch (Exception e){
e.printStackTrace();
return null;
}
}else{
return null;
}
}
}
|
