使用CXF和MTOM上传附件

jackyrong

CXF是一个不错的开源的WS框架，支持多种WS协议，其中包括对附件上传的协议MTOM，下文以一个例子来说明，如何用CXF和MTOM来
实现上传一个WORD的文件到服务端。
首先是服务端WS的实现。我们编写一个POJO，来处理一个待上传的简历：
Resume.java
import javax.activation.DataHandler; 
public class Resume
{
  private String candidateName;
  private String resumeFileType;
  private DataHandler resume;
。。。。。。
这里注意使用DataHandler来处理待上传的简历WORD文件
接口：ResumeUploadService.java
import javax.jws.WebParam;
import javax.jws.WebService;
import com.thea.dto.Resume;
@WebService
public interface ResumeUploadService {
   
    void uploadResume(@WebParam(name="resume") Resume resume);
}
  这里使用了jax-ws规范的注释去实现
实现类：
 
import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import javax.activation.DataHandler;
import javax.jws.WebService;
import com.thea.dto.Resume;
@WebService(endpointInterface = "com.thea.service.ResumeUploadService",
 serviceName = "ResumeService")
public class ResumeUploadServiceImpl implements ResumeUploadService {
    public void uploadResume(Resume resume) {
 DataHandler handler = resume.getResume();
 try {
     InputStream is = handler.getInputStream();
     OutputStream os = new FileOutputStream(new File("c:\\"
      + resume.getCandidateName() +"."+
      resume.getResumeFileType()));
     byte[] b = new byte[100000];
     int bytesRead = 0;
     while ((bytesRead = is.read(b)) != -1) {
  os.write(b, 0, bytesRead);
     }
     os.flush();
     os.close();
     is.close();
 } catch (IOException e) {
     e.printStackTrace();
 }
    }
}
然后在src目录下建立cxf.xml，做为服务端的配置文件
<beans xmlns="http://www.springframework.org/schema/beans"
      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      xmlns:jaxws="http://cxf.apache.org/jaxws"
      xsi:schemaLocation="http://www.springframework.org/schema/beans
      http://www.springframework.org/schema/beans/spring-beans.xsd
      http://cxf.apache.org/jaxws
      http://cxf.apache.org/schemas/jaxws.xsd">
  <import resource="classpath:META-INF/cxf/cxf.xml" />
  <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml"/>
  <import resource="classpath:META-INF/cxf/cxf-servlet.xml" />
  <jaxws:endpoint id="uploadresume"
                  implementor="com.thea.service.ResumeUploadServiceImpl"
                  address="/UploadResumeWS">
                  <jaxws:properties>
      <entry key="mtom-enabled" value="true"/>
    </jaxws:properties> 
    </jaxws:endpoint>
</beans>
这里注意使用了   <entry key="mtom-enabled" value="true"/>设置使用MTOM附件

接下来设计客户端：
作为客户端，必须首先有Resume的POJO类，以及还有服务端的接口ResumeUploadService，设计的Client如下：
  public static void main(String args[]) throws Exception {
     JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
     factory.getInInterceptors().add(new LoggingInInterceptor());
     factory.getOutInterceptors().add(new LoggingOutInterceptor());
     factory.setServiceClass(ResumeUploadService.class);
     factory.setAddress
     ("http://localhost:8085/CxfUploadService/services/UploadResumeWS");
     ResumeUploadService client = (ResumeUploadService) factory.create();
     Resume resume=new Resume();
     resume.setCandidateName("KarthikeyanC");
     resume.setResumeFileType("doc");
     
     DataSource source = new FileDataSource(new File("d:\\upload.doc"));
     resume.setResume(new DataHandler(source));
     client.uploadResume(resume);
     System.exit(0);
    }
注意这里由于使用了JaxWsProxyFactoryBean，并在程序中设定了对WS的各类指定，所以不用再写客户端的WS文件了