其實寫這篇文章的目的最多的想法是把自己在去年在瑞士做項目時應(yīng)用的一個框架給展現(xiàn)出來讓大家共享，但我又有點擔心我的表達能力不能將我在里面使用的思想很好的表現(xiàn)出來，所以遲遲 不敢下筆，最后還是下了決心，寫吧， 不行就在好好改改，當然也希望大家多提些意見。
　　一.背景
　　在現(xiàn)在的網(wǎng)站中，接入的渠道是越來越多了，技術(shù)也是越來越先進，WAP, SMS,EMAIL, 傳統(tǒng)的Web, Socket等等，如果連數(shù)據(jù)庫和LDAP也算接入的話，那在設(shè)計之中需要擴展的空間要做到很好 很好，才保證在添加新的渠道情況下不需要更多的修改代碼甚至不改代碼的情況。但可能嗎？我想也不可能，但有什么方式可以更好的解決這種多渠道接入的框架的完美性呢？
　　二.構(gòu)架
　　【圖一】
　　如圖一所顯示，在現(xiàn)有的所有接入都已經(jīng)使用上的時候，設(shè)計者看的都眼花繚亂了，如果是為了湊份子，那這些程序怎么寫都可以，而且也肯定可以實現(xiàn)，但維護起來就會比較痛苦，還是回到那個問題，怎么可以實現(xiàn)更完美呢？在項目組的構(gòu)架討論中，我提出了路由的感念，并得到了大
　　家統(tǒng)一的認可，如圖二顯示
　　【圖二】
　　圖二看起來象個八爪的章魚，章魚腿分別連接所有的接入渠道，進行連接所有這些渠道的核心就是這個章魚的頭XMLRouter，Router在此的作用是溝通所有渠道，實現(xiàn)數(shù)據(jù)的路由，爭強系統(tǒng)在構(gòu)架上的擴展性和靈活性，好處會很多很多。稱呼為XMLRouter是因為如果不使用XML這種靈活而又規(guī)范的語言來做為數(shù)據(jù)傳輸?shù)拿浇?那Router的工作量也同樣會成倍的增加,定義好XML的規(guī)范后將為以后的擴展帶來很多好處.
　　三.思想和模式
　　XMLRouter的最初想法來自于計算機的主板和<<Design Pattern>>之中的Builder Pattern, 計算機主板的PCI 插槽定義了PCI的規(guī)范,只要你生產(chǎn)的卡符合PCI標準,那你插入到這個主板上就可以工作, 至于里面是怎么工作的則是已經(jīng)封裝好了. Builder Pattern則是提出將復雜的構(gòu)建分離開來, 一步一步的進行實現(xiàn).XMLRouter是將這些復雜的渠道分離開來,一個個的進行表現(xiàn).
　　Services思想:為了能和Router進行溝通,在這些渠道接入時必須定義統(tǒng)一的接口,這里成為Services, 只要符合Services規(guī)范的程序就可以接入到Router并進行數(shù)據(jù)的路由.
　　Factory模式和Composite模式
　　XMLRouter在實際的設(shè)計中將采用Factory模式產(chǎn)生,Router由RouterFactory生產(chǎn), 在投入使用時將放置于隊列中,傳遞數(shù)據(jù)和接收數(shù)據(jù)以及返回數(shù)據(jù)都從隊列中取相應(yīng)的Router來調(diào)用,應(yīng)用了Composite的模式.
　　四.XML配置文件
　　XML文件對于Router之中的使用分為兩個部分, 第一個是Router的配置,如:
　　<?xml version="1.0" ?>
<services>
　　 <!-- database Service -->
　　 <service name="database" type="database" class="com.web.service.DBService">
　　 <connector
　　　　　　 driver="com.microsoft.jdbc.sqlserver.SQLServerDriver"
　　　　　　 url="jdbc:microsoft:sqlserver://192.168.0.179:1433" user="test"
　　　　　　 passwd="test" />
　　 </service>
　　 <!-- Web Service-->
　　 <service name="web" type="web" class="com.web.service.WebService" >
　　　　 <connector　/>
　　 </service>
……
</services>
　　這是Router的配置文件, service節(jié)點代表需要接入的渠道, service節(jié)點包含connector子節(jié)點, 子節(jié)點的配置根據(jù)type來區(qū)分, 如果是database則包含url, user, passwd,driver等屬性, 如果是socket則包含 port, maxthread等屬性, 屬性值可以根據(jù)自己的定義來配置.
　　另一種XML文件則是XML交易數(shù)據(jù)文件,用于在所有的services中傳遞數(shù)據(jù),每個Services自己包涵一個相應(yīng)的XML文件,比如webtrans.xml格式如下:
　　<?xml version="1.0" ?>
<transaction>
　　 <trans name="addDoc" service="database" method="insert">
　　　　 <property name="createtime" type="timestamp"/>
　　　　 <property name="creatorid" type="long"/>
　　　　 <property name="doctypeid" type="int"/>
　　　　 <property name="docstatusid" type="int"/>　　　　　　
　　 </trans>　　　　
</transaction>
　　相應(yīng)的dbtrans.xml格式如下
　　<trans name="addDoc" table="TDOC_DOCS" method="insert">
　　　　 <primarykey name="docid" />　　　　
　　　　 <set>
　　　　　　 <property name="createtime" type="timestamp"/>
　　　　　　 <property name="creatorid" type="long"/>
　　　　　　 <property name="doctypeid" type="int"/>
　　　　　　 <property name="docstatusid" type="int"/>　　　　　　
　　　　 </set>
　　 </trans>
#p#
　　其余XML則可按這樣的規(guī)則來定制
　　五.技術(shù)實現(xiàn)
　　RouterFactory
　　package com.web.router;
import com.web.platform.Exception.RouterException;
import java.util.java/util/Hashtable.java.html" target="_blank">Hashtable;
　　/**
* Router產(chǎn)生和清除的類
*/
public class RouterFactory　
{
　 /**
　　 * Router存儲的樹front
　　 */
　 private static java/util/Hashtable.java.html" target="_blank">Hashtable QueuePairFront = null;
　 /**
　　 * Router存儲的樹back
　　 */
　 private static java/util/Hashtable.java.html" target="_blank">Hashtable QueuePairBack = null;
/**
　　 * Router存儲的樹
　　 */
　 private static java/util/Hashtable.java.html" target="_blank">Hashtable QueueRouter = null;
　 /**
　　 * 返回的XMLRouter
　　 */
　 public static XMLRouter instance = null;
　 /**
　　 * Router的定義
　　 */
　 public static RouterDefine routerdefine = null;
　 /**
　　 * Router的ID號
　　 */
　 public static long routeIndex = 0;
　 /**
　　 * @roseuid 3F169C21027C
　　 */
　 public RouterFactory()　
　 {
　 }
　 /**
　　 * 初始化Hashtable和Vector
　　 */
　 public static void initFactory() throws java/lang/Exception.java.html" target="_blank">Exception
　 {
　　　　　 QueuePairFront = new java/util/Hashtable.java.html" target="_blank">Hashtable();　
　　　　　 QueuePairBack　= new java/util/Hashtable.java.html" target="_blank">Hashtable();　
　　　　　 QueueRouter　　　 = new java/util/Hashtable.java.html" target="_blank">Hashtable();
　　　　　 initRouteDefine();
　 }
/**
　　 * 初始化Route的設(shè)置
　　 *　
　　 */
　 private static void initRouteDefine() throws java/lang/Exception.java.html" target="_blank">Exception
　 {
　　　　　 if( routerdefine == null )
　　　　　　　 routerdefine = new RouterDefine();
　　　　　 routerdefine.loadRouterDef();
　 }
　 /**
　　 * 返回實例
　　 * @return com.web.router.XMLRouter
　　 */
　 public static XMLRouter getInstance(long index) throws RouterException
　 {
　　　　 return (XMLRouter)QueueRouter.get(new java/lang/Long.java.html" target="_blank">Long(index));
　 }
　 /**
　　 * 產(chǎn)生一個XMLRouter的實例
　　 * @return com.web.router.XMLRouter
　　 * @roseuid 3F1618A103BC
　　 */
　 public static XMLRouter popInstance() throws RouterException
　 {
　　　　　 routeIndex ;
　　　　　 instance = new XMLRouter(routeIndex);
　　　　　 setDefine( instance );
　　　　　 QueueRouter.put(new java/lang/Long.java.html" target="_blank">Long(routeIndex), instance);　　　　　
　　　　 return instance;
　 }
　 /**
　　 * 清空Hashtable，Vector等
　　 * @roseuid 3F1618B203C1
　　 */
　 private static void freeResource() throws java/lang/Exception.java.html" target="_blank">Exception
　 {
　　　　　 QueuePairFront.clear();
　　　　　 QueuePairBack.clear();
　　　　　 QueueRouter.clear();
　　　　　 QueuePairFront = QueuePairBack = QueueRouter = null;
}
　 /**
　　 * 清除實例
　　 * @param instanceID
　　 * @throws Exception
　　 */
　 public　static void removeInstance(XMLRouter instance) throws java/lang/Exception.java.html" target="_blank">Exception　
　 {
　　　　　 instance.clear();
　　　　 QueueRouter.remove( new java/lang/Long.java.html" target="_blank">Long(instance.getIndex() ) ) ;
　 }
/**
* Method isNull.
* @return boolean
*/
　 public static boolean isNull()
　 {
　　　　 ……　
　　　　　 return false;
　 }
}
　　XMLRouter
　　package com.web.router;
import com.web.platform.Exception.RouterException;
import com.web.common.*;
import java.util.*;
import java.lang.reflect.java/lang/reflect/Method.java.html" target="_blank">Method;
import java.lang.reflect.java/lang/reflect/Constructor.java.html" target="_blank">Constructor;
/**
* @author keli
* @version 0.0.1
* 平臺的關(guān)鍵，路由的類,每個Router將從RouterFactory里讀取
* Router存儲的樹front,和back,routeIndex,目的是為了能在路由
* 之后可以清除申請的對象。
* Router可以實現(xiàn)同步和異步的功能.
*/
public class XMLRouter　
{
　 /**
　　 * Router存儲的樹front
　　 */
　　 private static java/util/Hashtable.java.html" target="_blank">Hashtable QueuePairFront = null;
　 /**
　　 * Router存儲的樹back
　　 */
　　 private static java/util/Hashtable.java.html" target="_blank">Hashtable QueuePairBack = null;
/**
　　 * 本router的index號碼
　　 */
　　 private long routeIndex = 0;
/**
　　 * router的設(shè)置
　　 */
　　 private RouterDefine　define = null;　　
/**
　　 * 用于判斷是路由的起回點
　　 */
　　 private java/lang/String.java.html" target="_blank">String　action = "";
　　 /**
　　 *此變量只是用于在routeto方法中申請新的class　
　　 */
　　 private java/lang/String.java.html" target="_blank">String　classname = "";
　　　 /**
　　 */
　　　 public XMLRouter(long index)　
　　　 {
　　　　 routeIndex = index;
　　　 }
　　　 /**
　　 * 路由
　　 * @throws Exception
　　 * @roseuid 3F1616BD0186
　　 */
　　　 public void routing(Env env) throws RouterException, java/lang/Exception.java.html" target="_blank">Exception　
　　　 {
　　　　　 /*如果為起點*/
　　　　 if( action.equalsIgnoreCase( RouterConstant.CFG_FUNC_ROUTETO　) )　　
　　　　 {
　　　　　　 ……
　　　　 }
　　　　 /*如果為返回點*/
　　　　 else if( action.equalsIgnoreCase( RouterConstant.CFG_FUNC_ROUTEBACK　) )
　　　　 {
　　　　 ……
　　　　 }
　　　　 /*否則為錯誤*/
　　　　 else
　　　　　　 throw new RouterException("Set Router action error.");
　　　 }

　　 /**
　　 * 讀取本Router的id號.
　　 * @return long
　　 */
　　 public long　getIndex()
　　 {
　　　　　 return routeIndex;　　　　
　　 }
/**
　　 * 清除所有對象.
　　 * @throws RouterException
　　 */
　　 public void clear() throws RouterException
　　 {
　　　　 QueuePairFront.remove(new java/lang/Long.java.html" target="_blank">Long(routeIndex));
　　　　 QueuePairBack.remove(new java/lang/Long.java.html" target="_blank">Long(routeIndex));
　　　　 /*系統(tǒng)回收*/
　　　　 java/lang/System.java.html" target="_blank">System.runFinalization();　　　　　
　　 }
　　 /**
　　 * 設(shè)置本Router的設(shè)置.
　　 * @param def
　　 * @throws RouterException
　　 */
　　 public void setDefine(RouterDefine def) throws RouterException
　　 {
　　　　 define = def;　　
　　 }　
　　 /**
　　 * 設(shè)置action的值
　　 * @param actionName
　　 * @throws RouterException
　　 */
　　 public void setAction( java/lang/String.java.html" target="_blank">String actionName )
　　 {
　　　　 action = actionName;　　　　
　　 }
}
　　Service類
　　package com.web.common;
import com.web.platform.Exception.RouterException;
/**
* Service的父類，abstract　
*/
public abstract class RouteService　
{
　 /**
　　 */
　 public RouteService()　
　 {
　 }
　 /**
　　 * routeTo方法，是交易的起點。
　　 * @param env
　　 * @throws RouterException
　　 */
　 public abstract void routeto(Env env) throws RouterException;
　 /**
　　 * routeBack，交易的結(jié)束點，
　　 * @param env
　　 * @throws RouterException
　　 */
　 public abstract void routeback(Env env) throws RouterException;
　 /**
　　 * routeaccept方法，是交易的接收點，也是routeto的接收函數(shù)，
　　 * routeaccept為被動交易對象的主要處理函數(shù)
　　 * @param env
　　 * @throws RouterException
　　 */
　 public abstract void routeaccept(Env env) throws RouterException;　　
　 /**
　　 * routing方法，是Service對外的接口函數(shù)
　　 * @throws RouterException
　　 */
　 public abstract void routing() throws RouterException;
　　接下來則需要實現(xiàn)所有的Services的類了,這里就不做介紹了.
　　六.說明
　　這個Router到目前為止只能實現(xiàn)同步的交易, 暫時不支持異步的交易,但是由于對Router使用了Composite的模式設(shè)計的,實現(xiàn)異步交易也是可以擴展的,這里不做詳細分析.
　　這篇文章是我工作的一個總結(jié),希望能對大家有所幫助.不足之處希望多多指教.

最新評論