Spring Event 业务解耦神器(泛型喔!)

news2024/9/24 7:24:54

一.前言

又与我一直负责Cocos Creator的开发,我发现在TS领域,是可以自定义事件(有兴趣的大宝可以坐飞机直达:[CocosCreator]自定义事件(订阅/发布)管理器),这样做有什么好处呢?回答:解耦!

于是乎,我就觉得前端能干的事,后端也一样能干!当然,如果后端是TS或JS写的,比如nodeJS,那不必改造,直接照抄就行,奈何我后端使用的Java......

二.正文

既然是Java,那么既来之,则安之.首先考虑不自己造轮子,而是直接找Spring全家桶爸爸要,看爸爸有没有,我们直接拿来用就好了!

好消息是:爸爸还真有:Spring Event

坏消息是:不太好使!

假如我先定义一个事件基类:EventCustom

package com.zhcj.xzjh.event;

import lombok.AllArgsConstructor;
import lombok.Getter;

@Getter
@AllArgsConstructor
public class EventCustom<T> {

    private String eventName;
    private T eventObject;

}

我的想法是只要一个载体就足够完成所有的事件分发,那多好,所以我使用了泛型!

然后我写了个简单的测试类,发布事件



@Slf4j
@RestController
@RequestMapping("/system")
public class SystemController {

    @Autowired
    private ApplicationEventPublisher applicationEventPublisher;


    @GetMapping("/test")
    public Object test() {
        applicationEventPublisher.publishEvent(new EventCustom<>("hi", new UserInfo()));
        return map;
    }
}

接着写了一个简单的事件订阅类

package com.zhcj.xzjh.event;

import com.zhcj.xzjh.model.UserInfo;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

@Component
public class HiListener {


    // @Async
    @EventListener
    public void onUserUpdate(EventCustom<UserInfo> eventCustom) {
        System.out.println("UserListener:" + eventCustom.getEventObject().getId());
    }
}

你猜结果怎么着?能运行,不报错,但监听失败,或者说监听不到~ 于是乎,我就去官网寻宝了,还真找到了

简单翻译一下就是:通过泛型定义事件类型时，可以为事件传递不同的实体类型，例如 EntityCreatedEvent<Person> 只处理 Person 类型的事件。由于 Java 的类型擦除，监听器只能处理明确指定泛型类型的事件（如 PersonCreatedEvent）。为了解决这一局限性，可以实现 ResolvableTypeProvider，这样事件类可以提供其具体的泛型信息，帮助框架正确解析事件类型。这样不仅适用于 Person，还可以应用于其他任何对象类型的事件。

说人话就是:实现ResolvableTypeProvider就可以解决我们的问题!

既然找到答案,那么我就动手改造下吧:实现ResolvableTypeProvider接口,重写getResolvableType方法

package com.zhcj.xzjh.event;

import lombok.AllArgsConstructor;
import lombok.Getter;
import org.springframework.core.ResolvableType;
import org.springframework.core.ResolvableTypeProvider;

@Getter
@AllArgsConstructor
public class EventCustom<T>implements ResolvableTypeProvider {

    private String eventName;
    private T eventObject;

    @Override
    public ResolvableType getResolvableType() {
        return ResolvableType.forClassWithGenerics(getClass(), ResolvableType.forClass(eventObject.getClass()));
    }
}

然后测试: