歡迎光臨
每天分享高質量文章

通向架構師的道路 ( 第十二天 ) 之 Axis2 Web Service ( 三 )( 下 )

(點擊上方公眾號,可快速關註)


來源:袁鳴凱 ,

blog.csdn.net/lifetragedy/article/details/7801983


四、使用SWA(Soap WithAttachment)來進行附件傳送

有了上面兩個例子的基礎後,我們將使用這個例子來結束Axis2中的Soap特性的教學。

在Axis2中傳輸附件有兩種形式,一種叫MTOM,一種就是SWA。

SWAP即Soap With Attachment,這是業界的標準。

所謂的SWA傳輸,即客戶端把需要上傳的檔案,編譯成兩進制代碼凌晨隨著soap的request一起推送到服務端,該兩進制代碼以AttachmentId的形式來表示,即如下這樣的一個soap body:


 

 

test.jpg

 

urn:uuid:8B43A26FEE1492F85A1343628038693

 

 

服務端收到該soap的request可以直接使用如下的陳述句將這個AttachmentId還原成輸出流:

DataHandler dataHandler = attachment.getDataHandler(attchmentID);

 

File file = new File(uploadFilePath.toString());

 

fileOutputStream = new FileOutputStream(file);

 

dataHandler.writeTo(fileOutputStream);

 

fileOutputStream.flush();

在我們這個例子內,我們將使用客戶端上傳一個jpg檔案,服務端收到該jpg檔案(可以是任何的兩進制檔案)後解析後存入服務端的一個目錄。

先來看服務端代碼

org.sky.axis2.attachment.FileUploadService

package org.sky.axis2.attachment;

 

import java.io.File;

import java.io.FileOutputStream;

import java.io.IOException;

import javax.activation.DataHandler;

import org.apache.axiom.attachments.Attachments;

import org.apache.axis2.context.MessageContext;

import org.sky.axis2.util.UUID;

public class FileUploadService {

 

         public String uploadFile(String name, String attchmentID) throws Exception {

 

                   FileOutputStream fileOutputStream = null;

 

                   StringBuffer uploadFilePath = new StringBuffer();

 

                   String fileNamePrefix = “”;

 

                   String fileName = “”;

 

                   try {

 

                            MessageContext msgCtx = MessageContext.getCurrentMessageContext();

 

                            Attachments attachment = msgCtx.getAttachmentMap();

 

                            DataHandler dataHandler = attachment.getDataHandler(attchmentID);

 

                            fileNamePrefix = name.substring(name.indexOf(“.”), name.length());

 

                            fileName = UUID.getUUID();

 

                            System.out.println(“fileName=====” + fileName);

 

                            System.out.println(“fileNamePrefix====” + fileNamePrefix);

 

                            uploadFilePath.append(“D:/upload/axis2/”);

 

                            uploadFilePath.append(fileName);

 

                            uploadFilePath.append(fileNamePrefix);

 

                            System.out

 

                                               .println(“uploadFilePath====” + uploadFilePath.toString());

 

                            File file = new File(uploadFilePath.toString());

 

                            fileOutputStream = new FileOutputStream(file);

 

                            dataHandler.writeTo(fileOutputStream);

 

                            fileOutputStream.flush();

 

                   } catch (Exception e) {

 

                            throw new Exception(e);

 

                   } finally {

 

                            try {

 

                                     if (fileOutputStream != null) {

 

                                               fileOutputStream.close();

 

                                               fileOutputStream = null;

 

                                     }

 

                            } catch (Exception e) {

 

                            }

 

                   }

 

                   return “File saved succesfully.”;

         }

}

下麵是服務端的描述

service.xml檔案的內容為:

 

         org.sky.axis2.attachment.FileUploadService

 

         

 

         

 

                   urn:uploadFile

 

                   

 

         

 

該服務端接受客戶端上傳的附件後使用UUID重新命名上傳的檔案名,並將其存入服務端的” D:/upload/axis2/”目錄中。

來看客戶端代碼

org.sky.axis2.attachment.FileUploadClient

package org.sky.axis2.attachment;

import java.io.File;

import javax.activation.DataHandler;

import javax.activation.FileDataSource;

import javax.xml.namespace.QName;

import org.apache.axiom.om.OMAbstractFactory;

import org.apache.axiom.om.OMElement;

import org.apache.axiom.om.OMNamespace;

import org.apache.axiom.soap.SOAP11Constants;

import org.apache.axiom.soap.SOAPBody;

import org.apache.axiom.soap.SOAPEnvelope;

import org.apache.axiom.soap.SOAPFactory;

import org.apache.axis2.Constants;

import org.apache.axis2.addressing.EndpointReference;

import org.apache.axis2.client.OperationClient;

import org.apache.axis2.client.Options;

import org.apache.axis2.client.ServiceClient;

import org.apache.axis2.context.ConfigurationContext;

import org.apache.axis2.context.ConfigurationContextFactory;

import org.apache.axis2.context.MessageContext;

import org.apache.axis2.wsdl.WSDLConstants;

 

