Vergleichende Analyse von Beispielen für Beobachtermuster und Delegation in Java

Codierungshintergrund

Es gibt zwei Arten von Schülern in einer Klasse, Kategorie A: nicht lernen, spielen, sondern verschiedene Dinge spielen, manche spielen Spiele, manche schauen fern

Kategorie B: wachsame, spezialisierte Schüler beim Beobachten der Bewegungen des Lehrers: Wenn der Lehrer die Klasse betritt, werden alle sofort benachrichtigt.

Dies hat zu einer Forderung geführt, dass die Wachschüler alle spielenden Schüler benachrichtigen sollten, dass der Lehrer kommt, und verschiedene Schüler reagieren unterschiedlich darauf, dass sie den Fernseher sofort ausschalten und andere mit dem Spielen aufhören.

Beobachtermuster

Einführung

Beobachtermuster: Definiert eine Eins-zu-viele-Abhängigkeitsbeziehung, die es mehreren Beobachterobjekten ermöglicht, ein bestimmtes Themenobjekt gleichzeitig zu überwachen.
Dieses Themenobjekt benachrichtigt alle Beobachterobjekte, wenn sich sein Zustand ändert, sodass sie sich automatisch aktualisieren können.

Löst hauptsächlich: Das Problem, andere Objekte über Statusänderungen eines Objekts zu benachrichtigen und Benutzerfreundlichkeit und geringe Kopplung zu berücksichtigen, um ein hohes Maß an Zusammenarbeit sicherzustellen.

Verwendungszweck: Wenn sich der Zustand eines Objekts (Zielobjekts) ändert, werden alle abhängigen Objekte (Beobachterobjekte) benachrichtigt und es werden Broadcast-Benachrichtigungen erstellt.

So lösen Sie: Mit objektorientierter Technologie kann diese Abhängigkeit abgeschwächt werden.

Schlüsselcode: In der abstrakten Klasse gibt es eine ArrayList zum Speichern von Beobachtern.

Implementierung

Beobachter (Schüler)

/**
 * 抽象的观察者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:32
 */
public interface Observer {
    public abstract void updateState();
}
/**
 * 具体的观察者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:39
 */
public class ConcreteObserver implements Observer{
    //观察者的姓名
    private String name;
    //观察者的状态
    private String observerState;
    //明确具体的通知者
    private ConcreteSubject subject;
   //get set方法省略
    public ConcreteObserver(String name, ConcreteSubject subject) {
        this.name = name;
        this.subject = subject;
    }
    @Override
    public void updateState() {
        observerState=subject.getSubjectState();
        System.out.println(name+"在打游戏");
        String str=String.format("观察者%s的：新状态是%s", name,observerState);
        System.out.println(str);
    }
}
/**
 * 具体的观察者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:39
 */
public class ConcreteObserver2 implements Observer{
    //观察者的姓名
    private String name;
    //观察者的状态
    private String observerState;
    //明确具体的通知者
    private ConcreteSubject subject;
   //get set方法省略
    public ConcreteObserver2(String name, ConcreteSubject subject) {
        this.name = name;
        this.subject = subject;
    }
    @Override
    public void updateState() {
        observerState=subject.getSubjectState();
        System.out.println(name+"在看电视");
        String str=String.format("观察者%s：新状态是%s", name,observerState);
        System.out.println(str);
    }
}

Notifier (Lehrer)

/**
 * 抽象的通知者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:30
 */
public abstract class Subject {
    //管理观察者的集合
    private List<Observer> observers=new ArrayList<>();
    //增加观察者
    public void add(Observer observer){
        observers.add(observer);
    }
    //减少观察者
    public void detach(Observer observer){
        observers.remove(observer);
    }
    /**
     * 通知所有的观察者
     */
    public void notifyMsg(){
        for (Observer observer : observers) {
            observer.updateState();
        }
    }
}
/**
 * 具体的通知者
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:38
 */
public class ConcreteSubject extends Subject {
    //通知者的状态
    private String subjectState;
    //get set方法
    public String getSubjectState() {
        return subjectState;
    }
    public void setSubjectState(String subjectState) {
        this.subjectState = subjectState;
    }
}

