最近在一个PHP产品中需要加入对数据状态进行监控的功能集。当数据符合或不符合某种预设规则时&＃xff0c;需要自动通知用户&＃xff0c;通知的形式可以是email、短信、主页推送等。 这样的规则有多个&＃xff0c;随着需求的演化&＃xff0c;QP和老常会增加新的规则。
此时产品已基本成型&＃xff0c;要增加该功能&＃xff0c;不能对原有实现的其他功能、系统状态有影响。系统对于监控功能来说&＃xff0c;是只读的。
经设计决策&＃xff0c;监控功能采用observer模式的变种来实现。原理如下图。
- DataCollector&＃xff1a;负责收集需要监控的数据&＃xff0c;并对所有数据遍历&＃xff0c;执行预订规则检验。
-
- targets 属性: 被监控的数据对象集合&＃xff0c;其中每个元素均属于Target类型的对象&＃xff1b;
- iterate 方法&＃xff1a;遍历targets&＃xff0c;对每项数据调用callObserver方法&＃xff1b;
- callObserve 方法&＃xff1a;对接收的数据对象&＃xff0c;调用ObserverCenter的notify方法&＃xff0c;后者用所有已定义规则一一检查数据对象。
- Target&＃xff1a;被监控的数据对象&＃xff0c;具有统一的结构。
-
- states 属性&＃xff1a;被监控的数据的具体值。
- ObserverCenter&＃xff1a;维护数据检查规则集&＃xff0c;并将这些规则应用到被监控数据上。当有通知内容生成时&＃xff0c;将针对某一数据项的所有通知打包发送给用户。 在Observer模式中&＃xff0c;这个observer的注册机制是包含在Target中的&＃xff0c;但在产品中&＃xff0c;所有的target来源于多张数据表&＃xff0c;需要 DataCollector的在初始化时&＃xff0c;进行数据规格化。我们将原始数据的不一致屏蔽在DataCollector中&＃xff0c;将公共部分&＃xff08;对数据的监控规则&＃xff09; 集中在ObserverCenter中&＃xff0c;有利于后期规则变化时&＃xff0c;影响域更小。
-
- observers 属性&＃xff1a;监控规则对象集合&＃xff0c;observer的类名称数组。
- initObservers 方法&＃xff1a;收集所有的监控规则&＃xff0c;初始化observers属性。监控规则可存储于DB中&＃xff0c;也可以在配置文件中。
- addObserver 方法和 removeObserver 方法&＃xff1a;若监控规则可由用户增减&＃xff0c;这两个方法可作为增减接口&＃xff0c;将用户操作落实到监控规则的存储地&＃xff08;DB或配置文件&＃xff09;。
- notify 方法&＃xff1a;遍历监控规则集合observers&＃xff0c;用这些规则一一检验target数据&＃xff0c;即生成一个observer实例&＃xff0c;调用其checkTarget 方法。收集这些执行结果&＃xff08;即string类型的通知信息&＃xff09;&＃xff0c;一并发给用户。
- AbstractObserver&＃xff1a;监控规则虚基类。
-
- checkTarget 方法&＃xff1a;接收target参数&＃xff0c;返回通知内容string&＃xff0c;若无通知内容&＃xff0c;则返回空串。
- WinObserver&＃xff1a;具体的监控规则实现类&＃xff0c;继承AbstractObserver&＃xff0c;实现checkTarget方法。
- DangerObserver&＃xff1a;同上。
当监控规则需求变化时&＃xff0c;只需要改变具体的规则实现类即可。可以定义许多这样的规则实现类&＃xff0c;定义类后在存储地&＃xff08;DB、配置文件&＃xff09;登记该类&＃xff0c;运行时ObserverCenter将会自动加载实施该规则。
对上述模式还有一个可以增强的地方&＃xff0c;就是将给用户发送通知的功能从ObserverCenter转移到DataCollector中&＃xff0c;可以将某个用户的所有数据聚合后一次发送&＃xff0c;避免了一条数据发送一次通知。
京公网安备 11010802041100号