生产-消费模式的XML解析

核心提示：在B2B（企业对企业）应用中xml扮演一个重要的角色，在这些应用中采用Simple API for XML (SAX)或者document．nbspObject Model (DOM)解析器来解析xml文件，生产-消费模式的XML解析，（这两个解析器都是java的api，他们可以在下面的附录中找到）在一个单线程应用中解

　　在B2B（企业对企业）应用中xml扮演一个重要的角色。在这些应用中采用Simple API for XML (SAX)或者document．nbspObject Model (DOM)解析器来解析xml文件。（这两个解析器都是java的api，他们可以在下面的附录中找到）在一个单线程应用中解析是简单明了的。 但是，在多线程的应用中这就是很复杂和具有挑战性了，比如说做一个应用服务器，因为应用经常会为解析xml创建一个专门的线程，解析的数据用来为许多同时并发运行的线程服务。这篇文章描述了一个在并发应用中的xml的解析实现。

　　设计方法

　　基于并发的生产和消费设计概念，一个专门的线程作为一个生产者去解析xml。一组线程作为消费者，作为解析xml数据的生产线程，他把数据存储在一个共享的数据结构中以供消费线程在将来进行处理时取得，为了最大化产生数据的能力同时最小化内存的使用，这个设计使用了一个非凡的队列来分别为生产者、消费者存储和找到解析的数据.

　　巧妙的队列(Smart Queuing)

　　SmartQueue 队列类提供给生产消费线程们队列的功能，他主要的责任是维护队列防止（线程）超载和断流。换句话说，SmartQueue采用维护一个固定长度的队列的方法去保持资源的应用效率。他挂起和唤醒适当的线程在适当的时候，打个比方，假如没有填充数据的空间，队列将挂起生产线程直到一个消费线程从队列里移去一项。

　　下面的SmartQueue 代码片断展示了这种策略的实现。

public synchronized void put(Object data) {
// check to see if the length is 2
while (list.size() >= 2) {
try {
System.out.PRintln("Waiting to put data");
wait();
}
catch (Exception ex) {
}
}

list.add(data);
notifyAll();
}

public synchronized Object take() {
// wait until there is data to get
// come out if the end of file signaled
while (list.size() <= 0 && (eof != true)) {
try {
System.out.println("Waiting to consume data");
wait();
} catch (Exception ex) {
}
}

Object obj = null;

if (list.size() > 0) {
obj = list.remove(0);
} else {
System.out.println("Woke up because end of document．quot;);
}

notifyAll();
return obj;
}

　　xml 解析

　　这个设计使用SAX API来解析XML文件是有以下原因的：

　　这个API读取 XML数据是快速高效的,他不构造任何内部的XML数据描述，相应的，他在碰到XML元素时简单的把数据传递给应用程序。SAX API十分适合生产-消费模式。

　　xml 解析控制器（XMLParserHandler） 的类继续自SAX，实现回叫（callback ）方法从解析器中接收XML数据，当解析控制器类从解析器中接收XML数据时，他把数据put进hashtable里。在每个文档的结尾，解析控制器把数据put进SmartQueue队列里。这个控制器将进入一个等待状态假如SmartQueue队列里有空间，一旦消费线程从SmartQueue队列中移去一项，put方法将被调用。在完成整个XML文档的解析后，解析控制器（