core中提供了可序列化的網(wǎng)絡傳輸載體對象：ContextCarrier，同時ContextManager提供了兩個方法來支持ContextCarrier的注入和解壓

• inject 將當前上下文注入到ContextCarrier對象
• extract 將ContextCarrier對象解壓到當前上下文

而ContextCarrier的傳遞方式是不同插件根據(jù)實際組件自己實現(xiàn)的，比如：

• Fegin調(diào)用(Http)時是通過把ContextCarrier放到請求頭實現(xiàn)的
• Dubbo調(diào)用時是通過Dubbo框架提供的附件傳遞的
• Kafka是通過消息的形式傳遞的(todo 這里待細看)

以Fegin調(diào)用為例，F(xiàn)egin發(fā)起調(diào)用的客戶端攔截器是：DefaultHttpClientInterceptor

@Override
public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
                         MethodInterceptResult result) {
    // 創(chuàng)建載體
    ContextCarrier contextCarrier = new ContextCarrier(); 
    // 創(chuàng)建出口span，內(nèi)部執(zhí)行了inject方法注入載體
    AbstractSpan span = ContextManager.createExitSpan(operationName, contextCarrier, remotePeer);
    ...
    // 獲取上下文信息的每一項
    CarrierItem next = contextCarrier.items();
    while (next.hasNext()) {
        next = next.next();
        List<String> contextCollection = new ArrayList<String>(1);
        contextCollection.add(next.getHeadValue());
        // 加入請求的header中
        headers.put(next.getHeadKey(), contextCollection);
    }
    ...
}

對應的服務端一般是spring的@RequestMapping接口，對應的攔截器是RequestMappingMethodInterceptor

@Override
public void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
                         MethodInterceptResult result) throws Throwable {

    ...
    // 創(chuàng)建載體
    final ContextCarrier contextCarrier = new ContextCarrier();
    // http請求
    final HttpServletRequest httpServletRequest = (HttpServletRequest) request;
    CarrierItem next = contextCarrier.items();
    // 循環(huán)上下文信息的每一項
    while (next.hasNext()) {
        next = next.next();
        // 從header中獲取對應項，裝載到載體上
        next.setHeadValue(httpServletRequest.getHeader(next.getHeadKey()));
    }
    // 內(nèi)部調(diào)用extract，將載體解壓到上下文
    AbstractSpan span = ContextManager.createEntrySpan(operationName, contextCarrier);
}

插件定義

AbstractClassEnhancePluginDefine

skywalking-agent的插件首先要有一個類增強插件定義，skywalking-agent抽象出插件定義的規(guī)范：AbstractClassEnhancePluginDefine，各插件要給出具體實現(xiàn)，同時skywalking-agent-core情況有進一步抽象了兩種實現(xiàn)

• ClassInstanceMethodsEnhancePluginDefine 針對類實例攔截定義
• ClassStaticMethodsEnhancePluginDefine 針對靜態(tài)方法攔截定義

ClassInstanceMethodsEnhancePluginDefine

ClassInstanceMethodsEnhancePluginDefine，是針對對類實例的一種增強插件定義的抽象，插件通過繼承它可以實現(xiàn)對實例的攔截，只需實現(xiàn)如下方法：

/**
 * 需要被攔截Class
 * @return
 */
@Override
protected ClassMatch enhanceClass() {
    return null;
}

/**
 * 構造器切點，可以是多個
 * @return 
 */
@Override
public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
    return new ConstructorInterceptPoint[0];
}

/**
 * 方法切點，可以是多個
 * @return InstanceMethodsInterceptPoint
 */
@Override
public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
    return new InstanceMethodsInterceptPoint[0];
}

ClassMatch用來匹配類，agent-core提供如下常用API來實現(xiàn)類匹配

• NameMatch.byName 根據(jù)名稱匹配
• ClassAnnotationMatch.byClassAnnotationMatch 根據(jù)類注解匹配
• MethodAnnotationMatchbyMethodAnnotationMatch 根據(jù)類中方法注解匹配
• HierarchyMatch.byHierarchyMatch 根據(jù)父類或?qū)崿F(xiàn)接口匹配

ConstructorInterceptPoint和InstanceMethodsInterceptPoint下面介紹

ClassStaticMethodsEnhancePluginDefine

針對靜態(tài)方法攔截定義，繼承者需實現(xiàn)

/**
 * 構造器切點，可以是多個
 * @return 
 */
@Override
public ConstructorInterceptPoint[] getConstructorsInterceptPoints() {
    return new ConstructorInterceptPoint[0];
}

/**
 * 方法切點，可以是多個
 * @return InstanceMethodsInterceptPoint
 */
@Override
public InstanceMethodsInterceptPoint[] getInstanceMethodsInterceptPoints() {
    return new InstanceMethodsInterceptPoint[0];
}

ConstructorInterceptPoint和InstanceMethodsInterceptPoint下面介紹

InstanceMethodsInterceptPoint

無論是實例還是靜態(tài)方法，都需要InstanceMethodsInterceptPoint數(shù)組來進行方法切點和攔截器，主要包含如下屬性

public interface InstanceMethodsInterceptPoint {
    /**
     * 方法的匹配
     */
    ElementMatcher<MethodDescription> getMethodsMatcher();

    /**.
     *  返回一個攔截器全類名，所有攔截器必須實現(xiàn)InstanceMethodsAroundInterceptor 接口
     */
    String getMethodsInterceptor();

    /**
     * 是否要覆蓋原方法入?yún)?     */
    boolean isOverrideArgs();
}

其中指定的攔截器都需要實現(xiàn)InstanceMethodsAroundInterceptor接口

InstanceMethodsAroundInterceptor

具體的攔截代碼，主要實現(xiàn)如下方法

public interface InstanceMethodsAroundInterceptor {
    /**
     * 前置處理
     */
    void beforeMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        MethodInterceptResult result) throws Throwable;

    /**
     * 后置處理
     */
    Object afterMethod(EnhancedInstance objInst, Method method, Object[] allArguments, Class<?>[] argumentsTypes,
        Object ret) throws Throwable;

    /**
     * 異常處理
     */
    void handleMethodException(EnhancedInstance objInst, Method method, Object[] allArguments,
        Class<?>[] argumentsTypes, Throwable t);
}

ConstructorInterceptPoint

與InstanceMethodsInterceptPoint基本差不多，只不過針對的是構造方法

總結

插件的開發(fā)基本就是對skywalking-agent-core定義的一些抽象的具體實現(xiàn)，最總打成jar包，放入plugins目錄，插件即可生效

注：插件的resources目錄中一定要添加skywalking-plugin.def文件，內(nèi)容是

{name}={增強插件定義全路徑名}

可以是多個，以springmvc舉例如下

spring-mvc-annotation-5.x=org.apache.skywalking.apm.plugin.spring.mvc.v5.define.ControllerInstrumentation
spring-mvc-annotation-5.x=org.apache.skywalking.apm.plugin.spring.mvc.v5.define.RestControllerInstrumentation

同時skywalking-agent-core提供豐富的api用于插件攔截后的上報，詳見skywalking上報和采集