首页 > 代码库 > 设计模式>>>观察者模式

设计模式>>>观察者模式

#1、什么是观察者模式?

  观察者模式=(出版者+订阅者)模式,观察者模式定义了一种一对多的依赖关系,让多个观察者对象同时监听某一个主题对象。这个主题对象在状态发生变化时,会通知所有观察者对象,使它们能够自动更新自己。

  例如:你有一个新闻APP,你订阅了《程序员》模块,当这个模块有新的文章更新时,你能在第一时间获取更新。当你厌倦了这个模块的内容时,取消订阅就行了。简单点理解就是:注册--->接收消息--->取消--->不在通知。

#2、具体如何使用?

  *2.1场景描述:目前需要开发一款新闻应用,用户订阅某个模块后,系统会主动给他发送这个模块的消息,用户取消订阅后,不在向该用户推送这个模块的消息。

  *2.2设计类图如下:

  技术分享

 

  *2.3类图描述

   抽象出版者(NewsService):抽象观察者模式的出版中心,注册订阅用户,存储订阅用户,删除订阅用户,新闻推送,可以类比为最基本的用户增删改查。

   具体出版者(NewsServiceImpl):出版中心的具体实现,为所有订阅的用户发送通知。

   抽象订阅者(UserService):抽象订阅者需要的新闻信息,展示方式。

     具体订阅者(UserOne):抽象订阅者的具体实现,自定义新闻的展示方式。   

#3、项目具体实现细节

   *3.1项目结构

       技术分享

  *3.2具体代码

1 public interface NewsService {
2     void registerNews(UserService userService);
3     void setNewsInfo(NewsBean newsBean);
4     void notifyNews();
5     void cancleNews(UserService userService);
6 
7     void setState();
8     boolean getState();
9 }

  

1 public interface UserService {
2     void updateNews(NewsBean newsBean);
3     void displayNews();
4 }

 

 1 public class NewServiceImpl implements NewsService {
 2     private boolean state = false;
 3     private NewsBean newsBean;
 4     private List<UserService> userServiceList = null;
 5 
 6     private List<UserService> getUserServiceList(){
 7         if(userServiceList ==null){
 8             userServiceList = new ArrayList<>();
 9         }
10         return userServiceList;
11     }
12 
13     /**
14      * 初始化
15      */
16     public NewServiceImpl(){
17         getUserServiceList();
18     }
19 
20     @Override
21     public void registerNews(UserService userService) {
22         userServiceList.add(userService);
23     }
24 
25     @Override
26     public void cancleNews(UserService userService) {
27         userServiceList.remove(userService);
28     }
29 
30     /**
31      * 通知所有订阅用户
32      */
33     @Override
34     public void notifyNews() {
35         for (UserService userService : userServiceList) {
36             userService.updateNews(newsBean);
37         }
38     }
39 
40     /**
41      * 设置新闻信息
42      * @param newsBean
43      */
44     @Override
45     public void setNewsInfo(NewsBean newsBean){
46         this.newsBean = newsBean;
47         notifyNews();
48     }
49 
50     @Override
51     public void setState() {
52         state = true;
53     }
54 
55     @Override
56     public boolean getState() {
57         return this.state;
58     }
59 }

 

 1 public class UserOne implements UserService{
 2     private NewsService newsService;
 3     private NewsBean newsBean;
 4     /**
 5      * 订阅新闻
 6      * @param newsService
 7      */
 8     public UserOne(NewsService newsService){
 9         this.newsService = newsService;
10         newsService.registerNews(this);
11     }
12     @Override
13     public void updateNews(NewsBean newsBean) {
14         this.newsBean = newsBean;
15         displayNews();
16     }
17 
18     @Override
19     public void displayNews() {
20         System.out.println(newsBean);
21     }
22 }
 1 public class UserTwo implements UserService{
 2     private NewsService newsService;
 3     private NewsBean newsBean;
 4     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
 5 
 6     /**
 7      * 订阅新闻
 8      * @param newsService
 9      */
10     public UserTwo(NewsService newsService){
11         this.newsService = newsService;
12         newsService.registerNews(this);
13     }
14     @Override
15     public void updateNews(NewsBean newsBean) {
16         this.newsBean = newsBean;
17         displayNews();
18     }
19 
20     @Override
21     public void displayNews() {
22         System.out.println("\n>>>高级用户推送信息:"+"\n"+newsBean.getNewsTitle()+"\t"
23                 +sdf.format(newsBean.getNewsDate())+"\n"+newsBean.getNewsContent());
24     }
25 }

   

 1 public class NewsSystem {
 2 
 3     public static void main(String[] args) {
 4         NewsService newsService = new NewServiceImpl();
 5         // 用户类型一
 6         UserOne userOne = new UserOne(newsService);
 7         // 用户类型二
 8         UserTwo userTwo = new UserTwo(newsService);
 9         // 新闻推送
10         newsService.setNewsInfo(new NewsBean("天道酬勤","习大大说:“天上不会掉馅饼," +
11                 "努力奋斗才能梦想成真。”",new Date()));
12         // 用户类型一 取消订阅
13         newsService.cancleNews(userOne);
14         // 又一次新闻推送
15         newsService.setNewsInfo(new NewsBean("观察者模式","观察者模式=(出版者+订阅者)" +
16                 "模式",new Date()));
17     }
18 }

  *3.3运行结果

  技术分享

#4、模式总结

    *4.1优点

    出版者和订阅者之间用松耦合的方式结合,订阅者不必关心出版者如何给自己推送消息;

    在对象之间定义一对多的依赖关系,对订阅者统一进行推送消息。

  *4.2适用场景

    当一个对象改变公共对象时,他不知道在其他什么地方用到这个公共对象。

转载请标明地址:http://www.cnblogs.com/huaxingtianxia/p/6266913.html

   

    

设计模式>>>观察者模式