架构实战篇(十五):Spring Boot 解耦之事件驱动

程序那点儿事 2018-09-04 14:19:37 ⋅ 172 阅读

通过使用spring 事件来解决业务代码的耦合

下面通过一个下单的业务代码,拆解为使用事件驱动的方式开发

原始的业务代码

package com.itunion.example.service;

import com.itunion.example.domain.Order;
import com.itunion.example.mapper.OrderMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class OrderServiceImpl {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private EmailServiceImpl emailService;

    // 下单
    @Transactional
    public void placeOrder(Order order) {
        // 保存订单
        orderMapper.save(order);

        // 发送邮件通知
        emailService.sendEmail(order);
    }
}

这里有个下单接口,首先保存订单到数据库,然后发送邮件通知给客户

思考:如果某一段时间邮件服务器挂了,那是不是就下不了单了?
如果后续业务变化需要在下单之后增加其他逻辑,是不是需要修改代码

为了不影响下单我们需要把发送邮件解耦出来

引入事件发布对象

package com.itunion.example.service;

import com.itunion.example.domain.Order;
import com.itunion.example.mapper.OrderMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class OrderServiceImpl {

    @Autowired
    private OrderMapper orderMapper;
    @Autowired
    private ApplicationEventPublisher publisher;

    // 下单
    @Transactional
    public void placeOrder(Order order) {
        // 保存订单
        orderMapper.save(order);

        // 发布下单事件
        publisher.publishEvent(order);
    }
}

删除了邮件的依赖和发送邮件的方法
这里我们引入了 ApplicationEventPublisher 对象,用来发布下单事件

发布总要有接收处理事件的地方

接收并处理事件

package com.itunion.example.service;

import com.itunion.example.domain.Order;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Service;

@Service
public class EmailServiceImpl {

    public void sendEmail(Order order) {
        System.out.println("发送邮件到: " + order.getUserName().toLowerCase());
    }

    @EventListener
    public void placeOrderNotice(Order order) {
        sendEmail(order);
    }

}

sendEmail 是原本的发送邮件方法,增加一个 placeOrderNotice 方法,并加上@EventListener 注解,这样只要是Order 类型的消息都会到这个方法里来,然后调用原本的发送邮件方法

运行

package com.itunion.example;

import com.itunion.example.domain.Order;
import com.itunion.example.service.OrderServiceImpl;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
public class SpringBootEventApplicationTests {

    @Autowired
    private OrderServiceImpl orderService;

    @Test
    public void placeOrder() {
        Order order = new Order();
        order.setUserName("张三");
        order.setGoodsName("iphone X");
        orderService.placeOrder(order);
    }

}

编写一个单元测试运行一下

正常业务都执行了

模拟异常

    @Test
    public void placeOrder() {
        Order order = new Order();
        order.setUserName(null);
        order.setGoodsName("iphone X");
        orderService.placeOrder(order);
    }

单元测试的用户名设置为空,让邮件输出调用toLowerCase方法是报错

邮件报错,订单事务回滚了!这不是我们期望的结果呀

那能不能让我们的方法异步执行呢?答案肯定是可以的

开启异步执行

@EnableAsync
@SpringBootApplication
public class SpringBootEventApplication {

在我们的启动类上增加一个 @EnableAsync 注解

    @EventListener
    @Async
    public void placeOrderNotice(Order order) {
        sendEmail(order);
    }

在下单事件处理的方法上增加 @Async 异步调用注解

当我们再次执行的时候单元测试执行通过了,但是控制台打印了邮件发送失败的消息,订单也入库了,说明符合我们的逾期结果

仔细看日志打印了一个

[cTaskExecutor-1] .a.i.SimpleAsyncUncaughtExceptionHandler 

说明spring 是通过一个默认的线程池执行了这个发送邮件的方法,@Async 其实也支持指定你自己配置的线程池的

自定义线程池

 @Bean
    public ThreadPoolTaskExecutor myExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(5);
        executor.setMaxPoolSize(50);
        return executor;
    }

增加自定义线程池配置 myExecutor ,然后运行查看日志发现输出如下内容

2018-09-04 13:55:34.597 ERROR 7072 --- [   myExecutor-1]

说明已经在使用我们配置的线程池了

也可以增加多个 @EventListener 方法对下单做一连串的后续操作

当有多个下单处理的时候可以使用 @org.springframework.core.annotation.Order 注解来设置执行顺序

完整的项目结构

关注我们



全部评论: 0

    我有话说:

    架构实战七):Spring Boot Assembly 整合 thymeleaf

    如何让服务器上的 sprig boot 项目升级变的方便快捷

    架构实战三):Spring Boot Logback 邮件通知

    日志对于应用程序来说是非常重要的,当你的程序报错了,而你又不知道是多么可怕的一件事情,本文使用logback把程序报错信息邮件到开发者

    架构实战一):Spring Boot 集成企业级搜索引擎 SolrCloud

    Solr是以Lucene为基础实现的文本检索应用服务。Solr部署方式有单机方式、多机Master-Slaver方式、Cloud方式。

    架构实战(三)-Spring Boot架构搭建RESTful API案例

    之前分享了Spring Boot 整合Swagger 让API可视化和前后端分离架构 受到了大家一致好评 ,本节就接着上节的代码做了详细的查询代码的补充和完善并搭建RESTful API架构案例。

    架构实战(七):Spring Boot Data JPA 快速入门

    Spring Data JPA 是Spring Data 的一个子项目,它通过提供基于JPA的Repository极大了减少了操作JPA的代码。

    架构实战(六):Spring Boot RestTemplate的使用

    RestTemplate是Spring提供的用于访问Rest服务的客户端,RestTemplate提供了多种便捷访问远程Http服务的方法,能够大大提高客户端的编写效率。

    架构实战四):Spring Boot 多缓存实战

    多场景下的不同缓存策略解决方案

    架构实战(一)-Spring Boot+MyBatis基础架构搭建

    Spring的追求一定是简单点简单点,让java的开发变得更加简单、容易。瞧瞧的告诉你们直接copy就能用哦~~~

    架构实战):Spring Boot 集成 Dubbo

    Dubbo是阿里巴巴SOA服务化治理方案的核心框架,一个分布式服务框架,致力于提供高性能和透明化的RPC远程服务调用方案。

    微服务架构实战(六):Spring boot2.x 集成阿里大鱼短信接口详解与Demo

    Spring boot2.x 集成阿里大鱼短信接口,发送短信验证码及短信接口详解。

    架构实战):Spring Boot 表单验证和异常处理

    为了让API 能够更好的提供服务,表单数据验证和异常的处理是必不可少的,让我们来看看怎么处理......

    架构实战二):Spring Boot 分布式Session共享Redis

    分布式Web网站一般都会碰到集群session共享问题,小编整理了一套解决方案,内附GitHub 源码地址哦~~~

    架构实战六):Spring Boot Assembly服务化打包

    使用assembly来打包springboot微服务项目,让发布更简单

    码云推荐:一个优秀的分布式spring boot/Spring Cloud API限流框架,特别适合微服务架构

    一个优秀的分布式spring boot/Spring Cloud API限流框架,特别适合微服务架构.

    架构实战(九):Spring Boot 集成 RocketMQ

    快速集成阿里开源消息队列 RocketMQ

    微服务架构学习笔记:gRPC Spring Boot Starter 2.2.0 发布,及使用步骤

    gRPC Spring Boot Starter 项目是一个 gRPC 的 Spring Boot 模块。内嵌一个 gRPC Server 对外提供服务,并支持 Spring Cloud 的服务发现