科技有限公司可以做网站建设吗,媒体代发网站,金泉网是做网站的吗,网站内容侵权 怎么做文章目录 一、目标#xff1a;容器事件和事件监听器二、设计#xff1a;容器事件和事件监听器三、实现#xff1a;容器事件和事件监听器3.1 工程结构3.2 容器事件和事件监听器类图3.3 定义和实现事件3.3.1 定义事件抽象类3.3.2 定义应用上下文事件实现类3.3.3 上下文刷新事件… 文章目录 一、目标容器事件和事件监听器二、设计容器事件和事件监听器三、实现容器事件和事件监听器3.1 工程结构3.2 容器事件和事件监听器类图3.3 定义和实现事件3.3.1 定义事件抽象类3.3.2 定义应用上下文事件实现类3.3.3 上下文刷新事件类3.3.4 上下文关闭事件类 3.4 事件监听器3.4.1 类工具类添加判断代理对象3.4.2 事件监听器 3.5 事件广播器3.5.1 事件广播器接口3.5.2 事件广播器抽象类3.5.3 简单事件广播器 3.6 事件发布者的定义和实现3.6.1 定义事件发布者3.6.2 应用上下文接口3.6.3 应用上下文抽象类 四、测试容器事件和事件监听器4.1 添加测试配置4.1.1 创建自定义事件4.1.2 自定义事件监听器4.1.3 自定义事件刷新监听器4.1.4 自定义事件关闭监听器4.1.5 配置文件 4.2 单元测试 五、总结容器事件和事件监听器 一、目标容器事件和事件监听器 如何处理解耦什么是事件如何使用事件功能 在 Spring 中有一个 Event 事件功能它可以提供事件的定义、发布以及监听事件来完成一些自定义的动作。 比如你可以定义一个新用户注册的事件当有用户执行注册完成后在事件监听中给用户发送一些优惠券和短信提醒。这样的操作就可以把属于基本功能的注册和对应的策略服务分开降低系统的耦合。以后再扩展注册服务比如需要添加风控策略、添加实名认证、判断用户属性等都不会影响到依赖注册成功后执行的动作。 本节需要以观察者模式的方式设计和实现 Spring Event 的容器事件和事件监听器功能。 最终可以让 Spring 框架可以定义、监听和发布自己的事件信息。 二、设计容器事件和事件监听器 设计观察者模式实现 Spring Event 容器时间和事件监听器。 事件 的设计本身就是一种观察者模式的实现它所要解决的就是一个对象状态改变给其他对象通知的问题而且要考虑到易用和低耦合保证高度的协作。再功能上我们需要定义事件类、事件监听、事件发布。 这些类的功能需要结合到 Spring 的 AbstractApplicationContext#refresh()以便于处理事件初始化和注册事件监听器的操作。 在整个功能实现过程中需要在面向用户的应用上下文 AbstractApplicationContext 中添加相关事件内容。 包括初始化事件发布者、注册事件监听器、发布容器刷新完成事件。 使用观察者模式定义事件类、监听类、发布类同时还需要完成一个广播器的功能。 接收到事件推送时进行分析处理符合监听事件接收者感兴趣的事件也就是使用 isAssignableFrom 进行判断。 isAssignableFrom 和 instanceof 相似不过 isAssignableFrom 是用来判断子类和父类的关系的或者接口的实现类和接口的关系。 默认所有的类的终极父类都是 Object。如果 A.isAssignableFrom(B) 结果是 true证明 B 可以转换成 A也就是 A 可以由 B 转换而来。 三、实现容器事件和事件监听器 3.1 工程结构 spring-step-10 |-src|-main| |-java| |-com.lino.springframework| |-beans| | |-factory| | | |-config| | | | |-AutowireCapableBeanFactory.java| | | | |-BeanDefinition.java| | | | |-BeanFactoryPostProcessor.java| | | | |-BeanPostProcessor.java| | | | |-BeanReference.java| | | | |-ConfigurableBeanFactory.java| | | | |-SingletonBeanRegistry.java| | | |-support| | | | |-AbstractAutowireCapableBeanFactory.java| | | | |-AbstractBeabDefinitionReader.java| | | | |-AbstractBeabFactory.java| | | | |-BeabDefinitionReader.java| | | | |-BeanDefinitionRegistry.java| | | | |-CglibSubclassingInstantiationStrategy.java| | | | |-DefaultListableBeanFactory.java| | | | |-DefaultSingletonBeanRegistry.java| | | | |-DisposableBeanAdapter.java| | | | |-FactoryBeanRegistrySupport.java| | | | |-InstantiationStrategy.java| | | | |-SimpleInstantiationStrategy.java| | | |-support| | | | |-XMLBeanDefinitionReader.java| | | |-Aware.java| | | |-BeanClassLoaderAware.java| | | |-BeanFactory.java| | | |-BeanFactoryAware.java| | | |-BeanNameAware.java| | | |-ConfigurableListableBeanFactory.java| | | |-DisposableBean.java| | | |-FactoryBean.java| | | |-HierarcgicalBeanFactory.java| | | |-InitializingBean.java| | | |-ListableBeanFactory.java| | |-BeansException.java| | |-PropertyValue.java| | |-PropertyValues.java| |-context| | |-event| | | |-AbstractApplicationEventMulticaster.java| | | |-ApplicationContextEvent.java| | | |-ApplicationEventMulticaster.java| | | |-ContextclosedEvent.java| | | |-ContextRefreshedEvent.java| | | |-SimpleApplicationEventMulticaster.java| | |-support| | | |-AbstractApplicationContext.java| | | |-AbstractRefreshableApplicationContext.java| | | |-AbstractXmlApplicationContext.java| | | |-ApplicationContextAwareProcessor.java| | | |-ClassPathXmlApplicationContext.java| | |-ApplicationContext.java| | |-ApplicationContextAware.java| | |-ApplicationEvent.java| | |-ApplicationEventPublisher.java| | |-ApplicationListener.java| | |-ConfigurableApplicationContext.java| |-core.io| | |-ClassPathResource.java| | |-DefaultResourceLoader.java| | |-FileSystemResource.java| | |-Resource.java| | |-ResourceLoader.java| | |-UrlResource.java| |-util| | |-ClassUtils.java|-test|-java|-com.lino.springframework.test|-event| |-CustomClosedEventListener.java| |-CustomEvent.java| |-CustomEventListener.java| |-CustomRefreshedEventListener.java|-ApiTest.java|-resources|-spring.xml3.2 容器事件和事件监听器类图 整个类图以围绕实现 event 事件定义、发布、监听功能实现和把事件相关内容使用 AbstractApplicationContext#refresh 进行注册和处理操作。在实现的过程中主要以扩展 spring context 包为主事件的实现也是在这个包下进行扩展的当然也可以看出来目前所有的实现内容仍然是以 IOC 为主。ApplicationContext 容器继承事件发布功能接口 ApplicationEventPublisher并在实现类中提供事件监听功能。ApplicationEventMulticaster 接口是注册监听器和发布事件的广播器提供添加、移除和发布事件方法。最后是发布容器关闭事件这个仍然需要扩展到 AbstractApplicationContext#close 方法中由注册到虚拟机的钩子实现。 3.3 定义和实现事件 3.3.1 定义事件抽象类 ApplicationEvent.java package com.lino.springframework.context;import java.util.EventObject;/*** description: 定义事件抽象类*/ public abstract class ApplicationEvent extends EventObject {/*** Constructs a prototypical Event.** param source The object on which the Event initially occurred.* throws IllegalArgumentException if source is null.*/public ApplicationEvent(Object source) {super(source);} }以继承 java.util.EventObject 定义出具备事件功能的抽象类 ApplicationEvent后续所有事件的类都需要继承这个类。 3.3.2 定义应用上下文事件实现类 ApplicationContextEvent.java package com.lino.springframework.context.event;import com.lino.springframework.context.ApplicationContext; import com.lino.springframework.context.ApplicationEvent;/*** description: 定义应用上下文事件实现类*/ public class ApplicationContextEvent extends ApplicationEvent {/*** Constructs a prototypical Event.** param source The object on which the Event initially occurred.* throws IllegalArgumentException if source is null.*/public ApplicationContextEvent(Object source) {super(source);}/*** 获取应用上下文** return 应用上下文*/public final ApplicationContext getApplicationContext() {return (ApplicationContext) getSource();} }3.3.3 上下文刷新事件类 ContextRefreshedEvent.java package com.lino.springframework.context.event;/*** description: 上下文刷新事件类*/ public class ContextRefreshedEvent extends ApplicationContextEvent {/*** Constructs a prototypical Event.** param source The object on which the Event initially occurred.* throws IllegalArgumentException if source is null.*/public ContextRefreshedEvent(Object source) {super(source);} }3.3.4 上下文关闭事件类 ContextClosedEvent.java package com.lino.springframework.context.event;/*** description: 上下文关闭事件类*/ public class ContextClosedEvent extends ApplicationContextEvent {/*** Constructs a prototypical Event.** param source The object on which the Event initially occurred.* throws IllegalArgumentException if source is null.*/public ContextClosedEvent(Object source) {super(source);} }ApplicationContextEvent 是定义事件的类所有的事件包括关闭、刷新以及用户自己实现的事件都需要继承这个类。ContextRefreshedEvent、ContextClosedEvent分别是 Spring 框架自己实现的两个事件类可以用于监听刷新和关闭动作。 3.4 事件监听器 3.4.1 类工具类添加判断代理对象 ClassUtils.java package com.lino.springframework.util;/*** description: 类工具类*/ public class ClassUtils {/*** 获取默认类加载器** return 类加载器*/public static ClassLoader getDefaultClassLoader() {ClassLoader cl null;try {cl Thread.currentThread().getContextClassLoader();} catch (Throwable ex) {// Cannot access thread context ClassLoader - falling back to system class loader...}if (cl null) {// No thread context class loader - use class loader of this class.cl ClassUtils.class.getClassLoader();}return cl;}/*** 判断类是否是cglib代理对象** param clazz 类* return 是否是cglib代理对象*/public static boolean isCglibProxyClass(Class? clazz) {return (clazz ! null isCglibProxyClassName(clazz.getName()));}/*** 判断类名是否符合cglib代理类命名** param className 类名* return 是否符合cglib代理类命名*/public static boolean isCglibProxyClassName(String className) {return (className ! null className.contains($$));} }添加判断是否是 cglib 代理对象和是否符合 cglib 代理名称的方法。 3.4.2 事件监听器 ApplicationListener.java package com.lino.springframework.context;import java.util.EventListener;/*** description: 事件监听器* author: lingjian* createDate: 2022/12/1 15:01*/ public interface ApplicationListenerE extends ApplicationEvent extends EventListener {/*** 处理事件** param event 事件*/void onApplicationEvent(E event); }添加监听器开放接口后续开放给外部实现调用。 3.5 事件广播器 3.5.1 事件广播器接口 ApplicationEventMulticaster.java package com.lino.springframework.context.event;import com.lino.springframework.context.ApplicationEvent; import com.lino.springframework.context.ApplicationListener;/*** description: 事件广播器*/ public interface ApplicationEventMulticaster {/*** 添加监听器** param listener 监听器*/void addApplicationListener(ApplicationListener? listener);/*** 删除监听器** param listener 监听器*/void removeApplicationListener(ApplicationListener? listener);/*** 广播事件** param event 事件*/void multicastEvent(ApplicationEvent event); }在事件广播器中定义了添加监听和删除监听的方法以及一个广播事件的方法 multicastEvent。最终推送时间消息也会经过这个接口方法来处理谁该接收事件。 3.5.2 事件广播器抽象类 AbstractApplicationEventMulticaster.java package com.lino.springframework.context.event;import com.lino.springframework.beans.BeansException; import com.lino.springframework.beans.factory.BeanFactory; import com.lino.springframework.beans.factory.BeanFactoryAware; import com.lino.springframework.context.ApplicationEvent; import com.lino.springframework.context.ApplicationListener; import com.lino.springframework.util.ClassUtils; import java.lang.reflect.ParameterizedType; import java.lang.reflect.Type; import java.util.Collection; import java.util.LinkedHashSet; import java.util.LinkedList; import java.util.Set;/*** description: 事件广播器抽象类*/ public abstract class AbstractApplicationEventMulticaster implements ApplicationEventMulticaster, BeanFactoryAware {public final SetApplicationListenerApplicationEvent applicationListeners new LinkedHashSet();private BeanFactory beanFactory;Overridepublic void addApplicationListener(ApplicationListener? listener) {applicationListeners.add((ApplicationListenerApplicationEvent) listener);}Overridepublic void removeApplicationListener(ApplicationListener? listener) {applicationListeners.remove(listener);}Overridepublic void setBeanFactory(BeanFactory beanFactory) throws BeansException {this.beanFactory beanFactory;}/*** 获取事件监听器** param event 事件* return 监听器列表*/protected CollectionApplicationListener getApplicationListeners(ApplicationEvent event) {LinkedListApplicationListener allListeners new LinkedList();for (ApplicationListenerApplicationEvent listener : applicationListeners) {if (supportsEvent(listener, event)) {allListeners.add(listener);}}return allListeners;}/*** 监听器是否该事件感兴趣** param applicationListener 监听器* param event 事件* return 是否感兴趣*/protected boolean supportsEvent(ApplicationListenerApplicationEvent applicationListener, ApplicationEvent event) {Class? extends ApplicationListener listenerClass applicationListener.getClass();// 按照 CglibSubclassingInstantiationStrategy、SimpleInstantiationStrategy 不同的实例化类型需要判断后获取目标 classClass? targetClass ClassUtils.isCglibProxyClass(listenerClass) ? listenerClass.getSuperclass() : listenerClass;Type genericInterface targetClass.getGenericInterfaces()[0];Type actualTypeArgument ((ParameterizedType) genericInterface).getActualTypeArguments()[0];String className actualTypeArgument.getTypeName();Class? eventClassName;try {eventClassName Class.forName(className);} catch (ClassNotFoundException e) {throw new BeansException(wrong event class name: className);}// 判断此 eventClassName 对象所表示的类或接口与指定的 event.getClass() 参数所表示的类或接口是否相同或是否是超类或超接口// isAssignableFrom是用来判断子类和父类的关系的或者接口的实现类和接口的关系的默认所有的类的终极父类都是Object。// 如果A.isAssignableFrom(B)结果是true证明B可以转换成为A也就是A可以由B转换而来。return eventClassName.isAssignableFrom(event.getClass());} }AbstractApplicationEventMulticaster 是对事件广播器的公用方法提取在这个类中可以实现一些基本功能避免所有直接实现接口还需要处理细节。除了像 addApplicationListener、removeApplicationListener 这样的通用方法。这里主要是对 getApplicationListeners、supportsEvent 的处理。 getApplicationListeners主要是摘取符合广播事件中的监听处理器具体过滤动作在 supportsEvent 方法中。supportsEvent 主要包括对 Cglib、Simple 不同实例化需要获取父类的 ClassCglib 代理类需要获取父类的 Class。普通实例化则不需要。接下来就是通过提取接口和对应的 ParameterizedType 和 eventClassName方便最后确认是否为子类和父类的关系以此证明此事件归这个符合的类处理。 从结果看出最终 eventClassName 和 event.getClass() 在 isAssignableFrom 判断下为 true。关于 CglibSubclassingInstantiationStrategy、SimpleInstantiationStrategy 可以尝试在 AbstractApplicationContext 类中更换验证。 3.5.3 简单事件广播器 SimpleApplicationEventMulticaster.java package com.lino.springframework.context.event;import com.lino.springframework.beans.factory.BeanFactory; import com.lino.springframework.context.ApplicationEvent; import com.lino.springframework.context.ApplicationListener;/*** description: 简单事件广播器*/ public class SimpleApplicationEventMulticaster extends AbstractApplicationEventMulticaster {public SimpleApplicationEventMulticaster(BeanFactory beanFactory) {setBeanFactory(beanFactory);}SuppressWarnings(unchecked)Overridepublic void multicastEvent(final ApplicationEvent event) {for (final ApplicationListener listener : getApplicationListeners(event)) {listener.onApplicationEvent(event);}} }3.6 事件发布者的定义和实现 3.6.1 定义事件发布者 ApplicationEventPublisher.java package com.lino.springframework.context;/*** description: 事件发布者接口*/ public interface ApplicationEventPublisher {/*** 发布事件** param event 事件*/void publishEvent(ApplicationEvent event); }ApplicationEventPublisher 是一个事件的发布接口所有的事件都需要从这个接口发布出去。 3.6.2 应用上下文接口 ApplicationContext.java package com.lino.springframework.context;import com.lino.springframework.beans.factory.HierarchicalBeanFactory; import com.lino.springframework.beans.factory.ListableBeanFactory; import com.lino.springframework.core.io.ResourceLoader;/*** description: 应用上下文接口*/ public interface ApplicationContext extends ListableBeanFactory, HierarchicalBeanFactory, ResourceLoader, ApplicationEventPublisher { }3.6.3 应用上下文抽象类 AbstractApplicationContext.java package com.lino.springframework.context.support;import com.lino.springframework.beans.BeansException; import com.lino.springframework.beans.factory.ConfigurableListableBeanFactory; import com.lino.springframework.beans.factory.config.BeanFactoryPostProcessor; import com.lino.springframework.beans.factory.config.BeanPostProcessor; import com.lino.springframework.context.ApplicationEvent; import com.lino.springframework.context.ApplicationListener; import com.lino.springframework.context.ConfigurableApplicationContext; import com.lino.springframework.context.event.ApplicationEventMulticaster; import com.lino.springframework.context.event.ContextClosedEvent; import com.lino.springframework.context.event.ContextRefreshedEvent; import com.lino.springframework.context.event.SimpleApplicationEventMulticaster; import com.lino.springframework.core.io.DefaultResourceLoader; import java.util.Collection; import java.util.Map;/*** description: 抽象应用上下文*/ public abstract class AbstractApplicationContext extends DefaultResourceLoader implements ConfigurableApplicationContext {public static final String APPLICATION_EVENT_MULTICASTER_BEAN_NAME applicationEventMulticaster;private ApplicationEventMulticaster applicationEventMulticaster;Overridepublic void refresh() throws BeansException {// 1.创建 BeanFactory并加载 BeanDefinitionrefreshBeanFactory();// 2.获取 BeanFactoryConfigurableListableBeanFactory beanFactory getBeanFactory();// 3.添加 ApplicationContextAwareProcessor让继承自 ApplicationContextAware 的 Bean 对象都能感知所属的 ApplicationContextbeanFactory.addBeanPostProcessor(new ApplicationContextAwareProcessor(this));// 4.在 Bean 实例化之前执行 BeanFactoryPostProcessinvokeBeanFactoryPostProcessor(beanFactory);// 5.BeanPostProcessor 需要提前与其他 Bean 对象实例化之前执行注册操作registerBeanPostProcessor(beanFactory);// 6.初始化事件发布者initApplicationEventMulticaster();// 7.注册事件监听器registerListeners();// 8.提前实例化单例 Bean 对象beanFactory.preInstantiateSingletons();// 9.发布容器刷新完成事件finishRefresh();}...private void initApplicationEventMulticaster() {ConfigurableListableBeanFactory beanFactory getBeanFactory();applicationEventMulticaster new SimpleApplicationEventMulticaster(beanFactory);beanFactory.registerSingletonBean(APPLICATION_EVENT_MULTICASTER_BEAN_NAME, applicationEventMulticaster);}private void registerListeners() {CollectionApplicationListener applicationListeners getBeansOfType(ApplicationListener.class).values();for (ApplicationListener listener : applicationListeners) {applicationEventMulticaster.addApplicationListener(listener);}}private void finishRefresh() {publishEvent(new ContextRefreshedEvent(this));}Overridepublic void publishEvent(ApplicationEvent event) {applicationEventMulticaster.multicastEvent(event);}...Overridepublic void close() {// 发布容器关闭事件publishEvent(new ContextClosedEvent(this));// 执行销毁单例bean的销毁方法getBeanFactory().destroySingletons();}}在抽象应用上下文 AbstractApplicationContext#refresh 中主要新增了 初始化事件发布者、注册事件监听器、发布容器刷新完成事件。三个方法用于处理事件操作。 初始化事件发布者(initApplicationEventMulticaster)主要用于实例化一个 SimpleApplicationEventMulticaster这是一个事件广播器。注册事件监听器(registerListeners)通过 getBeansOfType 方法获取到所有从 spring.xml 中加载到的事件配置 Bean 对象。发布容器刷新完成事件(finishRefresh)发布了第一个服务器启动完成后的事件这个事件通过 publishEvent 发布出去其实也就是调用了 applicationEventMulticaster.multicastEvent(event) 方法。关闭方法(close)新增加了发布一个容器关闭事件。publishEvent(new ContextClosedEvent(this))。 四、测试容器事件和事件监听器 4.1 添加测试配置 4.1.1 创建自定义事件 CustomEvent.java package com.lino.springframework.test.event;import com.lino.springframework.context.event.ApplicationContextEvent;/*** description: 自定义事件*/ public class CustomEvent extends ApplicationContextEvent {private Long id;private String message;/*** Constructs a prototypical Event.** param source The object on which the Event initially occurred.* throws IllegalArgumentException if source is null.*/public CustomEvent(Object source, Long id, String message) {super(source);this.id id;this.message message;}public Long getId() {return id;}public void setId(Long id) {this.id id;}public String getMessage() {return message;}public void setMessage(String message) {this.message message;} }创建一个自定义事件在事件类的构造函数中可以添加自己想要的入参信息。这个事件类最终会被完成的监听类监听到所以你添加的属性也会被获得到。 4.1.2 自定义事件监听器 CustomEventListener.java package com.lino.springframework.test.event;import com.lino.springframework.context.ApplicationListener; import java.util.Date;/*** description: 自定义事件监听器*/ public class CustomEventListener implements ApplicationListenerCustomEvent {Overridepublic void onApplicationEvent(CustomEvent event) {System.out.println(收到 event.getSource() 消息;时间 new Date());System.out.println(消息 event.getId() : event.getMessage());} }这是一个用于监听 CustomEvent 事件的监听器这里可以处理自定义操作。 4.1.3 自定义事件刷新监听器 CustomRefreshedEventListener.java package com.lino.springframework.test.event;import com.lino.springframework.context.ApplicationListener; import com.lino.springframework.context.event.ContextRefreshedEvent;/*** description: 自定义事件刷新监听器* author: lingjian* createDate: 2022/12/1 15:48*/ public class CustomRefreshedEventListener implements ApplicationListenerContextRefreshedEvent {Overridepublic void onApplicationEvent(ContextRefreshedEvent event) {System.out.println(刷新事件 this.getClass().getName());} }4.1.4 自定义事件关闭监听器 CustomClosedEventListener.java package com.lino.springframework.test.event;import com.lino.springframework.context.ApplicationListener; import com.lino.springframework.context.event.ContextClosedEvent;/*** description: 自定义事件关闭监听器*/ public class CustomClosedEventListener implements ApplicationListenerContextClosedEvent {Overridepublic void onApplicationEvent(ContextClosedEvent event) {System.out.println(关闭事件 this.getClass().getName());} }4.1.5 配置文件 spring.xml ?xml version1.0 encodingutf-8 ? beansbean classcom.lino.springframework.test.event.CustomEventListener/bean classcom.lino.springframework.test.event.CustomRefreshedEventListener/bean classcom.lino.springframework.test.event.CustomClosedEventListener/ /beans在 spring.xml 配置文件中添加了三个事件监听器监听刷新、监控自定义事件、监听关闭事件。 4.2 单元测试 ApiTest.java Test public void test_event() {// 1.初始化 BeanFactoryClassPathXmlApplicationContext applicationContext new ClassPathXmlApplicationContext(classpath:spring.xml);applicationContext.publishEvent(new CustomEvent(applicationContext, 1019129009086763L, 成功监听到了));applicationContext.registerShutdownHook(); }通过使用 applicationContext 新增加的发布事件接口方法发布一个自定义事件 CustomEvent并传了相应的参数信息。 测试结果 刷新事件com.lino.springframework.test.event.CustomRefreshedEventListener$$EnhancerByCGLIB$$b3c3d48f 收到com.lino.springframework.context.support.ClassPathXmlApplicationContext4cdbe50f消息;时间Thu Dec 01 17:07:43 CST 2022 消息1019129009086763:成功监听到了 关闭事件com.lino.springframework.test.event.CustomClosedEventListener$$EnhancerByCGLIB$$20578a33从测试结果看我们自定义的事件和监听以及监听系统的事件信息都可以在控制台完成的输出。 五、总结容器事件和事件监听器 在现有的 Spring 的实现过程中可以逐步看到很多设计模式的使用。 比如简单工厂 BeanFactory、工厂方法 FactoryBean、策略模式访问资源、观察者模式 Event。 本节关于观察者模式的实现过程主要包括了事件的定义、事件的监听和发布事件发布完成后根据匹配策略监听器就会收到属于自己的事件内容并做相应的处理动作。在结合 Spring 后可以看到如何把观察者的实现和应用上下文结合。