Terry.Li-彬

虛其心，可解天下之問；專其心，可治天下之學；靜其心，可悟天下之理；恒其心，可成天下之業。

BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合

:: 管理 ::

143 隨筆 :: 344 文章 :: 130 評論 :: 0 Trackbacks

(轉載)使用Axis2傳輸附件(AXIS2 MTOM)--1

本文介紹如何使用Axis2傳遞附件。

author: ZJ 07-5-7

Blog: http://zhangjunhd.blog.51cto.com/

1．工作環境

IDE: Eclipse 3.1.2

jdk: jdk1.5.0_04

Tomcat: apache-tomcat-5.0.28

AXIS2:1.0(war版本和bin版本)

2．實現

在Eclipse新建一個動態web工程，在WEB-INF"lib下加入axis2所需的jar包。

本例的是一個系統的用戶上傳下載圖片格式文件的例子，每次上傳出攜帶附件外，還包括文件名, 文件類型。此webservice實現的2個功能就是upload, download.

AXIS2的webservice發布的時候是打包成xxx.aar發布的，xxx.aar展開后的目錄結構為

--META-INF

services.xml

--包含server端實現的class( 目錄跟package是一樣的結構)

3．服務器端FileTransferServer.java

package sample;

import org.apache.axiom.attachments.utils.IOUtils;

import org.apache.axiom.om.OMAbstractFactory;

import org.apache.axiom.om.OMElement;

import org.apache.axiom.om.OMFactory;

import org.apache.axiom.om.OMNamespace;

import org.apache.axiom.om.OMText;

import org.apache.axis2.AxisFault;

import java.io.File;

import java.io.FileOutputStream;

import java.io.InputStream;

import java.util.Iterator;

import javax.activation.DataHandler;

import javax.activation.FileDataSource;

