解决问题

观察者模式又称之为发布-订阅模式，它的一个关键作用是使角色之间解耦合。

应用场景

常见的应用场景是分布式事务处理与MVC架构，但我们也可以将其应用于解耦合。

原理图（UML）

image

Observer: 观察者接口，即当观察者观察到变化之后应该执行的操作
ConcreteObserver:具体执行操作的的实体对象
Subject:主题，也可以理解为被观察者，它主要由三个动作：添加观察对象、删除观察对象、通知观察对象，它持有一上属性：观察者对象列表

示例

类似发布-订阅的示例已经有很多了，我们举一个单纯解耦合的示例：当一个请求到来时，我需要调用多个（例子中使用两上个）依赖服务并返回结果

Observer:这里我将其理解为一个后台服务，一旦收到一个请求，就需要调用后台服务拿数据

public interface Server<T> { 
    public T excute(Request params); 
}

public class RpcServer<T> implements Server<T> { 
    public T excute(Request params) { 
        return null;// 定义具体的服务调用。。。。 
    } 
    // 参数解析、结果转换、异常处理、容灾等。。。。 
 
}

public class HttpServer<T> implements Server<T> { 
    public T excute(Request params) { 
        return null;// 定义具体的服务调用。。。。 
    } 
    // 参数解析、结果转换、异常处理、容灾等。。。。 
 
}

Suject:这里将其理解为一个HTTP服务，需要调用多个后台服务来为前台提供数据

/** 
 * 
 * 即为controller提供服务，controller传入request对象，service返回组装结果 
 */ 
public interface Service<R> { 
    public R getData(); 
}

public class HttpService implements Service<List< Object>> { 
    public List<Server> servers = Lists.newArrayList(); 
    public List<Object> getData() { 
        List<Object> result = Lists.newArrayList(); 
        // 这里可以一般用异步来实现。。。。 
        for (Server server : servers) { 
            result.add(server.excute(null)); 
        } 
        return null; 
    } 
 
}