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

时间：2017-01-10 08:22:55 阅读：226 评论：0 收藏：0 [点我收藏+]

标签：一对多 .com 努力奋斗 array img 如何使用 com 关系 bool

#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 }