public class FileTransferServer {

public static final String TMP_PATH = "D:/temp";

public OMElement upload(OMElement element) throws Exception {

OMElement _fileContent = null;//文件內容

OMElement _fileName = null;//文件名

OMElement _fileType = null;//文件類型

System.out.println("The element for upload: " + element);

for (Iterator _iterator = element.getChildElements(); _iterator

.hasNext();) {

OMElement _ele = (OMElement) _iterator.next();

if (_ele.getLocalName().equalsIgnoreCase("fileContent")) {

_fileContent = _ele;

}

if (_ele.getLocalName().equalsIgnoreCase("fileName")) {

_fileName = _ele;

}

if (_ele.getLocalName().equalsIgnoreCase("fileType")) {

_fileType = _ele;

}

if (_fileContent == null || _fileType == null) {

throw new AxisFault("Either Image or FileName is null");

}

OMText binaryNode = (OMText) _fileContent.getFirstOMChild();

String fileName = _fileName.getText();

String fileType = _fileType.getText();

String storeDir = TMP_PATH + "/" + "tempTest";

File dir = new File(storeDir);

if (!dir.exists()) {

dir.mkdir();

}

String filePath = storeDir + "/" + fileName + "." + fileType;

File uploadFile = new File(filePath);

if (uploadFile.exists()) {

filePath = storeDir + "/" + fileName + "(1)" + "." + fileType;

uploadFile = new File(filePath);

}

// Extracting the data and saving

DataHandler actualDH;

actualDH = (DataHandler) binaryNode.getDataHandler();

FileOutputStream imageOutStream = new FileOutputStream(uploadFile);

InputStream is = actualDH.getInputStream();

imageOutStream.write(IOUtils.getStreamAsByteArray(is));

// setting response

OMFactory fac = OMAbstractFactory.getOMFactory();

OMNamespace ns = fac.createOMNamespace("http://example.org/filedata",

"fd");

OMElement ele = fac.createOMElement("response", ns);

ele.setText("true");

return ele;

}

public OMElement download(OMElement element) throws Exception {

System.out.println("The element for download: " + element);

OMElement _userName = null;

OMElement _fileName = null;

OMElement _fileType = null;

for (Iterator _iterator = element.getChildElements(); _iterator

.hasNext();) {

OMElement _ele = (OMElement) _iterator.next();

if (_ele.getLocalName().equalsIgnoreCase("userName")) {

_userName = _ele;

}

if (_ele.getLocalName().equalsIgnoreCase("fileName")) {

_fileName = _ele;

}

if (_ele.getLocalName().equalsIgnoreCase("fileType")) {

_fileType = _ele;

}

String userName = _userName.getText();

String fileName = _fileName.getText();

String fileType = _fileType.getText();

String filePath = TMP_PATH + "/" + userName + "/" + fileName + "."

+ fileType;

System.out.println("The filePath for download: " + filePath);

FileDataSource dataSource = new FileDataSource(filePath);

DataHandler expectedDH = new DataHandler(dataSource);

OMFactory fac = OMAbstractFactory.getOMFactory();

OMNamespace ns = fac.createOMNamespace("http://example.org/filedata",

"fd");

OMText textData = fac.createOMText(expectedDH, true);

OMElement ele = fac.createOMElement("response", ns);

ele.addChild(textData);

return ele;

}

4.services.xml

This is a sample Web Service with two operations,echo and ping.

sample.FileTransferServer

urn:upload

urn:download

將這兩個文件打包并部署到Tomcat上（略）。

5．測試

FileTransferClient.java

package sample;

import java.io.File;

import java.io.FileOutputStream;

import java.io.InputStream;

import javax.activation.DataHandler;

import javax.activation.FileDataSource;

import org.apache.axiom.attachments.utils.IOUtils;

import org.apache.axiom.om.OMAbstractFactory;

import org.apache.axiom.om.OMElement;

import org.apache.axiom.om.OMFactory;

import org.apache.axiom.om.OMNamespace;

import org.apache.axiom.om.OMText;

import org.apache.axiom.soap.SOAP11Constants;

import org.apache.axis2.AxisFault;

import org.apache.axis2.Constants;

import org.apache.axis2.addressing.EndpointReference;

import org.apache.axis2.client.Options;

import org.apache.axis2.client.ServiceClient;

public class FileTransferClient {

private static EndpointReference targetEPR =

new EndpointReference("http://127.0.0.1:8080/axis2/services/FileOperation");

public static boolean upload(String fileName, File file, String fileType) {

try {

OMElement data = buildUploadEnvelope(fileName, file, fileType);

Options options = buildOptions();

ServiceClient sender = new ServiceClient();

sender.setOptions(options);

System.out.println("The data in method upload: "+data);

OMElement ome = sender.sendReceive(data);

System.out.println("Convert the data to element in method upload: "+ome);

String b = ome.getText();

return Boolean.parseBoolean(b);

}

catch(Exception e) {

e.printStackTrace();

}

return false;

}

public static boolean download(String userName, String fileName, String fileType) {

try {

OMElement data = buildDownloadEnvelope(userName, fileName, fileType);

Options options = buildOptions();

ServiceClient sender = new ServiceClient();

sender.setOptions(options);

System.out.println("The data in method download: "+data);

OMElement ome = sender.sendReceive(data);

System.out.println("Convert the data to element in method download: "+ome);

OMText binaryNode = (OMText) ome.getFirstOMChild();

binaryNode.setOptimize(true); //必須加此句，否則會出現ContentID is null的異常!

DataHandler actualDH = (DataHandler) binaryNode.getDataHandler();

FileOutputStream imageOutStream = new FileOutputStream("D:/userTemp/xx.gif");

InputStream is = actualDH.getInputStream();

imageOutStream.write(IOUtils.getStreamAsByteArray(is));

return true;

}

catch(Exception e) {

e.printStackTrace();

}

return false;

}

private static OMElement buildUploadEnvelope(String fileName, File file, String fileType) {

DataHandler expectedDH;

OMFactory fac = OMAbstractFactory.getOMFactory();

OMNamespace omNs = fac.createOMNamespace("http://example.org/filedata", "fd");

OMElement data = fac.createOMElement("upload", omNs);

OMElement fileContent = fac.createOMElement("fileContent", omNs);

FileDataSource dataSource = new FileDataSource(file);

expectedDH = new DataHandler(dataSource);

OMText textData = fac.createOMText(expectedDH, true);

fileContent.addChild(textData);

OMElement _fileName = fac.createOMElement("fileName", omNs);

_fileName.setText(fileName);

OMElement _fileType = fac.createOMElement("fileType", omNs);

_fileType.setText(fileType);

data.addChild(_fileName);

data.addChild(_fileType);

data.addChild(fileContent);

return data;

posted on 2008-07-10 16:54 禮物閱讀(1444) 評論(0) 編輯收藏所屬分類: web service

新用戶注冊刷新評論列表


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: (原)Axis2 OM 模式使用 Web Service Appender for Log4j 管理日志紀錄 (原創)用Axis2寫的通用WebService組件 Webservice 的設計和模式 WebService大講堂之Axis2（2）：復合類型數據的傳遞（轉載）WebService大講堂之Axis2（1）：用POJO實現0配置的WebService (轉載)使用Axis2的底層API開發Web Service 使用Axis2傳遞簡單Java對象（POJO） Axis2快速上手指南使用Axis2傳輸附件(AXIS2 MTOM)--2

Terry.Li-彬

常用鏈接

留言簿(19)

隨筆分類(107)

隨筆檔案(141)

文章分類(284)

文章檔案(342)

相冊

收藏夾(58)

家裝

最新隨筆

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