監控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();
       }
   }