课程标题《spring事件监听的观察者模式源码分析》
课程内容：
1.什么是观察者模式？
2.观察者模式优缺点
3.什么是事件监听
4.spring事件监听源码解读
5.jdk自带观察者模式源码解读

什么是观察者模式

在对象之间定义了一对多的依赖，这样一来，当一个对象改变状态，依赖它的对象会收到通知并自动更新。其实就是发布订阅模式，发布者发布信息，订阅者获取信息，订阅了就能收到信息，没订阅就收不到信息。

Spring封装事件监听

例如用户注册成功之后，会发送邮件和短信

package com.mayikt.service;import com.mayikt.service.entity.MsgEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.ApplicationContext;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;/**
* @author 余胜军
* @ClassName MayiktService
* @qq 644064779
* @addres www.mayikt.com
* 微信:yushengjun644
*/
@RestController
@Slf4j
public class MayiktService {@Autowiredprivate ApplicationContext applicationContext;/*** 注册代码** @return*/@RequestMapping("/register")public String register() {log.info("register...");// 发送短信、发送邮件、发送微信公众号// sendMsg();// sendEmail();// sendWechatTemplate();MsgEntity msgEntity =new MsgEntity(this, "18140668851", "644064@qq.com","wx123456", "dingding123456");applicationContext.publishEvent(msgEntity);return "ok";}}
package com.mayikt.service.entity;import lombok.Data;
import org.springframework.context.ApplicationEvent;/*** @author 余胜军* @ClassName MsgEntity* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Data
public class MsgEntity  extends ApplicationEvent {// 手机号码private String phone;// 邮件private String email;// 微信openidprivate String weChatOpenId;/*** 钉钉openid*/private String dindinOpenId;public MsgEntity(Object source, String phone, String email, String weChatOpenId, String dindinOpenId) {super(source);this.phone = phone;this.email = email;this.weChatOpenId = weChatOpenId;this.dindinOpenId = dindinOpenId;}@Overridepublic String toString() {return "MsgEntity{" +"phone='" + phone + '\'' +", email='" + email + '\'' +", weChatOpenId='" + weChatOpenId + '\'' +", dindinOpenId='" + dindinOpenId + '\'' +'}';}
}
package com.mayikt.service.listener;import com.mayikt.service.entity.MsgEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;/*** @author 余胜军* @ClassName WeChat* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Slf4j
@Component
public class WeChatMessageListener implements ApplicationListener<MsgEntity> {@Overridepublic void onApplicationEvent(MsgEntity event) {// 发送微信log.info("<发送微信:{}>", event.toString());}
}package com.mayikt.service.listener;import com.mayikt.service.entity.MsgEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.stereotype.Component;/*** @author 余胜军* @ClassName TextMessageListener* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Component
@Slf4j
public class TextMessageListener implements ApplicationListener<MsgEntity> {@Overridepublic void onApplicationEvent(MsgEntity event) {log.info("<发送短信:{}>", event.toString());}
}@Autowiredprivate ApplicationContext applicationContext;@RequestMapping("/login")public String login() {log.info("login...");// 1.步骤1：验证数据库信息（手机号码、密码） //1// 2.步骤2: 发送登录短信、邮件、公众号模板、赠送优惠卷、发送钉钉// 发送短信、发送邮件、发送微信公众号
//        sendMsg(); // 1s
//        sendEmail(); // 1s
//        sendWechatTemplate(); // 1s//send发送优惠券
//        sendDinDin();MsgEntity msgEntity =new MsgEntity(this, "18140668851", "644064@qq.com","wx123456", "dingding123456");applicationContext.publishEvent(msgEntity);// 给我们的每个观察者发送内容return "ok";}

整合线程池异步方式

package com.mayikt.service.listener;import com.mayikt.service.entity.MsgEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;/*** @author 余胜军* @ClassName TextMessageListener* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Component
@Slf4j
public class TextMessageListener implements ApplicationListener<MsgEntity> {@Override@Asyncpublic void onApplicationEvent(MsgEntity event) {log.info("<发送短信:{}>", event.toString());}
}package com.mayikt.service.listener;import com.mayikt.service.entity.MsgEntity;
import lombok.extern.slf4j.Slf4j;
import org.springframework.context.ApplicationEvent;
import org.springframework.context.ApplicationListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;/*** @author 余胜军* @ClassName WeChat* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Slf4j
@Component
public class WeChatMessageListener implements ApplicationListener<MsgEntity> {@Override@Asyncpublic void onApplicationEvent(MsgEntity event) {// 发送微信log.info("<发送微信:{}>", event.toString());}
}

观察者模式应用场景

Zookeeper事件通知节点、消息订阅通知、安卓开发事件注册、分布式配置中心。

1.抽象被观察者角色：也就是一个抽象主题，它把所有对观察者对象的引用保存在一个集合中，每个主题都可以有任意数量的观察者。抽象主题提供一个接口，可以增加和删除观察者角色。一般用一个抽象类和接口来实现。

2.抽象观察者角色：为所有的具体观察者定义一个接口，在得到主题通知时更新自己。

3.具体被观察者角色：也就是一个具体的主题，在集体主题的内部状态改变时，所有登记过的观察者发出通知。

4.具体观察者角色：实现抽象观察者角色所需要的更新接口，一边使本身的状态与制图的状态相协调。

使用观察者群发邮件、短信

抽象观察者

public interface ObServer {/*** 更新消息内容** @param message* @return*/public void update(String message);}

