多线程实现简单的事件异步处理框架

/**
 * 事件模型：用于表示个事件
 */
public class EventModel {
    /**
     * 事件类型，用于标识事件，同时在comsumer中根据这个值确定handler的具体实现类，一般可用一个枚举类型实现
     * 例如点赞通知对应的事件类型和注册发邮件进行激活的事件就应该属于不同的eventType，应该对应不同的handler实现类
     */
    private EventType eventType;
    /**
     * 事件触发者，例如用户A给用户B点赞，A就是时间触发者
     */
    private int actionId;/**
     * 事件发生对应的关联者，例如A给B点赞，A对应actionId,actionOwnerId
     */
    private int actionOwnerId;
    /**时间处理需要的额外的数据，采用map的方式可以保证程序的扩展性
     * 例如注册发送邮件的操作需要的数据和点赞通知需要的数据并不一样，所以用map存储最大程度地保证程序的灵活性
     */
    private Map<String,String> exts = new HashMap<>();

    /**
     * 注意序列化需要显式有一个无参构造函数
     */
    public EventModel(){

    }

    /**
     * getter 和setter，这部分省略
     */
   
}

/**
 * 事件生产者
 */
@Component
public class EventProducer {
    @Autowired
    private JedisEventHandlerAdaptor jedisEventHandlerAdaptor;
    @Autowired
    private JedisKeyUtil jedisKeyUtil;

    public void add(EventModel model){
        String modelJson = JSONObject.toJSONString(model);
        jedisEventHandlerAdaptor.add(jedisKeyUtil.getEventHandlerKey(),modelJson);
    }
}

/**
 * 事件处理类，该类负责调用handler，对事件进行处理，需要实现spring的两个接口，InitializingBean接口是初始化时自动注册handler要用；
 *ApplicationContextAware则是调用spring的applicationContext（该applicationContext中存储着handler具体实现类的bean对象）需要实现
 * 的接口，通过applicationContext获取handler对应的beans,然后就可以将handler自动注册到下面的config对象中了（是一个map)
 */
@Component
public class EventComsumer implements InitializingBean, ApplicationContextAware{
    private static final Logger logger = LoggerFactory.getLogger(MessageController.class);
    /**
     * threadPoolUtil封装了线程池的线程相关操作
     */
    @Autowired
    private ThreadPoolUtil threadPool;
    @Autowired
    private JedisEventHandlerAdaptor adaptor;
    /**
     * 这是一个与redis交互相关的工具类，用于获取特定的redis key，避免key冲突用，读者可以忽略
     */
    @Autowired
    private JedisKeyUtil jedisKeyUtil;
    /**
     * spring上下文对象，该对象存储着handler bean对象，必须通过setApplicationContext（ApplicationContextAware接口的实现方法）
     * 进行初始化，这样才能获取spring中的handler具体实现类的beans
     */
    private ApplicationContext applicationContext;
    /**设置消费函数阻塞时间，暂定为一天，redis阻塞list中必须要的参数，读者可以忽略
     */
    private static int COMSUME_TIMEOUT = 24*3600;
    /**
     * congif:该变量用于存储type和eventType的映射关系，在消费时，可以直接根据config中你的映射关系进行handler调用
     * 注意，这里为了保证程序的灵活性，eventHandler用一个list进行存储，因为有可能一个EventType事件类型可能对应多个
     * handler事件处理对象，例如点赞通知这个事件类型可能需要通知被点赞的人以及通知系统管理员，所以应该对应两个事件handler
     * 更具体的可以参考handler接口设计时的注释
     */
    Map<EventType,List<EventHandler>> config = new HashMap<>();

    /**
     * spring对该对象进行初始化的时候，将所有的handler具体对象注册到config对象中
     */
    @Override
    public void afterPropertiesSet() throws Exception {
　　　　//获取所有handler具体对象
        Map<String,EventHandler> beans = applicationContext.getBeansOfType(EventHandler.class);
　　　　//迭代注册handler对象
        for(Map.Entry<String,EventHandler> entry:beans.entrySet()){
            EventHandler handler = entry.getValue();
　　　　　　　//由于一个handler也可能对应多个事件类型，所以一个handler要注册到所有的eventType中去，这里如果看不懂可以结合后面的解释handler接口代码的注释进行理解
            for(EventType type:handler.getHandlerType()){
                if(config.get(type)==null){
                    config.put(type,new ArrayList<EventHandler>());
                }
                config.get(type).add(handler);
            }
        }
        //开线程调用消费函数，注意不能直接调用，否则会导致主线程阻塞
        threadPool.execute(new Runnable() {
            @Override
            public void run() {
                doConsume();
            }
        });
    }

    /**
     * 消费函数，用于执行handler
     */
    public void doConsume() {
        while(true){
            List<String> list = adaptor.pop(String.valueOf(COMSUME_TIMEOUT), jedisKeyUtil.getEventHandlerKey());
            //反序列化
            EventModel model = JSON.parseObject(list.get(1),EventModel.class);
            EventType type = model.getEventType();
            //获取事件的handler
            List<EventHandler> handlers = config.get(type);
            //执行handler
            for(EventHandler handler:handlers){
                handler.doHandler(model);
            }
        }
    }
    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        this.applicationContext = applicationContext;
    }
}

/**
 * 事件处理器：用于处理事件队列里面的事件，被eventConsumer调用
 * doHandler：model是具体的事件模型，它需要由调用者（一般是comsumer）传进来
 */
public interface EventHandler {
    public void doHandler(EventModel model);

    /**
     *
     * @return 表明该接口是什么类型的handler，list表明handler可以支持多个业务，也就是说，一个handler可以对应多个eventType
　　　*例如说，sendEmailHandler，邮件发送handler，具体业务例如注册激活的事件类型，点赞的发邮件通知时间类型都会需要这个handler，
　　　*所以一个handler是有必要对应多个eventType的，这里请读者务必理解，当初我也理解了挺久的。所以，具体handler实现类中必须有一个list变量来存储它对应的事件类型
     */
    public List<EventType> getHandlerType();

}