观察者模式又称为发布订阅模式，是对象的行为模式。观察者模式定义了一种一对多的依赖关系，让多个观察者对象同时监视着被观察者的状态，当被观察者的状态发生变化时，会通知所有观察者，并让其自动更新自已。

 看上面那些可能不太容易理解，简单举个例子，假如有一个产品列表，当这个产品列表更新的时候就会同步到一些电商平台，最简单的可能会用if进行判断，当产品列表更新就同步，例如下图：

按照这种方法，如果还有其他电商合作，那么还要继续在if语句里增加逻辑。首先，如果多达数百家电商，那么if的逻辑就异常复杂了。如果推送商品给淘宝发生异常，需要捕捉异常，避免影响之后的电商接口，导致其不能往下进行，这样代码耦合就会增多，同时也不利于维护和扩展

在现实中对开发团队而言，可能产品库是产品团队维护，而合作的电商又是电商团队在维护，这样两个团队之间又要维护同一段代码，显然会造成责任不清的问题。

1.观察者模式

它更容易扩展，责任更加清晰，我们把电商看成是一个观察者而产品列表就是被观察者对象（被观察者），每一个观察者都可以观察到被观察者，当产品列表更新就会触发各个电商接口发送新产品到合作电商

 这种一个或者多个对象（电商接口）去监视另一个对象（产品列表）就被称为观察者模式

观察者模式要同时存在观察者和被观察者双方，观察者可以是多个，

2.被观察者

被观察者需要继承java.util.Observable类

package observer;

import java.util.ArrayList;
import java.util.List;
import java.util.Observable;
import java.util.Observer;

public class ProductList extends Observable {
    private List<String>productList =null;//产品列表
    private static ProductList instance=null;//类唯一实例
    private ProductList(){};//构建方法私有化
    //取唯一实例
    public static ProductList getInstance(){
        if (instance==null){
            instance=new ProductList();
            instance.productList=new ArrayList<>();
        }
        return instance;
    }
    /**
     * 增加观察者对象（电商接口）
     * observer观察者
     */
    public void addProductListObservable(Observer observer){
        this.addObserver(observer);
    }

    /**
     * 增加商品
     * newProduct新产品
     */
    public void addNewProduct(String newProduct){
        productList.add(newProduct);
        System.out.println("增加新产品");
        this.setChanged();//设置被观察者（产品列表）发生变化
        this.notifyObservers(newProduct);//通知电商接口（观察者）发生变化
    }


}

构建方法私有化，避免通过new的方式创建对象，而是通过getInstance方法获得产品列表单例，这里使用的是单例模式。

addProductListObserver可以增加一个电商接口（观察者）。
核心逻辑在 addProduct 方法上。在产品列表上增加了一个新的产品，然后调用setChanged方法。这个方法用于告知观察者当前被观察者发生了变化，如果没有，则无法触发其行为。最后通过notifyObservers告知观察者，让它们发生相应的动作，并将新产品作为参数传递给观察者。

3.观察者

观察者需要实现java.util.Observer接口的update方法，如下代码：

package observer;

import java.util.Observable;
import java.util.Observer;

public class JingDongObserver implements Observer {
    ProductList productList=ProductList.getInstance();

    @Override
    public void update(Observable o, Object product) {
        String newProduct=(String)product;
        System.out.println("增加新产品同步到京东"+product);
    }
}

package observer;

import java.util.Observable;
import java.util.Observer;

public class TaoBaoObserver implements Observer {
    @Override
    public void update(Observable o, Object product) {
        String newProduct=(String)product;
        System.out.println("发布新产品同步到淘宝"+product);
    }
}

开启测试：

package observer;

import java.util.Observable;
import java.util.Observer;

public class ObserverTest {
    public static void main(String[] args) {
        ProductList productList=ProductList.getInstance();//获得被观察者唯一对象
        JingDongObserver jingDongObserver=new JingDongObserver();
        TaoBaoObserver taoBaoObserver=new TaoBaoObserver();
        productList.addObserver(taoBaoObserver);//addObserver被观察者（产品列表）注册观察者
        productList.addObserver(jingDongObserver);
        productList.addNewProduct("新增产品");

    }
}

4.被观察者注册到观察者 

重点是被观察者（产品列表）需要注册到观察者，这样观察者才能观察到被观察者

productList.addObserver(taoBaoObserver);
//addObserver被观察者（产品列表）注册观察者
 productList.addObserver(jingDongObserver);

输出结果如下：

增加新产品
增加新产品同步到京东新增产品
发布新产品同步到淘宝新增产品