异步调用WebService

renxiao2003 发表于 2011-12-21 08:44

<A class=postTitle2 id=ctl02_TitleUrl href="http://www.cnblogs.com/hoojo/archive/2011/03/16/1985744.html">八、异步调用WebService</A>
<DIV id=cnblogs_post_body>
异步，说到异步需要首先将以下同步。同步就是代码按照顺序执行，当前面的代码的请求没有正常返回结果的情况下，后面的代码是不能运行。而异步正好和这点不同，异步是代码运行后，不管当前的请求是否返回结果，后面的代码都会继续运行。
关于异步在此就不再赘述了，有兴趣的可以去网上查查这方面的资料。
1、编写服务器端的代码。
<DIV class=cnblogs_code><IMG id=Code_Closed_Image_498155 .click="this.style.display='none'; document.getElementById('Code_Closed_Text_498155').style.display='none'; document.getElementById('Code_Open_Image_498155').style.display='inline'; document.getElementById('Code_Open_Text_498155').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_498155 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Open_Text_498155').style.display='none'; getElementById('Code_Closed_Image_498155').style.display='inline'; getElementById('Code_Closed_Text_498155').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码package com.hoo.service;

/**
* function:异步WebService服务器端代码
* @author hoojo
* @createDate 2011-3-14 上午08:16:59
* @file AsynchronousService.java
* @package com.hoo.service
* @project Axis2WebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
public class AsynchronousService {
public String execute() {
System.out.println("正在执行此代码……");
//延迟5秒后，返回结果
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
return "完成";
}
}</DIV> 

2、 services.xml文件，创建aar文件，然后复制aar文件到\webapps\axis2\WEB-INF\services目录下
services.xml
<DIV class=cnblogs_code><IMG id=Code_Closed_Image_692644 .click="this.style.display='none'; document.getElementById('Code_Closed_Text_692644').style.display='none'; document.getElementById('Code_Open_Image_692644').style.display='inline'; document.getElementById('Code_Open_Text_692644').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_692644 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Open_Text_692644').style.display='none'; getElementById('Code_Closed_Image_692644').style.display='inline'; getElementById('Code_Closed_Text_692644').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码<service name="AsyncService">
<description>
AsyncService
 </description>
<parameter name="ServiceClass">
com.hoo.service.AsynchronousService
 </parameter>
<messageReceivers>
<messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-out"
class="org.apache.axis2.rpc.receivers.RPCMessageReceiver" />
<messageReceiver mep="http://www.w3.org/2004/08/wsdl/in-only"
class="org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver" />
</messageReceivers>
</service></DIV> 
3、编写客户端测试代码
<DIV class=cnblogs_code><IMG id=Code_Closed_Image_670056 .click="this.style.display='none'; document.getElementById('Code_Closed_Text_670056').style.display='none'; document.getElementById('Code_Open_Image_670056').style.display='inline'; document.getElementById('Code_Open_Text_670056').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ContractedBlock.gif" width=11 align=top><IMG id=Code_Open_Image_670056 style="DISPLAY: none" .click="this.style.display='none'; document.getElementById('Code_Open_Text_670056').style.display='none'; getElementById('Code_Closed_Image_670056').style.display='inline'; getElementById('Code_Closed_Text_670056').style.display='inline';" height=16 src="http://www.cnblogs.com/Images/OutliningIndicators/ExpandedBlockStart.gif" width=11 align=top>代码package com.hoo.service;

import java.io.IOException;
import javax.xml.namespace.QName;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.async.AxisCallback;
import org.apache.axis2.context.MessageContext;
import org.apache.axis2.rpc.client.RPCServiceClient;

/**
* function:异步WebService客户端代码
* @author hoojo
* @createDate 2011-3-14 上午09:00:03
* @file AsynchronousServiceClient.java
* @package com.hoo.service
* @project Axis2WebService
* @blog http://blog.csdn.net/IBM_hoojo
* @email hoojo_@126.com
* @version 1.0
*/
public class AsynchronousServiceClient {

public static void main(String[] args) throws IOException {
String target = "http://localhost:8080/axis2/services/AsyncService?wsdl";
RPCServiceClient client = new RPCServiceClient();
Options options = client.getOptions();
options.setManageSession(true);

EndpointReference epr = new EndpointReference(target);
options.setTo(epr);

QName qname = new QName("http://service.hoo.com", "execute");
//指定调用的方法和传递参数数据，及设置返回值的类型
client.invokeNonBlocking(qname, new Object[] {}, new AxisCallback() {

public void onMessage(MessageContext ctx) {
System.out.println(ctx.getEnvelope());
System.out.println("Message:" + ctx.getEnvelope().getFirstElement().getFirstElement().getFirstElement().getText());
}

public void onFault(MessageContext ctx) {
}

public void onError(Exception ex) {
}

public void onComplete() {
}
});
System.out.println("异步WebService");
//阻止程序退出
 System.in.read();
}
}</DIV> 

上面是异步调用WebService的代码，调用的方法是client.invokeNonBlocking，这个方法有三个参数，参数一是执行的方法签名，参数二是执行该方法的参数，参数三是异步回调，这里隐式实现AxiaCallback接口
注意的是运行程序的时候要用Debug方式运行。</DIV>

页: [1]

Chinaunix's Archiver

异步调用WebService