HAP_接口监控(注解)

作者: 灯下驼贼 | 来源:发表于2018-08-15 10:30 被阅读0次

HAP_接口监控(注解)
springboot系列——自定义注解
hystrix-dashboard只能监控带有@HystrixC
注解继承
Swagger
Java自定义注解实战
微服务架构（七）服务调用的监控
数据格式
Kotlin 高级编程语言特性代码实例
注解的反射

image.png

方法一：注解：

新建注解接口：

package wht.ora20796.aop;

import java.lang.annotation.*;

/**
 * Service注解
 */
@Inherited
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface ServiceAnnotation {
    String apiName() default "";
    String sysName() default "";
}

新建切面类监听注解接口：

image.png



package wht.ora20796.aop;

import com.fasterxml.jackson.databind.ObjectMapper;
import com.hand.hap.intergration.annotation.HapInbound;
import com.hand.hap.intergration.annotation.HapOutbound;
import com.hand.hap.intergration.aop.HapInvokeAspect;
import com.hand.hap.intergration.beans.HapInvokeInfo;
import com.hand.hap.intergration.beans.HapinterfaceBound;
import com.hand.hap.intergration.dto.HapInterfaceInbound;
import com.hand.hap.intergration.dto.HapInterfaceOutbound;
import com.hand.hap.intergration.util.HapInvokeLogUtils;
import com.hand.hap.message.IMessagePublisher;
import com.hand.hap.system.dto.ResponseData;
import net.sf.json.JSONObject;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Component;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpServletRequest;
import java.lang.reflect.Method;
import java.util.Date;

/**
* 切面类
*/
@Component
@Aspect  // 指定当前类为切面类
public class VendorAop {
  private static final Logger logger = LoggerFactory.getLogger(HapInvokeAspect.class);
  @Autowired
  private IMessagePublisher messagePublisher;
  @Autowired
  private ObjectMapper objectMapper;
  private Class interfaceHeaderServiceClazz;
  private Class interfaceHeaderClazz;
  private Object interfaceHeaderServiceImpl;

  public VendorAop() {
  }

