JAVA设计模式之观察者模式（通俗易懂的代码讲解）

心已赠人 2023-10-09 20:17 9阅读 0赞

简述：Java的**观察者模式**是一种**设计模式**，它定义了一种对象间的**一对多**的依赖关系，使得当一个对象的状态发生改变时，所有依赖于它的对象都能够得到收到消息通知。在这种模式中，被观察者维护了一个**观察者列表**，并提供了**添加**、**删除**和**通知**观察者的方法。

**目录**

一、什么是观察者模式

二、观察者模式使用场景

三、观察者与被观察者直观的关系图

四、完整代码示例，方便理解

1、首先定义被观察者接口类Observable：

2、观察者接口实现类：

3、再定义观察者接口类Observer：

4、再定义观察者接口实现类MyObserver：

5、主播开播发送通知消息演示：

--------------------

## 一、什么是观察者模式 ##

观察者先订阅被观察者对象，当被观察者行为发生改变时，观察者就能及时收到消息通知。

## 二、**观察者模式使用场景** ##

一个对象需要将自己的状态改变通知给其它多个对象，一个对象与它的多个依赖对象需要解耦，以便能对其修改，但不会对其它对象产生影响。

## 三、观察者与被观察者直观的关系图 ##

举例：张三（观察者1）、李四（观察者2）、张三（观察者1）在抖音上关注了某个美女主播，当美女主播开播时，他们的粉丝能收到开播的消息推送。在直播间里的这些观察者，可以观察到美女行为变化（如：跳舞、唱歌表演）。

![daa44161c12d49f5ada9ee9cbf931e41.png][]

## 四、完整代码示例，方便理解 ##

以下是一个Java观察者模式的示例代码：

#### 1、首先定义被观察者接口类Observable： ####

/**
     * 被观察者
     */
    public interface Observable {
    
        void addObserver(Observer observer);
    
        void removeObserver(Observer observer);
    
        void sendMessage(String message);
    }

#### 2、观察者接口实现类： ####

**内含有：**观察者列表，并提供了添加、删除和通知观察者的实现方法

/**
     * 被观察者实现类
     */
    public class MyObservable implements Observable {
    
        private static volatile MyObservable instance = null;
        
        private MyObservable() {
    
        }
        
        public static MyObservable getInstance() {
            if (instance == null) {
                synchronized (MyObserver.class) {
                    if (instance == null) {
                        instance = new MyObservable();
                    }
                }
            }
            return instance;
        }
        
        //维护的观察者列表
        private List<Observer> mObservers = new ArrayList<>();
    
    
        @Override
        public void addObserver(Observer observer) {
            mObservers.add(observer);
        }
    
        @Override
        public void removeObserver(Observer observer) {
            mObservers.remove(observer);
        }
    
        @Override
        public void sendMessage(String message) {
            notifyObserver(message);
        }
    
        /**
         * 通知所有观察着
         * 
         * @param message
         */
        private void notifyObserver(String message) {
            for (Observer observer : mObservers) {
                observer.receiveMessage(message);
            }
        }
    }

#### 3、再定义观察者接口类Observer： ####

/**
     * 观察者
     */
    public interface Observer {
        
        void receiveMessage(String message);
        
    }

#### 4、再定义观察者接口实现类MyObserver： ####

/**
     * 观察则实现类
     */
    public class MyObserver implements Observer {
        private String key;
        private ObserverListener mObserverListener;
    
        public MyObserver(String key, ObserverListener observerListener) {
            this.key = key;
            this.mObserverListener = observerListener;
        }
    
        @Override
        public void receiveMessage(String message) {
            if (mObserverListener != null) {
                System.out.println( key + "---------接收到消息:《" + message+"》");
                mObserverListener.receive(message);
            }
        }
    
        public interface ObserverListener {
            void receive(String message);
        }
    
    }

#### 5、主播开播发送通知消息演示： ####

/**
     * 演示代码
     */
    public class Main {
    
        public static void main(String[] args) {
            //粉丝1订阅
            MyObserver observer1=new MyObserver("粉丝-老林", message -> {
                  //这里进行消息处理
            });
            //粉丝2订阅
            MyObserver observer2=new MyObserver("粉丝-老王", message -> {
                   //这里进行消息处理
            });
    
            //加入观察者列表
            MyObservable.getInstance().addObserver(observer1);
            MyObservable.getInstance().addObserver(observer2);
    
            //通知所有订阅的观察者
            MyObservable.getInstance().sendMessage("大家好，菲儿已开播了,赶快来我直播间吧！");
        }
    }

![39b0201824b249aca7c4e72b7dbbb77a.png][]

--------------------

**各位看官，麻烦点个赞，感谢 ！！！**

[daa44161c12d49f5ada9ee9cbf931e41.png]: https://img-blog.csdnimg.cn/daa44161c12d49f5ada9ee9cbf931e41.png
[39b0201824b249aca7c4e72b7dbbb77a.png]: https://img-blog.csdnimg.cn/39b0201824b249aca7c4e72b7dbbb77a.png