Microservices Engine:Execute tarefas assíncronas para liberação canary de ponta a ponta do MSE

Pré-requisitos

É necessário utilizar o probe do MSE V3.2.0 ou superior (versão de prévia pública). Para atualizar o probe do MSE, participe do grupo DingTalk do MSE (ID: 43525005207).

Para consultar a versão do probe do MSE, execute o seguinte comando:

cat /home/admin/.opt/ArmsAgent/version

Método 1: Utilize a anotação @Async do Spring

Por padrão, o MSE suporta a propagação assíncrona de tags em tarefas criadas com a anotação @Async do Spring. O MSE aprimora automaticamente os seguintes executores e tarefas padrão do Spring:

• Executores:

  • 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

• Tarefas:

  org.springframework.aop.interceptor.AsyncExecutionInterceptor$1

  org.springframework.aop.interceptor.AsyncExecutionInterceptor$$Lambda$

Método 2: Adicione um pacote de varredura para passagem assíncrona

Em aplicações Java, adicione variáveis de ambiente ou parâmetros de inicialização Java para ativar a capacidade de passagem assíncrona de pacotes de varredura. Isso garante a propagação das tags de tráfego em tarefas assíncronas. As interfaces Runnable, Callable ou Supplier envolvidas capturam automaticamente o contexto do processo de chamada da thread atual no momento da criação de novos objetos. Ao utilizar threads em modo assíncrono, o contexto do processo de chamada viabiliza a propagação de ponta a ponta da tag de tráfego canary.

-Dprofiler.thread.match.package="com.alibaba.mse.brightroar.console.service"

Por exemplo, utilize um pacote de varredura para passagem assíncrona a fim de monitorar a tarefa assíncrona criada pelo código de amostra abaixo. O nome completo do pacote de varredura de amostra é com.alibaba.mse.brightroar.console.service.

package com.alibaba.mse.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());
            }
        });
    }
}