使用ARMS监控异步任务

监控Spring @Async标签实现的异步任务

添加异步透传扫描包

您可以选择在应用设置中添加异步透传扫描包实现异步任务监控。异步透传扫描包中的Runnable、Callable和Supplier接口在创建新对象时会自动捕获当前线程调用链的上下文，并在异步线程中执行时使用该调用链上下文，完成串联。

1. 登录ARMS控制台，在左侧导航栏选择应用监控 > 应用列表。

2. 在应用列表页面顶部选择目标地域，然后单击目标应用名称。

   说明

   语言列显示图标的应用为接入应用监控的应用，显示-图标的应用为接入可观测链路 OpenTelemetry 版的应用。

3. 在左侧导航栏，单击应用设置，然后单击自定义配置页签。

4. 在高级设置区域的异步透传扫描包名对话框中，添加异步透传扫描包。

   

5. 在页面底部，单击保存。

package com.alibaba.arms.brightroar.console.service;

@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，在异步线程中完成调用链串联，实现异步任务监控。

1. 在Maven项目的pom.xml中添加以下依赖。

   <dependency>
    <groupId>com.alibaba.arms.apm</groupId>
    <version>1.7.5</version>
    <artifactId>arms-sdk</artifactId>
   </dependency>

2. 增强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<String> future = new CompletableFuture<>();
           Runnable command = TraceRunnable.asyncEntry(() -> future.complete("asyncEntry-execute"));
           executor.execute(command);
           Thread.sleep(1000);
           return future.get();
       }
   }

   方式二：增强Executor

   使用TraceExecutors.wrapExecutorService(executor, 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<String> future = new 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<String> future = new CompletableFuture<>();
           traceExecutor.execute(TraceRunnable.wrap(() -> future.complete("manual-execute")));
           traceExecutor.execute(() -> "Not captured");
           Thread.sleep(1000);
           return future.get();
       }
   }