Spring中的观察者模式（发布订阅模式）（基于SpringBoot实现）

概述：

　　spring中的事件机制涉及到者几个类文件 ：ApplicationEvent(事件类型)、ApplicationListener（事件监听类）、ApplicationEventPublisher（事件发布类）。

　　ApplicationEvent：继承jdk Utill包中的 EventObject。

　　ApplicationListener ：接口继承了utill 包中的EventListener接口，泛型参数E必须继承ApplicationEvent类。

　　ApplicationEventPublisher： 事件发布接口 ，实现类很多，其中子类ApplicationContext，发布事件就用ApplicationContext类去发布。

举例：

　　在实际开发中，有一个这样的例子，当下单成功后会发送手机短信、发送绑定邮箱、微信、等

示例代码：

pom文件

　　<parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.9.RELEASE</version>
    </parent>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

定义事件：

/**
 * 定义订单事件
 */
public class OrderEvent extends ApplicationEvent {

    private String message;

    /**
     * Create a new ApplicationEvent.
     *
     * @param source the object on which the event initially occurred (never {@code null})
     */
    public OrderEvent(Object source, String message) {
        super(source);  //强制调用
        this.message = message;
    }

    @Override
    public Object getSource() {
        return super.getSource();
    }

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }
}

短信监听：

/**
 * 短信监听（异步执行）
 */
@Component
public class SmsListener implements ApplicationListener<OrderEvent> {


    private static final Logger logger = Logger.getLogger(SmsListener.class);

    @Override
    @Async  //异步
    public void onApplicationEvent(OrderEvent event) {
        System.out.println(Thread.currentThread() + "...短信监听到..." + event.getMessage()+ "......" + event.getSource());
    }
}

邮件监听：

/**
 * @Author zechuang
 * @Date 2019/8/21
 */
@Component
public class EmailListener implements ApplicationListener<OrderEvent> {

    private static final Logger logger = Logger.getLogger(EmailListener.class);
    
    @Override
    @Async
    public void onApplicationEvent(OrderEvent event) {
        System.out.println(Thread.currentThread() + "...邮件监听到..." + event.getMessage()+ "......" + event.getSource());
    }
}

springBoot启动类

@SpringBootApplication
@EnableAsync   //开启异步
public class MySpringBootApplication {

    public static void main(String[] args) {
        SpringApplication.run(MySpringBootApplication.class, args);
    }
}

测试：

@RunWith(SpringRunner.class)
@SpringBootTest(classes = MySpringBootApplication.class)
public class ObserverTest {

    @Autowired
    private ApplicationContext applicationContext;

    @Test
    public void test01(){
        OrderEvent order = new OrderEvent(this, "用户下单成功");
        applicationContext.publishEvent(order);
        System.out.println("....................over........................");
    }
}

测试结果：

....................over........................
Thread[SimpleAsyncTaskExecutor-1,5,main]...邮件监听到...用户下单成功......com.test.ObserverTest@19dd04d
Thread[SimpleAsyncTaskExecutor-2,5,main]...短信监听到...用户下单成功......com.test.ObserverTest@19dd04d