功能端点 (Functional Endpoints) _ Spring Framework6.1.14-SNAPSHOT中文文档(官方文档中文翻译)|Spring 教程 —

此版本仍在开发中，尚未被视为稳定版本。最新的稳定版本请使用 Spring Framework 6.1.13！spring-doc.cn

Spring Web MVC 包括 WebMvc.fn，这是一个轻量级函数式编程模型，其中函数用于路由和处理请求，而 Contract 旨在实现不变性。它是基于 Comments 的编程模型的替代方案，但在其他方面运行相同的 DispatcherServlet。spring-doc.cn

概述

在 Reactive 堆栈中查看 equivalentspring-doc.cn

在 WebMvc.fn 中，HTTP 请求使用：一个函数处理，该函数接受并返回一个 . 请求和响应对象都有不可变的契约，这些契约提供对 JDK 8 友好的访问 HTTP 请求和响应。等效于基于注释的编程模型。HandlerFunctionServerRequestServerResponseHandlerFunction@RequestMappingspring-doc.cn

传入请求被路由到具有：的处理程序函数，该函数接受并返回一个可选值（即）。当 router 函数匹配时，将返回一个处理程序函数;否则为空 Optional。等同于注释，但使用 major 不同之处在于 router 函数不仅提供数据，还提供行为。RouterFunctionServerRequestHandlerFunctionOptional<HandlerFunction>RouterFunction@RequestMappingspring-doc.cn

RouterFunctions.route()提供便于创建路由器的 Router 构建器，如下例所示：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import static org.springframework.http.MediaType.APPLICATION_JSON;
import static org.springframework.web.servlet.function.RequestPredicates.*;
import static org.springframework.web.servlet.function.RouterFunctions.route;

PersonRepository repository = ...
PersonHandler handler = new PersonHandler(repository);

RouterFunction<ServerResponse> route = route() (1)
	.GET("/person/{id}", accept(APPLICATION_JSON), handler::getPerson)
	.GET("/person", accept(APPLICATION_JSON), handler::listPeople)
	.POST("/person", handler::createPerson)
	.build();


public class PersonHandler {

	// ...

	public ServerResponse listPeople(ServerRequest request) {
		// ...
	}

	public ServerResponse createPerson(ServerRequest request) {
		// ...
	}

	public ServerResponse getPerson(ServerRequest request) {
		// ...
	}
}

1	使用创建路由器。`route()`

import org.springframework.web.servlet.function.router

val repository: PersonRepository = ...
val handler = PersonHandler(repository)

val route = router { (1)
	accept(APPLICATION_JSON).nest {
		GET("/person/{id}", handler::getPerson)
		GET("/person", handler::listPeople)
	}
	POST("/person", handler::createPerson)
}


class PersonHandler(private val repository: PersonRepository) {

	// ...

	fun listPeople(request: ServerRequest): ServerResponse {
		// ...
	}

	fun createPerson(request: ServerRequest): ServerResponse {
		// ...
	}

	fun getPerson(request: ServerRequest): ServerResponse {
		// ...
	}
}

1	使用路由器 DSL 创建路由器。

如果将注册为 bean，例如通过在类中公开它，则 servlet 将自动检测到它，如运行服务器中所述。RouterFunction@Configurationspring-doc.cn

1	使用创建路由器。`route()`

1	使用路由器 DSL 创建路由器。

HandlerFunction 函数

在 Reactive 堆栈中查看 equivalentspring-doc.cn

ServerRequest并且是提供 JDK 8 友好的不可变接口访问 HTTP 请求和响应，包括标头、正文、方法和状态代码。ServerResponsespring-doc.cn

服务器请求

ServerRequest提供对 HTTP 方法、URI、标头和查询参数的访问，而对 body 的访问是通过 methods.bodyspring-doc.cn

以下示例将请求正文提取为：Stringspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

String string = request.body(String.class);

val string = request.body<String>()

以下示例将正文提取为，其中对象是从序列化形式（如 JSON 或 XML）解码的：List<Person>Personspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

List<Person> people = request.body(new ParameterizedTypeReference<List<Person>>() {});

