在业务开发中，可能会跟第三方平台做对接，比如我们使用了腾讯云的第三方的功能。这个时候很多功能需要业务方自己处理事件回调。腾讯云的实时音视频会给我们业务后台发送事件回调，比如包含了退出房间，进入房间等等。这个时候，有人会用if到底的方式，比如
@PostMapping("xxx")
public void callback(Event e) {
if (e.eventType == 1) {
//todo something
}
else if (e.eventType == 2) {
//todo something
}
}
这么写也没问题，很多小公司小团队的要求就是能跑通，需求方能看到结果。但如果这么写的话，后面突然改版的话，需要处理其他事件，那么就需要继续加if else，从代码的质量上看很难看，可扩展性也很糟糕。其实这个时候可以通过加入设计模式处理各种不同事件。
1、先定义一个抽象的事件处理器
public abstract class AbstractEventHandler<T extends TrtcEventParam> {
/**
* 获取事件类型
*
* @return
*/
public abstract Integer getEventType();
/**
* 处理事件
*
* @param t
*/
public abstract void HandlerEvent(T t);
}
2、实现一个具体的事件处理器，这里比如处理退出房间事件
@Slf4j
@Component
public class ExitRoomEventHandler extends AbstractEventHandler<TrtcEventParam> {
@Override
public Integer getEventType() {
return RoomEvent.EventType.EVENT_TYPE_EXIT_ROOM;
}
@Autowired
private ApplicationContext applicationContext;
@Override
public void HandlerEvent(TrtcEventParam param) {
if (StringUtils.startsWith(param.getEventInfo().getUserId(), properties.getUserIdPrefix())) {
//这里使用了spring的事件发布机制，用来进一步增加可扩展性
applicationContext.publishEvent(new ExitRoomEvent(this, param));
}
}
事件定义
public class ExitRoomEvent extends ApplicationEvent {
@Getter
private TrtcEventParam param;
public ExitRoomEvent(Object source, TrtcEventParam param) {
super(source);
this.param = param;
}
}
3、定义一个简单工厂，当初始化bean时把bean放入一个map中，并对外提供根据事件码获取对应处理器的的方法
@Component
public class EventHandlerFactory implements InitializingBean, ApplicationContextAware {
private static final Map<Integer, AbstractEventHandler<TrtcEventParam>> EVENT_HANDLER_MAP = new HashMap<>();
private ApplicationContext applicationContext;
public AbstractEventHandler<TrtcEventParam> getHandler(Integer eventType) {
return EVENT_HANDLER_MAP.get(eventType);
}
@Override
public void afterPropertiesSet() throws Exception {
applicationContext.getBeansOfType(AbstractEventHandler.class).values()
.forEach(handler -> EVENT_HANDLER_MAP.put(handler.getEventType(), handler));
}
@Override
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
this.applicationContext = applicationContext;
}
4、在处理回调的controller中调用
@PostMapping("/room/event/callback")
R execute(@RequestBody String body) {
...
AbstractEventHandler handler = eventHandlerFactory.getHandler(param.getEventType());
Optional.ofNullable(handler).ifPresent(h -> h.HandlerEvent(param));
...
}
5、在Observer中中监听事件通知
@Slf4j
@Component
public class ExitRoomEventObservers {
//程序员1自己的业务
@Order(1)
@EventListener(ExitRoomEvent.class)
public void method1(ExitRoomEvent event) {
...
}
//程序员2自己的业务
@Order(2)
@EventListener(ExitRoomEvent.class)
public void method2(ExitRoomEvent event) {
...
}
//后来新增的业务处理
@Order(3)
@EventListener(ExitRoomEvent.class)
public void method3(ExitRoomEvent event) {
...
}
}
通过上述改造，如果后面需要增加新的事件处理时，加入新的事件处理器，并且发布事件就可以实现处理新增业务。当然，如果需要处理的业务跨了服务或者比较多的时候，还是建议使用mq，结合上面部分思路自行改造
