Java的webservice入门(视频+代码)

package com.job.dao; import java.net.MalformedURLException; import java.util.Collection; import java.util.HashMap; import javax.xml.namespace.QName; import org.codehaus.xfire.XFireRuntimeException; import org.codehaus.xfire.aegis.AegisBindingProvider; import org.codehaus.xfire.annotations.AnnotationServiceFactory; import org.codehaus.xfire.annotations.jsr181.Jsr181WebAnnotations; import org.codehaus.xfire.client.XFireProxyFactory; import org.codehaus.xfire.jaxb2.JaxbTypeRegistry; import org.codehaus.xfire.service.Endpoint; import org.codehaus.xfire.service.Service; import org.codehaus.xfire.soap.AbstractSoapBinding; import org.codehaus.xfire.transport.TransportManager; public class JobInfoClient { private static XFireProxyFactory proxyFactory = new XFireProxyFactory(); private HashMap endpoints = new HashMap(); private Service service0; public JobInfoClient() { create0(); Endpoint JobInfoHttpPortEP = service0 .addEndpoint(new QName("http://dao.job.com", "JobInfoHttpPort"), new QName("http://dao.job.com", "JobInfoHttpBinding"), "http://localhost:8080/job/services/JobInfo"); endpoints.put(new QName("http://dao.job.com", "JobInfoHttpPort"), JobInfoHttpPortEP); Endpoint JobInfoPortTypeLocalEndpointEP = service0 .addEndpoint(new QName("http://dao.job.com", "JobInfoPortTypeLocalEndpoint"), new QName("http://dao.job.com", "JobInfoPortTypeLocalBinding"), "xfire.local://JobInfo"); endpoints.put(new QName("http://dao.job.com", "JobInfoPortTypeLocalEndpoint"), JobInfoPortTypeLocalEndpointEP); } public Object getEndpoint(Endpoint endpoint) { try { return proxyFactory.create((endpoint).getBinding(), (endpoint).getUrl()); } catch (MalformedURLException e) { throw new XFireRuntimeException("Invalid URL", e); } } public Object getEndpoint(QName name) { Endpoint endpoint = ((Endpoint) endpoints.get((name))); if ((endpoint) == null) { throw new IllegalStateException("No such endpoint!"); } return getEndpoint((endpoint)); } public Collection getEndpoints() { return endpoints.values(); } private void create0() { TransportManager tm = (org.codehaus.xfire.XFireFactory.newInstance().getXFire().getTransportManager()); HashMap props = new HashMap(); props.put("annotations.allow.interface", true); AnnotationServiceFactory asf = new AnnotationServiceFactory(new Jsr181WebAnnotations(), tm, new AegisBindingProvider(new JaxbTypeRegistry())); asf.setBindingCreationEnabled(false); service0 = asf.create((com.job.dao.JobInfoPortType.class), props); { AbstractSoapBinding soapBinding = asf.createSoap11Binding(service0, new QName("http://dao.job.com", "JobInfoPortTypeLocalBinding"), "urn:xfire:transport:local"); } { AbstractSoapBinding soapBinding = asf.createSoap11Binding(service0, new QName("http://dao.job.com", "JobInfoHttpBinding"), "http://schemas.xmlsoap.org/soap/http"); } } public JobInfoPortType getJobInfoHttpPort() { return ((JobInfoPortType)(this).getEndpoint(new QName("http://dao.job.com", "JobInfoHttpPort"))); } public JobInfoPortType getJobInfoHttpPort(String url) { JobInfoPortType var = getJobInfoHttpPort(); org.codehaus.xfire.client.Client.getInstance(var).setUrl(url); return var; } public JobInfoPortType getJobInfoPortTypeLocalEndpoint() { return ((JobInfoPortType)(this).getEndpoint(new QName("http://dao.job.com", "JobInfoPortTypeLocalEndpoint"))); } public JobInfoPortType getJobInfoPortTypeLocalEndpoint(String url) { JobInfoPortType var = getJobInfoPortTypeLocalEndpoint(); org.codehaus.xfire.client.Client.getInstance(var).setUrl(url); return var; } public static void main(String[] args) { JobInfoClient client = new JobInfoClient(); //create a default service endpoint JobInfoPortType service = client.getJobInfoHttpPort(); //TODO: Add custom client code here // //service.yourServiceOperationHere(); System.out.println(service.jobinfo("aaa")); //System.exit(0); } }