在线做c 题的网站,淮安网站建设价格,大流量网站开发,湘潭做网站价格 d磐石网络简单的说#xff0c;观察者模式#xff0c;就类似于 广播站发送广播#xff0c;和收音机的关系。多个收音机去收听同一个广播频道。 在实际的业务场景中#xff0c;可以是这样的。创建订单成功后#xff0c;发布事件。然后减库存。发送短信。调用微信。调用物流服务。等多… 简单的说观察者模式就类似于 广播站发送广播和收音机的关系。多个收音机去收听同一个广播频道。 在实际的业务场景中可以是这样的。创建订单成功后发布事件。然后减库存。发送短信。调用微信。调用物流服务。等多个后续业务都去监听同一个事件。 定义一个事件。 package com.study.design.observer.spring;import org.springframework.context.ApplicationEvent;/*** 定义事件*/public class OrderEvent extends ApplicationEvent {public OrderEvent(Object source) {super(source);}
} 定义事件发布器 package com.study.design.observer.spring;import org.springframework.beans.BeansException;
import org.springframework.context.ApplicationContext;
import org.springframework.context.ApplicationContextAware;
import org.springframework.context.ApplicationEvent;
import org.springframework.stereotype.Service;// 事件发布器。把事件发布到 spring容器中。Service
public class OrderPublish implements ApplicationContextAware {private ApplicationContext applicationContext;Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {// 获取spring容器设置到私有属性。this.applicationContext applicationContext;}// 调用spring容器 发布事件public void publishEvent(ApplicationEvent event){applicationContext.publishEvent(event);}} 订单服务中发布事件 package com.study.design.observer.spring;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;/*** 订单操作业务伪代码*/
Service
public class OrderService {// 注入事件发布器Autowiredprivate OrderPublish orderPublish;/*** 电商 - 新订单订单*/public void saveOrder() {System.out.println(1、 订单创建成功);// 创建事件 可以设置参数OrderEvent orderEvent new OrderEvent(123456);// 发布事件orderPublish.publishEvent(orderEvent);}
} 发短信 监听器 服务 package com.study.design.observer.spring;import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;// 监听器 ,有事件发布后才会执行
Component
public class SmsListener implements ApplicationListenerOrderEvent {Overridepublic void onApplicationEvent(OrderEvent event) {// 获取事件中的参数。System.out.println(event.getSource的值是event.getSource());// 2---短信通知System.out.println(2、 调用短信发送的接口 - 恭喜喜提羽绒被子);}
} 如此就可以创建多个监听器进行不同的业务处理。这就是观察者模式。 转载于:https://www.cnblogs.com/itbac/p/10921041.html
