Analyse comparative d'exemples de modèle d'observateur et de délégation en Java

Code Background

Une classe, il y a deux types d'élèves, Type A : ne pas étudier, jouer, mais jouer les choses sont différentes, certains jouent à des jeux, certains regardent la télévision

Catégorie B : Les élèves qui sont des sentinelles, surveillent les mouvements de l'enseignant et avertissent immédiatement tout le monde si l'enseignant entre dans la classe.

Une demande s'est donc formée. Les élèves sentinelles devaient avertir tous les élèves qui jouaient : le professeur arrive, et différents élèves ont eu des réactions différentes. Certains ont immédiatement éteint la télévision, et certains ont arrêté de jouer.

Observer Pattern

Introduction

Observer Pattern : Définit une relation de dépendance un-à-plusieurs, permettant plusieurs objets observateur pour surveiller un certain objet de sujet en même temps.
Cet objet thématique avertira tous les objets observateurs lorsque son état change, leur permettant de se mettre automatiquement à jour.

Résout principalement : Le problème de la notification à d'autres objets des changements d'état d'un objet, et en tenant compte de la facilité d'utilisation et du faible couplage pour assurer un haut degré de collaboration.

Quand utiliser : Lorsque l'état d'un objet (objet cible) change, tous les objets dépendants (objets observateurs) seront notifiés et des notifications de diffusion seront effectuées.

Comment résoudre : Grâce à la technologie orientée objet, cette dépendance peut être affaiblie.

Code clé : Il y a une ArrayList dans la classe abstraite pour stocker les observateurs. # 🎜🎜 ## 🎜🎜 # réalisation # 🎜🎜 ## 🎜🎜 ## 🎜🎜 ## 🎜🎜 ## 🎜🎜 ## 🎜🎜 # # Observer (étudiant) # 🎜🎜 ## 🎜🎜 # #

/**
 * 抽象的观察者
 *
 * @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);
    }
}

# 🎜🎜 # # Notifiant (enseignant)

/**
 * 抽象的通知者
 *
 * @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;
    }
}

Méthode principale

/**
 * 控制台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("-----------");
    }
}

Introduction à la CommissionLa délégation peut penser à c'est une abstraction d'une fonction, une « classe » de fonctions. L'instance du délégué représentera une fonction spécifique

Un délégué peut transporter plusieurs méthodes, et toutes les méthodes sont invoquées dans l'ordre. Les méthodes portées par l’objet délégué n’ont pas besoin d’être de la même classe.

Le modèle d'événements délégués peut être défini par trois composants : les événements, les sources d'événements et les écouteurs d'événements.

La mise en œuvre de la délégation se met simplement en œuvre à l'aide de la réflexion.

réalisation

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();
        }
    }
}

#🎜🎜 # Événement # 🎜🎜 #

/**
 * 抽象出的事件类，也可以称为方法类
 * 事件
 * @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());
    }
}

# 🎜🎜 # Traitement d'événements # 🎜🎜 # #

/**
 * 管理哪些事件需要执行
 * 管理事件
 *
 * @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();
        }
    }
}

# 🎜🎜 # Méthode principale # 🎜🎜 #

/**
 * 启动类
 *
 * @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();
    }
}

# 🎜🎜 ## 🎜🎜 ## 🎜🎜 ## 🎜🎜 # Résumé # 🎜🎜 # # 🎜 🎜 🎜#1. D'abord le modèle d'observateur, puis la technologie d'événements délégués

2. Le modèle d'observateur ne peut notifier que les sous-classes qui héritent de la classe Observer, ou vous pouvez transformer l'Observateur en interface

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

#🎜🎜 # 3. Le délégué peut notifier n'importe quelle méthode de n'importe quelle classe. Réflexion, tout le monde

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

4. Le délégué a un exécuteur d'événement de plus que l'observateur, dissociant l'observateur du notificateur, et peut notifier n'importe quelle méthode de n'importe quel objet. Laissez les étudiants de type A et les étudiants de type B être complètement découplés, c'est-à-dire que le type A ne connaît pas du tout les étudiants de type B, mais peut avertir les étudiants de type B

6. vous pouvez utiliser les notifications asynchrones

7 L'observateur/délégué, c'est un peu comme l'abonnement et la publication dans MQ. Producteurs, files d'attente, consommateurs.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!