asyncpollingclient.java

web services 异步调用的 源码

package client;

import java.io.StringReader;
import java.net.URL;

import javax.xml.namespace.QName;
import javax.xml.transform.Source;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.sax.SAXSource;
import javax.xml.transform.stream.StreamResult;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Response;
import javax.xml.ws.Service;
import javax.xml.ws.Service.Mode;

import org.xml.sax.InputSource;

public class AsyncPollingClient {

	private static String payload = 
		"<ns1:sayHello xmlns:ns1='http://test/'>" +
		"	<arg0>Test</arg0>" +
		"</ns1:sayHello>";
	
	public static void main(String[] args) throws Exception {
		QName serviceName = new QName("http://test/", "HelloWorldImplService");
		Service service = Service.create(new URL("http://localhost:8080/HelloWorld?wsdl"), serviceName);
		QName portName = new QName("http://test/", "HelloWorldImplPort");
		Dispatch<Source> dispatch = service.createDispatch(portName, Source.class, Mode.PAYLOAD);
		
		Source msg = new SAXSource(new InputSource(new StringReader(payload)));
		Response<Source> responseSource = dispatch.invokeAsync(msg);
		
		System.out.println("Sleep...");
		Thread.sleep(1000);
		System.out.println("Wake up...");
		
		Source response = responseSource.get();
		Transformer transformer = TransformerFactory.newInstance().newTransformer();
		transformer.transform(response, new StreamResult(System.out));
	}

}