xfireclientfactorybeantest.java

来自「Xfire文件 用于开发web service 的一个开源工具 很好用的」· Java 代码 · 共 345 行

package org.codehaus.xfire.spring.remoting;

import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.util.Collections;
import java.util.Properties;

import org.codehaus.xfire.aegis.AbstractXFireAegisTest;
import org.codehaus.xfire.annotations.AnnotationServiceFactory;
import org.codehaus.xfire.annotations.WebAnnotations;
import org.codehaus.xfire.annotations.WebServiceAnnotation;
import org.codehaus.xfire.client.Client;
import org.codehaus.xfire.client.XFireProxy;
import org.codehaus.xfire.server.http.XFireHttpServer;
import org.codehaus.xfire.service.Service;
import org.codehaus.xfire.service.ServiceFactory;
import org.codehaus.xfire.service.binding.ObjectServiceFactory;
import org.codehaus.xfire.service.invoker.ObjectInvoker;
import org.codehaus.xfire.test.Echo;
import org.codehaus.xfire.test.EchoImpl;
import org.codehaus.xfire.transport.Channel;
import org.easymock.MockControl;
import org.springframework.aop.framework.AopProxy;

public class XFireClientFactoryBeanTest
    extends AbstractXFireAegisTest
{
    private String serviceURL = "http://localhost:8080/xfire/services/Echo";
    private String wsdlUrl;
    private XFireClientFactoryBean factory;
    
    protected void setUp() throws Exception {
        wsdlUrl = getTestFile("src/test/org/codehaus/xfire/spring/remoting/echo.wsdl").toURL().toString();
        System.out.println("URL : " + wsdlUrl);
        factory = new XFireClientFactoryBean();
        factory.setServiceInterface(Echo.class);
        //factory.setNamespaceUri("urn:Echo");
        //factory.setServiceName("Echo");
        factory.setWsdlDocumentUrl(wsdlUrl);
        factory.setUrl(serviceURL);
    }
    
    public void testMandatory() 
        throws Exception
    {
        factory = new XFireClientFactoryBean();
        try {
            factory.afterPropertiesSet();
            fail("expected exception without WSDL and service interface");
        } catch (IllegalStateException e) {
            // what we expect
        }

        factory = new XFireClientFactoryBean();
        try {
            factory.setServiceInterface(Echo.class);
            factory.afterPropertiesSet();
            fail("expected exception without WSDL or service url");
        } catch (IllegalStateException e) {
            // what we expect since WSDL is required
        }

        factory = new XFireClientFactoryBean();
        try {
            factory.setWsdlDocumentUrl("test");
            factory.afterPropertiesSet();
            fail("expected exception without service interface");
        } catch (IllegalStateException e) {
            // what we expect since interface is required
        }
    }
    
    public void testDefaults()
        throws Exception
    {
        assertTrue("expected lookupServiceOnStartup default to be true", factory.getLookupServiceOnStartup());
        assertNull("default username must be null", factory.getUsername());
        assertNull("default password must be null", factory.getPassword());
        assertEquals("default service factory is wrong type", ObjectServiceFactory.class, factory.getServiceFactory().getClass());
        assertEquals("default type (before afterPropertiesSet) is not interface", Echo.class, factory.getObjectType());

        assertNull("default service name must be null", factory.getServiceName());
        assertNull("default namespaceUri must be null", factory.getNamespaceUri());
    }
    
    public void testXFireProxyFactoryBeanLoadOnStartup()
        throws Exception
    {
        factory.afterPropertiesSet();
        
        Class objectType = factory.getObjectType();
        assertTrue("object created by factory does not implement interface", Echo.class.isAssignableFrom(objectType));

        Echo obj = (Echo)factory.getObject(); 
        Object handler = Proxy.getInvocationHandler(obj);
        Class handlerClass = handler.getClass();
        assertTrue("factory created own proxy: " + handlerClass, XFireProxy.class.isAssignableFrom(handlerClass));        
        XFireProxy fireProxy = (XFireProxy)handler;
        checkAuth(fireProxy, null, null);
        Client c = fireProxy.getClient();
        System.out.println(serviceURL);
        System.out.println(c.getUrl());
        assertEquals("wrong service URL", serviceURL, c.getUrl());
    }    
    
    public void testServerURL()
        throws Exception
    {
        factory.setUrl("http://localhost/test2");
        
        factory.afterPropertiesSet();
        
        Class objectType = factory.getObjectType();
        assertTrue("object created by factory does not implement interface", Echo.class.isAssignableFrom(objectType));
    
        Echo obj = (Echo)factory.getObject(); 
        Object handler = Proxy.getInvocationHandler(obj);
        Class handlerClass = handler.getClass();
        assertTrue("factory created own proxy: " + handlerClass, XFireProxy.class.isAssignableFrom(handlerClass));        
        XFireProxy fireProxy = (XFireProxy)handler;
        checkAuth(fireProxy, null, null);
        Client c = fireProxy.getClient();
       
        assertEquals("wrong service URL", "http://localhost/test2", c.getUrl());
    }
        
    public void testXFireProxyFactoryBeanNoLoadOnStartup()
        throws Exception
    {
        factory.setLookupServiceOnStartup(false);
        factory.afterPropertiesSet();
        
        Class objectType = factory.getObjectType();
        assertTrue("object created by factory does not implement interface", Echo.class.isAssignableFrom(objectType));
        Echo obj = (Echo)factory.getObject(); 
        Object handler = Proxy.getInvocationHandler(obj);
        Class handlerClass = handler.getClass();
        assertTrue("factory did not create own proxy: " + handlerClass, AopProxy.class.isAssignableFrom(handlerClass));
        
        assertEquals("Wrong uninit toString() for proxy", 
                     "Un-initialized XFire client proxy for: interface org.codehaus.xfire.test.Echo at: " + serviceURL, 
                     obj.toString());
    }
    
    public void testAuthentication() 
        throws Exception
    {
        String expectedUsername = "fried";
        String expectedPassword = "hoeben";
        factory.setUsername(expectedUsername);
        factory.setPassword(expectedPassword);
        factory.afterPropertiesSet();

        Echo obj = (Echo)factory.getObject(); 
        
        XFireProxy handler = (XFireProxy)Proxy.getInvocationHandler(obj);
        checkAuth(handler, expectedUsername, expectedPassword);
    }

    private void checkAuth(XFireProxy handler, String expectedUsername, String expectedPassword)
    {
        Client client = handler.getClient();
        String username = (String)client.getProperty(Channel.USERNAME);
        assertEquals("wrong username", expectedUsername, username);
        String password = (String)client.getProperty(Channel.PASSWORD);
        assertEquals("wrong password", expectedPassword, password);
    }
    
    public void testSetWSDLProperties()
        throws Exception
    {
        // first ensure we have a WSDL to parse
        super.setUp();
        ServiceFactory serverFact = getServiceFactory();
     
        XFireHttpServer server = new XFireHttpServer(getXFire());
        server.setPort(8191);
        server.start();
        
        Service service = serverFact.create(Echo.class);
        service.setProperty(ObjectInvoker.SERVICE_IMPL_CLASS, EchoImpl.class);

        getServiceRegistry().register(service);

        // now create a special factory that will actually use the created WSDL
        factory = new XFireClientFactoryBean();
        factory.setServiceInterface(Echo.class);
        factory.setWsdlDocumentUrl("http://localhost:8191/Echo?wsdl");
        factory.afterPropertiesSet();
        
        Echo echo = (Echo) factory.getObject();
        assertEquals("hi", echo.echo("hi"));
        
        server.stop();
    }

    public void testSetWSDLPropertiesClasspath()
        throws Exception
    {
        // first ensure we have a WSDL to parse
        super.setUp();
        
        wsdlUrl = "org/codehaus/xfire/spring/remoting/echo.wsdl";
        ServiceFactory serverFact = getServiceFactory();
     
        XFireHttpServer server = new XFireHttpServer(getXFire());
        server.setPort(8191);
        server.start();
        
        Service service = serverFact.create(Echo.class);
        service.setProperty(ObjectInvoker.SERVICE_IMPL_CLASS, EchoImpl.class);

        getServiceRegistry().register(service);

        // now create a special factory that will actually use the created WSDL
        factory = new XFireClientFactoryBean();
        factory.setServiceInterface(Echo.class);
        factory.setWsdlDocumentUrl("http://localhost:8191/Echo?wsdl");
        factory.afterPropertiesSet();
        
        Echo echo = (Echo) factory.getObject();
        assertEquals("hi", echo.echo("hi"));
        
        server.stop();
    }
    
    public void testServerClass() 
        throws Exception
    {
        MockControl control = MockControl.createControl(WebAnnotations.class);
        WebAnnotations webAnnotations = (WebAnnotations) control.getMock();
        
        WebServiceAnnotation serviceAnnotation = new WebServiceAnnotation();
        webAnnotations.getWebServiceAnnotation(Echo.class);
        control.setDefaultReturnValue(serviceAnnotation);
        
        webAnnotations.hasWebServiceAnnotation(Echo.class);
        control.setDefaultReturnValue(true);
        
        webAnnotations.hasWebServiceAnnotation(EchoImpl.class);
        control.setDefaultReturnValue(true);
        webAnnotations.hasHandlerChainAnnotation(EchoImpl.class);
        control.setReturnValue(false);
        webAnnotations.hasSOAPBindingAnnotation(Echo.class);
        control.setReturnValue(false);
        webAnnotations.hasWebServiceAnnotation(EchoImpl.class);
        control.setReturnValue(true);
        
        serviceAnnotation = new WebServiceAnnotation();
        serviceAnnotation.setServiceName("Echo");
        serviceAnnotation.setTargetNamespace("urn:Echo");
        serviceAnnotation.setEndpointInterface(Echo.class.getName());
        webAnnotations.getWebServiceAnnotation(EchoImpl.class);
        control.setReturnValue(serviceAnnotation);
        webAnnotations.getWebServiceAnnotation(EchoImpl.class);
        control.setReturnValue(serviceAnnotation);
        
        Method echoMethod = EchoImpl.class.getMethod("echo", new Class[]{String.class});
        webAnnotations.hasWebMethodAnnotation(echoMethod);
        control.setDefaultReturnValue(true);
        
        webAnnotations.hasWebMethodAnnotation(echoMethod);
        control.setDefaultReturnValue(false);
        webAnnotations.hasWebParamAnnotation(echoMethod, 0);
        control.setDefaultReturnValue(false);
        webAnnotations.hasWebResultAnnotation(echoMethod);
        control.setDefaultReturnValue(false);
        webAnnotations.hasOnewayAnnotation(echoMethod);
        control.setDefaultReturnValue(false);
        webAnnotations.getServiceProperties(EchoImpl.class);
        control.setDefaultReturnValue(new Properties());
        webAnnotations.getInHandlers(EchoImpl.class);
        control.setDefaultReturnValue(Collections.EMPTY_LIST);
        webAnnotations.getOutHandlers(EchoImpl.class);
        control.setDefaultReturnValue(Collections.EMPTY_LIST);
        webAnnotations.getFaultHandlers(EchoImpl.class);
        control.setDefaultReturnValue(Collections.EMPTY_LIST);
        
        control.replay();
        
        factory.setServiceFactory(new AnnotationServiceFactory(webAnnotations, 
                                                               getTransportManager()));
        factory.setServiceClass(EchoImpl.class);
        
        factory.afterPropertiesSet();
        
        control.verify();
    }
    

    public void testInterface() 
        throws Exception
    {
        MockControl control = MockControl.createControl(WebAnnotations.class);
        WebAnnotations webAnnotations = (WebAnnotations) control.getMock();
        
        WebServiceAnnotation serviceAnnotation = new WebServiceAnnotation();
        webAnnotations.getWebServiceAnnotation(Echo.class);
        control.setDefaultReturnValue(serviceAnnotation);
        
        webAnnotations.hasWebServiceAnnotation(Echo.class);
        control.setDefaultReturnValue(true);
        
        webAnnotations.hasSOAPBindingAnnotation(Echo.class);
        control.setReturnValue(false);
        
        serviceAnnotation = new WebServiceAnnotation();
        serviceAnnotation.setServiceName("Echo");
        serviceAnnotation.setTargetNamespace("urn:Echo");
        webAnnotations.getWebServiceAnnotation(Echo.class);
        control.setDefaultReturnValue(serviceAnnotation);
        
        Method echoMethod = EchoImpl.class.getMethod("echo", new Class[]{String.class});
        webAnnotations.hasWebMethodAnnotation(echoMethod);
        control.setDefaultReturnValue(true);
        
        webAnnotations.hasWebMethodAnnotation(echoMethod);
        control.setDefaultReturnValue(false);
        webAnnotations.hasWebParamAnnotation(echoMethod, 0);
        control.setDefaultReturnValue(false);
        webAnnotations.hasWebResultAnnotation(echoMethod);
        control.setDefaultReturnValue(false);
        webAnnotations.hasOnewayAnnotation(echoMethod);
        control.setDefaultReturnValue(false);
        webAnnotations.getServiceProperties(Echo.class);
        control.setDefaultReturnValue(new Properties());
        webAnnotations.hasHandlerChainAnnotation(Echo.class);
        control.setDefaultReturnValue(false);
        webAnnotations.getInHandlers(Echo.class);
        control.setDefaultReturnValue(Collections.EMPTY_LIST);
        webAnnotations.getOutHandlers(Echo.class);
        control.setDefaultReturnValue(Collections.EMPTY_LIST);
        webAnnotations.getFaultHandlers(Echo.class);
        control.setDefaultReturnValue(Collections.EMPTY_LIST);
        control.replay();
        
        factory.setServiceFactory(new AnnotationServiceFactory(webAnnotations, 
                                                               getTransportManager()));
        factory.setServiceClass(Echo.class);
        
        factory.afterPropertiesSet();
        
        control.verify();
    }
}