IDC资讯中心
程序员可能会经常碰到这样的事情：建立一个servlet应用程序，它与公司的数据库相连接，为客户提供一种特定的服务，这个应用程序受到一个强大的验证机制保护，全世界有成千上万的客户都在使用它。现在就出现了一个问题：当应用程序处在公司的防火墙之外时，你将如何从应用程序提供用户对数据库的访问？你知道，网络管理员是不会专门为你的应用程序与数据库相连接而打开一个特殊端口的。
http隧道技术和xml
如何越过防火墙与客户/服务器应用程序相连接这个问题已经困扰程序员很久了。在多数情况下，一个公司的防火墙总是尽可能少地打开端口。一般情况下，你能够使用的唯一端口就是80，这也就是web所使用的端口。
解决这个问题的方法就是使用http隧道技术（http tunneling）。这个方法首先将请求包装在一个http post请求中，然后这个请求再由一个在防火墙内的web 服务器上的cgi 应用程序（例如一个servlet）来处理。
servlet恢复原始的请求，执行它，然后将结果插入到http响应流中。防火墙将这种相互作用解释为对一个 web页面的常规请求，并允许对它继续进行处理。这就象特洛伊木马一样：看起来是一个普通的请求，但其中隐藏着预料不到的负载。
下一个问题是如何对请求进行格式化？当然，使用xml是将这些负载送入一个http请求中去的最佳选择。这个观念很有独创性，http之上的xml是一个热门的新兴领域，一些新的规则正在编写中，将来可以成为分布式应用程序的标准通讯协议。其中，简单对象访问协议（soap）是最得到公认的。
遗憾的是，现在还没有一个稳定执行的soap供我们使用，目前所能找到的最好的一个来自apache集团，但是它只支持简单的返回类型。因此，它对于我们的项目是没有用的。但是这也不错，这意味着我们可以提出自己的http上的xml的协议，并且借此来学习其中包含的概念。
概念
现在我们来建立一个简单的框架结构（framework），它将http上的xml作为基本的通讯策略，从而让我们能够创建一套服务，而且使得这些服务从分布在internet上四面八方的桌面应用程序都可以进行访问。
首先，我们需要建立普通请求和响应的语法。请求看起来是这样的：
<?xml version=1.0 encoding=utf-8 ?>
<http-request>
<requesttype>
[type of request]
</requesttype>
<request>
[application specific request.this will be an xml elment ]
</request>
</http-request>
响应看起来是这样的：
<?xml version=1.0 encoding=utf-8 ?>
<response>
<responsemessage>
[the response message]
</responsecode>
<responsecode>
[an application specific return code.]
</responsecode>
<response>
[application specific request.this will be an xml element]
</response>
</http-response>
为了理解这个框架结构背后的概念，我们要编写一个应用服务例程：一个简单的数据库服务，它对任何sql语句进行处理，并且将结果作为一个向量来返回。请求的细节，也就是请求元素所包含的xml标记非常简单，如下：
<sql-statement>
[the sql statement to be executed]
</ sql-statement >
响应结果是这样的：
<result-set>
</result-count>
[the number of rows in the result set]
</result-count>
<row>
<col name=name>
[the value]
</col>
?
</row>
?
<result-set>
httpservice是一个servlet，它响应一个post请求，恢复xml负载，并使用它来创建一个servicerequest例示。然后，根据请求的类型，将请求交给httpservicehandler 抽象类的一个特定子类。handler类执行请求，在serviceresponse的一个例示中存储结果，然后将这个结果发送回客户端应用程序。
通过按照惯例为服务处理器类命名，我们可以利用java的映象功能来创建处理器类的一个例示，这个处理器类仅仅是建立在servicerequest 对象的服务类型属性的基础上。这就取消了httpservice和所有服务处理器类之间的依赖性，从而意味着当我们增加一个新服务时，不再需要改变 httpservice类。
在我们这个例子中，服务的类型是dbservice，因此我们将创建httpservicehandler的一个子类，叫做dbservicehandler。在httpservice中，我们使用以下代码：
string classname = package_name + "." + request.getrequesttype() + "handler";
httpservicehandler handler = class.fromname(classname).newinstance();
handler.handlerequest(request);
一个httpservicehandler子类需要执行一个方法processrequest()，它需要取一个servicerequest对象，然后返回一个serviceresponse对象。这个方法是在handlerequest 方法的过程中由子类调用的：
public void handlerequest(servicerequest request)
{
serviceresponse response = processrequest(request);
sendresponse(response);
}
这是使用template（模板）方法模式的一个典型例子，在这个过程中，抽象超类调用在一个子类中执行的方法。
servicerequest类将服务特定数据存储为一个xml 文档。这个类由访问者来设置和获取请求类型，它还有方法来处理请求的细节。getrequest()方法返回包含在请求标记中的xml节点，setrequest()方法则用一个新生成的请求来覆盖原来的请求。这个类还使用两个factory方法，创建新的元素和文本节点，允许开发人员生成新的请求。serviceresponse类以一种非常简单的方法来处理请求的细节。
虽然这两个类允许我们对所有类型的请求和响应进行处理，但是开发人员也必须要了解每个请求的特殊语法。开发人员不能对请求的格式是否正确进行任何确认。
为了简化这个过程，我们将创建servicerequest和 serviceresponse的子类，它们分别叫做dbservicerequest和dbserviceresponse，它们都有处理服务特定细节的方法。例如，dbservicerequest有设置和获取sql 语句的方法，同时 dbserviceresponse有设置和获取结果记数值和结果设置矢量的方法。
服务是用httpserviceclient类来访问的。在客户端应用程序中，有以下的代码：
httpserviceclient client = new httpserviceclient(serviceurl);
dbservicerequest request = new dbservicerequest();
request.setsqlstatement(statement);
dbserviceresponse response = new dbserviceresponse(client.executerequest(request));
其中服务的url是这样的：
http://myhost/servlet/httpservice.httpservice.
细节
上面我们已经看到了框架结构中的所有元素，现在来看看那些有趣的细节。首先让我们来注意一下协议层。我们应该如何创建包装xml负载的http post 请求？我们应该如何处理http响应？
http 请求是标准化的、基于ascii的、与一个web 服务器的socket通讯。这里有一个例子：
post /servlet/
httpservice.httpservice http/1.0
host: localhostt:80
content-type: text/xml
content-length: 248
<?xml version=1.0 encoding=utf-8 ?>
<http-request>
<requesttype>dbservice</requesttype>
<request>
<sql-statement>
select * from mytable
</sql-statement >
</request>
</http-request>
来自web服务器的响应如下所示：
http/1.0 200 ok
date: fri, 24 nov 2000 16:09:57 gmt
status: 200
servlet-engine: tomcat web server/3.1 (jsp 1.1;
servlet 2.2; java 1.3.0; windows 2000 5.0 x86;
java.vendor=sun microsystems inc.)
content-type: text/xml
content-length: 726
content-language: en
<?xml version=1.0 encoding=utf-8 ?>
<http-response>
<responsemessage>ok</responsecode>
<responsecode>200</responsecode>
<response>
<result-set>
</result-count>2 </result-count>
<row>
<col name=col1>value11</col>
<col name=col2>value12</col>
</row>
<row>
<col name=col1>value21</col>
<col name=col2>value22/</col>
</row>
<result-set>
</response>
</http-response>
下面的代码显示了httpserviceclient类的执行，它将处理http 请求的所有细节。你能看到，一旦你了解了那些请求的准确格式，这就是一个非常简单的过程：
public class httpserviceclient
{
private static final string http_version = "1.0";
private static final string http_post_request ="post";
private static final string header_host = "host";
private static final string header_content_type = "content-type";
private static final string xml_mime_type = "text/xml";
private static final string
header_content_length = "content-length";
private static final int default_port = 80;
private string serviceurl;
private int returncode;
private string returnmessage;
private reader responsepayload;
public httpserviceclient(string serviceurl)
{
this.serviceurl = serviceurl;
}
public serviceresponse executerequest(servicerequest request)
throws httpserviceexception
{
try
{
string data = request.serializerequesttostring("utf-8");
postrequest(data);
//check for failures
if(returncode != 200)
throw new httpserviceexception(returnmessage);
inputsource source =
new inputsource(responsepayload);
domparser parser = new domparser();
parser.parse(source);
serviceresponse serviceresponse =
new serviceresponse(parser.getdocument());
string theresponse =
serviceresponse.serializeresponsetostring("utf-8");
system.err.println(theresponse);
return serviceresponse;
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception(ex.getmessage());
}
}
private void postrequest(string payload)
throws httpserviceexception
{
printwriter out = null;
bufferedreader in = null;
url url = null;
try
{
url = new url(serviceurl);
// no port? use default port 80
int port = url.getport () < 0 ? default_port : url.getport();
socket soket = new socket (url.gethost (), port);
out = new printwriter (soket.getoutputstream ());
in = new bufferedreader (new inputstreamreader(soket.getinputstream ()));
}
catch (exception ex)
{
throw new httpserviceexception ("error opening socket: " + ex.getmessage ());
}
out.print (http_post_request + " " + url.getfile() + "http/" + http_version + "\r\n");
out.print (header_host + ": " + url.gethost () + : + url.getport () + "\r\n");
out.print (header_content_type + ": " + xml_mime_type + "\r\n");
out.print (header_content_length + ": " + payload.length () + "\r\n");
out.print ("\r\n");
out.print (payload);
out.print ("\r\n\r\n");
out.flush ();
try
{
string statusline = in.readline();
system.err.println(statusline);
parsestatusline(statusline);
}
catch (exception ex)
{
throw new httpserviceexception ("error parsing http status line: " + ex.getmessage ());
}
// i will ignore all the headers and keep reading
// until i get an empty line
try
{
string headerline = null;
while ((headerline = in.readline ()) != null)
{
if (headerline.length () == 0)
break;
}
}
catch (exception ex)
{
throw new httpserviceexception ("error reading http headers: " + ex.getmessage ());
}
//what remains of the input stream is my payload
responsepayload = in;
}
private void parsestatusline(string statusline)
throws exception
{
stringtokenizer st =
new stringtokenizer (statusline);
// this is the http version
st.nexttoken ();
returncode = integer.parseint (st.nexttoken ());
stringbuffer retmessage = new stringbuffer ();
while (st.hasmoretokens ())
{
retmessage.append (st.nexttoken ());
if (st.hasmoretokens ())
{
retmessage.append (" ");
}
}
returnmessage = retmessage.tostring ();
}
}
web服务器接受了http请求后，它就创建一个httpservice servlet的新例示，接着调用dopost()方法，在httpservletrequest和httpservletresponse对象中传递。然后这个servlet 就恢复xml负载，并且创建servicerequest类的一个例示，最后将其转交给正确的处理器：
document dom;
domparser parser = new domparser();
inputsource input = new inputsource(request.getinputstream());
parser.parse(input);
dom = parser.getdocument();
servicerequest servicerequest = new servicerequest(dom);
string classname = package_name + "." + request.getrequesttype() + "handler";
httpservicehandler handler = class.fromname(classname).newinstance();
handler.handlerequest(request);
下面的代码显示了dbservicehandler类的执行情况，这个类创建数据库连接、执行查询并且生成dbserviceresponse对象。同样，要注意这个过程非常简单，因为许多复杂的问题都隐藏在serviceresponse和servicerequest类及子类的后面了：
public class dbservicehandler extends
httpservicehandler
{
public serviceresponse processrequest(servicerequest req)
throws httpserviceexception
{
dbservicerequest request = new dbservicerequest(req);
string sql = request.getsqlstatement();
dbserviceresponse response = new dbserviceresponse();
connection connection;
try
{
class.forname("oracle.jdbc.driver.oracledriver");
string connectionstring = "jdbc:oracle:thin:@fender.openport.com:1521:iplp";
connection = drivermanager.getconnection(connectionstring ,"op1","op1");
}
catch(classnotfoundexception ex)
{
ex.printstacktrace(system.err);
response.setresponsecode(400);
response.setresponsemessage("oracle driver not found");
return response;
}
catch(sqlexception ex2)
{
ex2.printstacktrace(system.err);
response.setresponsecode(400);
response.setresponsemessage("could not connect to database!");
return response;
}
string thesql = sql.trim().touppercase();
resultset resultset;
try
{
statement statement =
connection.createstatement();
if(thesql.startswith("select"))
{
resultset = statement.executequery(thesql);
vector theresults = parseresultset(resultset);
response.setresultscount(theresults.size() – 1);
response.setresultset(theresults);
}
else
{
statement.executeupdate(thesql);
response.setresultscount(-1);
response.setresultset(new vector());
}
}catch(sqlexception ex)
{
response.setresponsecode(400);
response.setresponsemessage(ex.getmessage());
return response;
}
response.setresponsecode(200);
response.setresponsemessage("ok");
string res = response.serializeresponsetostring("utf-8");
system.out.println(res);
return response;
}
?
}
在下面的代码中，你能看到servicerequest 和dbservicerequest的执行。请注意随着dbservice-request还提供了一个额外的构造器，它将servicerequest作为一个自变量。这就允许我们把原始请求的xml 文档作为当前文档来使用，从而向现有的数据提供一个额外的应用程序特有的界面：
public class servicerequest
{
public final static string request_type_tag_name = "requesttype";
public final static string request_tag_name = "request";
public final static string root_tag_name = "http-request";
protected document dom;
public servicerequest(document request)
{
dom = request;
}
public servicerequest()
{
dom = new documentimpl();
initializerequest();
}
//initializes an empty request
private void initializerequest()
{
element root = dom.createelement(root_tag_name);
dom.appendchild(root);
element erequesttype =
dom.createelement(request_type_tag_name);
erequesttype.appendchild(dom.createtextnode(""));
root.appendchild(erequesttype);
element erequest =
dom.createelement(request_tag_name);
root.appendchild(erequest);
}
public string getrequesttype()
throws httpserviceexception
{
try
{
return gettextattribute(request_type_tag_name);
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception("invalid request format.");
}
}
public void setrequesttype(string requesttype)
throws httpserviceexception
{
try
{
settextattribute(request_type_tag_name,requesttype);
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception("invalid request format.");
}
}
public node getrequest()
throws httpserviceexception
{
try
{
node request =
((nodelist)dom.getelementsbytagname(request_tag_name)).item(0);
return request.getfirstchild().clonenode(true);
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception("invalid request format.");
}
}
public element createelementnode(string elementname)
{
return dom.createelement(elementname);
}
public text createtextnode(string value)
{
return dom.createtextnode(value);
}
public void setrequest(node request)
throws httpserviceexception
{
try
{
node requestelement =
((nodelist)dom.getelementsbytagname(request_tag_name)).item(0);
node oldrequest =
requestelement.getfirstchild();
if(oldrequest != null)
requestelement.removechild(oldrequest);
requestelement.appendchild(request);
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception("invalid request format.");
}
}
public byte[] serializerequesttobytearray(string encoding)
throws httpserviceexception
{
try
{
return serializedom(encoding).tobytearray();
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception("error during serialization");
}
}
public string serializerequesttostring(string encoding)
throws httpserviceexception
{
try
{
return serializedom(encoding).tostring();
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception(
"error during serialization");
}
}
private bytearrayoutputstream serializedom(string encoding)
throws httpserviceexception
{
try
{
bytearrayoutputstream bytes =
new bytearrayoutputstream (4096);
printwriter out = new printwriter (new outputstreamwriter (bytes,encoding),true) ;
outputformat of =
new outputformat(dom,encoding,true);
xmlserializer serializer = new xmlserializer(out,of);
serializer.serialize(dom);
out.close();
return bytes;
}
catch(exception ex)
{
ex.printstacktrace(system.err);
throw new httpserviceexception("error during serialization");
}
}
protected string gettextattribute(string name)
{
node textattributenode = ((nodelist)dom.getelementsbytagname(name)).item(0);
node textattribute = textattributenode.getfirstchild();
if(textattribute.getnodetype() == node.text_node)
return textattribute.getnodevalue();
else
return null;
}
protected void settextattribute(string name, string value)
{
if (value == null)
value ="";
node textattributenode =((nodelist)dom.getelementsbytagname(name)).item(0);
node textattribute =
textattributenode.getfirstchild();
textattribute.setnodevalue(value);
}
}
public class dbservicerequest extends servicerequest
{
public final static string service_name = "dbservice";
public final static string sql_statement_tag_name = "sql-statement";
public dbservicerequest()
{
super();
initializeparameters();
}
public dbservicerequest(document request)
{
super(request);
}
public dbservicerequest(servicerequest request)
{
dom = request.dom;
}
public void setsqlstatement(string sql)
{
settextattribute(sql_statement_tag_name,sql);
}
public string getsqlstatement()
{
return gettextattribute(sql_statement_tag_name);
}
private void initializeparameters()
{
element edbrequest = null;
//not very nice but this should never fail
try
{
setrequesttype(service_name);
edbrequest = createelementnode(sql_statement_tag_name);
}
catch(exception ex)
{}
edbrequest.appendchild(dom.createtextnode(""));
try
{
setrequest(edbrequest);
}
catch(exception ex)
{
}
}
扩展框架结构
我们可以对这个框架进行扩展，从而处理任何类型的服务。要想创建一个新的服务，首先必须要定义xml请求和响应的语法。然后，创建servicerequest和serviceresponse的一个子类，它们将帮助处理服务特有的数据。最后，创建http-servicehandler的一个新子类，它将处理请求并生成适当的响应。整个过程就是这样。
虽然这个框架包含了一些功能，但是如果不增加一些更多功能的话，它在实际应用情况下还不是很实用。我有意识地省略了这些功能，以使框架结构保持简单，并将注意力集中到了最重要的细节上。为了完整起见，现在我们来简要分析这个框架结构的一些局限性以及应该如何去克服这些局限性。
首先，这个框架结构不能限制对服务的访问。这就意味着知道如何访问这个服务的每个人都能够进行访问。在你允许对服务的访问之前，请求某种证明可以解决这个问题。你可以用这同一个框架来创建一个证明服务，这样就能确认用户并生成一个唯一的id，当用户访问任何其它服务时，都会被要求这个id。系统会将这个id存储在某些类型的访问列表中，并且要求在一个有限时间内，每个请求都必须通过一个有效id才能访问服务。
另外，每次用户访问服务时，服务都要创建一个与数据库的连接。将服务与一个连接pooling框架组合起来可以解决这个问题，这样就将给请求分配一个现有连接，而不是每次都创建新连接。
最后一个局限是缺乏session的管理。由于我们是通过一个socket 直接访问servlet，因此不能使用特别有用的httpsession对象。由于在web 服务器与浏览器相互作用的过程中，在客户计算机上没有生成session cookie ，因此不能管理自动session。为了克服这个局限，我们可以执行我们自己的session管理。一个session可以是一个与唯一id相关联的对象，它可以存储其它对象。例如，你可以有一个上下文hash信号表格，在其中存储session对象，使用唯一的id 作为关键字。这个session对象还可以包含一个hash信号表格，它存储了你想在session中坚持使用的每个对象。
这个框架利用http隧道技术，允许一个桌面应用程序访问防火墙后面的服务，对其进行扩展后还提供对其它类型服务的简易访问。
