设计模式学习笔记(3)——观察者模式

1. 个人文章统计总数+1
2. 个人积分数+n
3. 关注者消息推送+1
4. 分类推送添加..

@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public  class User {
    private Integer userId;
    private String userName;
}

/**
 * <p color="orange">
 * 基础事件发布类
 * </p>
 *
 * @author BookSea
 * @date 2022/2/2 17:45
 */
public abstract class BaseEvent<T> extends ApplicationEvent {
    /**
     * 该类型事件携带的信息
     */
    private T eventData;
    /**
     *
     * @param source 最初触发该事件的对象
     * @param eventData 该类型事件携带的信息
     */
    public BaseEvent(Object source, T eventData) {
        super(source);
        this.eventData = eventData;
    }
    public T getEventData() {
        return eventData;
    }
}

public class UserEvent  extends BaseEvent<User>{
    public UserEvent(Object source, User user) {
        super(source,user);
    }
}

@Slf4j
@Service
public class UserListener {
    /*
     * @Async加了就是异步监听,没加就是同步
     * 可以使用@Order定义监听者顺序，默认是按代码书写顺序
     * 如果返回类型不为void,则会被当成一个新的事件,再次发布
     * @EventListener注解在EventListenerMethodProcessor类被扫描
     * 可以使用SpEL表达式来设置监听器生效的条件
     * 监听器可以看做普通方法,如果监听器抛出异常,在publishEvent里处理即可
     */
    //@Async
    @Order(1)
    @EventListener(condition = "#userEvent.getEventData().getUserName().equals('小明')")
    public String lister1(UserEvent userEvent){
       User user =userEvent.getEventData();
        System.out.println(user.toString());
        return "小米";
    }
    @Async
    @Order(2)
    @EventListener
    public void lister3(UserEvent userEvent){
        System.out.println("监听者2");
    }
    @Async
    @Order(3)
    @EventListener
    public void lister2(String name){
        System.out.println("我叫："+name);
    }
}

@Resource
private ApplicationEventPublisher applicationEventPublisher;
applicationEventPublisher.publishEvent(new UserEvent(this, new User(1, "小明")));