[Spring Webservices] 로컬 다중 Endpoint 배포

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


그전에 만들었던 LocalJaxWsServiceExporter 로는 맨처음 걸린 ethernet 의 아이피로만 배포가 되었습니다.

참고링크:

2008/11/24 - [JAVA/WebServices] - [Spring MVC] SimpleJaxWsServiceExporter 수정~




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

더보기

모든 소스를 다 구현할 수는 없기에 org.springframework.remoting.jaxws.AbstractJaxWsServiceExporter 클래스를 토대로 작업을 하였습니다.

LocalMultiJaxWsServiceExporter.java 소스 보기

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

InetAddress 로는 한계가 있기에 NetworkInterface 클래스를 이용하여 처리를 하였습니다.

참고자료:

http://www.cowtowncoder.com/blog/archives/2007/05/entry_35.html

나중에 java.net 패키지의 클래스들을 정리해봐야겠습니다.

유용한 것들이 많네요~