package com.example.controller;

import com.alibaba.fastjson.JSON;
import com.example.SpringbootRedisApplication;
import lombok.Data;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
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.context.ApplicationEvent;
import org.springframework.context.ApplicationEventPublisher;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.stereotype.Component;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

import java.util.Objects;

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = SpringbootRedisApplication.class)
@Slf4j
@EnableAsync
public class PublishEventDemo {
    /**
     * 事件機(jī)制：
     * 需要自定義一個(gè)事件類(lèi)繼承ApplicationEvent；
     * 需要自定義一個(gè)監(jiān)聽(tīng)器類(lèi)實(shí)現(xiàn)ApplicationListener接口，或普通類(lèi)的方法中使用@EventListener注解；
     * 使用默認(rèn)發(fā)布器ApplicationEventPublisher發(fā)布即可；
     * 事件類(lèi)不需要注入到IOC；監(jiān)聽(tīng)器需要注入到IOC；ApplicationEventPublisher用Autowired注入進(jìn)來(lái)即可；
     */


    /**
     * 事件發(fā)布器
     */
    @Autowired
    private ApplicationEventPublisher eventPublisher;

    /**
     * 測(cè)試類(lèi)
     */
    @Test
    public void publishTest() throws InterruptedException {
        Task task = new Task();
        task.setId(1L);
        task.setTaskName("測(cè)試任務(wù)");
        task.setTaskContext("任務(wù)內(nèi)容");
        task.setFinish(false);
        MyEvent event = new MyEvent(task);
        log.info("開(kāi)始發(fā)布任務(wù)");
        eventPublisher.publishEvent(event);
        //applicationContext.publishEvent(event);
        log.info("結(jié)束發(fā)布任務(wù)");
        Thread.sleep(10000);
    }
}

/**
 * 任務(wù)類(lèi)
 * 任務(wù)就是一個(gè)普通的類(lèi)，用來(lái)保存你要發(fā)布事件的內(nèi)容。這個(gè)沒(méi)有特殊限制，可以根據(jù)自己業(yè)務(wù)隨意設(shè)置。
 */
@Data
class Task {

    private Long id;

    private String taskName;

    private String taskContext;

    private boolean finish;
}

/**
 * 事件類(lèi)
 * 事件類(lèi)需要繼承org.springframework.context.ApplicationEvent，這樣發(fā)布的事件才能被Spring所識(shí)別
 */
@Slf4j
class MyEvent<T> extends ApplicationEvent {

    private Task task;

    public MyEvent(Task task) {
        super(task);
        this.task = task;
    }

    public Task getTask() {
        return task;
    }
}

/**
 * 事件監(jiān)聽(tīng)類(lèi)
 * 事件的監(jiān)聽(tīng)器需要實(shí)現(xiàn)org.springframework.context.ApplicationListener,并且需要注入到容器之中。
 */
@Component
@Slf4j
class MyEventListenerA implements ApplicationListener<MyEvent> {
    /**
     * 監(jiān)聽(tīng)方式1：實(shí)現(xiàn)ApplicationListener接口，重寫(xiě)onApplicationEvent方法
     * 需要使用Component注入IOC
     */
    @SneakyThrows
    @Async
    @Override
    public void onApplicationEvent(MyEvent MyEvent) {
        Thread.sleep(5000);
        if (Objects.isNull(MyEvent)) {
            return;
        }
        Task task = MyEvent.getTask();
        log.info("監(jiān)聽(tīng)器A接收任務(wù)：{}", JSON.toJSONString(task));
        task.setFinish(true);
        log.info("監(jiān)聽(tīng)器A此時(shí)完成任務(wù)");

    }
}

@Component
@Slf4j
class MyEventListenerB implements ApplicationListener<MyEvent> {
    /**
     * 監(jiān)聽(tīng)方式2：接口和注解混合使用
     * 但此時(shí) @EventListener不能與注解@Async在同一個(gè)類(lèi)中使用，會(huì)報(bào)錯(cuò)，至于為什么，不知道；
     * 需要使用Component注入IOC
     */
    //@Async//加上這個(gè)，@EventListener的方法就會(huì)報(bào)java.lang.IllegalStateException: Failed to load ApplicationContext
    @SneakyThrows
    @Override
    public void onApplicationEvent(MyEvent MyEvent) {
        Thread.sleep(1000);
        if (Objects.isNull(MyEvent)) {
            return;
        }
        Task task = MyEvent.getTask();
        log.info("監(jiān)聽(tīng)器B接收任務(wù)：{}", JSON.toJSONString(task));
        task.setFinish(true);
        log.info("監(jiān)聽(tīng)器B此時(shí)完成任務(wù)");
    }

    @EventListener
    public void someMethod(MyEvent event) throws InterruptedException {
        Thread.sleep(1000);
        log.info("監(jiān)聽(tīng)器@EventListenerB收到={}", event.getTask());
    }
}


@Component
@Slf4j
class MyEventListennerC {
    /**
     * 監(jiān)聽(tīng)方式3：注解@EventListener的監(jiān)聽(tīng)器不需要實(shí)現(xiàn)任何接口
     * 需要使用Component注入IOC
     */
    @EventListener
    public void someMethod(MyEvent event) throws InterruptedException {
        Thread.sleep(1000);
        log.info("監(jiān)聽(tīng)器@EventListenerC收到={}", event.getTask());
    }
}

package com.example.controller;

import ch.qos.logback.classic.Logger;
import com.example.SpringbootRedisApplication;
import lombok.ToString;
import lombok.extern.slf4j.Slf4j;
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.context.ApplicationContext;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ApplicationContextEvent;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import org.springframework.web.bind.annotation.RestController;

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = SpringbootRedisApplication.class)
@RestController
@Slf4j
public class PublishEventDemo2 {
    /**
     * 使用ApplicationContext發(fā)布事件
     */
    @Autowired
    ApplicationContext applicationContext;

    @Test
    public void send() {
        MyEvent2 myEvent2 = new MyEvent2(applicationContext);
        myEvent2.setData("數(shù)據(jù)");
        log.info("開(kāi)始發(fā)送事件");
        applicationContext.publishEvent(myEvent2);
        log.info("結(jié)束發(fā)送事件");
    }
}

/**
 * 監(jiān)聽(tīng)器類(lèi)
 */
@Slf4j
@Component
class MyEventListener2 implements ApplicationListener<MyEvent2> {
    @Override
    public void onApplicationEvent(MyEvent2 event) {
        log.info("監(jiān)聽(tīng)器MyEventListener2收到={}", event);
    }

    @EventListener
    public void someMethod(MyEvent2 event) {
        log.info("監(jiān)聽(tīng)器MyEventListener2@EventListener收到={}", event);
    }
}

/**
 * 監(jiān)聽(tīng)器類(lèi)
 */
@Slf4j
@Component
class MyEventListenner1 {
    @EventListener
    public void someMethod(MyEvent2 event) {
        log.info("監(jiān)聽(tīng)器MyEventListenner1收到={}", event);
    }
}

/**
 * 事件類(lèi)
 *
 * @param <T>
 */
@ToString
class MyEvent2<T> extends ApplicationContextEvent {
    private T data;

    public MyEvent2(ApplicationContext source) {
        super(source);
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }
}