码迷,mamicode.com
首页 > 其他好文 > 详细

设计模式之观察者模式

时间:2016-05-25 12:52:00      阅读:158      评论:0      收藏:0      [点我收藏+]

标签:

观察者模式,顾名思义需要两方,一方是被观察的(主题),另一方就是观察者。就拿直播间来说,直播间就相当于一个主题,而用户就是观察者,用户进入直播间就是向主题注册(加进了用户队列),一般来说,用户可以离开直播间(从主题中移除该用户),当然直播间的主播也可以将用户移出直播间(也相当于从主题中移除该用户)。也就是说其实主题和观察者的关系是一对多的关系,主题数据的变化,观察者能及时知道。

下面进行观察者模式的实现,首先是主题接口:

 1 package cn.liu.java.myjava.Interface;
 2 /**
 3  * 这是主题接口,主要作用是注册观察者,移除观察者还有就是通知观察者
 4  * 假设这里的应用场景是告知有当前注册的用户,现在有多少个观察者在监听
 5  * @author Administrator
 6  *
 7  */
 8 public interface Subject {
 9     //注册观察者
10     public void registerObserver(Observer observer);
11     //移除观察者
12     public void removeObserver(Observer observer);
13     //通知所有观察者
14     public void notifyObservers();
15 }

接下来是观察者接口:

 1 package cn.liu.java.myjava.Interface;
 2 /**
 3  * 观察者接口,该观察者主要是知道当前有多少个观察者注册了(相当于在线场景)
 4  * @author Administrator
 5  *
 6  */
 7 public interface Observer {
 8     //观察者被通知时候调用的方法
 9     public void show(int num);
10     //观察者主动注册
11     public void register();
12     //观察者主动取消订阅
13     public void remove();
14 }

接下来是主题接口的具体实现类:

 1 package cn.liu.java.myjava;
 2 
 3 import java.util.LinkedList;
 4 import java.util.List;
 5 
 6 import cn.liu.java.myjava.Interface.Observer;
 7 import cn.liu.java.myjava.Interface.Subject;
 8 
 9 /**
10  * 主题的实现类
11  * @author Administrator
12  *
13  */
14 public class SubjectImpl implements Subject{
15     //主题要通知观察者,那么必须在主题中注册观察者,用一个list来存储观察者。
16     //因为linkedlist的实现是使用了链表的实现方式,观察者模式经常需要增删用户,
17     //删除用户如果用链表就只需要调整指针,不需要移动后面的元素
18     private List<Observer> observers = new LinkedList<Observer>();
19 
20     public void registerObserver(Observer observer) {
21         // TODO Auto-generated method stub
22         observers.add(observer);
23         //添加了观察者就通知所有的观察者对象
24         notifyObservers();
25     }
26 
27     public void removeObserver(Observer observer) {
28         // TODO Auto-generated method stub
29         observers.remove(observer);
30         notifyObservers();
31     }
32     
33     public void notifyObservers() {
34         // TODO Auto-generated method stub
35         Observer observer = null;
36         for (int i = 0; i < observers.size(); i++) {
37             if ((observer = observers.get(i)) != null) {
38                 observer.show(observers.size());
39             }
40         }
41     }
42 
43     
44 }

最后就是观察者的具体实现:

package cn.liu.java.myjava;

import cn.liu.java.myjava.Interface.Observer;
import cn.liu.java.myjava.Interface.Subject;
/**
 * 观察者的实现
 * @author Administrator
 *
 */
public class ObserverImpl implements Observer{
    //观察者需要保留一个主题的引用,方便观察者的注册和移除
    private Subject subject;
    //为每个观察者给定一个名字
    private String name;
    public ObserverImpl(Subject subject , String name) {
        this.subject = subject;
        this.name = name;
    }
    public void show(int num) {
        // TODO Auto-generated method stub
        System.out.println(name+"收到通知:现在有"+num+"人注册了该服务");
    }
    public void register() {
        // TODO Auto-generated method stub
        subject.registerObserver(this);
    }
    public void remove() {
        // TODO Auto-generated method stub
        subject.removeObserver(this);
    }
    
}

接下来就是测试类:

 1 package cn.liu.java.myjava;
 2 
 3 import org.junit.Test;
 4 
 5 import cn.liu.java.myjava.Interface.Observer;
 6 import cn.liu.java.myjava.Interface.Subject;
 7 
 8 public class MyTest {
 9     @Test
10     public void testName() throws Exception {
11         Subject subject = new SubjectImpl();
12         Observer observer1 = new ObserverImpl(subject , "观察者一");
13         Observer observer2 = new ObserverImpl(subject , "观察者二");
14         Observer observer3 = new ObserverImpl(subject , "观察者三");
15         //观察者主动要求注册(其实其中的内部实现也是通过主题对象来注册)
16         subject.registerObserver(observer1);
17         //通过主题对象来注册
18         observer2.register();
19         observer3.register();
20         observer2.remove();
21         subject.removeObserver(observer3);
22         observer1.remove();
23         observer1.remove();
24     }
25 }

