mirror of
https://github.com/ctripcorp/zeus.git
synced 2024-09-22 00:26:05 +08:00
log
This commit is contained in:
fanqq
parent
2fbf654bc9
commit
d2018138a3
|
|
@ -17,4 +17,5 @@ public class AspectOrder {
|
|||
public static int CatReport = 3;
|
||||
public static int MessageReport = 1;
|
||||
public static int Authorization = 100;
|
||||
public static int Access = 150;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,87 @@
|
|||
package com.ctrip.zeus.service.aop.OperationLog;
|
||||
|
||||
import com.ctrip.zeus.access.AccessType;
|
||||
|
||||
import java.util.HashMap;
|
||||
|
||||
/**
|
||||
* Created by fanqq on 2015/7/16.
|
||||
*/
|
||||
public class OperationLogConfig {
|
||||
|
||||
private static HashMap<String,OpConf> config = new HashMap<>();
|
||||
private static OperationLogConfig logConfig = new OperationLogConfig();
|
||||
|
||||
private OperationLogConfig() {
|
||||
loadConfig();
|
||||
}
|
||||
|
||||
private void loadConfig(){
|
||||
config.put("ActivateResource.activateSlb",new OpConf(AccessType.SLB,new int[]{2,3}));
|
||||
config.put("ActivateResource.activateGroup",new OpConf(AccessType.GROUP,new int[]{2,3}));
|
||||
|
||||
config.put("DeactivateResource.deactivateGroup",new OpConf(AccessType.GROUP,new int[]{2,3}));
|
||||
|
||||
config.put("GroupResource.list",new OpConf(AccessType.GROUP,null,true));
|
||||
config.put("GroupResource.get",new OpConf(AccessType.GROUP,new int[]{2,3}));
|
||||
config.put("GroupResource.add",new OpConf(AccessType.GROUP,new int[]{-1,2}));
|
||||
config.put("GroupResource.update",new OpConf(AccessType.GROUP,new int[]{2}));
|
||||
config.put("GroupResource.delete",new OpConf(AccessType.GROUP,new int[]{2}));
|
||||
|
||||
config.put("SlbResource.list",new OpConf(AccessType.SLB,null,true));
|
||||
config.put("SlbResource.get",new OpConf(AccessType.SLB,new int[]{2,3}));
|
||||
config.put("SlbResource.add",new OpConf(AccessType.SLB,new int[]{-1,2}));
|
||||
config.put("SlbResource.update",new OpConf(AccessType.SLB,new int[]{2}));
|
||||
config.put("SlbResource.delete",new OpConf(AccessType.SLB,new int[]{2}));
|
||||
|
||||
config.put("ServerResource.upServer",new OpConf(AccessType.SERVER,new int[]{2}));
|
||||
config.put("ServerResource.downServer",new OpConf(AccessType.SERVER,new int[]{2}));
|
||||
config.put("ServerResource.upMember",new OpConf(AccessType.SERVER,new int[]{2,3}));
|
||||
config.put("ServerResource.downMember",new OpConf(AccessType.SERVER,new int[]{2,3}));
|
||||
|
||||
config.put("StatusResource.allGroupStatusInSlb",new OpConf(AccessType.SLB,new int[]{2,3}));
|
||||
config.put("StatusResource.groupStatus",new OpConf(AccessType.GROUP,new int[]{2,3}));
|
||||
}
|
||||
|
||||
public static OperationLogConfig getInstance(){return logConfig;}
|
||||
public AccessType getType(String key){
|
||||
OpConf tmp = config.get(key);
|
||||
if (tmp != null){
|
||||
return tmp.getType();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
public int[] getIds(String key){
|
||||
OpConf tmp = config.get(key);
|
||||
if (tmp != null){
|
||||
return tmp.getId();
|
||||
}
|
||||
return null;
|
||||
}
|
||||
public boolean getBatch(String key){
|
||||
OpConf tmp = config.get(key);
|
||||
if (tmp != null){
|
||||
return tmp.getBatch();
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
class OpConf{
|
||||
private AccessType type;
|
||||
private int[] id;
|
||||
private boolean batch;
|
||||
OpConf(AccessType _type , int[]_id , boolean _batch){
|
||||
type = _type;
|
||||
id = _id;
|
||||
batch = _batch;
|
||||
}
|
||||
OpConf(AccessType _type , int[]_id){
|
||||
type = _type;
|
||||
id = _id;
|
||||
batch = false;
|
||||
}
|
||||
protected int[] getId(){return id;}
|
||||
protected AccessType getType(){return type;}
|
||||
protected boolean getBatch(){return batch;}
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,16 @@
|
|||
package com.ctrip.zeus.service.aop.OperationLog;
|
||||
|
||||
/**
|
||||
* Created by fanqq on 2015/7/16.
|
||||
*/
|
||||
public enum OperationLogType {
|
||||
SLB,
|
||||
GROUP,
|
||||
SERVER;
|
||||
public String value() {
|
||||
return name();
|
||||
}
|
||||
public static OperationLogType fromValue(String v) {
|
||||
return valueOf(v);
|
||||
}
|
||||
}
|
||||
354
src/main/java/com/ctrip/zeus/service/aop/OperationLogAspect.java
Normal file
354
src/main/java/com/ctrip/zeus/service/aop/OperationLogAspect.java
Normal file
|
|
@ -0,0 +1,354 @@
|
|||
package com.ctrip.zeus.service.aop;
|
||||
|
||||
import com.ctrip.zeus.access.AccessType;
|
||||
import com.ctrip.zeus.model.entity.Group;
|
||||
import com.ctrip.zeus.model.entity.Slb;
|
||||
import com.ctrip.zeus.model.transform.DefaultJsonParser;
|
||||
import com.ctrip.zeus.model.transform.DefaultSaxParser;
|
||||
import com.ctrip.zeus.service.aop.OperationLog.OperationLogConfig;
|
||||
import com.ctrip.zeus.service.model.GroupRepository;
|
||||
import com.ctrip.zeus.service.model.SlbRepository;
|
||||
import com.netflix.config.DynamicBooleanProperty;
|
||||
import com.netflix.config.DynamicPropertyFactory;
|
||||
import org.aspectj.lang.JoinPoint;
|
||||
import org.aspectj.lang.ProceedingJoinPoint;
|
||||
import org.aspectj.lang.annotation.Around;
|
||||
import org.aspectj.lang.annotation.Aspect;
|
||||
import org.aspectj.lang.reflect.MethodSignature;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.core.Ordered;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import javax.annotation.Resource;
|
||||
import javax.servlet.http.HttpServletRequest;
|
||||
import javax.ws.rs.QueryParam;
|
||||
import javax.ws.rs.core.HttpHeaders;
|
||||
import javax.ws.rs.core.MediaType;
|
||||
import java.lang.annotation.Annotation;
|
||||
import java.lang.reflect.Method;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.ArrayList;
|
||||
import java.util.Date;
|
||||
import java.util.HashMap;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* Created by fanqq on 2015/7/15.
|
||||
*/
|
||||
@Aspect
|
||||
@Component
|
||||
public class OperationLogAspect implements Ordered {
|
||||
@Resource
|
||||
private GroupRepository groupRepository;
|
||||
@Resource
|
||||
private SlbRepository slbRepository;
|
||||
|
||||
private final static String QUERY_NAME_SLB_ID="slbId";
|
||||
private final static String QUERY_NAME_SLB_NAME="slbName";
|
||||
private final static String QUERY_NAME_GROUP_ID="groupId";
|
||||
private final static String QUERY_NAME_GROUP_NAME="groupName";
|
||||
private final static String ID_NEW="New";
|
||||
private final static String ID_UNKNOW="Unknow";
|
||||
private final static String ID_BATCH="Batch";
|
||||
|
||||
|
||||
private Logger logger = LoggerFactory.getLogger(this.getClass());
|
||||
|
||||
private DynamicBooleanProperty enableAccess = DynamicPropertyFactory.getInstance().getBooleanProperty("log.access.enable", true);
|
||||
|
||||
@Around("execution(* com.ctrip.zeus.restful.resource.*Resource.*(..))")
|
||||
public Object interceptException(ProceedingJoinPoint point) throws Throwable {
|
||||
if (!enableAccess.get()){
|
||||
return point.proceed();
|
||||
}
|
||||
|
||||
MethodSignature signature = (MethodSignature)point.getSignature();
|
||||
Method method = signature.getMethod();
|
||||
String key = point.getTarget().getClass().getSimpleName()+"."+method.getName();
|
||||
|
||||
Object[] args = point.getArgs();
|
||||
HttpServletRequest request = findRequestArg(point);
|
||||
if (request==null){
|
||||
return point.proceed();
|
||||
}
|
||||
Annotation[][] annotations = method.getParameterAnnotations();
|
||||
HttpHeaders hh = findHttpHeaders(point);
|
||||
|
||||
String type = OperationLogConfig.getInstance().getType(key).value();
|
||||
String id = findId(key,request,args,point,hh);
|
||||
String op = method.getName();
|
||||
String userName = request.getRemoteUser();
|
||||
String remoteAddr = request.getRemoteAddr();
|
||||
HashMap<String,String>data = findData(key,request,args,hh,method);
|
||||
SimpleDateFormat simpleDateFormat = new SimpleDateFormat ("yyyy-MM-dd-hh:mm:ss");
|
||||
String date = simpleDateFormat.format(new Date());
|
||||
Object response = null;
|
||||
String errMsg = null;
|
||||
boolean success = false;
|
||||
|
||||
try{
|
||||
response = point.proceed();
|
||||
}catch (Throwable throwable){
|
||||
errMsg = throwable.getMessage();
|
||||
throw throwable;
|
||||
}finally {
|
||||
logger.info("type:"+type);
|
||||
logger.info("id:"+id);
|
||||
logger.info("op:"+op);
|
||||
logger.info("userName:"+userName);
|
||||
logger.info("remoteAddr:"+remoteAddr);
|
||||
logger.info("data:"+data.toString());
|
||||
logger.info("date:"+date);
|
||||
logger.info("errMsg:"+errMsg);
|
||||
if (response!=null){
|
||||
success=true;
|
||||
}
|
||||
logger.info("success:"+success);
|
||||
}
|
||||
return response;
|
||||
}
|
||||
@Override
|
||||
public int getOrder() {
|
||||
return AspectOrder.Access;
|
||||
}
|
||||
private HttpServletRequest findRequestArg(JoinPoint point) {
|
||||
Object[] args = point.getArgs();
|
||||
for (Object arg : args) {
|
||||
if (arg instanceof HttpServletRequest){
|
||||
return (HttpServletRequest)arg;
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
private HttpHeaders findHttpHeaders(JoinPoint point){
|
||||
Object[] args = point.getArgs();
|
||||
for (Object arg : args) {
|
||||
if (arg instanceof HttpHeaders){
|
||||
return (HttpHeaders)arg;
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
private String findId(String key,HttpServletRequest request ,Object[] args ,JoinPoint point,HttpHeaders hh) throws Exception {
|
||||
//1. Batch is true, return "Batch"
|
||||
if (OperationLogConfig.getInstance().getBatch(key)){
|
||||
return ID_BATCH;
|
||||
}
|
||||
// find by config ids
|
||||
int[]ids = OperationLogConfig.getInstance().getIds(key);
|
||||
for (int i : ids)
|
||||
{
|
||||
//2. if id is out of range , return New
|
||||
if (i<0||i>=args.length)
|
||||
{
|
||||
return ID_NEW;
|
||||
}
|
||||
//3. if request Method is Post , Parse post data to get id
|
||||
if (request.getMethod().equals("POST")&&null!=args[i])
|
||||
{
|
||||
// 3.1 httpHeaders is null , Can not parse post data;
|
||||
if (null == hh){
|
||||
return ID_UNKNOW;
|
||||
}
|
||||
// 3.2 type is AccessType.SLB , parse data to Slb object.
|
||||
if (OperationLogConfig.getInstance().getType(key)==AccessType.SLB){
|
||||
Slb slb = parseSlb(hh.getMediaType(),(String)args[i]);
|
||||
if (slb == null){
|
||||
return ID_UNKNOW;//"Slb Parse Fail";
|
||||
}
|
||||
return slb.getId()!=null?String.valueOf(slb.getId()):slb.getName();
|
||||
}
|
||||
// 3.3 type is AccessType.GROUP , parse data to Group object.
|
||||
if (OperationLogConfig.getInstance().getType(key)==AccessType.GROUP){
|
||||
Group group = parseGroup(hh.getMediaType(),(String)args[i]);
|
||||
if (group == null){
|
||||
return ID_UNKNOW;//"Group Parse Fail";
|
||||
}
|
||||
return group.getId()!=null?String.valueOf(group.getId()):group.getName();
|
||||
}
|
||||
return ID_UNKNOW;
|
||||
}
|
||||
// 4. if method is GET , find id from args. Type Long comes first.
|
||||
if (null!=args[i])
|
||||
{
|
||||
String name = null;
|
||||
if (args[i] instanceof String)
|
||||
{
|
||||
name = (String)args[i];
|
||||
}
|
||||
if (args[i] instanceof Long)
|
||||
{
|
||||
return String.valueOf((Long)args[i]);
|
||||
}
|
||||
if (args[i] instanceof List<?>)
|
||||
{
|
||||
List tmp = (List)args[i];
|
||||
if (tmp.size()>1){
|
||||
return ID_BATCH;
|
||||
}else if (tmp.size()==1){
|
||||
if (tmp.get(0) instanceof String){
|
||||
name=(String)tmp.get(0);
|
||||
}else {
|
||||
return tmp.get(0).toString();
|
||||
}
|
||||
}
|
||||
}
|
||||
if (OperationLogConfig.getInstance().getType(key)==AccessType.GROUP&&name!=null)
|
||||
{
|
||||
Group group =groupRepository.get(name);
|
||||
return group==null?name:String.valueOf(group.getId());
|
||||
}else if (OperationLogConfig.getInstance().getType(key)==AccessType.SLB&&name!=null){
|
||||
Slb slb =slbRepository.get(name);
|
||||
return slb==null?name:String.valueOf(slb.getId());
|
||||
}else if (name!=null){
|
||||
return name;
|
||||
}
|
||||
}
|
||||
}
|
||||
return ID_UNKNOW;
|
||||
}
|
||||
private HashMap<String,String> findData(String key , HttpServletRequest request ,Object[] args ,HttpHeaders hh,Method method) throws Exception {
|
||||
HashMap<String,String>data = new HashMap<>();
|
||||
int[] ids = OperationLogConfig.getInstance().getIds(key);
|
||||
if (ids==null||ids.length<=0){
|
||||
return data;
|
||||
}
|
||||
Annotation[][] annotations = method.getParameterAnnotations();
|
||||
//1. request Method is Post, data should be Name and Version
|
||||
if (request.getMethod().equals("POST")){
|
||||
//1.1 in case of New
|
||||
if (ids.length>0&&(ids[0]<0||ids[0]>=args.length))
|
||||
{
|
||||
data.put("SlbVersion","1");
|
||||
if (ids.length>=2&&args[ids[1]] instanceof String)
|
||||
{
|
||||
String postData = (String)args[ids[1]];
|
||||
if (OperationLogConfig.getInstance().getType(key)==AccessType.SLB&&hh!=null){
|
||||
Slb slb = parseSlb(hh.getMediaType(),postData);
|
||||
if (slb==null){
|
||||
data.put("Slb","Slb Parse Fail!");
|
||||
}else {
|
||||
data.put("SlbName",String.valueOf(slb.getName()));
|
||||
}
|
||||
|
||||
}else if (OperationLogConfig.getInstance().getType(key)==AccessType.GROUP&&hh!=null){
|
||||
Group group = parseGroup(hh.getMediaType(),postData);
|
||||
if (group==null){
|
||||
data.put("Group","Group Parse Fail!");
|
||||
}else{
|
||||
data.put("GroupName",String.valueOf(group.getName()));
|
||||
}
|
||||
}
|
||||
}
|
||||
return data;
|
||||
}
|
||||
//1.2 in case of update
|
||||
Object obj = args[ids[0]];
|
||||
String tmp = null;
|
||||
if (obj instanceof String){
|
||||
tmp=(String)obj;
|
||||
}else {
|
||||
data.put("errMsg",ids[0]+"'st argument is not String");
|
||||
return data;
|
||||
}
|
||||
if (OperationLogConfig.getInstance().getType(key)==AccessType.SLB&&hh!=null){
|
||||
Slb slb = parseSlb(hh.getMediaType(),tmp);
|
||||
if (slb==null){
|
||||
data.put("Slb","Slb Parse Fail!");
|
||||
}else {
|
||||
data.put("SlbName",String.valueOf(slb.getName()));
|
||||
data.put("Version",String.valueOf(slb.getVersion()));
|
||||
}
|
||||
|
||||
}else if (OperationLogConfig.getInstance().getType(key)==AccessType.GROUP&&hh!=null){
|
||||
Group group = parseGroup(hh.getMediaType(),tmp);
|
||||
if (group==null){
|
||||
data.put("Group","Group Parse Fail!");
|
||||
}else{
|
||||
data.put("GroupName",String.valueOf(group.getName()));
|
||||
data.put("Version",String.valueOf(group.getVersion()));
|
||||
}
|
||||
}
|
||||
return data;
|
||||
}else {
|
||||
//2. request method is GET, get data from QueryString
|
||||
String tmpKey = null;
|
||||
for (int i=0; i < args.length;i++)
|
||||
{
|
||||
if (annotations[i][0] instanceof QueryParam){
|
||||
//1. get queryParam Names
|
||||
tmpKey = ((QueryParam)annotations[i][0]).value();
|
||||
//2. queryParam Names equals QUERY_NAME_GROUP_ID , must be groupId.
|
||||
if (tmpKey.equalsIgnoreCase(QUERY_NAME_GROUP_ID)&&args[i]!=null) {
|
||||
if (args[i] instanceof Long) {
|
||||
Group group = groupRepository.getById((Long)args[i]);
|
||||
data.put(AccessType.GROUP.value(),group!=null?group.getName():args[i].toString()+"[id not found]");
|
||||
}
|
||||
if (args[i] instanceof List) {
|
||||
List list = (List)args[i];
|
||||
List<String> groupNames = new ArrayList<>();
|
||||
for (Object groupId : list){
|
||||
Group group = groupRepository.getById((Long)groupId);
|
||||
groupNames.add(group!=null?group.getName():groupId.toString()+"[id not found]");
|
||||
}
|
||||
if (groupNames.size()>0) {
|
||||
data.put(AccessType.GROUP.value(), groupNames.toString());
|
||||
}
|
||||
}
|
||||
}else if (tmpKey.equalsIgnoreCase(QUERY_NAME_SLB_ID)&&args[i]!=null) {
|
||||
if (args[i] instanceof Long) {
|
||||
Slb slb = slbRepository.getById((Long)args[i]);
|
||||
data.put(AccessType.SLB.value(),slb!=null?slb.getName():args[i].toString()+"[id not found]");
|
||||
}
|
||||
if (args[i] instanceof List) {
|
||||
List list = (List)args[i];
|
||||
List<String> slbNames = new ArrayList<>();
|
||||
for (Object slbId : list){
|
||||
Slb slb = slbRepository.getById((Long)slbId);
|
||||
slbNames.add(slb!=null?slb.getName():slbId.toString()+"[id not found]");
|
||||
}
|
||||
if (slbNames.size()>0){
|
||||
data.put(AccessType.SLB.value(),slbNames.toString());
|
||||
}
|
||||
}
|
||||
}else if (args[i]!=null){
|
||||
if (args[i] instanceof List&&((List)args[i]).size()>0||args[i] instanceof Long){
|
||||
data.put(tmpKey,args[i].toString());
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
return data;
|
||||
}
|
||||
}
|
||||
|
||||
private Group parseGroup(MediaType mediaType, String group) {
|
||||
Group g;
|
||||
try{
|
||||
if (mediaType.equals(MediaType.APPLICATION_XML_TYPE)) {
|
||||
g = DefaultSaxParser.parseEntity(Group.class, group);
|
||||
} else {
|
||||
g = DefaultJsonParser.parse(Group.class, group);
|
||||
}
|
||||
}catch (Exception e) {
|
||||
logger.warn("Group Parse Fail!");
|
||||
return null;
|
||||
}
|
||||
return g;
|
||||
}
|
||||
private Slb parseSlb(MediaType mediaType, String slb) {
|
||||
Slb s;
|
||||
try{
|
||||
if (mediaType.equals(MediaType.APPLICATION_XML_TYPE)) {
|
||||
s = DefaultSaxParser.parseEntity(Slb.class, slb);
|
||||
} else {
|
||||
s = DefaultJsonParser.parse(Slb.class, slb);
|
||||
}
|
||||
}catch (Exception e) {
|
||||
logger.warn("Slb Parse Fail!");
|
||||
return null;
|
||||
}
|
||||
return s;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in a new issue