val people = request.body<Person>()

以下示例显示如何访问参数：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

MultiValueMap<String, String> params = request.params();

val map = request.params()

服务器响应

ServerResponse提供对 HTTP 响应的访问，并且由于它是不可变的，因此您可以使用一个创建它的方法。您可以使用生成器设置响应状态，以添加响应 headers 或提供正文。以下示例使用 JSON 创建 200 （OK）响应内容：buildspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

Person person = ...
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(person);

val person: Person = ...
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(person)

以下示例显示如何构建带有标头但无正文的 201 （CREATED）响应：Locationspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

URI location = ...
ServerResponse.created(location).build();

val location: URI = ...
ServerResponse.created(location).build()

您还可以使用异步结果作为正文，采用、或 .例如：CompletableFuturePublisherReactiveAdapterRegistryspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

Mono<Person> person = webClient.get().retrieve().bodyToMono(Person.class);
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(person);

val person = webClient.get().retrieve().awaitBody<Person>()
ServerResponse.ok().contentType(MediaType.APPLICATION_JSON).body(person)

如果不仅 body 基于 body，而且 status 或 headers 都基于异步类型，您可以在上使用 static 方法，该方法接受、或 .例如：asyncServerResponseCompletableFuture<ServerResponse>Publisher<ServerResponse>ReactiveAdapterRegistryspring-doc.cn

Javaspring-doc.cn

Mono<ServerResponse> asyncResponse = webClient.get().retrieve().bodyToMono(Person.class)
  .map(p -> ServerResponse.ok().header("Name", p.name()).body(p));
ServerResponse.async(asyncResponse);

Server-Sent Events 可以通过 static 方法。该方法提供的生成器允许您以 JSON 格式发送字符串或其他对象。例如：sseServerResponsespring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

public RouterFunction<ServerResponse> sse() {
	return route(GET("/sse"), request -> ServerResponse.sse(sseBuilder -> {
				// Save the sseBuilder object somewhere..
			}));
}

// In some other thread, sending a String
sseBuilder.send("Hello world");

// Or an object, which will be transformed into JSON
Person person = ...
sseBuilder.send(person);

// Customize the event by using the other methods
sseBuilder.id("42")
		.event("sse event")
		.data(person);

// and done at some point
sseBuilder.complete();

