在前面幾篇文章中都是使用同步方式來(lái)調(diào)用WebService。也就是說(shuō)，如果被調(diào)用的WebService方法長(zhǎng)時(shí)間不返回，客戶端將一直被阻塞，直到該方法返回為止。使用同步方法來(lái)調(diào)用WebService雖然很直觀，但當(dāng)WebService方法由于各種原因需要很長(zhǎng)時(shí)間才能返回的話，就會(huì)使客戶端程序一直處于等待狀態(tài)，這樣用戶是無(wú)法忍受的。
??? 當(dāng)然，我們很容易就可以想到解決問(wèn)題的方法，這就是多線程。解決問(wèn)題的基本方法是將訪問(wèn)WebService的任務(wù)交由一個(gè)或多個(gè)線程來(lái)完成，而主線程并不負(fù)責(zé)訪問(wèn)WebService。這樣即使被訪問(wèn)的WebService方法長(zhǎng)時(shí)間不返回，客戶端仍然可以做其他的工作。我們可以管這種通過(guò)多線程訪問(wèn)WebService的方式稱為異步訪問(wèn)。
??? 雖然直接使用多線程可以很好地解決這個(gè)問(wèn)題，但比較麻煩。幸好Axis2的客戶端提供了異步訪問(wèn)WebService的功能。
??? RPCServiceClient類(lèi)提供了一個(gè)invokeNonBlocking方法可以通過(guò)異步的方式來(lái)訪問(wèn)WebService。下面先來(lái)建立一個(gè)WebService。
??? MyService是一個(gè)WebService類(lèi)，代碼如下：
package?service;
public?class?MyService
{
????public?String?getName()
????{
????????try
????????{????????????
????????????System.out.println("getName方法正在執(zhí)行");
????????????//??延遲5秒
????????????Thread.sleep(5000);
????????}
????????catch?(Exception?e)
????????{????????
????????}
????????return?"火星";
????}
}

??? 為了模擬需要一定時(shí)間才返回的WebService方法，在getName方法中使用了sleep方法來(lái)延遲5秒。
??? 下面是MyService類(lèi)的配置代碼：

<!--??services.xml??-->
<service?name="myService">
????<description>
????????異步調(diào)用演示
????</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的配置方式完全一樣，也就是說(shuō)，MyService只是一個(gè)普通的WebService。
??? 下面是異步調(diào)用MyService的Java客戶端代碼：

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
????{
????????RPCServiceClient?serviceClient?=?new?RPCServiceClient();
????????Options?options?=?serviceClient.getOptions();
????????EndpointReference?targetEPR?=?new?EndpointReference(
????????????????"http://localhost:8080/axis2/services/myService");
????????options.setTo(targetEPR);
????????Object[]?opAddEntryArgs?=?new?Object[]{};
????????QName?opAddEntry?=?new?QName("http://service",?"getName");
????????serviceClient.invokeNonBlocking(opAddEntry,?opAddEntryArgs,
????????????????new?org.apache.axis2.client.async.AxisCallback()
????????????????{
????????????????????@Override
????????????????????public?void?onComplete()
????????????????????{
????????????????????}
????????????????????@Override
????????????????????public?void?onError(Exception?arg0)
????????????????????{
????????????????????}????????????????????}
????????????????????@Override
????????????????????public?void?onFault(MessageContext?arg0)
????????????????????{
????????????????????}
????????????????????@Override
????????????????????public?void?onMessage(MessageContext?mc)
????????????????????{
????????????????????????//??輸出返回值
????????????????????????System.out.println(mc.getEnvelope().getFirstElement()
????????????????????????????????.getFirstElement().getFirstElement().getText());
????????????????????}
????????????????});
????????System.out.println("異步調(diào)用！");
????????//??阻止程序退出
????????System.in.read();
????}
}?

