在业务开发中，可能会跟第三方平台做对接，比如我们使用了腾讯云的第三方的功能。这个时候很多功能需要业务方自己处理事件回调。腾讯云的实时音视频会给我们业务后台发送事件回调，比如包含了退出房间，进入房间等等。这个时候，有人会用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，结合上面部分思路自行改造