欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

WebService大講堂之Axis2(8):異步調用WebServi

系統 2039 0

本文為原創,如需轉載,請注明作者和出處,謝謝!

上一篇: WebService大講堂之Axis2(7):將Spring的裝配JavaBean發布成WebService

在前面幾篇文章中都是使用同步方式來調用 WebService 。也就是說,如果被調用的 WebService 方法長時間不返回,客戶端將一直被阻塞,直到該方法返回為止。使用同步方法來調用 WebService 雖然很直觀,但當 WebService 方法由于各種原因需要很長時間才能返回的話,就會使客戶端程序一直處于等待狀態,這樣用戶是無法忍受的。
當然,我們很容易就可以想到解決問題的方法,這就是多線程。解決問題的基本方法是將訪問 WebService 的任務交由一個或多個線程來完成,而主線程并不負責訪問 WebService 。這樣即使被訪問的 WebService 方法長時間不返回,客戶端仍然可以做其他的工作。我們可以管這種通過多線程訪問 WebService 的方式稱為異步訪問。
雖然直接使用多線程可以很好地解決這個問題,但比較麻煩。幸好 Axis2 的客戶端提供了異步訪問 WebService 的功能。
RPCServiceClient 類提供了一個 invokeNonBlocking 方法可以通過異步的方式來訪問 WebService 。下面先來建立一個 WebService
MyService
是一個 WebService 類,代碼如下:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> package service;
public class MyService
{
public StringgetName()
{
try
{
System.out.println(
" getName方法正在執行 " );
// 延遲5秒
Thread.sleep( 5000 );
}
catch (Exceptione)
{
}
return " 火星 " ;
}
}

為了模擬需要一定時間才返回的 WebService 方法,在 getName 方法中使用了 sleep 方法來延遲 5 秒。
下面是 MyService 類的配置代碼:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> <!-- services.xml -->
< service name ="myService" >
< description >
異步調用演示
</ description >
< parameter name ="ServiceClass" >
service.MyService
</ parameter >
< messageReceivers >
< messageReceiver mep ="http://www.w3.org/2004/08/wsdl/in-out"
class
="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
</ messageReceivers >
</ service >

從上面的配置代碼可以看出, MyService 的配置方式與前幾章的 WebService 的配置方式完全一樣,也就是說, MyService 只是一個普通的 WebService
下面是異步調用 MyService Java 客戶端代碼:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> package client;

import javax.xml.namespace.QName;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.rpc.client.RPCServiceClient;

public class RPCAsyncClient
{
public static void main(String[]args) throws Exception
{
RPCServiceClientserviceClient
= new RPCServiceClient();
Optionsoptions
= serviceClient.getOptions();
EndpointReferencetargetEPR
= new EndpointReference(
" http://localhost:8080/axis2/services/myService " );
options.setTo(targetEPR);
Object[]opAddEntryArgs
= new Object[]{};
QNameopAddEntry
= new QName( " http://service " , " getName " );
serviceClient.invokeNonBlocking(opAddEntry,opAddEntryArgs,
new org.apache.axis2.client.async.AxisCallback()
{
@Override
public void onComplete()
{
}
@Override
public void onError(Exceptionarg0)
{
}}
@Override
public void onFault(MessageContextarg0)
{
}
@Override
public void onMessage(MessageContextmc)
{
// 輸出返回值
System.out.println(mc.getEnvelope().getFirstElement()
.getFirstElement().getFirstElement().getText());
}
});
System.out.println(
" 異步調用! " );
// 阻止程序退出
System.in.read();
}
}

從上面的代碼可以看出, invokeNonBlocking 方法有三個參數,前兩個參數分別指定了要調用的方法及方法參數的相關信息,而最后一個參數并不是方法返回值的類型信息,而是一個實現 org.apache.axis2.client.async.AxisCallback 接口的類的對象實例。在本例中隱式實現了 AxisCallback 接口。在 AxisCallback 接口中有四個方法需要實現,其中當被異步調用的方法返回時 onMessage 方法被調用。當運行上面的程序后,將輸出如下的信息:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> 異步調用!
火星

雖然上面的例子可以實現異步調用,但比較麻煩。為了更方便地實現異步調用,可以使用 wsdl2java 命令的 -a 參數生成可異步調用的 Stub 類。下面的命令可生成同步和異步調用的客戶端代碼(兩個類),其中 -s 表示生成同步調用代碼, -a 表示生成異步調用代碼。

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> %AXIS2_HOME%\bin\wsdl2java-urihttp://localhost: 8080 /axis2/services/myService?wsdl-pclient-s-a-ostub

