spring 事件使用

import lombok.Data;
import org.springframework.context.ApplicationEvent;

/**
 * 事件定义，这里监听MsgMessage消息对象
 */
@Data
public class MsgApplicationEvent extends ApplicationEvent {

    private MsgMessage message;

    public MsgApplicationEvent(Object source,MsgMessage message) {
        super(source);
        this.message=message;
    }
}

import com.alibaba.fastjson.JSON;
import org.springframework.context.event.EventListener;
import org.springframework.stereotype.Component;

/**
 * 事件监听，处理事件
 */
@Component
public class HandleEnvent {

    @EventListener(MsgApplicationEvent.class)
    public void handeEnvent(MsgApplicationEvent event){
        MsgMessage message= event.getMessage();
        System.out.println("消息处理事件...:"+ JSON.toJSONString(message));
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.stereotype.Service;

/**
 * 发布事件
 */
@Service
public class MsgPublishEvent {

    @Autowired
    ApplicationContext context;

    public void publishEvent(MsgMessage message){
        context.publishEvent(new MsgApplicationEvent(new Object(),message));
    }
}

  @Autowired
    private MsgPublishEvent msgPublishEvent;

    @GetMapping("/test")
    @ResponseBody
    public String test(){
        MsgMessage message=new MsgMessage();
        message.setTitle("hello");
        message.setMessage("我是个消息提示哦!");

        msgPublishEvent.publishEvent(message);

        return "success";
    }