  public void contextInitialized(ApplicationContext applicationContext) {
      try {
          this.interfaceHeaderServiceClazz = Class.forName("com.hand.hap.intergration.service.IHapInterfaceHeaderService");
          if (this.interfaceHeaderServiceClazz != null) {
              this.interfaceHeaderClazz = Class.forName("com.hand.hap.intergration.dto.HapInterfaceHeader");
              this.interfaceHeaderServiceImpl = applicationContext.getParentBeanFactory().getBean("hapInterfaceHeaderServiceImpl", this.interfaceHeaderServiceClazz);
          }
      } catch (Exception var3) {
          logger.debug("interface module class not found");
      }

  }
//    @HapOutbound
//    HapInvokeAspect hapInvokeAspect;
  //指定切入点表单式:拦截哪些方法：即为哪些类生成代理对象
 //@Pointcut("execution(* wht.ora20796.service.ISoapVendorService.*(..))")
  @Pointcut("@annotation(wht.ora20796.aop.ServiceAnnotation)")
  public void pointCut_() {
  }
  @Around("@annotation(bound)")
  public Object aroundMethod(ProceedingJoinPoint pjd, ServiceAnnotation bound) throws Throwable {
      System.out.println("-------------------注解监听------------------");
      Long startTime = System.currentTimeMillis();
      Object result = null;
      Throwable throwable = null;
      HapInterfaceOutbound outbound = new HapInterfaceOutbound();
      HapInvokeInfo.OUTBOUND.set(outbound);
      boolean var18 = false;

      HapinterfaceBound hapinterfaceBound;
      label165: {
          try {
              var18 = true;
              outbound.setRequestTime(new Date());
              Object[] args = pjd.getArgs();
              String sysName = null;
              String apiName = null;
              Object[] var10 = args;
              int var11 = args.length;

              for(int var12 = 0; var12 < var11; ++var12) {
                  Object obj = var10[var12];
                  if (obj instanceof HttpServletRequest) {
                      sysName = ((HttpServletRequest)obj).getParameter("sysName");
                      apiName = ((HttpServletRequest)obj).getParameter("apiName");
                  }
              }

              if (sysName == null && apiName == null) {
                  sysName = bound.sysName();
                  apiName = bound.apiName();
              }

              outbound.setInterfaceName(sysName + "-" + apiName);
              if (this.interfaceHeaderServiceClazz != null && this.interfaceHeaderClazz != null && this.interfaceHeaderServiceImpl != null) {
                  Method getHeaderAndLineMethod = this.interfaceHeaderServiceClazz.getMethod("getHeaderAndLine", String.class, String.class);
                  Object hapInterfaceHeaderObject = getHeaderAndLineMethod.invoke(this.interfaceHeaderServiceImpl, sysName, apiName);
                  if (hapInterfaceHeaderObject != null) {
                      Method getDomainUrl = this.interfaceHeaderClazz.getMethod("getDomainUrl");
                      Method getIftUrl = this.interfaceHeaderClazz.getMethod("getIftUrl");
                      outbound.setInterfaceUrl(getDomainUrl.invoke(hapInterfaceHeaderObject).toString() + getIftUrl.invoke(hapInterfaceHeaderObject).toString());
                  } else {
                      outbound.setInterfaceUrl(" ");
                  }
              }

              result = pjd.proceed();
              if (HapInvokeInfo.OUTBOUND_REQUEST_PARAMETER.get() != null) {
                  outbound.setRequestParameter((String)HapInvokeInfo.OUTBOUND_REQUEST_PARAMETER.get());
              }

              if (HapInvokeInfo.HTTP_RESPONSE_CODE.get() != null) {
                  outbound.setResponseCode(((Integer)HapInvokeInfo.HTTP_RESPONSE_CODE.get()).toString());
              }

              if (HapInvokeInfo.OUTBOUND_RESPONSE_DATA.get() != null) {
                  outbound.setResponseContent((String)HapInvokeInfo.OUTBOUND_RESPONSE_DATA.get());
              } else if (result != null) {
                  outbound.setResponseContent(result.toString());
              }

              outbound.setRequestStatus("success");
              HapInterfaceInbound inbound = (HapInterfaceInbound)HapInvokeInfo.INBOUND.get();
              if (inbound != null) {
                  if (inbound.getStackTrace() != null) {
                      outbound.setStackTrace(inbound.getStackTrace());
                      outbound.setRequestStatus("failure");
                  }

                  HapInvokeInfo.INBOUND.remove();
                  var18 = false;
              } else {
                  var18 = false;
              }
              break label165;
          } catch (Throwable var19) {
              throwable = var19;
              result = new JSONObject();
              ((JSONObject)result).put("error", var19.getMessage());
              var18 = false;
          } finally {
              if (var18) {
                  outbound.setResponseTime(System.currentTimeMillis() - startTime);
                  HapInvokeLogUtils.processExceptionInfo(outbound, throwable);
                   hapinterfaceBound = new HapinterfaceBound(outbound);
                  this.messagePublisher.message("invoke.service", hapinterfaceBound);
                  HapInvokeInfo.clearOutboundInfo();
              }
          }

          outbound.setResponseTime(System.currentTimeMillis() - startTime);
          HapInvokeLogUtils.processExceptionInfo(outbound, throwable);
          hapinterfaceBound = new HapinterfaceBound(outbound);
          this.messagePublisher.message("invoke.service", hapinterfaceBound);
          HapInvokeInfo.clearOutboundInfo();
          return result;
      }

      outbound.setResponseTime(System.currentTimeMillis() - startTime);
      HapInvokeLogUtils.processExceptionInfo(outbound, throwable);
      hapinterfaceBound = new HapinterfaceBound(outbound);
      this.messagePublisher.message("invoke.service", hapinterfaceBound);
      HapInvokeInfo.clearOutboundInfo();
      return result;
  }

  // 环绕通知：环绕目标方式执行
  /*@Around("@annotation(bound)")
  public void around(ProceedingJoinPoint pjp,ServiceAnnotation bound) throws Throwable {
      System.out.println("环绕前....");
      pjp.proceed();  // 执行目标方法
      System.out.println("环绕后....");
  }*/