在執行上面的命令后,將生成兩個類: MyServiceStub MyServiceCallbackHandler 類,其中 MyServiceStub 類負責同步和異步調用 WebService MyServiceCallbackHandler 類是一個抽象類,也是一個回調類,當使用異步方式調用 WebService 方法時,如果方法返回,則 MyServiceCallbackHandler 類的 receiveResultgetName 方法被調用。下面是使用 MyServiceStub 類異步訪問 WebService 的代碼:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> package client;

import client.MyServiceStub.GetNameResponse;

class MyCallback extends MyServiceCallbackHandler
{
@Override
public void receiveResultgetName(GetNameResponseresult)
{
// 輸出getName方法的返回結果
System.out.println(result.get_return());
}
}
public class StubClient
{
public static void main(String[]args) throws Exception
{
MyServiceStubstub
= new MyServiceStub();
// 異步調用WebService
stub.startgetName( new MyCallback());
System.out.println(
" 異步調用! " );
System.in.read();
}
}

執行上面的程序后,將輸出如下的信息:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> 異步調用!
火星

在.net中也可以使用異步的方式來調用WebService,如在C#中可使用如下的代碼來異步調用getName方法:
<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> // 回調方法
private void getNameCompletedEvent(objectsender,WSC.asyn.getNameCompletedEventArgse)
{
listBox1.Items.Add(e.Result.@
return );
}
private void button1_Click(objectsender,EventArgse)
{
async.myServicemy
= new WSC.async.myService();
my.getNameCompleted
+= new WSC.async.getNameCompletedEventHandler(getNameCompletedEvent);
my.getNameAsync();
MessageBox.Show(
" 完成調用 " );
}

其中 async 是引用 MyService 的服務名。要注意的是,在 C# 中不能在同一個 WebService 實例的 getName 方法未返回之前,再次調用該實例的 getName 方法,否則將拋出異常。如下面的代碼會拋出一個異常:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> async.myServicemy = new WSC.async.myService();
my.getNameCompleted
+= new WSC.async.getNameCompletedEventHandler(getNameCompletedEvent);
my.getNameAsync();
// 將拋出異常
my.getNameAsync();

但不同的 WebService 實例的方法可以在方法未返回時調用,如下面的代碼是可以正常工作的:

<!--<br /> <br /> Code highlighting produced by Actipro CodeHighlighter (freeware)<br /> http://www.CodeHighlighter.com/<br /> <br /> --> asyn.myServicemy = new WSC.asyn.myService();
my.getNameAsync();
my.getNameCompleted
+= new WSC.asyn.getNameCompletedEventHandler(getNameCompletedEvent);
asyn.myServicemy1
= new WSC.asyn.myService();
my1.getNameCompleted
+= new WSC.asyn.getNameCompletedEventHandler(getNameCompletedEvent);
my1.getNameAsync();

下一篇: WebService大講堂之Axis2(9):編寫Axis2模塊(Module)

國內最棒的Google Android技術社區(eoeandroid),歡迎訪問!

《銀河系列原創教程》 發布

《Java Web開發速學寶典》 出版,歡迎定購

WebService大講堂之Axis2(8):異步調用WebService


更多文章、技術交流、商務合作、聯系博主

微信掃碼或搜索:z360901061

微信掃一掃加我為好友

QQ號聯系: 360901061

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

【本文對您有幫助就好】

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

發表我的評論
最新評論 總共0條評論
主站蜘蛛池模板: 成人福利视频在线看高清观看 | 欧美日本中文字幕 | 国产精品视频免费的 | 久久夜色精品国产亚洲 | 天天操天天插 | 日韩在线免费视频 | 久久久久国产成人精品亚洲午夜 | 免费级毛片| 欧美猛妇色xxxxxbbbb | 免费观看呢日本天堂视频 | 成人欧美一级毛片免费观看 | 三级黄色片网站 | 日本高清视频wwww色 | 91嫩草精品 | 日韩欧美在线播放 | 九九久久亚洲综合久久久 | av毛片免费看 | 一区免费看| 91精品国产91久久久久久吃药 | 亚洲免费福利 | 国产99久久久久久免费看 | 亚洲狠狠婷婷综合久久蜜桃 | 魏千翔| 深夜福利一区二区 | 国产精品大片在线观看 | 欧美日韩一区二区三区在线观看 | 亚洲精品久久久一区二区三区 | 手机在线看片国产日韩生活片 | 久久婷婷是五月综合色狠狠 | 老人与老人免费a级毛片 | 亚洲日韩中文字幕天堂不卡 | 欧美日韩网站 | 一二三区免费视频 | 午夜寂寞影视在线观看 | 日韩在线观看视频免费 | 亚洲最大在线 | 亚洲精品人成网在线播放影院 | 粉嫩在线| 精品乱子伦一区二区三区 | 国产永久在线视频 | 亚洲精品小视频 |