springboot事件推送

蔚落 2023-02-21 06:22 15阅读 0赞

案例:用户注册成功之后往往会有额外的反复修改的不影响注册事件的事件,比如:发送短信/邮件/积分/优惠券等.上面这四种事件因注册事件的成功而发生,但是事件本身的成功与否不应该影响注册事件本身,而且这些事件在项目的整个周期中存在反复添加修改删除,所以这些事件与注册事件不应该耦合在一起.  
解决上面的问题除了采用MQ的方式外,spring提供了一种广播-监听的方式来实现.当注册事件成功之后,广播一天消息:xxx注册成功;众多监听者听到这条广播时,对这条广播有兴趣的会立刻回应,给XXX一张优惠券/给XXX200积分;当我们不需要发送注册积分的时候,只要解雇这个监听者或者让它对注册广播不感兴趣就行了.

事件模式中的几个概念

> 事件源:事件的触发者，比如上面的注册成功这个行为  
> 事件:描述发生了什么事情的对象，比如上面的:xxx注册成功的事件  
> 事件监听器:监听到事件发生的时候，做一些处理，比如上面的：积分监听者和优惠券监听者

实现步骤

//第一步定义事件
    //需要继承ApplicationEvent
    public class UserRegisterEvent extends ApplicationEvent { 
    
        private String userName;
    
        /** * 功能描述: 创建用户注册成功事件对象 * * @param source 事件源 * @Author: cy * @Date: 2020-06-29 10:17 * @Version 1.0 **/
        public UserRegisterEvent(Object source, String userName) { 
            super(source);
            this.userName = userName;
        }
    
        public String getUserName() { 
            return userName;
        }
    
    }
    //第二步定义监听器,这里使用了注解不要实现ApplicationListener接口实现onApplicationEvent方法
    @Component
    public class UserRegisterListener { 
    
        @EventListener//定义成事件监听
        public void sendEmail(UserRegisterEvent event) { 
            System.out.println(String.format("向[%s]发送注册邮件成功", event.getUserName()));
        }
    
        @EventListener
        @Order(3)//排序 无排序优先输出 有排序值越小越靠前
        public void sendMessage(UserRegisterEvent event) { 
            System.out.println(String.format("向[%s]发送注册短信成功", event.getUserName()));
        }
    
        @EventListener
        @Order(1)
        public void sendScore(UserRegisterEvent event) { 
            System.out.println(String.format("向[%s]发送注册积分成功", event.getUserName()));
        }
    
        @EventListener
        public void sendDiscountCoupon(UserRegisterEvent event) { 
            System.out.println(String.format("向[%s]发送注册优惠券成功", event.getUserName()));
        }
    }
    
    @Component
    public class UserService { 
    
        @Autowired
        private ApplicationEventPublisher publisher;
    
        public void userRegister() { 
        	//注册事件
            String userName = "张三";
            System.out.println(String.format("%s,注册成功", userName));
    		//广播
            publisher.publishEvent(new UserRegisterEvent(this, userName));
        }
    }
    
    //测试用例
    @RunWith(SpringRunner.class)
    @SpringBootTest
    class UserServiceTest { 
    
        @Autowired
        public ApplicationContext context;
    
        @Test
        void userRegister() { 
    
            UserService bean = context.getBean(UserService.class);
            bean.userRegister();
        }
    }