Hauptmethode

/**
 * 控制台Main方法
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/10 - 15:48
 */
public class MainTest {
    public static void main(String[] args) {
        //创建一个主题/通知者
        ConcreteSubject subject=new ConcreteSubject();
        //new出观察者（学生）
        ConcreteObserver studentZhang = new ConcreteObserver("小张", subject);
        ConcreteObserver studentLiu = new ConcreteObserver("小刘", subject);
        ConcreteObserver studentWang = new ConcreteObserver("小王", subject);
        //将观察者添加到通知队列里
        subject.add(studentZhang);
        subject.add(studentLiu);
        subject.add(studentWang);
        //通知者（老师）状态修改，通知每个学生
        subject.setSubjectState("老师回来了，我要好好学习");
        subject.notifyMsg();
        System.out.println("-----------");
    }
}

Delegation. Einführung

Delegation kann als Abstraktion einer Funktion angesehen werden, die a ist Funktion „freundlich“. Die Instanz des Delegaten stellt eine bestimmte Funktion dar. Ein Delegat kann mehrere Methoden tragen und alle Methoden werden nacheinander aufgerufen. Die vom Delegate-Objekt getragenen Methoden müssen nicht zur selben Klasse gehören.
Das delegierte Ereignismodell kann durch drei Komponenten definiert werden: Ereignisse, Ereignisquellen und Ereignis-Listener.

Die Umsetzung der Delegation erfolgt einfach mittels Reflexion.

Implementierung

Observer

/**
 * 监听器/观察者 玩游戏
 * 事件监听器
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:17
 */
public class PlayingGameListener {
    public PlayingGameListener(){
        System.out.println("我正在玩游戏 开始时间"+new Date());
    }
    public void stopPlayingGame(Date date){
        System.out.println("老师来了，快回到座位上，结束时间"+date);
    }
}
/**
 * 监听器/观察者 看电视
 * 事件监听器
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:17
 */
public class WatchingTVListener {
    public WatchingTVListener(){
        System.out.println("我正在看电视 "+new Date());
    }
    public void stopWatchingTV(Date date){
        System.out.println("老师来了，快关闭电视 。 结束时间"+date);
    }
}

Notifier

/**
 * 通知者的抽象类
 * 事件源
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:15
 */
public abstract class Notifier {
    //每个通知者都有一个需要通知的队列（通知：对象、方法、参数）
    private EventHandler eventHandler=new EventHandler();
    public EventHandler getEventHandler() {
        return eventHandler;
    }
    public void setEventHandler(EventHandler eventHandler) {
        this.eventHandler = eventHandler;
    }
    //增加需要帮忙放哨的学生
    public abstract void addListener(Object object,String methodName,Object...args);
    //告诉所有要帮忙放哨的学生：老师来了
    public abstract void notifyX();
}
/**
 * 通知者的子类，放哨人
 * 事件源
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:15
 */
public class GoodNotifier extends Notifier {
    @Override
    public void addListener(Object object, String methodName, Object...args) {
        System.out.println("有新的同学委托尽职尽责的放哨人!");
        this.getEventHandler().addEvent(object, methodName, args);
    }
    @Override
    public void notifyX() {
        System.out.println("尽职尽责的放哨人告诉所有需要帮忙的同学：老师来了");
        try{
            //优化：异步通知
            this.getEventHandler().notifyX();
        }catch(Exception e){
            e.printStackTrace();
        }
    }
}

Event

/**
 * 抽象出的事件类，也可以称为方法类
 * 事件
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:03
 */