??? 從上面的代碼可以看出，invokeNonBlocking方法有三個(gè)參數(shù)，前兩個(gè)參數(shù)分別指定了要調(diào)用的方法及方法參數(shù)的相關(guān)信息，而最后一個(gè)參數(shù)并不是方法返回值的類(lèi)型信息，而是一個(gè)實(shí)現(xiàn)org.apache.axis2.client.async.AxisCallback接口的類(lèi)的對(duì)象實(shí)例。在本例中隱式實(shí)現(xiàn)了AxisCallback接口。在AxisCallback接口中有四個(gè)方法需要實(shí)現(xiàn)，其中當(dāng)被異步調(diào)用的方法返回時(shí)onMessage方法被調(diào)用。當(dāng)運(yùn)行上面的程序后，將輸出如下的信息：

異步調(diào)用！
火星

??? 雖然上面的例子可以實(shí)現(xiàn)異步調(diào)用，但比較麻煩。為了更方便地實(shí)現(xiàn)異步調(diào)用，可以使用wsdl2java命令的-a參數(shù)生成可異步調(diào)用的Stub類(lèi)。下面的命令可生成同步和異步調(diào)用的客戶端代碼（兩個(gè)類(lèi)），其中-s表示生成同步調(diào)用代碼，-a表示生成異步調(diào)用代碼。

%AXIS2_HOME%\bin\wsdl2java?-uri?http://localhost:8080/axis2/services/myService?wsdl?-p?client?-s?-a?-o?stub

??? 在執(zhí)行上面的命令后，將生成兩個(gè)類(lèi)：MyServiceStub和MyServiceCallbackHandler類(lèi)，其中MyServiceStub類(lèi)負(fù)責(zé)同步和異步調(diào)用WebService，MyServiceCallbackHandler類(lèi)是一個(gè)抽象類(lèi)，也是一個(gè)回調(diào)類(lèi)，當(dāng)使用異步方式調(diào)用WebService方法時(shí)，如果方法返回，則MyServiceCallbackHandler類(lèi)的receiveResultgetName方法被調(diào)用。下面是使用MyServiceStub類(lèi)異步訪問(wèn)WebService的代碼：

package?client;

import?client.MyServiceStub.GetNameResponse;

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

?? 執(zhí)行上面的程序后，將輸出如下的信息：???

異步調(diào)用！
火星

??? ? 在.net中也可以使用異步的方式來(lái)調(diào)用WebService，如在C#中可使用如下的代碼來(lái)異步調(diào)用getName方法：
//??回調(diào)方法
private?void?getNameCompletedEvent(object?sender,?WSC.asyn.getNameCompletedEventArgs?e)
{
????listBox1.Items.Add(?e.Result.@return);
}
private?void?button1_Click(object?sender,?EventArgs?e)
{??????????
????async.myService?my?=?new?WSC.async.myService();
????my.getNameCompleted?+=?new?WSC.async.getNameCompletedEventHandler(getNameCompletedEvent);
?????my.getNameAsync();
?????MessageBox.Show("完成調(diào)用");
}

??? 其中async是引用MyService的服務(wù)名。要注意的是，在C#中不能在同一個(gè)WebService實(shí)例的getName方法未返回之前，再次調(diào)用該實(shí)例的getName方法，否則將拋出異常。如下面的代碼會(huì)拋出一個(gè)異常：

????async.myService?my?=?new?WSC.async.myService();
????my.getNameCompleted?+=?new?WSC.async.getNameCompletedEventHandler(getNameCompletedEvent);
??? my.getNameAsync();
??? //??將拋出異常
??? my.getNameAsync();

??? 但不同的WebService實(shí)例的方法可以在方法未返回時(shí)調(diào)用，如下面的代碼是可以正常工作的：

asyn.myService?my?=?new?WSC.asyn.myService();
my.getNameAsync();
my.getNameCompleted?+=?new?WSC.asyn.getNameCompletedEventHandler(getNameCompletedEvent);
asyn.myService?my1?=?new?WSC.asyn.myService();
my1.getNameCompleted?+=?new?WSC.asyn.getNameCompletedEventHandler(getNameCompletedEvent);
my1.getNameAsync();