运行Spring WebFlux@controller而不

Question

我正在尝试在没有Spring Boot的情况下从main启动Spring应用程序，我设法获得了工作的路由器功能，但无法使其工作到经典的@控制器。我调试并观看了启动的源代码，内置了配置，添加了RequestMappingHandlerMapping，它注册了我的控制器，但无论如何WebHandler都看不到它。我可以看到spring发现我的@控制器是一个bean，所以这不是问题。有人能帮帮我吗？谢谢。

2018年4月13日7:27:30 PM org.springframework.context.support.abstractApplicationContext准备刷新信息：刷新org.springframework.context.annotation.annotationConfigApplicationContext@20e2cbe0:启动日期[Fri Apr 13 19:27:30 EEST 2018]；上下文层次结构的根目录2018年4月13日7:27:31 PM org.SpringFramework.web.reactive.result.method.AbstractHandlerMethodMapping$MappingRegistry注册信息：将“{[/test],methods=[GET]}”映射到公共java.lang.String test.wboot.controller.test（）[DEBUG]（main）使用控制台日志[DEBUG]（main）默认Epoll支持：false[DEBUG]（main）默认KQueue支持

public class Application {
    public static void main(String[] args) {
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(AppConfig.class);
        context.start();
    }
}

.

@Configuration
@ComponentScan("test.wboot")
public class AppConfig {

    public static final int port = 9099;

    @Bean
    public NettyContext servak(ApplicationContext applicationContext) throws IOException {


//        this handler works just perfect
//        HttpHandler httpHandler = RouterFunctions.toHttpHandler(routingFunction());

//        And this one can not see Controller
        HttpHandler httpHandler = WebHttpHandlerBuilder.applicationContext(applicationContext).build();

        ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(httpHandler);
        NettyContext localhost = HttpServer.create("localhost", port).newHandler(adapter).block();
        System.out.println("Press button to exit");
        System.in.read();
        return localhost;
    }

    public RouterFunction<ServerResponse> routingFunction() {
        return nest(path("/test"), route(GET(""), new HandlerFunction<ServerResponse>() {
            public Mono<ServerResponse> handle(ServerRequest request) {
                return ServerResponse.ok().syncBody("Hello yopta");
            }
        }));
    }

    @Bean
    public RequestMappingHandlerMapping requestMappingHandlerMapping(ApplicationContext applicationContext) {
        RequestMappingHandlerMapping requestMappingHandlerMapping = new RequestMappingHandlerMapping();
        requestMappingHandlerMapping.setApplicationContext(applicationContext);
        requestMappingHandlerMapping.afterPropertiesSet();
        return requestMappingHandlerMapping;
    }

    @Bean
    public WebHandler webHandler(ApplicationContext applicationContext) {
        DispatcherHandler webHandler = new DispatcherHandler();
        webHandler.setApplicationContext(applicationContext);
        return webHandler;
    }
}

.

@RestController
@RequestMapping("/test")
public class Controller {

    @GetMapping
    public String test() {
        return "work";
    }
}

Maven依赖项：

<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webflux</artifactId>
        <version>5.0.5.RELEASE</version>
    </dependency>

    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-context</artifactId>
        <version>5.0.5.RELEASE</version>
    </dependency>

    <dependency>
        <groupId>io.projectreactor.ipc</groupId>
        <artifactId>reactor-netty</artifactId>
        <version>0.7.6.RELEASE</version>
    </dependency>
</dependencies>

Answer 1

你为什么要重新拨号？Spring Framework提供了一个@enablewebflux注释，它可以完成以上功能，因此您只需在@configuration类上添加该注释即可。

然后，您只需按照这里的说明，使用框架自动创建的webhandler启动服务器；对于Reactor Netty来说，这看起来像：

HttpHandler handler = ...
ReactorHttpHandlerAdapter adapter = new ReactorHttpHandlerAdapter(handler);
HttpServer.create(host, port).newHandler(adapter).block();