Axis2之异步调用

package com.alfred.client;

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;

public class ServiceClient {
	public static void main(String args[]) throws IOException {
		sendAxis2();
	}

	/**
	 * 发送axis2的接口信息
	 *
	 * @throws IOException
	 */
	private static void sendAxis2() throws IOException {
		// 使用RPC方式调用WebService
		RPCServiceClient serviceClient = new RPCServiceClient();

		Options optiOns= serviceClient.getOptions();
		// 指定调用WebService的URL
		EndpointReference targetEPR = new EndpointReference(
				"http://127.0.0.1:8080/awyb/services/mySoapService");
		options.setTo(targetEPR);
		// 指定sayHello方法的参数值，如果有多个，继续往后面增加即可
		Object[] opAddEntryArgs = new Object[] { "alfred" };
		// 在创建QName对象时，QName类的构造方法的第一个参数表示WSDL，文件的命名空间名，也就是元素的targetNamespace属性值
		// 第二个参数是要调用的方法名
		QName opAddEntry = new QName("http://service.alfred.com", "sayHello");
		serviceClient.invokeNonBlocking(opAddEntry, opAddEntryArgs,new AxisCallback() {
			public void onComplete() {}

			public void onError(Exception arg0) {}

			public void onFault(MessageContext arg0) {}

			public void onMessage(MessageContext mc) {
				// 输出返回值
				System.out.println(mc.getEnvelope().getFirstElement()
						.getFirstElement().getFirstElement().getText());
			}
		});
		System.out.println("异步调用！");
		// 阻止程序退出
		System.in.read();
	}

}

package com.alfred.service;

import org.apache.axis2.AxisFault;

public class SoapService {
	public String sayHello(String name) throws AxisFault {
		try {
			System.out.println("sayHello方法正在执行 ");
			// 延迟5秒
			Thread.sleep(5000);
		} catch (Exception e) {
			e.printStackTrace();
		}
		return "Hello," + name;
	}

	public String getWorld() {
		return "Hello,World";
	}
}

package client;

import client.MySoapServiceStub.GetWorldResponse;
import client.MySoapServiceStub.SayHelloResponse;

public class MyCallback extends MySoapServiceCallbackHandler {

	@Override
	public void receiveResultgetWorld(GetWorldResponse result) {
		// 输出getWorld方法的返回结果
		System.out.println(result.get_return());
	}

	@Override
	public void receiveResultsayHello(SayHelloResponse result) {
		// 输出sayHello方法的返回结果
		System.out.println(result.get_return());
	}

}

package client;

import client.MySoapServiceStub.SayHello;

public class StubClient {
	public static void main(String[] args) throws Exception {
		MySoapServiceStub stub = new MySoapServiceStub();
		// 异步调用WebService
		SayHello sayHello = new SayHello();
		sayHello.setName("alfred other");
		stub.startsayHello(sayHello, new MyCallback());
		System.out.println("异步调用！");
		System.in.read();
	}
}