  // 前置通知 : 在执行目标方法之前执行
/*  @Before("pointCut_()")
  public void begin() {
      System.out.println("-----------ISoapVendorService---------");
      System.out.println("开始事务/异常");

  }

  // 后置/最终通知：在执行目标方法之后执行  【无论是否出现异常最终都会执行】
  @After("pointCut_()")
  public void after() {
      System.out.println("-----------ISoapVendorService---------");
      System.out.println("提交事务/关闭");
  }*/
/*
  // 返回后通知： 在调用目标方法结束后执行 【出现异常不执行】
  @AfterReturning("pointCut_()")
  public void afterReturning() {
      System.out.println("afterReturning()");
  }

  // 异常通知： 当目标方法执行异常时候执行此关注点代码
  @AfterThrowing("pointCut_()")
  public void afterThrowing() {
      System.out.println("afterThrowing()");
  }
*/



}

给方法添加新建的注解：

image.png

测试：

image.png

方法二：（非注解）对ISoapVendorService.java中的方法继续切面增强

package wht.ora20796.aop;

import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.*;
import org.springframework.stereotype.Component;

/**
 * 切面类
 */
@Component
@Aspect  // 指定当前类为切面类
public class VendorAop {
    //指定切入点表单式:拦截哪些方法：即为哪些类生成代理对象
    @Pointcut("execution(* wht.ora20796.service.ISoapVendorService.*(..))")
    //@Pointcut("execution(* wht.ora20796.aop.UserDaoImpl.save(..))")
    public void pointCut_() {
    }

    // 前置通知 : 在执行目标方法之前执行
    @Before("pointCut_()")
    public void begin() {
        System.out.println("-----------ISoapVendorService---------");
        System.out.println("开始事务/异常");

    }

    /*// 后置/最终通知：在执行目标方法之后执行  【无论是否出现异常最终都会执行】
    @After("pointCut_()")
    public void after() {
        System.out.println("提交事务/关闭");
    }

    // 返回后通知： 在调用目标方法结束后执行 【出现异常不执行】
    @AfterReturning("pointCut_()")
    public void afterReturning() {
        System.out.println("afterReturning()");
    }

    // 异常通知： 当目标方法执行异常时候执行此关注点代码
    @AfterThrowing("pointCut_()")
    public void afterThrowing() {
        System.out.println("afterThrowing()");
    }

    // 环绕通知：环绕目标方式执行
    @Around("pointCut_()")
    public void around(ProceedingJoinPoint pjp) throws Throwable {
        System.out.println("环绕前....");
        pjp.proceed();  // 执行目标方法
        System.out.println("环绕后....");
    }*/


}

效果：

image.png

HAP_接口监控(注解)
方法一：注解：新建注解接口：新建切面类监听注解接口：给方法添加新建的注解：测试：方法二：（非注解）对IS...
springboot系列——自定义注解
项目需要实现对登录用户的实时监控，对用户部分相关操作进行埋点统计。这里我使用了自定义注解，对需要监控的接口使用注解...
hystrix-dashboard只能监控带有@HystrixC
在开发中发现如果标注@HystrixCommand注解，dashboard将会监控不到任何此接口的数据。
注解继承
接口注解不能被实现类继承。接口注解不能被子接口继承。父类接口能被子类接口继承，注解需要被@Inherited元注解...
Swagger
接口注解:@ApiOperation(value = "接口描述", notes = "") 接口类注解@Rest...
Java自定义注解实战
注解简介注解的本质是一个接口，该接口默认继承Annotation接口，使用@interface进行定义。注解主要...
微服务架构（七）服务调用的监控
服务调用的监控监控的对象，指标，维度监控的对象客户端监控：功能的监控接口的监控：接口调用情况的监控资源监...
数据格式
首页1 接口1：接口2：首页2 接口1：接口2：监控页-服务器接口1：接口2：筛选监控详情告警-...
Kotlin 高级编程语言特性代码实例
定义接口使用注解实现接口枚举类 enum class BizEnum 注解 annotation class...
注解的反射
我们用Annotation接口来描述注解这个东西，注解是一种特殊的接口，而接口是一种特殊的类所以注解可有抽象...