利用接口实现自定义监听事件以及观察者模式

前段时间刚做过,事件一长就容易忘,赶紧记下来先

package com.xujingyang.JT;

public class Jt {
    interface Listenner{
        public void run();
    }
    
    
     class test{
         Listenner listenner=null;
        public void setOnRunListenner(Listenner ls){
            listenner=ls;
        }
        
        public void changeEvent(){
            if(listenner!=null){
                listenner.run();
            }
        }
    }
    
    
    public static void main(String[] args) {
        test t=new Jt().new test();
        t.setOnRunListenner(new Listenner() {
            
            @Override
            public void run() {
                System.out.println("我是run");
            }
        });
        
        t.changeEvent();
    }
}

代码稍微修改,便是标准的观察者模式

观察者模式很好理解，类似于邮件订阅和RSS订阅，当我们浏览一些博客或wiki时，经常会看到RSS图标，就这的意思是，当你订阅了该文章，如果后续有更新，会及时通知你。其实，简单来讲就一句话：当一个对象变化时，其它依赖该对象的对象都会收到通知，并且随着变化！对象之间是一种一对多的关系。先来看看关系图：

package com.xujingyang.JT;

import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;

public class Jt {
    interface Listenner {
        public void run();
    }

    class Listenner1 implements Listenner {

        @Override
        public void run() {
            System.out.println("run1");
        }

    }

    class Listenner2 implements Listenner {

        @Override
        public void run() {
            System.out.println("run2");
        }

    }

    interface subject {
        /* 增加观察者 */
        public void add(Listenner observer);

        /* 删除观察者 */
        public void del(Listenner observer);

        /* 通知所有的观察者 */
        public void notifyObservers();

        /* 自身的操作 */
        public void operation();
    }
    
    abstract class AbstractSubject implements subject{

        List< Listenner> list=new LinkedList<Listenner>();
        @Override
        public void add(Listenner observer) {
            list.add(observer);
        }

        @Override
        public void del(Listenner observer) {
            list.remove(observer);
        }

        @Override
        public void notifyObservers() {
            Iterator<Listenner> iterator = list.iterator();
            while (iterator.hasNext()) {
                iterator.next().run();
            }
        }

     }

    
    class mySubject extends AbstractSubject{

        @Override
        public void operation() {
            System.out.println("开始啦...");
            notifyObservers();
        }
        
    }
    
    

    public static void main(String[] args) {
        subject s=new Jt().new mySubject();
        s.add(new Jt().new Listenner1());
        s.add(new Jt().new Listenner2());
        s.operation();
    }
}

结果: