专栏首页用户1337634的专栏事件中心 - 解耦核心业务与辅助功能

事件中心 - 解耦核心业务与辅助功能

随着业务的不断发展,原来融入在业务系统主流程中的辅助功能越来越多,每次增加新的逻辑,都要修改主干流程,比如发送微信服务号消息,发送邮件提醒等。 这种做法,让主干流程和辅助功能耦合太紧密,很容易在修改辅助功能的时候,导致主干流程的bug。本文介绍利用事件中心,让主干流程专注于业务核心,其他辅助功能会通过监听事件中心来实现,大大解耦了核心业务和辅助逻辑。

实现

  • 事件中心EventHub

事件中心,一般用来监听收集各种事件并分发给监听者列表.

/**
 * 事件中心,一般用来监听收集各种事件并分发给监听者列表.
 *
 * @author tenmao
 * @since 2019/12/12
 */
@Slf4j
public class EventHub<Event, Entity> {
    private final MdcThreadPoolExecutor mdcThreadPoolExecutor = MdcThreadPoolExecutor.newWithInheritedMdc(4, 16, 1, TimeUnit.MINUTES, new ArrayBlockingQueue<>(100));

    /**
     * 同步监听(一般可以用在事务一致性场景).
     */
    private Map<Event, Set<Consumer<Entity>>> syncListenerMap = new HashMap<>();

    /**
     * 异步监听.
     */
    private Map<Event, Set<Consumer<Entity>>> asyncListenerMap = new HashMap<>();


    /**
     * 注册同步监听器.
     *
     * @param event        事件
     * @param syncListener 同步监听器
     */
    public void subscribeSync(Event event, Consumer<Entity> syncListener) {
        Preconditions.checkNotNull(event);
        Preconditions.checkNotNull(syncListener);
        log.info("subscribeSync: event[{}], listener[{}]", event, syncListener);
        addListener(syncListenerMap, event, syncListener);
    }

    /**
     * 注册异步监听器.
     *
     * @param event         事件
     * @param asyncListener 异步监听器
     */
    public void subscribeAsyncListener(Event event, Consumer<Entity> asyncListener) {
        Preconditions.checkNotNull(event);
        Preconditions.checkNotNull(asyncListener);
        log.info("subscribeAsyncListener: event[{}], listener[{}]", event, asyncListener);
        addListener(asyncListenerMap, event, asyncListener);
    }

    private synchronized void addListener(Map<Event, Set<Consumer<Entity>>> map, Event event, Consumer<Entity> listener) {
        Set<Consumer<Entity>> consumers = map.get(event);
        if (consumers == null) {
            consumers = new HashSet<>();
            map.putIfAbsent(event, consumers);
        }
        consumers.add(listener);
    }


    /**
     * 发布事件.
     *
     * @param event  事件
     * @param entity 事件实体
     */
    public void publishEvent(Event event, Entity entity) {
        //订单状态变更
        log.info("publishEvent: event[{}], entity[{}]", event, entity);
        for (Consumer<Entity> consumer : syncListenerMap.get(event)) {
            consumer.accept(entity);
        }

        for (Consumer<Entity> asyncObserver : asyncListenerMap.get(event)) {
            mdcThreadPoolExecutor.execute(() -> {
                try {
                    asyncObserver.accept(entity);
                } catch (Exception e) {
                    log.warn("fail to finish listener for event: event[{}], entity[{}]", event, entity);
                }
            });
        }
    }
}
  • 为不同类型事件配置事件中心
/**
 * @author tenmao
 * @since 2019/12/12
 */
@Configuration
public class EventHubConfiguration {
    /**
     * 订单状态事件中心.
     */
    @Bean
    public EventHub<OrderStatus, Order> orderEventHub() {
        return new EventHub<>();
    }

    /**
     * 退款状态事件中心.
     */
    @Bean
    public EventHub<RefundStatus, Refund> refundEventHub() {
        return new EventHub<>();
    }
}

事件监听者

/**
 * 发送提醒消息.
 *
 * @author tenmao
 * @since 2019/12/12
 */
@Slf4j
@Component
public class EmailListener {
    @Resource
    private EmailRemoteManager EmailRemoteManager;

    @Resource
    private EventHub<OrderStatus, Order> orderEventHub;

    @PostConstruct
    private void init() {
        //监听多个不同的事件,监听到后会发送提醒消息
        orderEventHub.subscribeAsyncListener(OrderStatus.PAYED, this::handleOrderPayed);
        orderEventHub.subscribeAsyncListener(OrderStatus.ARRIVAL, this::handleOrderArrival);
    }

    private void handleOrderPayed(Order order) {
        //推送 Email
        EmailRequest EmailRequest = EmailRequest.build(order);
        EmailRemoteManager.sendEmail(EmailRequest);
    }

    private void handleOrderArrival(Order order) {
        //推送 Email
        EmailRequest EmailRequest = EmailRequest.build(order);
        EmailRemoteManager.sendEmail(EmailRequest);
    }
}

事件源

业务系统,比如订单系统中,会在不同的订单状态时,发送相应的订单事件.

@Slf4j
@Component
public class OrderManager {
    @Resource
    private EventHub<OrderStatus, Order> orderEventHub;

    public void payOrder(String orderNo) {
        //TODO 订单付款
        Order order = getOne(orderNo);
        orderEventHub.publishEvent(OrderStatus.PAYED, order);
    }

    public void orderArrival(String orderNo) {
        //TODO 订单到货
        Order order = getOne(orderNo);
        orderEventHub.publishEvent(OrderStatus.ARRIVAL, order);
    }
    //TODO 还有其他事件
}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 两次死锁的分析

    以上过程,因为S锁升级为X锁的时间间隔很短,所以不是很好复现,一般在高并发的时候出现。不过可以用3个事务来复现:

    十毛
  • CentOS设置代理

    /etc/yum.conf 最后添加一行Proxy=http://192.168.58.100:8080 (注意:在/etc/yum.repos.d下建立文...

    十毛
  • BTrace常用场景示例

    查看com.tim.BtraceCase#count耗时很长时的上下文:入参、成员变量等信息

    十毛
  • 事件对象的使用、属性和方法

    IT故事会
  • Event(事件)的传播与冒泡

    特性说明和原理图: 标准浏览器和Ie9+浏览器都支持事件的冒泡和捕获,而IE8-浏览器只支持冒泡 标准和Ie9+浏览器用stopPropagation()或c...

    sam dragon
  • Qt事件系统与应用举例

    在Qt中,事件都是从抽象类QEvent派生出来的对象。它们表示发生在应用程序内部或由于应用程序需要了解的外部活动而发生的事情。 事件可以由QObject子类的任...

    用户5908113
  • 屏蔽相应键盘按钮

     //屏蔽鼠标右键、Ctrl+N、Shift+F10、F11、F5刷新、退格键 //AuthorJavaScript ...

    Java架构师必看
  • Cypress web自动化16-参数化,数据驱动测试案例

    自动化测试里面参数化思想是非常重要的,同一类型的测试,只需维护不同的数据就可以了。 对每组测试数据自动生成对应的测试用例,并且每个测试用例的结果互不影响,不能因...

    上海-悠悠
  • React基础语法06-事件对象的应用

    老规矩,先看完官方文档,记录学习笔记: 教程:https://www.runoob.com/react/react-tutorial.html 文档:htt...

    王小婷
  • 屏蔽鼠标右键,F1帮助和常用快捷键

    源哥

扫码关注云+社区

领取腾讯云代金券