亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

Webservice傳送文件的實(shí)現(xiàn)(AXIS2 MTOM)

系統(tǒng) 1624 0
工作環(huán)境 :IDE:Eclipse 3.1.2
jdk: jdk1.5.0_06
Tomcat: apache-tomcat-5.5.15
AXIS2:1.0(war 版本和bin版本)
環(huán)境準(zhǔn)備:
Distribution url: http://apache.justdn.org/ws/axis2/1_0/axis2-1.0-docs.zip 。把這兩個(gè)文件解壓,比如解壓縮的后得目錄為 C:/axis2-std-1.0-bin C:/axis2.war. Eclipse 下通過(guò)菜單 window—preferences…--Java—Build Path—User Libraries 新建一個(gè) user library, 比如名字就叫 axis2 C:/axis2-std-1.0-bin/lib 下的所有 jar 文件包含進(jìn)來(lái)。把 axis2.war 拷貝到 %TOMCAT-HOME%/webapps 下面。
實(shí)現(xiàn)
Eclipse 新建一個(gè)工程,裝了 Eclipse tomcat plugin 的就新建一個(gè) tomcat project 好了, build path 包含上面創(chuàng)建的 user library:axis2. 我的例子的場(chǎng)景是一個(gè)語(yǔ)音信箱系統(tǒng)的用戶上傳下載問(wèn)候語(yǔ)文件( greeting) 的,每個(gè)語(yǔ)音信箱系統(tǒng)的用戶擁有一個(gè)唯一的 mailbox number, 問(wèn)候語(yǔ)有不同的類型,比如忙的時(shí)候問(wèn)候語(yǔ),出差時(shí)候問(wèn)候語(yǔ),不同時(shí)段的問(wèn)候語(yǔ),問(wèn)候語(yǔ)文件支持的類型有 wav,mp3 等等。
所以我的 webservice 要實(shí)現(xiàn)的 2 個(gè)功能就是 upload, download.
AXIS2 webservice 發(fā)布的時(shí)候是打包成 xxx.aar 發(fā)布的, xxx.aar 展開(kāi)后的目錄結(jié)構(gòu)為
--
--META-INF
services.xml
-- 包含 server 端實(shí)現(xiàn)的 class( 目錄跟 package 是一樣的結(jié)構(gòu) )
新建 2 個(gè)類: FileTransferClient.java, interopService.java. 兩個(gè)類內(nèi)容如下:
FileTransferClient( 調(diào)用 webservice 的客戶端代碼 )
package sample.mtom.interop.client;
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.axiom.soap.SOAP12Constants;
import org.apache.axis2.Constants;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;
import javax.activation.DataHandler;
import javax.activation.FileDataSource;
import javax.xml.namespace.QName;
import java.io.File;
import java.io.InputStream;
public class FileTransferClient {
private static EndpointReference targetEPR = new EndpointReference("http://127.0.0.1:8080/axis2/services/interop");
public static boolean upload(String mailboxnum, short greetingType, File file, String fileType) {
try {
OMElement data = buildUploadEnvelope(mailboxnum, greetingType, file, fileType);
Options options = buildOptions();
ServiceClient sender = new ServiceClient();
sender.setOptions(options);
System.out.println(data);
OMElement ome = sender.sendReceive(data);
System.out.println(ome);
String b = ome.getText();
return Boolean.parseBoolean(b);
}
catch(Exception e) {
}
return false;
}
public static InputStream download(String mailboxnum, short greetingType, String FileType) {
try {
OMElement data = buildDownloadEnvelope(mailboxnum, greetingType, FileType);
Options options = buildOptions();
ServiceClient sender = new ServiceClient();
sender.setOptions(options);
System.out.println(data);
OMElement ome = sender.sendReceive(data);
System.out.println(ome);
OMText binaryNode = (OMText) ome.getFirstOMChild();
DataHandler actualDH = (DataHandler) binaryNode.getDataHandler();
return actualDH.getInputStream();
}
catch(Exception e) {
}
return null;
}
private static OMElement buildUploadEnvelope(String mailboxnum, short greetingType, File file, String FileType) {
DataHandler expectedDH;
OMFactory fac = OMAbstractFactory.getOMFactory();
OMNamespace omNs = fac.createOMNamespace("http://example.org/mtom/data", "x");
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 mboxnum = fac.createOMElement("mailboxnum", omNs);
mboxnum.setText(mailboxnum);
OMElement gtType = fac.createOMElement("greetingType", omNs);
gtType.setText(greetingType+"");
OMElement fileType=fac.createOMElement("fileType", omNs);
fileType.setText(FileType);
data.addChild(mboxnum);
data.addChild(gtType);
data.addChild(fileType);
data.addChild(fileContent);
return data;
}
private static OMElement buildDownloadEnvelope(String mailboxnum, short greetingType, String FileType) {
OMFactory fac = OMAbstractFactory.getOMFactory();
OMNamespace omNs = fac.createOMNamespace("http://example.org/mtom/data", "x");
OMElement data = fac.createOMElement("download", omNs);
OMElement mboxnum = fac.createOMElement("mailboxnum", omNs);
mboxnum.setText(mailboxnum);
OMElement gtType = fac.createOMElement("greetingType", omNs);
gtType.setText(greetingType+"");
OMElement fileType=fac.createOMElement("fileType", omNs);
fileType.setText(FileType);
data.addChild(mboxnum);
data.addChild(gtType);
data.addChild(fileType);
return data;
}
private static Options buildOptions() {
Options options = new Options();
options.setSoapVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI);
options.setTo(targetEPR);
// enabling MTOM in the client side
options.setProperty(Constants.Configuration.ENABLE_MTOM, Constants.VALUE_TRUE);
options.setTransportInProtocol(Constants.TRANSPORT_HTTP);
return options;
}
public static void main(String agrs[]) {
String file = "C:/deploy.wsdd";
short gt = 1;
String mn = "20060405";
String ft="wsdd";
boolean rtv = upload(mn,gt,new File(file),ft);
System.out.println(rtv);
InputStream is = download(mn,gt,ft);
}
}
interopService(webservice server 端實(shí)現(xiàn)代碼 )
package sample.mtom.interop.service;
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.FileOutputStream;
import java.io.*;
import java.util.Iterator;
import javax.activation.DataHandler;
import javax.activation.FileDataSource;
public class interopService {
public static final String TMP_PATH = "c:/tmp";
public OMElement upload(OMElement element) throws Exception {
OMElement _fileContent = null;
OMElement _mailboxnum = null;
OMElement _greetingType = null;
OMElement _fileType = null;
System.out.println(element);
for (Iterator _iterator = element.getChildElements(); _iterator.hasNext();) {
OMElement _ele = (OMElement) _iterator.next();
if (_ele.getLocalName().equalsIgnoreCase("fileContent")) {
_fileContent = _ele;
}
if (_ele.getLocalName().equalsIgnoreCase("mailboxnum")) {
_mailboxnum = _ele;
}
if (_ele.getLocalName().equalsIgnoreCase("greetingType")) {
_greetingType = _ele;
}
if (_ele.getLocalName().equalsIgnoreCase("fileType")) {
_fileType = _ele;
}
}
if (_fileContent == null || _mailboxnum == null || _greetingType== null || _fileType==null) {
throw new AxisFault("Either Image or FileName is null");
}
OMText binaryNode = (OMText) _fileContent.getFirstOMChild();
String mboxNum = _mailboxnum.getText();
String greetingType = _greetingType.getText();
String fileType = _fileType.getText();
String greetingstoreDir = TMP_PATH+"/"+mboxNum;
File dir = new File(greetingstoreDir);
if(!dir.exists()) {
dir.mkdir();
}
String filePath = greetingstoreDir+"/"+greetingType+"."+fileType;
File greetingFile = new File(filePath);
if(greetingFile.exists()) {
greetingFile.delete();
greetingFile = new File(filePath);
}
// Extracting the data and saving
DataHandler actualDH;
actualDH = (DataHandler) binaryNode.getDataHandler();
FileOutputStream imageOutStream = new FileOutputStream(greetingFile);
InputStream is = actualDH.getInputStream();
imageOutStream.write(IOUtils.getStreamAsByteArray(is));
// setting response
OMFactory fac = OMAbstractFactory.getOMFactory();
OMNamespace ns = fac.createOMNamespace("http://example.org/mtom/data", "x");
OMElement ele = fac.createOMElement("response", ns);
ele.setText("true");
return ele;
}
public OMElement download(OMElement element) throws Exception {
System.out.println(element);
OMElement _mailboxnum = null;
OMElement _greetingType = null;
OMElement _fileType = null;
for (Iterator _iterator = element.getChildElements(); _iterator.hasNext();) {
OMElement _ele = (OMElement) _iterator.next();
if (_ele.getLocalName().equalsIgnoreCase("mailboxnum")) {
_mailboxnum = _ele;
}
if (_ele.getLocalName().equalsIgnoreCase("greetingType")) {
_greetingType = _ele;
}
if (_ele.getLocalName().equalsIgnoreCase("fileType")) {
_fileType = _ele;
}
}
String mboxNum = _mailboxnum.getText();
String greetingType = _greetingType.getText();
String fileType = _fileType.getText();
String filePath = TMP_PATH+"/"+mboxNum+"/"+greetingType+"."+fileType;
FileDataSource dataSource = new FileDataSource(filePath);
DataHandler expectedDH = new DataHandler(dataSource);
OMFactory fac = OMAbstractFactory.getOMFactory();
OMNamespace ns = fac.createOMNamespace("http://example.org/mtom/data", "x");
OMText textData = fac.createOMText(expectedDH, true);
OMElement ele = fac.createOMElement("response", ns);
ele.addChild(textData);
return ele;
}
}
新建一個(gè) services.xml, 內(nèi)容如下 :
<service name= "MTOMService" >
<description>
This is a sample Web Service with two operations,echo and ping.
</description>
<parameter name= "ServiceClass" locked= "false" > sample.mtom.interop.service.interopService </parameter>
<operation name= "upload" >
<actionMapping> urn:upload </actionMapping>
<messageReceiver class= "org.apache.axis2.receivers.RawXMLINOutMessageReceiver" />
</operation>
<operation name= "download" >
<actionMapping> urn:download </actionMapping>
<messageReceiver class= "org.apache.axis2.receivers.RawXMLINOutMessageReceiver" />
</operation>
</service>
打包
新建一個(gè)目錄叫 build, 拷貝相應(yīng)的文件到 build 下面, build 的目錄展開(kāi)如圖所示:
就像這樣的
--build
--interop
--META-INF
--services.xml
--sample
--mtom
--interop
--service
-- interopService.class
windows 環(huán)境下 , console 下,更換目錄到 build/interop :
輸入一下命令:
jar –cfinterop.aar . , 注意最后一個(gè)點(diǎn)代表當(dāng)前目錄。
發(fā)布
AXIS2 webservice 的發(fā)布是這樣的,首先你要先把 AXIS2 war distribution 發(fā)到到一個(gè) servlet 容器中,我這里用的是 Tomcat. 發(fā)布的方法前面提到了: axis2.war 拷貝到 %TOMCAT-HOME%/webapps
啟動(dòng) tomcat, 然后輸入: http://localhost:8080/axis2/axis2-admin/ 輸入用戶名 admin 密碼 axis2 就進(jìn)入了 axis2 Web Admin Module, 然后在頁(yè)面左邊的菜單的 Tools 下選擇 Upload Service, 然后選擇前面打好的 interop.aar
upload.
還有種手動(dòng)發(fā)布的方式 , 你發(fā)布 axis2.war tomcat 的時(shí)候, tomcat 會(huì)自動(dòng)展開(kāi)生成一個(gè) axis2 的目錄在
%TOMCAT-HOME%/webapps 下面,進(jìn)入到目錄 %TOMCAT-HOME%/webapps/axis2/WEB-INF/services ,把前面打好包的 interop.aar 拷貝到這里 .
測(cè)試
eclipse 里運(yùn)行 FileTransferClient
代碼分析
利用 Axis2 Mtom 發(fā)送附件跟 Sun SAAJ 差不多。用過(guò) javamail 的朋友也會(huì)覺(jué)得代碼似曾相識(shí),應(yīng)為都應(yīng)用了 builder 模式。要向一個(gè) webserive 發(fā)送請(qǐng)求,首先就要構(gòu)建一個(gè)請(qǐng)求的 Envelope,Axis2 構(gòu)建 Envelope 的時(shí)候是利用的 Axis2 AXIOM api( 就是 axis2 java object xml 的映射處理機(jī)制 ), 其編程模式和 DOM 差不多的 . 看這一段 :
private static OMElement buildUploadEnvelope(String mailboxnum, short greetingType, File file, String FileType) {
DataHandler expectedDH;
OMFactory fac = OMAbstractFactory.getOMFactory();
OMNamespace omNs = fac.createOMNamespace("http://example.org/mtom/data", "x");
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 mboxnum = fac.createOMElement("mailboxnum", omNs);
mboxnum.setText(mailboxnum);
OMElement gtType = fac.createOMElement("greetingType", omNs);
gtType.setText(greetingType+"");
OMElement fileType=fac.createOMElement("fileType", omNs);
fileType.setText(FileType);
data.addChild(mboxnum);
data.addChild(gtType);
data.addChild(fileType);
data.addChild(fileContent);
return data;
}
這一段其實(shí)是構(gòu)建的 data 對(duì)像是這樣一段 xml java object 代表:
<x:upload xmlns:x= "http://example.org/mtom/data" >
<x:mailboxnum> 20060405 </x:mailboxnum>
<x:greetingType> 1 </x:greetingType>
<x:fileType> wsdd </x:fileType>
<x:fileContent>
Dwvc2VydmljZT4NCjwvZGVwbG95bWVudD4NCg0K
</x:fileContent>
</x:upload>
其中的 Dwvc2VydmljZT4NCjwvZGVwbG95bWVudD4NCg0K 是要傳送的文件的內(nèi)容代表,至于什么編碼,我沒(méi)有深究。注意這一句 :
OMElement data = fac.createOMElement("upload", omNs);
這里的“ upload 參數(shù)對(duì)應(yīng)的是 webservice 的一個(gè)操作的名稱,這個(gè)操作的名稱是跟 webservice server 端實(shí)現(xiàn)類的方法名和 services.xml 的所定義的
] <operation name= "upload" >
<actionMapping> urn:upload </actionMapping>
<messageReceiver class= "org.apache.axis2.receivers.RawXMLINOutMessageReceiver" />
</operation>
要一致的。
我們?cè)倏纯催@一段,
private static Options buildOptions() {
Options options = new Options();
options.setSoapVersionURI(SOAP11Constants.SOAP_ENVELOPE_NAMESPACE_URI);
options.setTo(targetEPR);
// enabling MTOM in the client side
options.setProperty(Constants.Configuration.ENABLE_MTOM, Constants.VALUE_TRUE);
options.setTransportInProtocol(Constants.TRANSPORT_HTTP);
return options;
}
這里構(gòu)建的 Options 對(duì)象,顧名思義就是調(diào)用 webservice 的相應(yīng)的選項(xiàng):
比如這里就指定了 Soap 協(xié)議為 1.1
指定了所請(qǐng)求的 service EPR( 就是地址 )
聲明在 client 應(yīng)用 MTOM
指定傳輸協(xié)議為 HTTP
構(gòu)建好要傳送的 data options , 所執(zhí)行的代碼為:
ServiceClient sender = new ServiceClient();
// 設(shè)定選項(xiàng)
sender.setOptions(options);
// 打印要傳送的數(shù)據(jù),為一段 xml
System.out.println(data);
// 傳送數(shù)據(jù),得到返回值
OMElement ome = sender.sendReceive(data);
// 打印返回值,為一段 xml
System.out.println(ome);
// 析取返回值中的數(shù)據(jù)
String b = ome.getText();
// 返回
return Boolean.parseBoolean(b);
大家可以發(fā)現(xiàn), server 端和 client 的中間傳遞數(shù)據(jù)都是通過(guò)
org.apache.axiom.om.OMElement 對(duì)象的,這個(gè)對(duì)象是一段 xml java 對(duì)象映射 .
疑惑 :
貌似是 Axis2 bug, 我在 method buildUploadEnvelope 最后是這樣寫的,
data.addChild(mboxnum);
data.addChild(gtType);
data.addChild(fileType);
data.addChild(fileContent);
return data;
data.addChild(fileContent); 對(duì)應(yīng)的是
<x:upload xmlns:x= "http://example.org/mtom/data" >
<x:mailboxnum> 20060405 </x:mailboxnum>
<x:greetingType> 1 </x:greetingType>
<x:fileType> wsdd </x:fileType>
<x:fileContent>
Dwvc2VydmljZT4NCjwvZGVwbG95bWVudD4NCg0K
</x:fileContent>
</x:upload> 中紅色的部分。
這樣沒(méi)有問(wèn)題, service 端接受到的 message 的數(shù)據(jù)跟 client 一致的。
但是如果我這樣寫 , 就是把要傳送的文件內(nèi)容提前加入
data.addChild(fileContent);
data.addChild(mboxnum);
data.addChild(gtType);
data.addChild(fileType);
return data;
Client 端的數(shù)據(jù)是這樣的:
<x:upload xmlns:x= "http://example.org/mtom/data" >
<x:fileContent>
Dwvc2VydmljZT4NCjwvZGVwbG95bWVudD4NCg0K
</x:fileContent>
<x:mailboxnum> 20060405 </x:mailboxnum>
<x:greetingType> 1 </x:greetingType>
<x:fileType> wsdd </x:fileType>
</x:upload>
但是 server 接收到的數(shù)據(jù)成了
<x:upload xmlns:x= "http://example.org/mtom/data" >
<x:fileContent>
Dwvc2VydmljZT4NCjwvZGVwbG95bWVudD4NCg0K
</x:fileContent>
</x:upload>
后面的 3 條數(shù)據(jù)都沒(méi)了!!!!!
參考文獻(xiàn):
Axis2 user guide
Axis2 sample(Axis2 binary distribution 自帶 )
友情提醒:
如果大家要用 Axis2 開(kāi)發(fā) webservice, 強(qiáng)烈建議你先看 IBM developerWorks
中國(guó)
上的一個(gè)教程 -- Apache Geronimo Axis2 實(shí)現(xiàn)在線銀行,第 1 部分 : 服務(wù):布設(shè)框架
URL https://www6.software.ibm.com/developerworks/cn/education/opensource/os-ag-onbank1/index.html ,看這個(gè)教程需要注冊(cè) developerWorks 中國(guó) 的賬號(hào),免費(fèi)注冊(cè)的。
這個(gè)教程的第 2 ,第 3 部分的 url :
我從這個(gè)教程受益匪淺,相信你也一定會(huì)有收獲的。
Contact:
msn: samcyyl1229@hotmail.com
QQ:363991184

