在 reactive Spring Webflux REST 控制器中重定向

Question

我正在为 spring 反应式项目创建简单的控制器服务器。在设置重定向到另一个位置时，我在调用 http://localhost:8080/:

时发现错误

There was an unexpected error (type=Internal Server Error, status=500).
ModelAttributeMethodArgumentResolver does not support multi-value reactive type wrapper: interface reactor.netty.http.server.HttpServerResponse
java.lang.IllegalStateException: ModelAttributeMethodArgumentResolver does not support multi-value reactive type wrapper: interface reactor.netty.http.server.HttpServerResponse
    at org.springframework.util.Assert.state(Assert.java:94)
    at org.springframework.web.reactive.result.method.annotation.ModelAttributeMethodArgumentResolver.resolveArgument(ModelAttributeMethodArgumentResolver.java:112)
    at org.springframework.web.reactive.result.method.HandlerMethodArgumentResolverComposite.resolveArgument(HandlerMethodArgumentResolverComposite.java:123)
    at org.springframework.web.reactive.result.method.InvocableHandlerMethod.getMethodArgumentValues(InvocableHandlerMethod.java:190)
    at org.springframework.web.reactive.result.method.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:133)
    at org.springframework.web.reactive.result.method.annotation.RequestMappingHandlerAdapter.lambda$handle(RequestMappingHandlerAdapter.java:200)
    at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:44)
...

这是控制器代码：

import reactor.core.publisher.Mono;
import reactor.netty.http.server.HttpServerResponse;

@RestController
public class BaseController {
    @GetMapping("/")
    public Mono<Void> indexController(HttpServerResponse response) {

        return response.sendRedirect("/api/v1");
    }
// ...
}

我预计它会从 localhost:8080/ 重定向到 localhost:8080/api/v1。但是我遇到了上述异常。

Answer 1

使用 Controller MVC 的旧方法重定向：

import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

import java.net.URI;

@RestController
public class Controller {
    @GetMapping("/")
    public Mono<Void> indexController(ServerHttpResponse response) {
        response.setStatusCode(HttpStatus.PERMANENT_REDIRECT);
        response.getHeaders().setLocation(URI.create("/api/v1"));
        return response.setComplete();
    }
}

如果有人更喜欢函数式 Router/Handler 方法，可以调查：。

@Bean
RouterFunction<ServerResponse> routerFunction() {
    return route(GET("/"), req ->
            ServerResponse.temporaryRedirect(URI.create("/api/v1"))
                    .build());
}

Answer 2

当使用 @RestController 时，ResponseEntity 也可以工作（这里使用 kotlin 协程实现）：

@RestController
class SomeController() {
  suspend fun someMethod() : ResponseEntity<Unit> {
    return ResponseEntity
      .status(HttpStatus.TEMPORARY_REDIRECT)
      .location(URI.create("/api/v1"))
      .build()
  }
}

在 reactive Spring Webflux REST 控制器中重定向

Redirection inside reactive Spring Webflux REST controller

java

reactive-programming

spring-restcontroller

spring-webflux