【java規則引擎】規則引擎RuleBase中利用觀察者模式

（1）當RuleBase中有規則添加或刪除，利用觀察者模式實現，一旦有變動，規則引擎其他組件也做出相應的改變。
（2）學習思想：當一個應用中涉及多個組件，為了實現易擴展，解耦思想。可以利用觀察者模式實現。基於易變動的數據結構中加入監聽者，監聽者依據被監聽者的變動動作，定義自己的動作。在監聽者內部通知其他組件做出相應改變。實現面向對象的思想。組建之間實現了解藕。

 

一：被監聽數據，也就是規則網絡RuleBase的接口定義

package com.nonbankcard.commons.doorls.ruleBaseListern;
/**
 * 定義一個核心數據的對象的接口
 * 
 * @author sxf
 *
 */
public interface RuleBase {
    /**
     * 添加一個規則
     * @param rule
     */
    public void addRule(String rule);
    /**
     * 刪除一個規則
     * @param rule
     */
    public void removeRule(String rule);
    /**
     * 修改一個規則
     * @param rule
     */
    public void updateRule(String rule);

}

二：被監聽數據，也就是規則網絡RuleBase的實現定義

package com.nonbankcard.commons.doorls.ruleBaseListern;
/**
 * 真正的RuleBase對象
 * @author sxf
 *
 */
public class ReootoRuleBase  implements RuleBase{
    
    private RuleBaseListernSupport support;

    @Override
    public void addRule(String rule) {
        support.addRule(rule);
        System.out.println("ReootoRuleBase.addRule(添加規則的操作)");
        
    }

    @Override
    public void removeRule(String rule) {
        support.removeRule(rule);
        System.out.println("ReootoRuleBase.removeRule(規則刪除的操作)");
    }

    @Override
    public void updateRule(String rule) {
    
        
    }

    
}

三：用於管理不同組件監聽器的監聽管理者。

package com.nonbankcard.commons.doorls.ruleBaseListern;

import java.util.List;


/**
 * 管理ruleBase某些動作的事件監聽管理
 * 
 * （1）當ruleBase對象發生某個動作，都要告訴監聽管理器，監聽管理器做相應的處理
 * （2）監聽管理者，包括監聽器的行為都是依據RuleBase的動作為定。
 * @author sxf
 *
 */
public class RuleBaseListernSupport {
    
    /**
     * 事件支持的監聽器集合
     */
    private List<RuleBaseEventListern> listeners;

    /**
     * 規則添加監聽器發布事件
     * @param rule
     */
    public void addRule(String rule) {
        RuleBaseEvent event=new RuleBaseEvent(rule);
        for(RuleBaseEventListern listener:listeners){
            listener.ruleBaseAddRule(event);
        }
    }

    
    /**
     * 規則刪除監聽器發布事件
     * @param rule
     */
    public void removeRule(String rule){
        RuleBaseEvent event=new RuleBaseEvent(rule);
        for(RuleBaseEventListern listener:listeners){
            listener.ruleBaseRemove(event);
        }
    }


    public List<RuleBaseEventListern> getListeners() {
        return listeners;
    }


    public void setListeners(List<RuleBaseEventListern> listeners) {
        this.listeners = listeners;
    }
    
    
    
}

四：各種組件監聽器的接口定義

package com.nonbankcard.commons.doorls.ruleBaseListern;
/**
 * （1）監聽器接口，將來不同的組件監聽RuleBase的變動，都可以聲明一個監聽器，實現該接口
 * （2）將監聽器注冊到RuleBase的監聽管理者內部
 * @author sxf
 *
 */
public interface RuleBaseEventListern {
    
    /**
     * 一個規則被添加
     * @param event
     */
    public void ruleBaseAddRule(RuleBaseEvent event);
    /**
     * 一個規則被刪除
     * @param event
     */
    public void ruleBaseRemove(RuleBaseEvent event);

}

五：各種監聽器的監聽事件的定義

package com.nonbankcard.commons.doorls.ruleBaseListern;
/**
 * ruleBase的監聽事件
 * @author sxf
 *
 */
public class RuleBaseEvent {

    private Object source;

    public RuleBaseEvent(Object source) {
        super();
        this.source = source;
    }

    public Object getSource() {
        return source;
    }

    public void setSource(Object source) {
        this.source = source;
    }
    
    
}

六：RuleBase變動日記記錄的監聽器

package com.nonbankcard.commons.doorls.ruleBaseListern;
/**
 * ruleBase改變記錄日志的監聽器
 * @author sxf
 *
 */
public class LogRecordRuleBaseListener implements RuleBaseEventListern {

    @Override
    public void ruleBaseAddRule(RuleBaseEvent event) {
        String rule=(String) event.getSource();
        System.out.println("LogRecordRuleBaseListener.ruleBaseAddRule(一個規則被添加===>"+rule);
        
    }

    @Override
    public void ruleBaseRemove(RuleBaseEvent event) {
        String ruleString=(String) event.getSource();
        System.out.println("LogRecordRuleBaseListener.enclosing_method(一個規則被刪除)"+ruleString);
        
    }
    
    

}

七：RuleBase變動通知用戶的監聽器

package com.nonbankcard.commons.doorls.ruleBaseListern;

public class NoticeSystemRuleBaseListener implements RuleBaseEventListern {

    @Override
    public void ruleBaseAddRule(RuleBaseEvent event) {
        String rule=(String) event.getSource();
        System.out.println("NoticeSystemRuleBaseListener.ruleBaseRemove(通知用戶添加一個規則)"+rule);
        
    }

    @Override
    public void ruleBaseRemove(RuleBaseEvent event) {
        String rule=(String) event.getSource();
        System.out.println("NoticeSystemRuleBaseListener.ruleBaseRemove(通知用戶刪除了一個規則)"+rule);
    }

}