`
wangdei
  • 浏览: 374549 次
社区版块
存档分类
最新评论

JAVA分布式应用中使用XML数据

阅读更多

可扩展标记语言(XML)作为一种简单的、中性的、易读的数据表示形式已经变得越来越流行,许多软件厂商宣布的“支持XML",意味着他们的产品将能生成或处理XML数据。XML也被看作再企业间交换数据最佳格式。它允许企业在所交换的数据的XML的文档类型定义(Document Type Definitions,DTDs)或模式(Schema)上取得一致。这些DTDs或Schema是独立于企业使用的数据库模式的。 本文将用研究在不同计算机之间通讯与处理XML数据的分布式系统的构建方法,主要是运行在不同的虚拟机上的JAVA应用之间的XML通讯。 XML通讯 万维网协会(World Wide Web Consortium, W3C)在XML规范中定义了XML的语法和语义。为了处理XML数据,XML文档必须经过解析。W3C定义了文档对象模型(DOM),它是应用程序员处理XML数据的接口。DOM已经有包括JAVA在内的许多语言的实现。JAVA应用程序可以通过DOM API来访问XML数据。XML解析器将产生XML文档的DOM表示。 图1说明了处理XML文档的JAVA分布式应用的简单模型。这个模型假设数据可以从诸如关系数据库之类的数据源得到。JAVA代码处理数据并最终产生DOM表示,这些代码表示为图中的处理器。 处理器代码将DOM代表的XML数据传给发送者。发送者是与接收者进行XML数据通讯的JAVA代码。接收者JAVA代码来接受XML数据,产生DOM表示的数据并把它传送给另一个处理器。简而言之,发送者和接收者抽象了DOM表示的XML数据的通讯。 发送者和接收者不是在同一个JAVA虚拟机上执行的。他们是通过分布式系统的构件来相连的。无论是接收者还是发送者都既是客户端又是服务器端,两者的数据传输都是双向的。 Xbeans 就像将要看到的一样,在本文中描述的发送者和接收者的三种实现方法都都是通过Xbeans来实现。Xbeans是一种接受XML数据作为输入,处理这个输入然后向下一个Xbeans输出XML结果的软件构件。Xbeans的输入输出都是XML的DOM文档,亦即传送给Xbeans的不是需要XML解析器解析的字符串,而是通过W3C的标准DOM API解析成了文档对象。图2说明了一个Xbeans。 Xbeans是JavaBeans,支持封装、重用、连接和客户化Java代码。通过适当的一些Xbeans和JavaBeans的设计工具,我们就能编很少的代码构建非常有用的分布式应用。 Xbeans从IBM的XML的JAVA开发工具包而来,在其上作了少量修改以便更适合分布式的应用。Xbeans能够从www.Xbeans.org的开放源码项目中免费获得。 实现发送方和接收方 下面将介绍用JAVA实现发送者和接收者的三种不同的方法。然后对每种方法作一个简单的分析。 方法一:用标准的web 服务器 这种方法将只是简单的将XML作为文本发送给远程计算机上的web服务器。发送方必须将DOM表示的XML转化为文本来与接收方进行通讯。然后,接受方必须将文本还原为DOM表示,如图3: 以下代码段用HTTP来实现发送者。这里用到了IBM Java开发包中的DOMWriter类来实现DOM表示到文本XML表示的转换。


/**偷窥无罪 http://www.bt285.cn/content.php?id=141970
《我的丑娘》  http://www.bt285.cn/wodechounian/
甜性涩爱 http://www.bt285.cn/1196863/story/story_1.html
public void documentReady(DOMEvent evt) throws XbeansException { try { URL receiver = new URL (getRemoteURL ()); URLConnection receiverConnection = receiver.openConnection(); receiverConnection.setDoOutput(true); //向发送者打开一个输出流然后发送文本形式的XML数据 OutputStream out = receiverConnection.getOutputStream(); DOMWriter writer = new DOMWriter(); writer.setPrintWriter(new PrintWriter(out)); writer.documentReady( new com.ibm.xml.xpk4j.dom.DOMEvent( this,evt.getDocument())); out.close(); // 为结果打开一个输入流 BufferedReader in = New BufferedReader( new InputStreamReader(receiverConnection.getInputStream())); // 处理结果:"OK" 表示成功;"Exception" 表示输入流串行化异常 ... in.close(); } catch (Throwable e) { e.printStackTrace(System.err); } }

注意到以上的documentReady()方法用remoteURL属性得到服务器上的CGI脚本的URL。为了与HTTP兼容,CGI脚本类用字符串”Content-type: text/html"封装接收者的输出。这个脚本然后调用服务器上的the receiverMain()方法。 Main()函数只是简单的实例化接收者然后调用其receiveDocument()方法。



import org.xbeans.communication.stdio.receiver.*; 
public class receiverMain { 
static Bean theReceiver = new Bean(); 
public static void main(String[] args) { 
theReceiver.receiveDocument(); 
} 
} 

最后receiveDocument()方法的代码段将重新生成DOM表示以便进一步处理。这里用到了IBM的XML解析器。



DOMParser parser = new DOMParser(); // 构造解析器 
try { // 调用解析器 
parser.parse(new InputSource(System.in)); 
} catch (Throwable e) { 
throw new XbeansException("","receiver","io error parsing incoming document", 
"io error parsing incoming document "+e); 
} 
//将文档传向下一个bean 
DOMListener.documentReady(new DOMEvent(this,parser.getDocument())); 

方法二:通过JAVA远程方法调用串行化文档 这个方法通过JAVA远程方法调用(JAVA RMI)和DOM串行化(serialization)来从发送者向接收者传输XML DOM 文档。如图4: 以下代码用JAVA远程方法调用实现发送方与接受方的通讯.



public void documentReady(DOMEvent evt) throws XbeansException { 
if (DOMListener==null) { 
try { 
DOMListener = (DOMListener)Naming.lookup(getReceiverName()); 
} catch (Exception e) { 
throw new XbeansException( evt.getDocument().getNodeName(), 
"sender", "error obtaining remote receiver", 
"The name may be wrong or the network may be down."); 
} 
} 
DOMListener.documentReady(evt); } 

以下是接受方的JAVA 远程方法调用的实现。setName()方法将接受这传送给RMI注册(registry),documentReady()方法仅仅将接收到的文档传送给下一个组件。

/**偷窥无罪 http://www.bt285.cn/content.php?id=141970
《我的丑娘》  http://www.bt285.cn/wodechounian/
甜性涩爱 http://www.bt285.cn/1196863/story/story_1.html
public void setReceiverName(String newName) { try { if (receiverName!=null) Naming.unbind(receiverName); receiverName = newName; Naming.rebind(receiverName, this ); } catch( Exception e ) { System.out.println( e ); } } public void documentReady(Document incomingDocument) throws RemoteException, XbeansException { if (DOMListener==null) { throw new XbeansException(incomingDocument.getNodeName(),"rmiReceiver", "next component not established", "The component needs to be configured."); } DOMListener.documentReady(new DOMEvent(this,incomingDocument)); }

方法三:CORBA-IIOP 第三方法用CORBA-IIOP(CORBA over Internet Inter-ORB Protocol)来传输数据。对象管理组织(OMG)正在建议扩展接口定义语言(IDL)将XML数据类型包括进去。这样,将来CORBA产品将能传输XML数据。如图5所示: 以下的OMG IDL给出了发送者和接收者CORBA实现的接口。



exception RemoteReceiverException { 
string remoteIdentifier; 
string documentName; 
string componentName; 
string message; 
string moreMessage; 
}; 
 
typedef sequence byteArray; 
interface XMLReceiver { 
void documentReady(in byteArray serializedDocument) 
raises(RemoteReceiverException); 
}; 

以下代码用JAVA串行化DOM和CORBA实现发送者。



public void documentReady(DOMEvent evt) throws XbeansException { 
Document documentToSend = evt.getDocument(); 
try { 
ByteArrayOutputStream bastream = new ByteArrayOutputStream(); 
ObjectOutputStream p = new ObjectOutputStream(bastream); 
p.writeObject(documentToSend); 
p.flush(); 
org.omg.CORBA.ORB orb = org.omg.CORBA.ORB.init( new String[0], 
System.getProperties()); 
XMLReceiver receiver = urlToObject(orb,getReceiverURL()); 
receiver.documentReady(bastream.toByteArray()); 
} catch (RemoteReceiverException rre) { 
throw new XbeansException(rre.remoteIdentifier, rre.documentName, 
rre.componentName, rre.message,rre.moreMessage); 
} catch (Throwable e) { 
throw new XbeansException("","sender", "error sending document "+e, 
"error sending document "+e); 
} 
} 

以下代码用JAVA串行化DOM和CORBA实现接收者。



public void documentReady(byte[] serializedDocument)throws RemoteReceiverException { 
// 反串行化字节流 
ByteArrayInputStream bais = new ByteArrayInputStream(serializedDocument); 
Document theDocument; 
try { 
ObjectInputStream ois = new ObjectInputStream(bais); 
theDocument = (Document)ois.readObject(); 
} catch(Throwable e) { 
throw new RemoteReceiverException(corbaName,"incoming document","receiver", 
"error deserializing document","error deserializing document"+e); 
} 
try { //将文档传向监听者 
local.DOMListener.documentReady(new DOMEvent(this,theDocument)); 
} catch (XbeansException xbe) { 
throw new RemoteReceiverException( xbe.remoteIdentifier(), 
xbe.documentName(),xbe.componentName(), 
xbe.message(),xbe.moreMessage()); 
} 
} 

分析: 测试表明,纯文本表示的XML要比DOM串行化表示性能更好。同时,解析DOM和文本所用的时间也要比用JAVA直接串行化和法串行化所用的时间少。 标准的web服务器方式的优势是其应用基础要广泛许多。CGI脚本能够在绝大多数web服务器上运行,而且,接受方能够很容易的通过URL标识。而对于RMI,则需要RMI注册。CORBA的解决办法则需要在服务器上安装对象请求代理(Object Request Broker,ORB ),而且,CORBA发送者的实现使用的是一个URL的命名模式而不是接收者的CORBA对象引用,用一个字符串与一个URL相联系,然后在客户端转化。 CORBA 和RMI支持JAVA 客户端到JAVA服务器的解决方案。没有CGI脚本也不需要从标准输入中读取编码异常。而且,不需要在发送者每次用XML通讯时都启动一个JAVA虚拟机。他们两则均支持接收者的自动激活。 JAVA RMI方式只能在JAVA代码之间工作,对于web服务器包括CORBA理论上能在任何编程语言之间通讯。对于JAVA串行化的DOM来说,即便是客户端和服务器端均需要是JAVA代码的要求不是问题,它还存在另外一个困难,即JAVA串行化要求客户端和服务器运行的是相同的DOM实现。 结论 正如上面所述,有许多方法可以实现在JAVA分布式应用中发送XML数据,每一种方法的性能和互操作性都是不同的。重要的是应该把XML通讯从分布式应用逻辑中抽取出来。也就是,实现发送和接受XML的代码应和应用逻辑的代码中分离出来。通过把代码打包成软件组件,就能够改变发送方和接受方的代码而不会影响到应用其余实现。

分享到:
评论

相关推荐

    Java分布式实战指南.pdf

    《Java分布式实战指南》这本书详细介绍了如何构建一个完整的Java分布式系统,主要涵盖了技术选型、分布式基础设施环境构建以及项目运营与部署环境等多个方面。在Java微服务领域,它提供了丰富的实践经验和理论指导。...

    Java 分布式应用程序设计

    在Java分布式应用程序设计中,我们探讨的是如何利用Java技术构建能够在多台计算机上协同工作的系统。这涵盖了网络通信、服务发现、负载均衡、容错机制等多个核心概念。下面,我们将根据给定的压缩包文件章节名称,...

    java分布式锁实现代码

    本文将深入探讨如何使用Redisson和Curator框架来实现Java环境中的分布式锁。 首先,让我们来看一下Redisson实现的分布式锁。Redis是一个高性能的键值数据库,常被用作分布式系统的缓存或数据存储。Redisson是基于...

    基于分布式系统的JAVA聊天系统

    总的来说,基于分布式系统的JAVA聊天系统是一个结合了网络通信、并发处理、数据交换、容错机制和安全策略的综合应用。它不仅展示了JAVA在分布式系统中的强大能力,也体现了软件工程中良好的设计原则和实践。对于...

    用JAVA和XML构建分布式系统

    图1展示了一个处理XML文档的Java分布式应用模型。在这个模型中,数据可以从关系数据库等数据源获取。Java代码负责处理这些数据,并最终生成DOM表示。这部分处理逻辑被称为“处理器”。 #### 发送者与接收者的角色 ...

    (开发入门)分布式java基础与实践

    CAP定理指出,分布式系统无法同时满足一致性、可用性和分区容错性,因此,Paxos、Raft等一致性算法和ZooKeeper、Etcd等协调服务在Java分布式系统中扮演着重要角色。 通过深入理解和实践这些概念,开发者可以构建出...

    java分布式程序设计

    Java分布式程序设计是构建大规模、高可用、可扩展系统的核心技术之一。在现代互联网应用中,随着业务量的不断增长,单体应用往往无法满足需求,因此需要将应用程序拆分为多个独立的服务,这些服务可以跨多台机器进行...

    Java分布式开发与集群技术

    但为了更高效和更安全地处理分布式应用中的通信问题,Java提供了高级的通信机制,如RMI(远程方法调用)和Web服务。RMI可以让对象在不同的虚拟机或不同的主机之间进行通信,而Web服务则允许不同的系统通过XML、SOAP...

    分布式java应用开发

    至于文件列表中的"content.xml"、"styles.xml"、"meta.xml"等,它们通常是文档或电子书格式如ODF(OpenDocument Format)的一部分,用于存储文档内容、样式和元数据。这些文件对于理解具体的Java分布式开发技术没有...

    JMS和XML的分布式应用研究.pdf

    JMS与XML的结合使用,可以创建一个强大的分布式应用系统,尤其在处理异构数据库环境中的数据通信问题。通过XML,数据可以在不同的数据库系统间以统一的格式进行交换,而JMS则提供了一种异步、非阻塞的消息传递机制,...

    基于Java及多语言实现的多组件分布式应用行为追踪设计源码

    本项目为多组件分布式应用行为追踪设计源码,采用Java作为主要编程语言,并融合了JavaScript、Shell、CSS和HTML等多种语言。...该源码旨在展示多组件分布式应用的追踪机制,以实现行为数据的全面监控和分析。

    通过webservice提交xml数据以及soap协议的使用

    Web服务(WebService)是一...总之,掌握通过Web服务提交XML数据以及SOAP协议的使用对于构建分布式系统和实现跨平台的数据交换至关重要。了解这些基本概念和操作流程,能帮助你更好地设计和实现高效的Web服务解决方案。

    Java分布式开发spring+jta+jotm

    Java分布式开发是一个复杂而关键的领域,特别是在大型企业级应用中。Spring框架是Java开发者广泛使用的工具,它提供了丰富的功能来简化开发,包括对分布式系统的支持。在Spring中,Java Transaction API (JTA) 和 ...

    基于Java的多层分布式应用模型研究.pdf

    通过上述内容,可以看出在基于Java的多层分布式应用模型中,J2EE平台提供了完整的技术框架和丰富的组件,开发者可以利用这些组件和服务来构建稳定、高效的分布式系统。同时,了解和掌握MVC模式、J2EE架构以及各种...

    Java-XML的分布式异构数据库同步系统的实现.pdf

    随着信息技术的发展,分布式应用系统变得越来越普遍,各种行业和机构的业务和数据管理已经离不开计算机的支持。在这样的背景下,如何在不同的服务器数据库之间实现数据的一致性成为了关键问题。Java-XML技术在解决...

    Java程序设计EJB、XML与数据库

    **EJB(Enterprise JavaBeans)**:EJB是Java EE的一部分,它提供了一种标准的组件模型,用于在分布式环境中构建可扩展的、安全的和事务性的企业级应用。EJB有三种主要类型:会话bean(Session Beans)处理客户端...

    XA 多数据源分布式事物实现 java

    4. **编程模型**:项目可能提供了示例代码,展示了如何在Java应用程序中使用JTA和XA进行事务管理。这通常涉及到声明事务边界(例如,使用`@Transactional`注解)、获取UserTransaction实例以及调用其start、commit和...

    java解析XML详解

    Java作为一门流行的编程语言,提供了多种方式来解析XML文档,以便开发者能够有效地读取、操作和转换XML数据。本文将深入探讨Java解析XML的各种方法及其应用场景,旨在为读者提供全面而深入的理解。 ### Java解析XML...

    推荐5个强大的Java分布式缓存框架

    本文将详细介绍五种常用的Java分布式缓存框架,帮助开发人员更好地理解如何利用这些工具来优化应用程序。 ### 1. Ehcache - Java分布式缓存框架 #### 特点 - **高速存取**:Ehcache 提供了极快的数据存取速度,...

Global site tag (gtag.js) - Google Analytics