public class Event {
    //要执行方法的对象
    private Object object;
    //要执行的方法名称
    private String methodName;
    //要执行方法的参数
    private Object[] params;
    //要执行方法的参数类型
    private Class[] paramTypes;
    //若干setter getter
    public Object getObject() {
        return object;
    }
    public String getMethodName() {
        return methodName;
    }
    public void setMethodName(String methodName) {
        this.methodName = methodName;
    }
    public Object[] getParams() {
        return params;
    }
    public void setParams(Object[] params) {
        this.params = params;
    }
    public Class[] getParamTypes() {
        return paramTypes;
    }
    public void setParamTypes(Class[] paramTypes) {
        this.paramTypes = paramTypes;
    }
    public Event(){
    }
    public Event(Object object,String methodName,Object...args){
        this.object=object;
        this.methodName=methodName;
        this.params=args;
        contractParamTypes(this.params);
    }
    //根据参数数组生成参数类型数组
    private void contractParamTypes(Object[] params){
        this.paramTypes=new Class[params.length];
        for(int i=0;i<params.length;i++){
            this.paramTypes[i]=params[i].getClass();
        }
    }
    //执行该 对象的该方法
    public void invoke() throws Exception{
        //通过class,method,paramTypes 确定执行哪个类的哪个方法
        Method method=object.getClass().getMethod(this.getMethodName(), this.getParamTypes());
        if(null==method){
            return;
        }
        //方法执行
        method.invoke(this.getObject(), this.getParams());
    }
}

Event-Handling

/**
 * 管理哪些事件需要执行
 * 管理事件
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:03
 */
public class EventHandler {
    //是用一个List
    private List<Event> objects;
    //添加某个对象要执行的事件，及需要的参数
    public void addEvent(Object object,String methodName,Object...args){
        objects.add(new Event(object,methodName,args));
    }
    public EventHandler(){
        objects=new ArrayList<Event>();
    }
    //通知所有的对象执行指定的事件
    public void notifyX() throws Exception{
        for(Event e : objects){
            e.invoke();
        }
    }
}

Hauptmethode

/**
 * 启动类
 *
 * @author Promsing(张有博)
 * @version 1.0.0
 * @since 2022/5/8 - 11:19
 */
public class EventMain {
    public static void main(String[] args) {
        //创建一个尽职尽责的放哨者
        Notifier goodNotifier = new GoodNotifier();
        //创建一个玩游戏的同学，开始玩游戏
        PlayingGameListener playingGameListener = new PlayingGameListener();
        //创建一个看电视的同学，开始看电视
        WatchingTVListener watchingTVListener = new WatchingTVListener();
        //玩游戏的同学告诉放哨的同学，老师来了告诉一下
        goodNotifier.addListener(playingGameListener, "stopPlayingGame", new Date());
        //看电视的同学告诉放哨的同学，老师来了告诉一下
        goodNotifier.addListener(watchingTVListener, "stopWatchingTV", new Date());
        try {
            //一点时间后
            Thread.sleep(1000);
        } catch (Exception e) {
            e.printStackTrace();
        }
        //老师出现，放哨的人通知所有要帮忙的同学:老师来了
        goodNotifier.notifyX();
    }
}

Zusammenfassung

1. Erstens: Hinter dem Beobachtermuster steckt eine delegierte Ereignistechnologie

2 . Das Observer-Muster kann nur Unterklassen benachrichtigen, die die Observer-Klasse erben, oder Sie können Observer in eine Schnittstelle umwandeln

for (Observer observer : observers) {
        observer.updateState();
}

3. Reflection, allone

 Method method=object.getClass().getMethod(this.getMethodName(), this.getParamTypes());
if(null==method){
        return;
}
 method.invoke(this.getObject(), this.getParams());

4. Der Delegat hat einen Ereignisausführer mehr als der Beobachter, wodurch der Beobachter und der Benachrichtiger entkoppelt werden, und kann jede Methode über jedes Objekt benachrichtigen. Lassen Sie Schüler vom Typ A und Schüler vom Typ B vollständig entkoppeln, das heißt, Typ A kennt die Schüler vom Typ B überhaupt nicht, kann aber die Schüler vom Typ B benachrichtigen

6 Richten Sie einen Auslösemechanismus ein, Sie können asynchrone Benachrichtigungen verwenden

7. Observer/Delegation ist der Abonnementveröffentlichung in MQ ziemlich ähnlich. Produzenten, Warteschlangen, Konsumenten.

Das obige ist der detaillierte Inhalt vonVergleichende Analyse von Beispielen für Beobachtermuster und Delegation in Java. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!