package com.priest.service;

import java.util.Date;
import javax.jws.WebService;
import javax.xml.ws.Endpoint;

@WebService
public class TestServer {

	public String testMethod(String inParam) {
		System.out.println("服务端收到：" + inParam);
		return "服务端于" + new Date() + "收到了客户端发送的：" + inParam;
	}

	public static void main(String[] args) {
		Endpoint.publish("http://localhost:8088/service/TestServer", new TestServer());
		System.out.println("服务端启动完毕");
	}

}

package com.priest.client;

public class TestClient1 {

	public static void main(String[] args) {
		TestServerService service = new TestServerService();
		TestServer ts = service.getTestServerPort();

		String result = ts.testMethod("客户端1测试");
		System.out.println("客户端1测试的结果：\n" + result);
	}

}

package com.priest.client;

import java.net.URL;

import javax.xml.namespace.QName;
import javax.xml.ws.Service;

public class TestClient2 {
	public static void main(String[] args) {
		try {
			URL url = new URL("http://localhost:8088/service/TestServer?wsdl");
			QName qname = new QName("http://service.priest.com/", "TestServerService");
			Service service = Service.create(url, qname);
			TestServer ts = service.getPort(TestServer.class);
			String result = ts.testMethod("客户端2测试");
			System.out.println("客户端2测试的结果：\n" + result);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

package com.priest.client2;

import java.net.URL;

import javax.xml.namespace.QName;

import org.apache.axis.client.Call;
import org.apache.axis.client.Service;

public class TestClient3 {

	public static void main(String[] args) {
		try {
			//服务地址
			URL url = new URL("http://localhost:8088/service/TestServer");
			//命名空间
			String nameSpace = "http://service.priest.com/";
			//方法名
			String method = "testMethod";

			Service service = new Service();
			Call call = (Call) service.createCall();

			call.setOperationName(new QName(nameSpace, method));
			call.setTargetEndpointAddress(url);
			call.setTimeout(3000);
			call.addParameter("arg0", org.apache.axis.Constants.XSD_STRING, javax.xml.rpc.ParameterMode.IN);
			call.setReturnType(org.apache.axis.Constants.XSD_STRING);

			String result = (String) call.invoke(new Object[] {"客户端3测试"});
			System.out.println("客户端3测试结果：\n" + result);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

package com.priest.client4;

public class TestClient4 {

	public static void main(String[] args) {

		try {
			//重新指定url是为了防止本地客户端代码是旧的，而对方迁了服务地址
			String url = "http://localhost:8088/service/TestServer";
			TestServerServiceLocator locator = new TestServerServiceLocator();
			locator.setTestServerPortEndpointAddress(url);
			TestServerPortBindingStub stub = (TestServerPortBindingStub) locator.getTestServerPort();
			stub.setTimeout(3000);
			String result = stub.testMethod("客户端4测试");
			System.out.println("客户端4测试结果：\n" + result);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}

package com.priest.client5;

import javax.xml.namespace.QName;

import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.rpc.client.RPCServiceClient;

public class TestClinent5 {

	public static void main(String[] args) {
		try {
			String url = "http://localhost:8088/service/TestServer";
			String namespace = "http://service.priest.com/";
			String method = "testMethod";
			Object[] inParam = new Object[] {"客户端5测试"};
			Class[] returnType = new Class[] { String.class };
			Object[] ret = null;

			RPCServiceClient serviceClient = new RPCServiceClient();
			Options options = serviceClient.getOptions();
			EndpointReference targetURL = new EndpointReference(url);
			options.setTo(targetURL);
			QName opQName = new QName(namespace, method);

			ret = serviceClient.invokeBlocking(opQName, inParam, returnType);
			String result = (String) ret[0];
			System.out.println("客户端5测试：\n" + result);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}

package com.priest.client6;

import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
import org.apache.axis2.client.ServiceClient;

public class TestClient6 {

	public static void main(String[] args) {
		try {
			EndpointReference targetEPR = new EndpointReference("http://localhost:8088/service/TestServer");
			OMFactory factory = OMAbstractFactory.getOMFactory();
			OMNamespace nameSpace = factory.createOMNamespace("http://service.priest.com/", "tns");
			OMElement method = factory.createOMElement("testMethod", nameSpace);
			//因服务端没有为入参设置命名空间，所以此处用null
			OMElement inParam = factory.createOMElement("arg0", null);
			inParam.setText("客户端6测试");
			method.addChild(inParam);

			Options options = new Options();
			options.setTo(targetEPR);
			ServiceClient axiomClient = new ServiceClient();
			axiomClient.setOptions(options);

			OMElement retOM = axiomClient.sendReceive(method);
			String result = retOM.getFirstElement().getText();
			System.out.println("客户端6测试：\n" + result);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}

package com.priest.service;

public class TestClient7 {
	public static void main(String[] args) {
		try {
			TestServerServiceStub stub = new TestServerServiceStub();
			TestMethodE testMethodE = new TestMethodE();
			TestMethod testMethod = new TestMethod();
			testMethod.setArg0("客户端7测试");
			testMethodE.setTestMethod(testMethod);

			TestMethodResponseE respE = stub.testMethod(testMethodE);
			TestMethodResponse resp = respE.getTestMethodResponse();
			String result = resp.get_return();

			System.out.println("客户端7测试：\n" + result);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}