在SpringBoot中实现Java异步编程

在Spring Boot中实现Java异步编程有多种方法，这里将介绍两种常用的方法：使用@Async注解和使用CompletableFuture

1. 使用@Async注解

@Async是Spring提供的一个注解，用于声明一个方法是异步的。要使用@Async，请按照以下步骤操作：

步骤1：在Spring Boot的主类或者配置类上添加@EnableAsync注解，以启用异步支持。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableAsync;

@SpringBootApplication
@EnableAsync
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

步骤2：创建一个服务类，并在需要异步执行的方法上添加@Async注解。

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

@Service
public class AsyncService {

    @Async
    public void asyncMethod() {
        System.out.println("异步方法开始执行");
        try {
            Thread.sleep(3000); // 模拟耗时操作
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("异步方法执行完毕");
    }
}

步骤3：在需要调用异步方法的地方，直接调用该方法。由于方法上已经添加了@Async注解，所以Spring会自动为该方法创建一个新的线程并执行。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class AsyncController {

    @Autowired
    private AsyncService asyncService;

    @GetMapping("/async")
    public String async() {
        asyncService.asyncMethod();
        return "异步方法已调用";
    }
}

2. 使用CompletableFuture

CompletableFuture是Java 8引入的一个类，用于表示异步计算的结果。要使用CompletableFuture，请按照以下步骤操作：

步骤1：创建一个服务类，并在需要异步执行的方法上返回CompletableFuture对象。

import org.springframework.stereotype.Service;

import java.util.concurrent.CompletableFuture;

@Service
public class AsyncService {

    public CompletableFuture<String> asyncMethod() {
        System.out.println("异步方法开始执行");
        CompletableFuture<String> future = new CompletableFuture<>();

        // 模拟耗时操作
        new Thread(() -> {
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            future.complete("异步方法执行完毕");
        }).start();

        return future;
    }
}

步骤2：在需要调用异步方法的地方，使用CompletableFuture的thenAccept方法处理异步计算的结果。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class AsyncController {

    @Autowired
    private AsyncService asyncService;

    @GetMapping("/async")
    public String async() {
        asyncService.asyncMethod().thenAccept(result -> {
            System.out.println("异步方法执行完毕，结果：" + result);
        });
        return "异步方法已调用";
    }
}

以上就是在Spring Boot中实现Java异步编程的两种方法。使用@Async注解的方法更简单，适用于大多数场景；而使用CompletableFuture则提供了更多的功能和灵活性，适用于更复杂的场景。