SpringBoot @FunctionalInterface注解的项目实战

// 1. 定义自定义事件
public class UserRegisteredEvent extends ApplicationEvent {
    private final String username;
    public UserRegisteredEvent(Object source, String username) {
        super(source);
        this.username = username;
    }
    public String getUsername() { return username; }
}

// 2. 定义函数式事件监听接口
@FunctionalInterface
public interface ApplicationEventListener<T extends ApplicationEvent> {
    void onApplicationEvent(T event);
}

// 3. 在服务中发布事件并使用函数式监听
@Service
public class UserService {
    private final List<ApplicationEventListener<UserRegisteredEvent>> listeners = new CopyOnWriteArrayList<>();
    @Autowired
    private ApplicationEventPublisher eventPublisher;

    // 提供注册监听器的方法
    public void addRegisterListener(ApplicationEventListener<UserRegisteredEvent> listener) {
        listeners.add(listener);
    }

    public void registerUser(String username, String email) {
        // ... 用户注册逻辑 ...
        System.out.println("用户注册成功: " + username);
        
        // 发布事件
        UserRegisteredEvent event = new UserRegisteredEvent(this, username);
        eventPublisher.publishEvent(event);
        
        // 通知所有自定义监听器
        listeners.forEach(listener -> {
            try {
                listener.onApplicationEvent(event);
            } catch (Exception e) {
                // 避免单个监听器异常影响其他监听器
            }
        });
    }
}

// 4. 在配置或控制器中注册监听逻辑
@Configuration
public class AppConfig {
    @Autowired
    private UserService userService;
    
    @Bean
    public CommandLineRunner setupListeners() {
        return args -> {
            // 使用Lambda表达式注册监听器，代码非常简洁
            userService.addRegisterListener(event -> {
                System.out.println("[监听器A] 发送欢迎邮件给: " + event.getUsername());
            });
            
            userService.addRegisterListener(event -> {
                System.out.println("[监听器B] 记录用户注册日志: " + event.getUsername());
            });
        };
    }
}

// 定义配置校验器接口
@FunctionalInterface
public interface ConfigValidator {
    boolean isValid(String configValue);
}

@Component
public class AppConfigService {
    private final Map<String, String> configMap = new HashMap<>();
    private final List<ConfigValidator> validators = new CopyOnWriteArrayList<>();

    // 注册校验器
    public void addValidator(ConfigValidator validator) {
        validators.add(validator);
    }

    @PostConstruct
    public void init() {
        // 添加一些内置校验器
        addValidator(value -> value != null && !value.trim().isEmpty()); // 非空校验
        addValidator(value -> value.length() >= 8); // 最小长度校验
    }

    public void updateConfig(String key, String value) {
        // 使用Stream API和函数式接口进行所有校验
        boolean allValid = validators.stream()
                                   .allMatch(validator -> validator.isValid(value));
        if (allValid) {
            configMap.put(key, value);
            System.out.println("配置已更新: " + key + " = " + value);
        } else {
            throw new IllegalArgumentException("配置值无效: " + value);
        }
    }
}

// 传统注解控制器方式
@RestController
@RequestMapping("/api/users")
public class UserController {
    @GetMapping
    public List<User> getUsers() { ... }
}

// 函数式端点定义方式 (WebFlux)
@Configuration
public class FunctionalRouter {
    @Bean
    public RouterFunction<ServerResponse> userRoutes(UserHandler userHandler) {
        return RouterFunctions.route()
                .GET("/api/users", request -> userHandler.getUsers())
                .build();
    }
}