public class FileUploadClient {

 

         private static EndpointReference targetEPR = new EndpointReference(

 

                            “http://localhost:8080/Axis2Service/services/AttachmentService”);

 

  

 

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

 

                   new FileUploadClient().transferFile();

 

         }

 

  

 

         public void transferFile() throws Exception {

 

                   String filePath = “D:/deployment/test.jpg”;

 

                   String destFile = “test.jpg”;

 

                   Options options = new Options();

 

                   options.setTo(targetEPR);

 

                   options.setProperty(Constants.Configuration.ENABLE_SWA,

 

                                     Constants.VALUE_TRUE);

 

                   options.setSoapVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI);

 

                   options.setTimeOutInMilliSeconds(10000);

 

                   options.setTo(targetEPR);

 

                   options.setAction(“urn:uploadFile”);

 

                   ConfigurationContext configContext = ConfigurationContextFactory

 

                                     .createConfigurationContextFromFileSystem(

 

                                                        “D:/wspace/Axis2Service/WebContent/WEB-INF/modules”,

 

                                                        null);

 

  

 

                   ServiceClient sender = new ServiceClient(configContext, null);

 

                   sender.setOptions(options);

 

                   OperationClient mepClient = sender

 

                                     .createClient(ServiceClient.ANON_OUT_IN_OP);

 

  

 

                   MessageContext mc = new MessageContext();

 

                   FileDataSource fileDataSource = new FileDataSource(new File(filePath));

 

  

 

                   // Create a dataHandler using the fileDataSource. Any implementation of

 

                   // javax.activation.DataSource interface can fit here.

 

                   DataHandler dataHandler = new DataHandler(fileDataSource);

 

                   String attachmentID = mc.addAttachment(dataHandler);

 

  

 

                   SOAPFactory fac = OMAbstractFactory.getSOAP11Factory();

 

                   SOAPEnvelope env = fac.getDefaultEnvelope();

 

                   OMNamespace omNs = fac.createOMNamespace(

 

                                     “http://attachment.axis2.sky.org”, “”);

 

                   OMElement uploadFile = fac.createOMElement(“uploadFile”, omNs);

 

                   OMElement nameEle = fac.createOMElement(“name”, omNs);

 

                   nameEle.setText(destFile);

 

                   OMElement idEle = fac.createOMElement(“attchmentID”, omNs);

 

                   idEle.setText(attachmentID);

 

                   uploadFile.addChild(nameEle);

 

                   uploadFile.addChild(idEle);

 

                   env.getBody().addChild(uploadFile);

 

                   System.out.println(“message====” + env);

 

                   mc.setEnvelope(env);

 

  

 

                   mepClient.addMessageContext(mc);

 

                   mepClient.execute(true);

 

                   MessageContext response = mepClient

 

                                     .getMessageContext(WSDLConstants.MESSAGE_LABEL_IN_VALUE);

 

                   SOAPBody body = response.getEnvelope().getBody();

 

                   OMElement element = body.getFirstElement().getFirstChildWithName(

 

                                     new QName(“http://attachment.axis2.sky.org”, “return”));

 

                   System.out.println(element.getText());

 

         }

}

註意紅色加粗部分的代碼,由其是:

FileDataSource fileDataSource = new FileDataSource(new File(filePath));

String attachmentID = mc.addAttachment(dataHandler);

這兩句就是把客戶端需要上傳的附件轉成AttachmentId的陳述句,然後把這個AttachementId作為一個OMElement的型別加入到客戶端的soap request中去即可:

OMElement idEle = fac.createOMElement(“attchmentID”, omNs);

idEle.setText(attachmentID);

uploadFile.addChild(nameEle);

uploadFile.addChild(idEle);

env.getBody().addChild(uploadFile);

來看運行效果。

客戶端:

上傳d:/deployment/test.jpg檔案

客戶端收到服務端傳回的”File saved successfully”即可在服務端的” D:/upload/axis2”目錄中查詢是否成功上傳了該檔案了

可以看到,由於我們使用的是UUID因此每次上傳,服務端的檔案名都不會重覆。

附錄 UUID.java

package org.sky.axis2.util;

 

public class UUID {

 

         protected static int count = 0;

         public static synchronized String getUUID() {

                    count++;

                   long time = System.currentTimeMillis();

 

  

 

                   String timePattern = Long.toHexString(time);

 

                   int leftBit = 14 – timePattern.length();

 

                   if (leftBit > 0) {

 

                            timePattern = “0000000000”.substring(0, leftBit) + timePattern;

 

                   }

 

                   String uuid = timePattern

 

                                     + Long.toHexString(Double.doubleToLongBits(Math.random()))

                                     + Long.toHexString(Double.doubleToLongBits(Math.random()))

 

                                     + “000000000000000000”;

 

                   uuid = uuid.substring(0, 32).toUpperCase(); 

                   return uuid;

         }

}

系列


看完本文有收穫?請轉發分享給更多人

關註「ImportNew」,提升Java技能

赞(0)

分享創造快樂