您可以在应用的业务日志中关联调用链的TraceId信息，从而在应用出现问题时，能够通过调用链的TraceId快速关联到业务日志，及时定位分析、解决问题。
背景信息
ARMS在业务日志中关联调用链TraceId的功能基于MDC（Mapped Diagnostic Context）机制实现，支持主流的Log4j、Log4j2和Logback日志框架。
开启关联业务日志与TraceId开关
登录ARMS控制台，在左侧导航栏选择应用监控 > 应用列表。
在应用列表页面顶部选择目标地域，然后单击目标应用名称。
在左侧导航栏中单击应用设置，并在右侧单击自定义配置页签。
在自定义配置页签的应用日志关联配置区域，选择日志源为日志服务，打开关联业务日志与TraceId开关，选择日志服务所在地域，然后绑定Project和Logstore。
说明
开启此开关后，业务日志中将会自动生成调用链的TraceId。
在您业务日志的Layout的Pattern属性中添加%X{EagleEye-TraceID}配置。
说明 如何在业务代码中获取{EagleEye-TraceID}，请参见ARMS SDK使用说明。
下面分别展示Log4j、Log4j2和Logback组件的示例配置文件：
Log4j配置文件log4j.properties的修改示例：
log4j.appender.warn.layout=org.apache.log4j.PatternLayout
log4j.appender.warn.layout.ConversionPattern=%-d{yyyy-MM-dd HH:mm:ss}-[%p]-(%C:%L) - traceId:%X{EagleEye-TraceID} - %m%n
Log4j2配置文件log4j2.xml的修改示例：
Logback配置文件logback.xml的修改示例：
重启应用。
在应用的业务日志中成功打印出TraceId信息，则说明业务日志关联调用链的TraceId关联成功，如下图所示。
用户自己的异步线程，这个是没有埋点的，需要按照这个文档配置一下包名
对于通过Spring @Async标签实现的异步任务，ARMS默认支持对其进行监控。此外，ARMS还支持通过添加异步透传扫描包和使用ARMS SDK进行手动透传对自定义异步任务实现监控。若您的异步任务出现接口超时等异常，可以通过调用链路查看异步任务上下游以便及时处理潜在问题。
前提条件
该功能要求ARMS探针版本为公测版本v2.7.1.3及以上。请联系ARMS钉钉服务账号arms160804，为您进行探针新版本升级。
方式一：默认支持Spring @Async标签
ARMS默认支持监控使用Spring @Async标签实现的异步任务。对于下列Spring框架中默认的Executor和Task，ARMS会自动完成增强：
Executor：
org.springframework.scheduling.concurrent.ConcurrentTaskExecutor
org.springframework.core.task.SimpleAsyncTaskExecutor
org.springframework.scheduling.quartz.SimpleThreadPoolTaskExecutor
org.springframework.core.task.support.TaskExecutorAdapter
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler
org.springframework.jca.work.WorkManagerTaskExecutor
org.springframework.scheduling.commonj.WorkManagerTaskExecutor
Task：
org.springframework.aop.interceptor.AsyncExecutionInterceptor$1
org.springframework.aop.interceptor.AsyncExecutionInterceptor$$Lambda$
方式二：添加异步透传扫描包
您可以选择在应用设置中添加异步透传扫描包实现异步任务监控。异步透传扫描包中的Runnable、Callable和Supplier接口在创建新对象时会自动捕获当前线程调用链的上下文，并在异步线程中执行时使用该调用链上下文，完成串联。
登录ARMS控制台。
在左侧导航栏，选择应用监控 > 应用列表。
在顶部菜单栏，选择地域。
在应用列表页面，单击应用名称。
在左侧导航栏，单击应用设置，然后单击自定义配置页签。
在高级设置区域的异步透传扫描包名对话框中，添加异步透传扫描包。
7、在页面底部，单击保存。
注意 配置后需重启应用才能使功能生效。如需添加多个异步透传扫描包，可以使用半角逗号（,）分隔。
例如，对于通过以下示例代码创建的异步任务，您可以使用添加异步透传扫描包的方式对此异步任务进行监控。此示例代码中，异步透传包名为com.alibaba.arms.brightroar.console.service。
注意 在配置时，您可以按需调整异步透传包名的范围。若需监控的异步任务过多，您可以缩小异步透传包名的范围。在本示例中，除了输入完整的异步透传包名com.alibaba.arms.brightroar.console.service以外，您还可以输入更短的前缀包名com.alibaba.arms来自动扫描此目录下的所有子透传包。但需注意的是，若前缀包名范围过大，会对性能产生影响，请谨慎操作。
package com.alibaba.arms.brightroar.console.service; //arms
@Service
public class NameService {
private ExecutorService es = Executors.newFixedThreadPool(5);
public void name() {
es.submit(new Runnable() {
@Override
public void run() {
System.out.println(System.currentTimeMillis()+ ": my name is john, " + Thread.currentThread().getId());
}
});
}
}
方式三：使用ARMS SDK手动透传
当您的使用方式比较复杂，上述场景无法满足需求时，您还可以选择使用ARMS SDK进行手动透传。通过手动增强Runnable接口、Callable接口和Executor，在异步线程中完成调用链串联，实现异步任务监控。
在Maven项目的pom.xml中添加以下依赖。
增强Runnable接口、Callable接口和Executor。您可以按需选择以下任意一种增强方式。
方式一：增强Runnable接口和Callable接口
使用TraceRunnable.asyncEntry()增强Runnable接口，使用TraceCallable.asyncEntry()增强Callable接口。示例代码如下：
public class AsyncEntryExample {
private final ExecutorService executor = Executors.newSingleThreadExecutor();
@GetMapping(value = "/sdk-async-plugin/asyncEntry-propagation")
public String asyncEntryAndExecute() throws Exception {
CompletableFuture
Runnable command = TraceRunnable.asyncEntry(() -> future.complete("asyncEntry-execute"));
executor.execute(command);
Thread.sleep(1000);
return future.get();
}
}
方式二：增强Executor
使用TraceExecutors.wrapExecutorService(executr, true)增强Executor。示例代码如下：
public class AutoExample {
private final ExecutorService contextPropagationExecutor
= TraceExecutors.wrapExecutorService(Executors.newSingleThreadExecutor(), true);
@GetMapping(value = "/sdk-async-plugin/auto-context-propagation")
public String autoWrapAndExecute() throws Exception {
CompletableFuture
contextPropagationExecutor.execute(() -> future.complete("auto-execute"));
Thread.sleep(1000);
return future.get();
}
}
方式三：同时增强Runnable接口、Callable接口和Executor
示例代码如下：
public class ManualExample {
private final ExecutorService traceExecutor
= TraceExecutors.wrapExecutorService(Executors.newSingleThreadExecutor());
@GetMapping(value = "/sdk-async-plugin/manual-context-propagation")
public String manualWrapAndExecute() throws Exception {
CompletableFuture
traceExecutor.execute(TraceRunnable.wrap(() -> future.complete("manual-execute")));
traceExecutor.execute(() -> "Not captured");
Thread.sleep(1000);
return future.get();
}
}
执行结果
配置完成后，您可以在调用链路详情页查看异步任务的调用链详情。具体详情，请参见调用链路查询。
https://help.aliyun.com/document_detail/158582.html
发表评论