1

我正在创建要部署到 Fuse 6.2.1 的 Restful (Jax-RS) 服务。（使用 Apache CFX，并使用 OSGi 包部署到 Karaf）服务器仅支持 Spring 3.2.12.RELEASE。我正在尝试使用几乎为零的 XML 配置来做所有事情。

到目前为止一切顺利，一切正常，我可以部署和运行我的服务。

但是，我希望能够在本地测试我的服务而无需部署它们。所以我希望能够启动一个网络服务器并注册我的 servlet，但不能完全弄清楚我们的方式。

我正在用这个配置 servlet（使用 Spring 的 WebApplicationInitializer 而不是 web.xml）：

import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import javax.servlet.ServletRegistration;

import org.apache.cxf.transport.servlet.CXFServlet;
import org.springframework.web.WebApplicationInitializer;
import org.springframework.web.context.ContextLoaderListener;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.AnnotationConfigWebApplicationContext;

public class CxfServletInitializer implements WebApplicationInitializer {

@Override
public void onStartup(ServletContext servletContext) throws ServletException {
    servletContext.addListener(new ContextLoaderListener(createWebAppContext()));
    addApacheCxfServlet(servletContext);
}

private void addApacheCxfServlet(ServletContext servletContext) {
    CXFServlet cxfServlet = new CXFServlet();
    ServletRegistration.Dynamic appServlet = servletContext.addServlet("CXFServlet", cxfServlet);
    appServlet.setLoadOnStartup(1);
    Set<String> mappingConflicts = appServlet.addMapping("/*");
}

private WebApplicationContext createWebAppContext() {
    AnnotationConfigWebApplicationContext appContext = new AnnotationConfigWebApplicationContext();
    appContext.register(CxfServletConfig.class);
    return appContext;
}

}

我的主要 Spring 配置如下所示：

import javax.ws.rs.core.Application;
import javax.ws.rs.ext.RuntimeDelegate;

import org.apache.cxf.bus.spring.SpringBus;
import org.apache.cxf.endpoint.Server;
import org.apache.cxf.jaxrs.JAXRSServerFactoryBean;
import org.springframework.context.ApplicationContext;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.DependsOn;

import com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider;

@Configuration
public class CxfServletConfig {

private static final org.slf4j.Logger log = org.slf4j.LoggerFactory.getLogger(CxfServletConfig.class);

@Bean(destroyMethod = "shutdown")
public SpringBus cxf() {
    return new SpringBus();
}

@Bean
@DependsOn("cxf")
public Server jaxRsServer(ApplicationContext appContext) {
    JAXRSServerFactoryBean endpoint = RuntimeDelegate.getInstance(). 
        createEndpoint(jaxRsApiApplication(), JAXRSServerFactoryBean.class);

    endpoint.setServiceBeans(Arrays.<Object> asList(testSvc()));
    endpoint.setAddress(endpoint.getAddress());
    endpoint.setProvider(jsonProvider());
    return endpoint.create();
}

@Bean
public Application jaxRsApiApplication() {
    return new Application();
}

@Bean
public JacksonJsonProvider jsonProvider() {
    return new JacksonJsonProvider();
}

@Bean(name = "testSvc")
public TestService testSvc() {
    return new TestService();
}

所以为了清楚起见，上面的代码是我当前的、工作的、可部署的配置。所以现在我想创建一个使用相同但也启动 Jetty 并注册我的 servlet 的测试配置，但不能完全弄清楚如何。有什么帮助吗？谢谢！

编辑：原来我根本不需要 WebApplicationInitializer 来让它工作。我最终为 Spring 创建了一个测试配置，它将一个 Jetty 服务器定义为一个 bean。似乎工作：

@Configuration
public class TestingSpringConfig {

@Bean (name="jettyServer", destroyMethod = "stop")
public Server jettyServer() throws Exception {

    Server server = new Server(0); //start jetty on a random, free port
    // Register and map the dispatcher servlet
    final ServletHolder servletHolder = new ServletHolder( new CXFServlet() );
    final ServletContextHandler context = new ServletContextHandler();  
    context.setContextPath( "/" );
    //fuse uses cxf as base url path for cxf services, so doing so as well here so urls are consistent
    context.addServlet( servletHolder, "/mybaseurl/*" );
    context.addEventListener( new ContextLoaderListener() );

    context.setInitParameter( "contextClass", AnnotationConfigWebApplicationContext.class.getName() );
    //this will load the spring config for the CFX servlet
    context.setInitParameter( "contextConfigLocation", CxfServletConfig.class.getName() );

    server.setHandler( context );
    server.start();
    //server.join(); if running from a main class instead of bean
    return server;
}

@Bean(name = "jettyPort")
@DependsOn("jettyServer")
public Integer jettyPort() throws Exception {
    Integer port = jettyServer().getConnectors()[0].getLocalPort();
    log.info("Jetty started on port: " + port);
    return  port;
}
}
4

0 回答 0