image
image.gif
/**
* 观察者模式是一种比较常见的方案，某些事件发生时（比如状态转变），如果一个对象（通
* 常我们称之为主题）需要自动地通知其他多个对象（称为观察者），就会采用该方案。创建图形
* 用户界面（GUI）程序时，你经常会使用该设计模式。这种情况下，你会在图形用户界面组件（比
* 如按钮）上注册一系列的观察者。如果点击按钮，观察者就会收到通知，并随即执行某个特定的
* 行为。 但是观察者模式并不局限于图形用户界面。比如，观察者设计模式也适用于股票交易的
* 情形，多个券商可能都希望对某一支股票价格（主题）的变动做出响应。
*/
public interface Subject {
/**注册一个新的观察者*/
void registerObserver(Observer o);
/**通知它的观察者一个新闻的到来*/
void notifyObserver(String tweet);
}
class Feed implements Subject{
private final List<Observer> observers = CollUtil.newArrayList();
/**
* 注册一个新的观察者
*
* @param o 观察者
*/
@Override
public void registerObserver(Observer o) {
this.observers.add(o);
}
/**
* 通知它的观察者一个新闻的到来
*
* @param tweet 消息
*/
@Override
public void notifyObserver(String tweet) {
observers.forEach(o->o.notify(tweet));
}
}
image.gif
public interface Observer {
void notify(String tweet);
}
class NYTimes implements Observer{
@Override
public void notify(String tweet) {
if(tweet!=null && tweet.contains("money")){
System.out.println("Breaking news in NY! " + tweet);
}
}
}
class Guardian implements Observer{
@Override
public void notify(String tweet) {
if(tweet!=null && tweet.contains("queen")){
System.out.println("Yet another news in London... " + tweet);
}
}
}
class LeMonde implements Observer{
@Override
public void notify(String tweet) {
if(tweet!=null && tweet.contains("wine")){
System.out.println("Today cheese,wine and news!! " + tweet);
}
}
}
image.gif
public class FeedTest {
@Test
public void registerObserver() {
///java8以前写法
Feed f = new Feed();
f.registerObserver(new NYTimes());
f.registerObserver(new Guardian());
f.registerObserver(new LeMonde());
f.notifyObserver("The queen said her favourite book is java 8 in action!");
///java8 lambda表达式
f.registerObserver(tweet -> {
if(tweet!=null && tweet.contains("book")){
System.out.println("Point book->" + tweet);
}
});
f.registerObserver(tweet -> {
if(tweet!=null && tweet.contains("java")){
System.out.println("jdk->" + tweet);
}
});
f.notifyObserver("The queen said her favourite book is java 8 in action!");
}
}
image.gif
