用DataHandler来实现一个带附件的soap请求的web services

王朝html/css/js·作者佚名  2006-12-17
窄屏简体版  字體: |||超大  

用DataHandler来实现一个带附件的soap请求的web services

用DataHandler来实现一个带附件的soap请求的web services

1.为了使其对DataHandler的支持。除了配置好axis环境之外,还要在sun的网站上下载jaf 1-0-2.jar包,并把它注册到CLASS_PATH中。

2.编写服务程序(.java),既支持文本文件,也支持二进制文件。

package test.gaolong;

import java.io.*;

import javax.activation.*;

public class FileService{

public static String Repository='./files/';

public String putFile(DataHandler dh,String name){

if(name==null)

name='test.tmp';

System.out.println('test');

try{

File dir=new File(Repository);

if(!dir.exists()){

dir.mkdir(); System.out.println('makedir'+'test');

}

InputStream input=dh.getInputStream();

FileOutputStream fos=new FileOutputStream(new File(dir,name));

System.out.println('test');

byte[] buffer=new byte[1024*4];

int n=0;

while((n=input.read(buffer))!=-1){

fos.write(buffer,0,n);

System.out.println(buffer);

}

System.out.println('test');

input.close();

fos.close();

}catch(IOException e){

e.printStackTrace();

}

return name+'send OK';

}

public DataHandler getFile(String name){

File dir=new File(Repository);

if(!dir.exists())

dir.mkdir();

File data=new File(dir,name);

if(data.exists())

return new DataHandler(new FileDataSource(data));

else

return null;

}

}

3。写deploy.wsdd部署描述文件如下:

<deployment xmlns='http://xml.apache.org/axis/wsdd/' xmlns:java='http://xml.apache.org/axis/wsdd/providers/java' xmlns:ns1='http://localhost:7001/axis/services/FileService' >

<service name='FileService' provider='java:RPC'>

<parameter name='className' value='test.gaolong.FileService'/>

<parameter name='allowedMethods' value='*'/>

<parameter name='allowedRoles' value='user'/>

<operation name='getFile' returnQName='returnqname' returnType='ns1:DataHandler' xmlns:SchemaNS='http://www.w3.org/2001/XMlSchema'>

<parameter name='name' type='SchemaNS:string'/>

</operation>

<operation name='putFile' returnQName='returnqname' returnType='ns1:DataHandler' xmlns:SchemaNS='http://www.w3.org/2001/XMlSchema'>

<parameter name='dh' type='ns1:DataHandler'/>

<parameter name='name' type='SchemaNS:string'/>

</operation>

<typeMapping deserializer='org.apache.axis.encoding.ser.JAFDataHandlerDeserializerFactory' type='java:javax.activation.DataHandler' qname='ns1:DataHandler' serializer='org.apache.axis.encoding.ser.JAFDataHandlerSerializerFactory' encodingStyle='http://schemas.xmlsoap.org/soap/encoding/'/>//注意见下面的。

</service>

</deployment>

注:对于soap1.2而言,要使用上面的<typeMaping>,而对于soap1.1而言,则有一点区别如下:

<typeMapping deserializer='org.apache.axis.encoding.ser.JAFDataHandlerDeserializerFactory' lanuageSpecificType='java:javax.activation.DataHandler' qname='ns1:DataHandler' serializer='org.apache.axis.encoding.ser.JAFDataHandlerSerializerFactory' encodingStyle='http://schemas.xmlsoap.org/soap/encoding/'/>

4。启动服务器,用java org.apache.axis.client.AdminClient -p 7001 deploy.wsdd部署webservices即可访问。

5。编写客户端应用访问程序如下:

import javax.xml.rpc.ParameterMode;

import org.apache.axis.client.Call;

import org.apache.axis.client.Service;

import org.apache.axis.encoding.XMLType;

import javax.xml.namespace.QName;

import org.apache.axis.soap.SOAP11Constants;

import java.net.URL;

import javax.activation.DataHandler;

import javax.activation.FileDataSource;

import org.apache.axis.encoding.ser.*;

public class ServiceClient{

public static void main(String[] args) throws Exception{

String filename='HelloWorld.java';

DataHandler dh=new DataHandler(new FileDataSource(filename));

String endpoint='http://127.0.0.1:7003/axis/services/FileService';

String name='gaolong1';

Service service=new Service();

Call call=(Call) service.createCall();

call.setTargetEndpointAddress(new java.net.URL(endpoint));

call.setOperationName(new QName('http://127.0.0.1:7001/axis/services/FileService', 'putFile'));//指定方法的命名空间

QName qnameattachment=new QName('FileService','DataHandler');

call.registerTypeMapping(dh.getClass(),qnameattachment,JAFDataHandlerSerializerFactory.class,JAFDataHandlerDeserializerFactory.class);

call.addParameter('s1',qnameattachment,ParameterMode.IN);

call.addParameter('s2',XMLType.XSD_STRING,ParameterMode.IN);

call.setReturnType(XMLType.XSD_STRING);//XMLType.XSD_STRING);//用Class.forName('java.lang.String')来获取java类型

String ret=(String)call.invoke(new Object[] {dh,'HelloWorld.java'});

System.out.println(ret);

}

}

6。成功执行客户端应用程序,可以找到上传文件。

请求的soap消息:

POST /axis/services/FileService HTTP/1.0

Content-Type: multipart/related; type='text/xml'; start='<3165C8664597DC7EF29D5BFAC8972562>'; boundary='----=_Part_0_21866740.1141202759484'

Accept: application/soap+xml, application/dime, multipart/related, text/*

User-Agent: Axis/1.2.1

Host: localhost:7003

Cache-Control: no-cache

Pragma: no-cache

SOAPAction: ''

Content-Length: 1050

------=_Part_0_21866740.1141202759484

Content-Type: text/xml; charset=UTF-8

Content-Transfer-Encoding: binary

Content-Id: <3165C8664597DC7EF29D5BFAC8972562>

<?xml version='1.0' encoding='UTF-8'?><soapenv:Envelope xmlns:soapenv='http://schemas.xmlsoap.org/soap/envelope/' xmlns:xsd='http://www.w3.org/2001/XMLSchema' xmlns:xsi='http://www.w3.org/2001/XMLSchema-instance'><soapenv:Body><ns1:putFile soapenv:encodingStyle='http://schemas.xmlsoap.org/soap/encoding/' xmlns:ns1='http://127.0.0.1:7001/axis/services/FileService'><s1 href='cid:03D9C1D3A9E0788D274934C3ABD52811' xsi:type='ns2:DataHandler' xmlns:ns2='FileService'/><s2 xsi:type='xsd:string'>HelloWorld.java</s2></ns1:putFile></soapenv:Body></soapenv:Envelope>

------=_Part_0_21866740.1141202759484

Content-Type: application/octet-stream

Content-Transfer-Encoding: binary

Content-Id: <03D9C1D3A9E0788D274934C3ABD52811>

public class HelloWorld{

public String sayHello(String name){

return 'Hello'+name;

}

}

------=_Part_0_21866740.1141202759484--

上传后的文件的位置:/*在该目录下创建文件夹:D:\bea\user_projects\domains\mydomain\files,并把相应的文件存入该目录下*/

7.另一种基于java mail的带附件的传输,是基于xmlDOM+servlet可以来实现,只是比较底层而已。

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航