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