经典案例:消息的发布与订阅。
public String publish(){
System.out.println("开始发布消息");
String message = "有内鬼,终止交易!";
concreteObserver.acceptMessage(message);
eventObserver.receiveMessage(message);
messageObserver.getMessage(message);
return "success";
}
以上三种服务订阅消息,当订阅方增加时,必须修改原有代码去改变这种情况。
那么可以使用观察者模式解决以上的问题,参考美团:设计模式二三事。
观察者模式[1-5]:指多个对象间存在一对多的依赖关系,当一个对象的状态发生改变时,所有依赖于它的对象都得到通知并被自动更新。这种模式有时又称作发布-订阅模式、模型-视图模式,它是对象行为型模式。观察者模式的主要角色如下。
抽象主题(Subject)角色:也叫抽象目标类,它提供了一个用于保存观察者对象的聚集类和增加、删除观察者对象的方法,以及通知所有观察者的抽象方法。
具体主题(Concrete Subject)角色:也叫具体目标类,它实现抽象目标中的通知方法,当具体主题的内部状态发生改变时,通知所有注册过的观察者对象。
抽象观察者(Observer)角色:它是一个抽象类或接口,它包含了一个更新自己的抽象方法,当接到具体主题的更改通知时被调用。
具体观察者(Concrete Observer)角色:实现抽象观察者中定义的抽象方法,以便在得到目标的更改通知时更新自身的状态。
/**
* @Author: maoyouhua
* @CreateTime: 2024/03/25
* @Version: jdk21
* @Description:
*
* 抽象主题(抽象被观察者)
* 具体主题(具体被观察者)
*/
public interface Subject {
void add(Observer observer);
void remove(Observer observer);
void notifyObservers(String message);
}
@Component
public class ConcreteSubject implements Subject {
private List<Observer> observerList = new ArrayList<>();
@Override
public void add(Observer observer){
observerList.add(observer);
}
@Override
public void remove(Observer observer){
observerList.remove(observer);
}
@Override
public void notifyObservers(String message) {
for (Observer observer : observerList) {
observer.response(message);
}
}
}
/**
* @Author: maoyouhua
* @CreateTime: 2024/03/25
* @Version: jdk21
* @Description:
*
* 抽象观察者
* 具体观察者
*/
public interface Observer {
void response(String message);
}
@Component
public class ConcreteObserver implements Observer {
public ConcreteObserver(@Autowired Subject subject) {
subject.add(this);
}
@Override
public void response(String message) {
acceptMessage(message);
}
public void acceptMessage(String message){
System.out.println(this.getClass().getSimpleName()+ "接收到消息:" + message);
}
}
@Component
public class EventObserver implements Observer {
public EventObserver(@Autowired Subject subject) {
subject.add(this);
}
@Override
public void response(String message) {
receiveMessage(message);
}
public void receiveMessage(String message){
System.out.println(this.getClass().getSimpleName()+ "接收到消息:" + message);
}
}
@Component
public class MessageObserver implements Observer {
public MessageObserver(@Autowired Subject subject) {
subject.add(this);
}
@Override
public void response(String message) {
getMessage(message);
}
public void getMessage(String message) {
System.out.println(this.getClass().getSimpleName()+ "接收到消息:" + message);
}
}
/**
* @Author: maoyouhua
* @CreateTime: 2024/03/25
* @Version: jdk21
* @Description: TODO
*/
@RestController
@RequestMapping("/observermode")
public class ObserverController {
@Autowired
private Subject subject;
@Autowired
private ConcreteObserver concreteObserver;
@Autowired
private EventObserver eventObserver;
@Autowired
private MessageObserver messageObserver;
@RequestMapping("/test")
public String test(){
return "Hi Observer Mode";
}
@RequestMapping("/publish")
public String publish(){
System.out.println("开始发布消息");
String message = "有内鬼,终止交易!";
concreteObserver.acceptMessage(message);
eventObserver.receiveMessage(message);
messageObserver.getMessage(message);
return "success";
}
@RequestMapping("/publishbyobserver")
public String publishByObserver(){
System.out.println("开始发布消息");
subject.notifyObservers("有内鬼,终止交易!");
return "success";
}
}