1. 배경
오늘날의 웹사이트에는 WAP, SMS, EMAIL, 기존 웹, 소켓 등 접속 채널이 점점 더 많아지고 기술도 점점 발전하고 있습니다. 데이터베이스와 LDAP가 연결된 것으로 간주하더라도 새 채널을 추가할 때 더 이상 코드 수정이나 코드 변경이 필요하지 않도록 설계에서 확장해야 하는 공간이 매우 좋아야 합니다. 그런데 불가능할 것 같은데, 이 다중 채널 액세스 프레임워크의 완벽함을 더 잘 해결할 수 있는 방법은 없을까요?
2. 아키텍처
【그림 1】
그림 1과 같이 기존 액세스를 모두 사용했을 때 디자이너는 당황하여 공유를 얻으려면 다음과 같은 프로그램을 작성하면 됩니다. 어쨌든 구현될 수는 있지만 유지 관리가 더 어려울 것입니다. 다시 질문으로 돌아가서 어떻게 하면 그림 2에서 볼 수 있듯이
[그림 2]
그림 2는 발톱이 여덟 개인 문어처럼 생겼는데, 이 모든 채널을 연결하는 핵심이 바로 문어머리 xmlRouter이다. 여기서 라우터의 장점은 모든 채널을 통해 통신하고, 데이터 라우팅을 구현하고, 시스템 아키텍처의 확장성과 유연성을 향상시키는 것입니다. 유연하고 표준화된 언어인 XML을 데이터 전송 매체로 사용하지 않으면 라우터의 작업 부하도 기하급수적으로 증가하기 때문에 XMLRouter라고 합니다.
3. 아이디어 및 패턴
XMLRouter의 원래 아이디어는 컴퓨터 마더보드의 빌더 패턴에서 왔으며 컴퓨터 마더보드의 PCI 슬롯은 PCI 사양을 정의합니다. 제작한 카드가 PCI 표준을 준수하는 한 마더보드에 꽂으면 작동합니다. 내부 작동 방식은 빌더 패턴으로 캡슐화하여 복잡한 구성을 구현하도록 제안합니다. .XMLRouter는 이러한 복잡한 채널을 분리하여 하나씩 수행합니다.
서비스 아이디어: 라우터와 통신하려면 이러한 채널에 액세스할 때 통합 인터페이스를 정의해야 하며 이를 서비스라고 합니다. 프로그램이 서비스 사양을 준수하는 한 라우터 및 경로 데이터에 액세스할 수 있습니다.
Factory 모드 및 Composite 모드
XMLRouter는 실제 설계에서 Factory 모드를 사용하여 생성됩니다. RouterFactory Production에 의해 생성된 라우터는 사용 시 대기열에 배치되며 데이터 전송, 데이터 수신 및 데이터 반환을 위한 해당 라우터가 대기열에서 호출되고 복합 모드가 적용됩니다.
4. XML 구성 파일 XML 파일은 라우터에서 사용하기 위해 두 부분으로 나뉩니다. 첫 번째는 다음과 같은 라우터 구성입니다.<?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>
<?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>
<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>
나머지 XML은 이러한 규칙에 따라 사용자 정의할 수 있습니다.
package com.web.router; import com.web.platform.Exception.RouterException; import java.util.java/util/Hashtable.java.html" target="_blank">Hashtable;
/** * Router产生和清除的类 */ 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的设置 * */ 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)); } /** * 产生一个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 * 平台的关键,路由的类,每个Router将从RouterFactory里读取 * Router存储的树front,和back,routeIndex,目的是为了能在路由 * 之后可以清除申请的对象。 * Router可以实现同步和异步的功能. */ 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的设置 */ 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)); /*系统回收*/ java/lang/System.java.html" target="_blank">System.runFinalization(); } /** * 设置本Router的设置. * @param def * @throws RouterException */ public void setDefine(RouterDefine def) throws RouterException { define = def; } /** * 设置action的值 * @param actionName * @throws RouterException */ public void setAction( java/lang/String.java.html" target="_blank">String actionName ) { action = actionName; } }
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,交易的结束点, * @param env * @throws RouterException */ public abstract void routeback(Env env) throws RouterException; /** * routeaccept方法,是交易的接收点,也是routeto的接收函数, * routeaccept为被动交易对象的主要处理函数 * @param env * @throws RouterException */ public abstract void routeaccept(Env env) throws RouterException; /** * routing方法,是Service对外的接口函数 * @throws RouterException */ public abstract void routing() throws RouterException;