불친절한자수씨

모든 소스를 다 구현할 수는 없기에 org.springframework.remoting.jaxws.AbstractJaxWsServiceExporter 클래스를 토대로 작업을 하였습니다.
[#M_LocalMultiJaxWsServiceExporter.java 소스 보기|접기|import java.net.InterfaceAddress; import java.net.NetworkInterface; import java.net.SocketException; import java.util.ArrayList; import java.util.Enumeration; import java.util.LinkedHashSet; import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.Executor; import javax.jws.WebService; import javax.xml.ws.Endpoint; import org.apache.log4j.Logger; import org.springframework.beans.factory.BeanFactory; import org.springframework.beans.factory.BeanFactoryAware; import org.springframework.beans.factory.DisposableBean; import org.springframework.beans.factory.InitializingBean; import org.springframework.beans.factory.ListableBeanFactory; import org.springframework.core.task.TaskExecutor; import org.springframework.core.task.support.ConcurrentExecutorAdapter; import org.springframework.remoting.jaxws.SimpleHttpServerJaxWsServiceExporter; import org.springframework.remoting.jaxws.SimpleJaxWsServiceExporter; /** * Abstract exporter for JAX-WS services, autodetecting annotated service beans * (through the JAX-WS {@link javax.jws.WebService} annotation). Subclasses need * to implement the {@link #publishEndpoint} template method for actual endpoint * exposure. * * @author Juergen Hoeller * @since 2.5.5 * @see javax.jws.WebService * @see javax.xml.ws.Endpoint * @see SimpleJaxWsServiceExporter * @see SimpleHttpServerJaxWsServiceExporter */ public class LocalMultiJaxWsServiceExporter implements BeanFactoryAware, InitializingBean, DisposableBean { static Logger logger = Logger.getLogger(LocalMultiJaxWsServiceExporter.class); private Map<String, Object> endpointProperties; private Executor executor; private ListableBeanFactory beanFactory; private final Set<Endpoint> publishedEndpoints = new LinkedHashSet<Endpoint>(); private List<String> addressList = new ArrayList<String>(); private int port; /** * Set the property bag for the endpoint, including properties such as * "javax.xml.ws.wsdl.service" or "javax.xml.ws.wsdl.port". * * @see javax.xml.ws.Endpoint#setProperties * @see javax.xml.ws.Endpoint#WSDL_SERVICE * @see javax.xml.ws.Endpoint#WSDL_PORT */ public void setEndpointProperties(Map<String, Object> endpointProperties) { this.endpointProperties = endpointProperties; } /** * Set the JDK concurrent executor to use for dispatching incoming requests * to exported service instances. * * @see javax.xml.ws.Endpoint#setExecutor */ public void setExecutor(Executor executor) { this.executor = executor; } /** * Set the Spring TaskExecutor to use for dispatching incoming requests to * exported service instances. * * @see javax.xml.ws.Endpoint#setExecutor */ public void setTaskExecutor(TaskExecutor executor) { this.executor = new ConcurrentExecutorAdapter(executor); } /** * Obtains all web service beans and publishes them as JAX-WS endpoints. */ public void setBeanFactory(BeanFactory beanFactory) { if (!(beanFactory instanceof ListableBeanFactory)) { throw new IllegalStateException(getClass().getSimpleName() + " requires a ListableBeanFactory"); } this.beanFactory = (ListableBeanFactory) beanFactory; } public void setPort(int port) { this.port = port; } /** * Immediately publish all endpoints when fully configured. * * @see #publishEndpoints() */ public void afterPropertiesSet() throws Exception { publishEndpoints(); } /** * Publish all {@link javax.jws.WebService} annotated beans in the * containing BeanFactory. * * @see #publishEndpoint */ public void publishEndpoints() throws Exception { String[] beanNames = this.beanFactory.getBeanNamesForType(Object.class, false, false); for (String beanName : beanNames) { Class<?> type = this.beanFactory.getType(beanName); WebService annotation = type.getAnnotation(WebService.class); if (annotation != null) { for (Enumeration<NetworkInterface> e = NetworkInterface.getNetworkInterfaces(); e.hasMoreElements(); ) { NetworkInterface ni = e.nextElement(); for (InterfaceAddress addr : ni.getInterfaceAddresses()) { String address = addr.getAddress().getHostAddress(); publishEndpoint(annotation, beanName, address); } } } } } /** * Actually publish the given endpoint. To be implemented by subclasses. * * @param annotation * * @param beanName * * @param address * */ private void publishEndpoint(WebService annotation, String beanName, String address) { String baseAddress = (new StringBuilder()).append("http://").append(address).append(":").append(port).append("/").toString(); Endpoint endpoint = Endpoint.create(this.beanFactory .getBean(beanName)); if (this.endpointProperties != null) { endpoint.setProperties(this.endpointProperties); } if (this.executor != null) { endpoint.setExecutor(this.executor); } try { publishEndpoint(endpoint, annotation, baseAddress); this.publishedEndpoints.add(endpoint); } catch (Exception e) { System.out.println("publishEndpoint >> " + e); } } /** * Actually publish the given endpoint. To be implemented by subclasses. * * @param endpoint * the JAX-WS Endpoint object * @param annotation * the service bean's WebService annotation * @param baseAddress * the local address */ protected void publishEndpoint(Endpoint endpoint, WebService annotation, String baseAddress) { String fullAddress = (new StringBuilder()).append(baseAddress).append(annotation.serviceName()).toString(); endpoint.publish(fullAddress); if (logger.isInfoEnabled()) logger.info((new StringBuilder()).append("Publishing endpoint: ").append(fullAddress)); } /** * Stops all published endpoints, taking the web services offline. */ public void destroy() { for (Endpoint endpoint : this.publishedEndpoints) { endpoint.stop(); } } public static void main(String[] args) { try { for (Enumeration<NetworkInterface> e = NetworkInterface.getNetworkInterfaces(); e.hasMoreElements(); ) { NetworkInterface ni = e.nextElement(); for (InterfaceAddress addr : ni.getInterfaceAddresses()) { System.out.println(addr.getAddress().getHostAddress()); } } } catch (SocketException e) { e.printStackTrace(); } } }

kr.co.vicki.webservices.webservice.MultiJaxWsServiceExporter.java
  - org.springframework.remoting.jaxws.AbstractJaxWsServiceExporter 를 참고하여 만들었습니다.
  - 최초 Export 된 서비스만 처리되는 문제점을 해결...
package kr.co.vicki.webservices.webservice; import java.util.LinkedHashSet; import java.util.Map; import java.util.Set; import java.util.concurrent.Executor; import javax.jws.WebService; import javax.xml.ws.Endpoint; import org.springframework.beans.factory.DisposableBean; import org.springframework.beans.factory.InitializingBean; import org.springframework.core.task.TaskExecutor; import org.springframework.core.task.support.ConcurrentExecutorAdapter; public class MultiJaxWsServiceExporter implements InitializingBean, DisposableBean { public static final String DEFAULT_BASE_ADDRESS = "http://localhost:8080/"; private Map<String, Object> endpointProperties; private Executor executor; private final Set<Endpoint> publishedEndpoints = new LinkedHashSet<Endpoint>(); private String baseAddress = DEFAULT_BASE_ADDRESS; private Object serviceEndpointInterface; public void setEndpointProperties(Map<String, Object> endpointProperties) { this.endpointProperties = endpointProperties; } public void setExecutor(Executor executor) { this.executor = executor; } public void setTaskExecutor(TaskExecutor executor) { this.executor = new ConcurrentExecutorAdapter(executor); } public void setBaseAddress(String baseAddress) { this.baseAddress = baseAddress; } public void setServiceEndpointInterface(Object serviceEndpointInterface) { this.serviceEndpointInterface = serviceEndpointInterface; } public void afterPropertiesSet() throws Exception { publishEndpoints(); } public void publishEndpoints() { if (serviceEndpointInterface == null) return; Class<?> type = serviceEndpointInterface.getClass(); WebService annotation = type.getAnnotation(WebService.class); if (annotation != null) { Endpoint endpoint = Endpoint.create(serviceEndpointInterface); if (this.endpointProperties != null) { endpoint.setProperties(this.endpointProperties); } if (this.executor != null) { endpoint.setExecutor(this.executor); } publishEndpoint(endpoint, annotation); this.publishedEndpoints.add(endpoint); } } protected void publishEndpoint(Endpoint endpoint, WebService annotation) { String fullAddress = this.baseAddress + annotation.serviceName(); endpoint.publish(fullAddress); } public void destroy() { for (Endpoint endpoint : this.publishedEndpoints) { endpoint.stop(); } } }

webservicesContext.xml
  - serviceEndpointInterface 속성에 @WebSerivce 어노테이션이 달린 bean 을 정의
<bean class="kr.co.vicki.webservices.webservice.MultiJaxWsServiceExporter"> <property name="baseAddress" value="http://localhost:12345/"/> <property name="serviceEndpointInterface" ref="loginWebService"/> </bean> <bean id="loginWebService" class="kr.co.vicki.webservices.webservice.LoginWebService"> <property name="loginService" ref="loginService" /> </bean> <bean class="kr.co.vicki.webservices.webservice.MultiJaxWsServiceExporter"> <property name="baseAddress" value="http://localhost:12346/"/> <property name="serviceEndpointInterface" ref="uploadWebService"/> </bean> <bean id="uploadWebService" class="kr.co.vicki.webservices.webservice.UploadWebService"/>