[Spring Webservices] 로컬 다중 Endpoint 배포

오늘 실서버에 배포를 하다보니... 실서버는 ethernet 이 4개나...

그전에 만들었던 LocalJaxWsServiceExporter 로는 맨처음 걸린 ethernet 의 아이피로만 배포가 되었습니다.
참고링크: 2008/11/24 - [JAVA/WebServices] - [Spring MVC] SimpleJaxWsServiceExporter 수정~


그래서 시스템의 모든 ethernet 컨트롤러를 조사하여 각각의 endpoint 로 배포하는 것을 맹글어 보았습니다.

모든 소스를 다 구현할 수는 없기에 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(); } } }

InetAddress 로는 한계가 있기에 NetworkInterface 클래스를 이용하여 처리를 하였습니다.
참고자료: http://www.cowtowncoder.com/blog/archives/2007/05/entry_35.html

_M#]
나중에 java.net 패키지의 클래스들을 정리해봐야겠습니다.
유용한 것들이 많네요~