Spring Boot集成Guava EventBus并注入Bean

最新推荐文章于 2025-05-02 23:07:36 发布

mt23

最新推荐文章于 2025-05-02 23:07:36 发布

阅读量2.9k

点赞数 2

CC 4.0 BY-SA版权

分类专栏： # 后端开发文章标签： eventbus guava

本文链接：https://blog.csdn.net/mathcoder23/article/details/108793655

本文介绍了如何在Spring Boot应用中集成Guava EventBus，实现事件的解耦和灵活传递。通过基础类的设计，如IEventBus、AbstractSpringEventBus和IEventConsumer，简化了生产者和消费者的实现。Guava EventBus作为事件的枢纽，处理线程、限流等。文中提供了具体的代码实践，展示了如何在业务中创建事件总线、投递消息以及定义消费者。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

前言

基于事件总线的方式开发，可以使我们代码更加简洁，而且解耦
Guava的EventBus是个轻量级的事件总线，而且事件间可以相互隔离，所以更加灵活多变
本文不讲EventBus的具体功能，只考虑应用场景

目标

在Spring中集成Guava的EventBus，并友好的注入Bean
消费者只需要实现接口，即可接收事件消息
生产者只需要关心消息的生产
事件总线只需要关心生产投递与消息消费的线程、限流等问题

事件总线介绍

概览图

在这里插入图片描述
从上面的事件流图我们可以看到，事件总线是生产者与消费者的枢纽，
我们按照这样的方式，使生产者和消费者解耦，这也是我们为什么要选择事件总线的原因。而且还有重要的是，整个流程被划分成了三块：生成者、消费者、事件枢纽。每一块有只专注自己该干的事。当然这其实就是消息队列，比如其中的限流功能、过滤器功能等等。但我们在轻量级架构使用轻量级的消息队列就好，没必要直接就来Rocket、Rabbit、Kafka。

代码实践

这是我定义的三个基础类，为我们集成到Spring 打下基础

基础类

IEventBus

顶级事件管理接口，提供消费者订阅、事件投递


/**
 * @author pettyfox
 * @version 1.0
 * @date 2020/9/25 11:57
 */
public interface IEventBus {
   
   
    /**
     * 发布事件
     * @param event 事件实体
     */
    void post(Object event);

    /**
     * 添加消费者
     * @param obj 消费者对象，默认以class为key
     */
    void addConsumer(Object obj);

    /**
     * 移除消费者
     * @param obj 消费者对象，默认以class为key
     */
    void removeConsumer(Object obj);

    /**
     * 扫描消费者
     * @param packageName 扫描包
     */
    void scanConsumer(String packageName);
}

AbstractSpringEventBus

这个抽象类是Guava EventBus和Spring的桥梁，当然严格来讲是子类实现与Spring的桥梁

import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;