fun sse(): RouterFunction<ServerResponse> = router {
	GET("/sse") { request -> ServerResponse.sse { sseBuilder ->
		// Save the sseBuilder object somewhere..
	}
}

// In some other thread, sending a String
sseBuilder.send("Hello world")

// Or an object, which will be transformed into JSON
val person = ...
sseBuilder.send(person)

// Customize the event by using the other methods
sseBuilder.id("42")
		.event("sse event")
		.data(person)

// and done at some point
sseBuilder.complete()

处理程序类

我们可以将处理程序函数编写为 lambda，如下例所示：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

HandlerFunction<ServerResponse> helloWorld =
  request -> ServerResponse.ok().body("Hello World");

val helloWorld: (ServerRequest) -> ServerResponse =
  { ServerResponse.ok().body("Hello World") }

这很方便，但在应用程序中，我们需要多个函数和多个内联 Lambda 可能会变得混乱。因此，将相关的处理程序函数一起分组到一个处理程序类中是很有用的，该具有与基于注释的应用程序类似的角色。例如，以下类公开了一个反应式存储库：@ControllerPersonspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import static org.springframework.http.MediaType.APPLICATION_JSON;
import static org.springframework.web.reactive.function.server.ServerResponse.ok;

public class PersonHandler {

	private final PersonRepository repository;

	public PersonHandler(PersonRepository repository) {
		this.repository = repository;
	}

	public ServerResponse listPeople(ServerRequest request) { (1)
		List<Person> people = repository.allPeople();
		return ok().contentType(APPLICATION_JSON).body(people);
	}

	public ServerResponse createPerson(ServerRequest request) throws Exception { (2)
		Person person = request.body(Person.class);
		repository.savePerson(person);
		return ok().build();
	}

	public ServerResponse getPerson(ServerRequest request) { (3)
		int personId = Integer.parseInt(request.pathVariable("id"));
		Person person = repository.getPerson(personId);
		if (person != null) {
			return ok().contentType(APPLICATION_JSON).body(person);
		}
		else {
			return ServerResponse.notFound().build();
		}
	}

}

1	`listPeople`是一个处理程序函数，它将在存储库中找到的所有对象作为 JSON 的 JSON 格式。`Person`
2	`createPerson`是一个处理程序函数，用于存储请求正文中包含的 new。`Person`
3	`getPerson`是一个处理程序函数，它返回一个 person，由路径变量。我们从存储库中检索该响应并创建一个 JSON 响应（如果是发现。如果未找到，我们将返回 404 Not Found 响应。`idPerson`

class PersonHandler(private val repository: PersonRepository) {

	fun listPeople(request: ServerRequest): ServerResponse { (1)
		val people: List<Person> = repository.allPeople()
		return ok().contentType(APPLICATION_JSON).body(people);
	}

	fun createPerson(request: ServerRequest): ServerResponse { (2)
		val person = request.body<Person>()
		repository.savePerson(person)
		return ok().build()
	}

	fun getPerson(request: ServerRequest): ServerResponse { (3)
		val personId = request.pathVariable("id").toInt()
		return repository.getPerson(personId)?.let { ok().contentType(APPLICATION_JSON).body(it) }
				?: ServerResponse.notFound().build()

	}
}

1	`listPeople`是一个处理程序函数，它将在存储库中找到的所有对象作为 JSON 的 JSON 格式。`Person`
2	`createPerson`是一个处理程序函数，用于存储请求正文中包含的 new。`Person`
3	`getPerson`是一个处理程序函数，它返回一个 person，由路径变量。我们从存储库中检索该响应并创建一个 JSON 响应（如果是发现。如果未找到，我们将返回 404 Not Found 响应。`idPerson`

验证

功能性端点可以使用 Spring 的验证工具来对请求正文应用验证。例如，给定一个自定义的 Spring Validator 实现：Personspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

public class PersonHandler {

	private final Validator validator = new PersonValidator(); (1)

	// ...

	public ServerResponse createPerson(ServerRequest request) {
		Person person = request.body(Person.class);
		validate(person); (2)
		repository.savePerson(person);
		return ok().build();
	}

	private void validate(Person person) {
		Errors errors = new BeanPropertyBindingResult(person, "person");
		validator.validate(person, errors);
		if (errors.hasErrors()) {
			throw new ServerWebInputException(errors.toString()); (3)
		}
	}
}

1	Create instance 创建实例。`Validator`
2	应用验证。
3	引发 400 响应的异常。

class PersonHandler(private val repository: PersonRepository) {

	private val validator = PersonValidator() (1)

	// ...

	fun createPerson(request: ServerRequest): ServerResponse {
		val person = request.body<Person>()
		validate(person) (2)
		repository.savePerson(person)
		return ok().build()
	}

	private fun validate(person: Person) {
		val errors: Errors = BeanPropertyBindingResult(person, "person")
		validator.validate(person, errors)
		if (errors.hasErrors()) {
			throw ServerWebInputException(errors.toString()) (3)
		}
	}
}

1	Create instance 创建实例。`Validator`
2	应用验证。
3	引发 400 响应的异常。

处理程序还可以通过创建和注入来使用标准 bean 验证 API （JSR-303）基于的全局实例。参见 Spring Validation。ValidatorLocalValidatorFactoryBeanspring-doc.cn

1	`listPeople`是一个处理程序函数，它将在存储库中找到的所有对象作为 JSON 的 JSON 格式。`Person`
2	`createPerson`是一个处理程序函数，用于存储请求正文中包含的 new。`Person`
3	`getPerson`是一个处理程序函数，它返回一个 person，由路径变量。我们从存储库中检索该响应并创建一个 JSON 响应（如果是发现。如果未找到，我们将返回 404 Not Found 响应。`idPerson`

1	`listPeople`是一个处理程序函数，它将在存储库中找到的所有对象作为 JSON 的 JSON 格式。`Person`
2	`createPerson`是一个处理程序函数，用于存储请求正文中包含的 new。`Person`
3	`getPerson`是一个处理程序函数，它返回一个 person，由路径变量。我们从存储库中检索该响应并创建一个 JSON 响应（如果是发现。如果未找到，我们将返回 404 Not Found 响应。`idPerson`

1	Create instance 创建实例。`Validator`
2	应用验证。
3	引发 400 响应的异常。

1	Create instance 创建实例。`Validator`
2	应用验证。
3	引发 400 响应的异常。

`RouterFunction`

在 Reactive 堆栈中查看 equivalentspring-doc.cn

Router 函数用于将请求路由到相应的 . 通常，您不会自己编写 router 函数，而是使用 Utility 类上的方法创建一个。（无参数）为您提供用于创建路由器的 Fluent 构建器函数，而提供直接的创建路由器。HandlerFunctionRouterFunctionsRouterFunctions.route()RouterFunctions.route(RequestPredicate, HandlerFunction)spring-doc.cn

通常，建议使用构建器，因为它提供了适用于典型映射场景的便捷捷径，无需难以发现 static imports。例如，router 函数构建器提供了为 GET 请求创建 Map 的方法;和 POST。route()GET(String, HandlerFunction)POST(String, HandlerFunction)spring-doc.cn

除了基于 HTTP 方法的映射之外，路由构建器还提供了一种引入其他谓词。对于每个 HTTP 方法，都有一个重载的变体，它将 a 作为参数，通过该参数可以表示其他约束。RequestPredicatespring-doc.cn

谓词

您可以编写自己的，但 utility 类提供常用的实现，基于请求路径、HTTP 方法、内容类型、等等。以下示例使用请求谓词创建基于 header 的约束：RequestPredicateRequestPredicatesAcceptspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

RouterFunction<ServerResponse> route = RouterFunctions.route()
	.GET("/hello-world", accept(MediaType.TEXT_PLAIN),
		request -> ServerResponse.ok().body("Hello World")).build();

import org.springframework.web.servlet.function.router

val route = router {
	GET("/hello-world", accept(TEXT_PLAIN)) {
		ServerResponse.ok().body("Hello World")
	}
}

您可以使用以下方法将多个请求谓词组合在一起：spring-doc.cn

RequestPredicate.and(RequestPredicate)— 两者必须匹配。spring-doc.cn
RequestPredicate.or(RequestPredicate)— 两者都可以匹配。spring-doc.cn

许多谓词都是组合的。例如，由和组成。上面显示的示例还使用了两个请求谓词，因为生成器在内部使用，并使用谓词组合它。RequestPredicatesRequestPredicates.GET(String)RequestPredicates.method(HttpMethod)RequestPredicates.path(String)RequestPredicates.GETacceptspring-doc.cn

路线

路由器功能按顺序评估：如果第一个路由不匹配，则 second 被评估，依此类推。因此，在一般路由之前声明更具体的路由是有意义的。在将路由器函数注册为 Spring bean 时，这一点也很重要，也是如此稍后描述。请注意，此行为与基于 Comments 的编程模型不同，其中 “最具体”控制器方法会自动选取。spring-doc.cn

使用 router 函数构建器时，所有定义的路由都组合成一个路由，该路由从返回。还有其他方法可以将多个 router 功能组合在一起：RouterFunctionbuild()spring-doc.cn

add(RouterFunction)在构建器上RouterFunctions.route()spring-doc.cn
RouterFunction.and(RouterFunction)spring-doc.cn
RouterFunction.andRoute(RequestPredicate, HandlerFunction)— 嵌套的快捷方式。RouterFunction.and()RouterFunctions.route()spring-doc.cn

以下示例显示了四个路由的组合：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

import static org.springframework.http.MediaType.APPLICATION_JSON;
import static org.springframework.web.servlet.function.RequestPredicates.*;

PersonRepository repository = ...
PersonHandler handler = new PersonHandler(repository);

RouterFunction<ServerResponse> otherRoute = ...

RouterFunction<ServerResponse> route = route()
	.GET("/person/{id}", accept(APPLICATION_JSON), handler::getPerson) (1)
	.GET("/person", accept(APPLICATION_JSON), handler::listPeople) (2)
	.POST("/person", handler::createPerson) (3)
	.add(otherRoute) (4)
	.build();

1	`GET /person/{id}`将匹配 JSON 的标头路由到`AcceptPersonHandler.getPerson`
2	`GET /person`将匹配 JSON 的标头路由到`AcceptPersonHandler.listPeople`
3	`POST /person`在没有其他谓词的情况下映射到，并且`PersonHandler.createPerson`
4	`otherRoute`是在其他地方创建并添加到 Route built 的 router 函数。

import org.springframework.http.MediaType.APPLICATION_JSON
import org.springframework.web.servlet.function.router

val repository: PersonRepository = ...
val handler = PersonHandler(repository);

val otherRoute = router {  }

val route = router {
	GET("/person/{id}", accept(APPLICATION_JSON), handler::getPerson) (1)
	GET("/person", accept(APPLICATION_JSON), handler::listPeople) (2)
	POST("/person", handler::createPerson) (3)
}.and(otherRoute) (4)

1	`GET /person/{id}`将匹配 JSON 的标头路由到`AcceptPersonHandler.getPerson`
2	`GET /person`将匹配 JSON 的标头路由到`AcceptPersonHandler.listPeople`
3	`POST /person`在没有其他谓词的情况下映射到，并且`PersonHandler.createPerson`
4	`otherRoute`是在其他地方创建并添加到 Route built 的 router 函数。

嵌套路由

一组 router 函数通常具有共享谓词，例如共享的路径。在上面的示例中，共享谓词将是与、匹配的路径谓词，由其中 3 条路由使用。使用注释时，可以通过使用映射到 . 在 WebMvc.fn 中，可以通过路由器函数构建器上的方法共享路径谓词。例如，通过使用嵌套路由，可以通过以下方式改进上面示例的最后几行：/person@RequestMapping/personpathspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

RouterFunction<ServerResponse> route = route()
	.path("/person", builder -> builder (1)
		.GET("/{id}", accept(APPLICATION_JSON), handler::getPerson)
		.GET(accept(APPLICATION_JSON), handler::listPeople)
		.POST(handler::createPerson))
	.build();

1	请注意，第二个参数 of 是采用路由器构建器的使用者。`path`

import org.springframework.web.servlet.function.router

val route = router {
	"/person".nest { (1)
		GET("/{id}", accept(APPLICATION_JSON), handler::getPerson)
		GET(accept(APPLICATION_JSON), handler::listPeople)
		POST(handler::createPerson)
	}
}

1	使用 DSL。`nest`

尽管基于路径的嵌套是最常见的，但你可以使用构建器上的方法。上面仍然包含一些共享 -header 谓词形式的重复。我们可以通过将该方法与以下方法结合使用来进一步改进：nestAcceptnestacceptspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

RouterFunction<ServerResponse> route = route()
	.path("/person", b1 -> b1
		.nest(accept(APPLICATION_JSON), b2 -> b2
			.GET("/{id}", handler::getPerson)
			.GET(handler::listPeople))
		.POST(handler::createPerson))
	.build();

import org.springframework.web.servlet.function.router

val route = router {
	"/person".nest {
		accept(APPLICATION_JSON).nest {
			GET("/{id}", handler::getPerson)
			GET("", handler::listPeople)
			POST(handler::createPerson)
		}
	}
}

1	`GET /person/{id}`将匹配 JSON 的标头路由到`AcceptPersonHandler.getPerson`
2	`GET /person`将匹配 JSON 的标头路由到`AcceptPersonHandler.listPeople`
3	`POST /person`在没有其他谓词的情况下映射到，并且`PersonHandler.createPerson`
4	`otherRoute`是在其他地方创建并添加到 Route built 的 router 函数。

1	`GET /person/{id}`将匹配 JSON 的标头路由到`AcceptPersonHandler.getPerson`
2	`GET /person`将匹配 JSON 的标头路由到`AcceptPersonHandler.listPeople`
3	`POST /person`在没有其他谓词的情况下映射到，并且`PersonHandler.createPerson`
4	`otherRoute`是在其他地方创建并添加到 Route built 的 router 函数。

1	请注意，第二个参数 of 是采用路由器构建器的使用者。`path`

1	使用 DSL。`nest`

服务资源

WebMvc.fn 提供对服务资源的内置支持。spring-doc.cn

除了下面描述的功能之外，由于 RouterFunctions#resource（java.util.function.Function）还可以实现更灵活的资源处理。

重定向到资源

可以将与指定谓词匹配的请求重定向到资源。这可能很有用，例如，用于处理单页应用程序中的重定向。spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

   ClassPathResource index = new ClassPathResource("static/index.html");
List<String> extensions = Arrays.asList("js", "css", "ico", "png", "jpg", "gif");
RequestPredicate spaPredicate = path("/api/**").or(path("/error")).or(pathExtension(extensions::contains)).negate();
RouterFunction<ServerResponse> redirectToIndex = route()
	.resource(spaPredicate, index)
	.build();

   val redirectToIndex = router {
	val index = ClassPathResource("static/index.html")
	val extensions = listOf("js", "css", "ico", "png", "jpg", "gif")
	val spaPredicate = !(path("/api/**") or path("/error") or
		pathExtension(extensions::contains))
	resource(spaPredicate, index)
}

从根位置提供资源

还可以将匹配给定模式的请求路由到相对于给定根位置的资源。spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

Resource location = new FileSystemResource("public-resources/");
RouterFunction<ServerResponse> resources = RouterFunctions.resources("/resources/**", location);

val location = FileSystemResource("public-resources/")
val resources = router { resources("/resources/**", location) }

除了下面描述的功能之外，由于 RouterFunctions#resource（java.util.function.Function）还可以实现更灵活的资源处理。

运行 Server

在 Reactive 堆栈中查看 equivalentspring-doc.cn

通常通过 MVC Config 在基于 DispatcherHandler 的设置中运行路由器函数，该配置使用 Spring 配置来声明处理请求所需的组件。MVC Java 配置声明以下内容支持功能终端节点的基础设施组件：spring-doc.cn

RouterFunctionMapping：在 Spring 中检测到一个或多个 bean 配置，对它们进行排序，通过组合它们，并将请求路由到生成的 composed 。RouterFunction<?>RouterFunction.andOtherRouterFunctionspring-doc.cn
HandlerFunctionAdapter：允许调用 a 映射到请求。DispatcherHandlerHandlerFunctionspring-doc.cn

前面的组件允许功能端点适应请求处理生命周期，并且（可能）与带注释的控制器并行运行，如果任何（any）都已声明。这也是 Spring Boot Web 启用功能端点的方式起动机。DispatcherServletspring-doc.cn

以下示例显示了 WebFlux Java 配置：spring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

@Configuration
@EnableMvc
public class WebConfig implements WebMvcConfigurer {

	@Bean
	public RouterFunction<?> routerFunctionA() {
		// ...
	}

	@Bean
	public RouterFunction<?> routerFunctionB() {
		// ...
	}

	// ...

	@Override
	public void configureMessageConverters(List<HttpMessageConverter<?>> converters) {
		// configure message conversion...
	}

	@Override
	public void addCorsMappings(CorsRegistry registry) {
		// configure CORS...
	}

	@Override
	public void configureViewResolvers(ViewResolverRegistry registry) {
		// configure view resolution for HTML rendering...
	}
}

@Configuration
@EnableMvc
class WebConfig : WebMvcConfigurer {

	@Bean
	fun routerFunctionA(): RouterFunction<*> {
		// ...
	}

	@Bean
	fun routerFunctionB(): RouterFunction<*> {
		// ...
	}

	// ...

	override fun configureMessageConverters(converters: List<HttpMessageConverter<*>>) {
		// configure message conversion...
	}

	override fun addCorsMappings(registry: CorsRegistry) {
		// configure CORS...
	}

	override fun configureViewResolvers(registry: ViewResolverRegistry) {
		// configure view resolution for HTML rendering...
	}
}

筛选处理程序函数

在 Reactive 堆栈中查看 equivalentspring-doc.cn

您可以通过在路由上使用、或方法来筛选处理程序函数函数构建器。使用注释，您可以通过使用、 a 或两者来实现类似的功能。该筛选条件将应用于构建器构建的所有路由。这意味着嵌套路由中定义的筛选条件不适用于 “top-level” 路由。例如，请考虑以下示例：beforeafterfilter@ControllerAdviceServletFilterspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

RouterFunction<ServerResponse> route = route()
	.path("/person", b1 -> b1
		.nest(accept(APPLICATION_JSON), b2 -> b2
			.GET("/{id}", handler::getPerson)
			.GET(handler::listPeople)
			.before(request -> ServerRequest.from(request) (1)
				.header("X-RequestHeader", "Value")
				.build()))
		.POST(handler::createPerson))
	.after((request, response) -> logResponse(response)) (2)
	.build();

1	添加自定义请求标头的筛选条件仅适用于两个 GET 路由。`before`
2	记录响应的筛选条件将应用于所有路由，包括嵌套路由。`after`

import org.springframework.web.servlet.function.router

val route = router {
	"/person".nest {
		GET("/{id}", handler::getPerson)
		GET(handler::listPeople)
		before { (1)
			ServerRequest.from(it)
					.header("X-RequestHeader", "Value").build()
		}
	}
	POST(handler::createPerson)
	after { _, response -> (2)
		logResponse(response)
	}
}

1	添加自定义请求标头的筛选条件仅适用于两个 GET 路由。`before`
2	记录响应的筛选条件将应用于所有路由，包括嵌套路由。`after`

路由器构建器上的方法采用：一个函数，该函数采用 AND 并返回 . handler 函数参数表示链中的下一个元素。这通常是路由到的处理程序，但也可以是另一个 filter （如果应用了多个）。filterHandlerFilterFunctionServerRequestHandlerFunctionServerResponsespring-doc.cn

现在我们可以向路由添加一个简单的安全过滤器，假设我们有一个可以确定是否允许特定路径。以下示例显示了如何执行此操作：SecurityManagerspring-doc.cn

Javaspring-doc.cn
Kotlinspring-doc.cn

SecurityManager securityManager = ...

RouterFunction<ServerResponse> route = route()
	.path("/person", b1 -> b1
		.nest(accept(APPLICATION_JSON), b2 -> b2
			.GET("/{id}", handler::getPerson)
			.GET(handler::listPeople))
		.POST(handler::createPerson))
	.filter((request, next) -> {
		if (securityManager.allowAccessTo(request.path())) {
			return next.handle(request);
		}
		else {
			return ServerResponse.status(UNAUTHORIZED).build();
		}
	})
	.build();

import org.springframework.web.servlet.function.router

val securityManager: SecurityManager = ...

val route = router {
	("/person" and accept(APPLICATION_JSON)).nest {
		GET("/{id}", handler::getPerson)
		GET("", handler::listPeople)
		POST(handler::createPerson)
		filter { request, next ->
			if (securityManager.allowAccessTo(request.path())) {
				next(request)
			}
			else {
				status(UNAUTHORIZED).build();
			}
		}
	}
}

前面的示例演示了调用 is optional。我们只允许在允许访问时运行处理程序函数。next.handle(ServerRequest)spring-doc.cn

除了在路由器函数构建器上使用该方法外，还可以应用通过 Filter 筛选到现有路由器函数。filterRouterFunction.filter(HandlerFilterFunction)spring-doc.cn

对功能终端节点的 CORS 支持通过专用的 CorsFilter 提供。

1	添加自定义请求标头的筛选条件仅适用于两个 GET 路由。`before`
2	记录响应的筛选条件将应用于所有路由，包括嵌套路由。`after`

1	添加自定义请求标头的筛选条件仅适用于两个 GET 路由。`before`
2	记录响应的筛选条件将应用于所有路由，包括嵌套路由。`after`

对功能终端节点的 CORS 支持通过专用的 CorsFilter 提供。