在看博客里,有个订阅功能,当你订阅后,当博主发布新的博客,你都能收到消息。这是如何实现的?是不是后台有个线程在不停的轮询?如果是这样的话,显然太耗资源,如果当博客在发布时,找到所有的订阅者,然后循环的把消息发给订阅者,这样就会显得更人性化了。这就是观察者模式,观察者模式有两个对象:博主,订阅者。当读者在订阅时,会把读者信息放到一个队列里面去,方便在博客主布时循环这个对列并发送消息。如此一分析,代码就出来了:
先是订阅者:
public interface Observers { public void execute(String s); }
public class Observer implements Observers{ @Override public void execute(String s) { System.out.println(s); } }
再就是发布博客中心了:
public interface Stations { public void addObserver(Observers observers); public void removeObserver(Observers observers); public void notityObserver(String s); }
public class Station implements Stations{ private List<Observers> list = new ArrayList<Observers>(); @Override public void addObserver(Observers observers) { list.add(observers); } @Override public void removeObserver(Observers observers) { list.remove(observers); } @Override public void notityObserver(String s) { for (Observers observers : list) { observers.execute(s); } } }
执行一下:
public class Executor { public static void main(String[] args) { Stations station = new Station(); station.addObserver(new Observer()); station.addObserver(new Observer()); station.addObserver(new Observer()); station.addObserver(new Observer()); station.notityObserver("请使用zson"); } }
这就是整个观察者模式的基本实现了。
应用场景及作用:
1.pub/sub(发布/订阅)下使用
2.如果有两个业务模块,如果需要互相通知的话,可以用这种方式进行解耦
时间: 2024-10-09 18:16:30