测试结果如图:

技术分享

观察者模式基本实现就是这样了,java类库中也有观察者模式的具体接口,可以直接使用java类库来实现观察者模式,上述例子中不太好的就是由主题来进行各个观察者的通知,其实比较好的就是观察者可以主动到主题中抓取数据,这样可以方便不同的观察者按需来抓取需要的数据,减小主题的复杂性。

下面实现观察者主动去提取主题中的数据(size)

 1 package cn.liu.java.myjava.Interface;
 2 /**
 3  * 这是主题接口,主要作用是注册观察者,移除观察者还有就是通知观察者
 4  * 假设这里的应用场景是告知有当前注册的用户,现在有多少个观察者在监听
 5  * @author Administrator
 6  *
 7  */
 8 public interface Subject {
 9     //注册观察者
10     public void registerObserver(Observer observer);
11     //移除观察者
12     public void removeObserver(Observer observer);
13     //通知所有观察者
14     public void notifyObservers();
15 }
 1 package cn.liu.java.myjava.Interface;
 2 /**
 3  * 观察者接口,该观察者主要是知道当前有多少个观察者注册了(相当于在线场景)
 4  * @author Administrator
 5  *
 6  */
 7 public interface Observer {
 8     //观察者被通知时候调用的方法
 9     public void show();
10     //观察者主动注册
11     public void register();
12     //观察者主动取消订阅
13     public void remove();
14 }
 1 package cn.liu.java.myjava;
 2 
 3 import java.util.LinkedList;
 4 import java.util.List;
 5 
 6 import cn.liu.java.myjava.Interface.Observer;
 7 import cn.liu.java.myjava.Interface.Subject;
 8 
 9 /**
10  * 主题的实现类
11  * @author Administrator
12  *
13  */
14 public class SubjectImpl implements Subject{
15     //主题要通知观察者,那么必须在主题中注册观察者,用一个list来存储观察者。
16     //因为linkedlist的实现是使用了链表的实现方式,观察者模式经常需要增删用户,
17     //删除用户如果用链表就只需要调整指针,不需要移动后面的元素
18     private List<Observer> observers = new LinkedList<Observer>();
19     private int size;
20     public void registerObserver(Observer observer) {
21         // TODO Auto-generated method stub
22         observers.add(observer);
23         size = observers.size();
24         //添加了观察者就通知所有的观察者对象
25         notifyObservers();
26     }
27 
28     public void removeObserver(Observer observer) {
29         // TODO Auto-generated method stub
30         observers.remove(observer);
31         size = observers.size();
32         notifyObservers();
33     }
34     
35     public void notifyObservers() {
36         // TODO Auto-generated method stub
37         Observer observer = null;
38         for (int i = 0; i < observers.size(); i++) {
39             if ((observer = observers.get(i)) != null) {
40                 observer.show();
41             }
42         }
43     }
44 
45     public int getSize() {
46         return size;
47     }
48     
49     
50 }
 1 package cn.liu.java.myjava;
 2 
 3 import cn.liu.java.myjava.Interface.Observer;
 4 import cn.liu.java.myjava.Interface.Subject;
 5 /**
 6  * 观察者的实现
 7  * @author Administrator
 8  *
 9  */
10 public class ObserverImpl implements Observer{
11     //观察者需要保留一个主题的引用,方便观察者的注册和移除
12     private Subject subject;
13     //为每个观察者给定一个名字
14     private String name;
15     public ObserverImpl(Subject subject , String name) {
16         this.subject = subject;
17         this.name = name;
18     }
19     public void show() {
20         // TODO Auto-generated method stub
21         System.out.println(name+"收到通知:现在有"+((SubjectImpl)subject).getSize()+"人注册了该服务");
22     }
23     public void register() {
24         // TODO Auto-generated method stub
25         subject.registerObserver(this);
26     }
27     public void remove() {
28         // TODO Auto-generated method stub
29         subject.removeObserver(this);
30     }
31     
32 }

测试结果和第一个实现没区别,第二个只是不需要主题传递数据给观察者,观察者直接从主题提取需要的数据。

 

设计模式之观察者模式

标签:

原文地址:http://www.cnblogs.com/liucaihao/p/5526450.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!