抽象主题

package com.mayikt.obServer;/*** @author 余胜军* @ClassName AbstractSubject* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
public interface AbstractSubject {/*** 新增addObServer*/void addObServer(ObServer obServer);/*** 删除数据*/void removeObServer(ObServer obServer);/*** 通知所有的ObServerAll*/void notifyObServerAll(String message);
}

具体主题

package com.mayikt.obServer.impl;import com.mayikt.obServer.AbstractSubject;
import com.mayikt.obServer.ObServer;import java.util.ArrayList;
import java.util.List;/*** @author 余胜军* @ClassName MsgSubject* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
public class MsgSubject implements AbstractSubject {// 发送消息主题private List<ObServer> obServers = new ArrayList<>();@Overridepublic void addObServer(ObServer obServer) {obServers.add(obServer);}@Overridepublic void removeObServer(ObServer obServer) {obServers.remove(obServer);}@Overridepublic void notifyObServerAll(String message) {// 循环遍历调用，每个ObServerobServers.forEach((o) -> {// 调用updateo.update(message);});}
}

具体观察者

package com.mayikt.obServer.impl;import com.mayikt.obServer.ObServer;
import lombok.extern.slf4j.Slf4j;/*** @author 余胜军* @ClassName WeChatObServerImpl* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Slf4j
public class WeChatObServer implements ObServer {@Overridepublic void update(String message) {log.info("发送微信模板消息:{}", message);}
}package com.mayikt.obServer.impl;import com.mayikt.obServer.ObServer;
import lombok.extern.slf4j.Slf4j;/*** @author 余胜军* @ClassName TextMessageObServer* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Slf4j
public class TextMessageObServer  implements ObServer {@Overridepublic void update(String message) {log.info("发送短信消息:{}", message);}
}

责任链与观察者模式区别

责任链有严格顺序、多个观察者（没有顺序要求）

运行测试

package com.mayikt.obServer;import com.mayikt.obServer.impl.MsgSubject;
import com.mayikt.obServer.impl.TextMessageObServer;
import com.mayikt.obServer.impl.WeChatObServer;/*** @author 余胜军* @ClassName Test01* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
public class Test01 {public static void main(String[] args) {ObServer textMessageObServer = new TextMessageObServer();ObServer weChatObServer = new WeChatObServer();MsgSubject msgSubject = new MsgSubject();msgSubject.addObServer(textMessageObServer);msgSubject.addObServer(weChatObServer);msgSubject.notifyObServerAll("mayikt");}
}

JDK自带封装的观察者

（1）. Observable类追踪所有的观察者，并通知他们。
（2）. Observer这个接口看起来很熟悉，它和我们之前写的类几乎一样。
package com.mayikt.obServer.jdk;import java.util.Observable;/*** @author 余胜军* @ClassName MessageObServable* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
public class MessageObServable extends Observable  {@Overridepublic void notifyObservers(Object obj) {// 1.改变数据setChanged();// 2.通知所有观察者改变super.notifyObservers(obj);}
}package com.mayikt.obServer.jdk.impl;import com.mayikt.obServer.jdk.MessageObServable;
import lombok.extern.slf4j.Slf4j;import java.util.Observable;
import java.util.Observer;/*** @author 余胜军* @ClassName EmailObServer* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Slf4j
public class EmailObServer implements Observer {@Overridepublic void update(Observable o, Object arg) {// 1.获取主题MessageObServable MessageObServable= (MessageObServable) o;log.info("获取到发送的邮件内容:"+arg);}
}package com.mayikt.obServer.jdk.impl;import com.mayikt.obServer.jdk.MessageObServable;
import lombok.extern.slf4j.Slf4j;import java.util.Observable;
import java.util.Observer;/*** @author 余胜军* @ClassName EmailObServer* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
@Slf4j
public class TextMessageObServer implements Observer {@Overridepublic void update(Observable o, Object arg) {// 1.获取主题MessageObServable MessageObServable = (MessageObServable) o;log.info("获取到发送的短信内容:" + arg);}
}package com.mayikt.obServer.jdk.impl;import com.mayikt.obServer.jdk.MessageObServable;/*** @author 余胜军* @ClassName Test01* @qq 644064779* @addres www.mayikt.com* 微信:yushengjun644*/
public class Test01 {public static void main(String[] args) {MessageObServable messageObServable = new MessageObServable();messageObServable.addObserver(new TextMessageObServer());messageObServable.addObserver(new EmailObServer());messageObServable.notifyObservers("mayikt");;}
}

06.设计模式之观察者模式

什么是观察者模式

Spring封装事件监听

Spring封装事件监听

整合线程池异步方式

观察者模式应用场景

使用观察者群发邮件、短信

抽象观察者

抽象主题

具体主题

具体观察者

责任链与观察者模式区别

运行测试

JDK自带封装的观察者

相关代码

06.设计模式之观察者模式相关推荐

最新文章

热门文章