ruby、javascript、php中的观察者模式实现代码-巨人网络通讯

ruby、javascript、php中的观察者模式实现代码

面试被问及到js中的观察者模式，这玩意儿早就了解过，可以说是动态语言中非常有用的一个设计模式，非常惭愧的没有系统的研究过。不过没关系，哪里不会补哪里，立刻动手，用所会的语言都实现一遍。

观察者模式

关于观察者模式，《松本行弘的程序世界》讲的非常清楚：观察者模式是当某个对象状态发生变化时，依存于该状态的全部对象自动得到通知，被观察者和观察者们是一对多的关系。书中还举了一个非常易懂的例子：获取系统当前时间并输出到命令行中。如果要硬编码也很简单，定义一个方法，先获取时间，然后再处理展示。这样获取时间的功能基本就不能复用了，因为带了个处理展示的拖油瓶。

如果用观察者模式则可以这样：定义两个类，一个用于计时，获取当前时间；另一个用于展示时间。展示时间的类就是观察者，这样做的好处是降低相互的依赖性。第一个类改变后不需要处理任何事物，只需要发出通知告诉它的观察者们，具体事物由它们处理。比如有一天我们想换种形式展示时间，或者用多种方式展示时间，完全不需要牵扯到第一个类。

PS:《松本行弘的程序世界》真是一本好书。起初是想把这本书当做ruby教程来读的，后来发现根本不是，书中用非常易懂的语言深入浅出的讲明白了很多深奥的哲学思想。虽然这本书对我这种刚入门的菜鸟来说几乎没有什么实用价值，但是读完之后有种豁然开朗的感觉，是一次非常好的阅读体验。

ruby实现

用ruby实现观察者模式简直简单清晰的令人发指，上代码：

复制代码代码如下:

require "observer"

#被观察者

class Subject

    include Observable

    def notify

        #do sth

        changed #更新标志为真

        notify_observers(*args) #如果更新标志为真，调用观察者带参数args的方法

    end

end

#观察者

class Obs

    #回调函数，好像只能这么叫

    def update

        #do sth

    end

end

#实例

sub = Subject.new

sub.add_observer(Obs.new)

sub.notify

没错，就是这么简单。。。
主要是依靠Observer模块，除了上面用到的，此模块还有如下接口：

1.delete_observer(obj) 删除特定的观察者
2.delete_observers 删除全部观察者
3.count_observers 获取观察者数目
4.changed? 检查更新标志

php实现

php实现起来也不麻烦：

复制代码代码如下:

//被观察者

class Subject

{

    private $_observers;

    public function __construct() {

        $this->_observers = array();

    }

    public function add_observer($obs) {

        $this->_observers[] = $obs;

    }

    public funtion delete_observer($bos) {

        $index = array_search($bos, $this->_observers);

        unset($this->_observers[$index]);

    }

    public function notify_observers() {

        foreach($this->_observers as $v) {

            $v->update();

        }

    }

}

//观察者

class Observer

{

    public function __construct() {

        do sth;

    }

    public function update() {

        do sth;

    }

}

//实例

$sub = new Subject();

$obs = new Observer();

$sub->add_observer($obs);

$sub->notify_observers();

js实现

js实现起来也不麻烦，就是得写些工具函数方便用，比如删除数组指定的元素。下面只用最简单的实现方法。

复制代码代码如下:

//被观察者

function Subject() {

    var _this = this;

    this.observers = [];

    this.addObserver = function(obj) {

        _this.observers.push(obj);

    }

    this.deleteObserver = function(obj) {

        var length = _this.observers.length;

        for(var i = 0; i  length; i++) {

            if(_this.observers[i] === obj) {

                _this.observers.splice(i, 1);

            }

        }

    }

    this.notifyObservers = function() {

        var length = _this.observers.length;

        console.log(length)

        for(var i = 0; i  length; i++) {

            _this.observers[i].update();

        }

    }

}

//观察者

function Observer() {

    this.update = function() {

        alert(1)

    }

}

var sub = new Subject();

var obs = new Observer();

sub.addObserver(obs);

sub.notifyObservers();

var sub = new Subject();