在SpringBoot中灵活使用异步事件的操作步骤

import org.springframework.context.ApplicationEvent;
public class UserRegisteredEvent extends ApplicationEvent {
    private final String username;
    private final String email;
    public UserRegisteredEvent(Object source, String username, String email) {
        super(source);
        this.username = username;
        this.email = email;
    }
    public String getUsername() {
        return username;
    }
    public String getEmail() {
        return email;
    }
}

import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;
@Component
public class UserRegistrationListener implements ApplicationListener<UserRegisteredEvent> {
    @Override
    public void onApplicationEvent(UserRegisteredEvent event) {
        System.out.println("Received user registration event for user: " + event.getUsername());
        // 在这里可以加入发送邮件、记录日志等处理逻辑
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
@Service
public class UserService {
    @Autowired
    private ApplicationEventPublisher publisher;
    public void registerUser(String username, String email) {
        // 执行用户注册逻辑
        System.out.println("User registered: " + username);
        // 发布注册事件
        UserRegisteredEvent event = new UserRegisteredEvent(this, username, email);
        publisher.publishEvent(event);
    }
}

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);
    }
}

import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;
@Component
public class UserRegistrationListener implements ApplicationListener<UserRegisteredEvent> {
    @Async
    @Override
    public void onApplicationEvent(UserRegisteredEvent event) {
        System.out.println("Received user registration event for user: " + event.getUsername());
        // 此处可以进行异步处理
    }
}