Webservice傳送文件的實(shí)現(xiàn)(AXIS2 MTOM)


更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號(hào)聯(lián)系: 360901061

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長(zhǎng)非常感激您!手機(jī)微信長(zhǎng)按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。

【本文對(duì)您有幫助就好】

您的支持是博主寫作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧,站長(zhǎng)會(huì)非常 感謝您的哦!!!

發(fā)表我的評(píng)論
最新評(píng)論 總共0條評(píng)論
主站蜘蛛池模板: 欧美激情在线播放一区二区 | 欧美操人视频 | 欧美人交性视频在线香蕉 | 久久成年人 | 性一交一乱一视频免费看 | 婷婷中文 | 久久社区 | 久久a热6| 四虎影院地址 | 午夜影院免费在线观看 | 日本老乱video | 99热资源| 久久久久国产精品四虎 | 欧美专区一区二区三区 | 亚洲精品久久久久久小说 | 国产天天射 | 久久精品无码一区二区日韩av | 国产成人v片视频在线观看 国产成人爱片免费观看视频 | 大伊香蕉精品视频在线天堂 | 久久久久成人精品一区二区 | 久久视频在线免费观看 | 香蕉福利久久福利久久香蕉 | 四库国产精品成人 | 鲁丝一区二区三区不属 | 中文字幕伦理聚合第一页 | 亚洲高清中文字幕综合网 | 在线播放精品 | 香蕉久久成人网 | 国产精品亚洲综合色拍 | 一区二区三区不卡免费视频97 | 加勒比精品久久一区二区三区 | 日韩国产欧美精品综合二区 | 日日操夜夜骑 | 久久99国产综合色 | 久久午夜宅男免费网站 | 亚洲国产女人aaa毛片在线 | 欧美日韩综合视频 | 亚洲精品乱码久久久久久中文字幕 | 欧美大片日韩精品四虎影视 | 男人在线资源 | 国产精品久久久久久久久ktv |