Конфігурація WebFlux

@Configuration
@EnableWebFlux
class WebConfig : WebFluxConfigurer {
override fun configureViewResolvers(registry: ViewResolverRegistry) {
val resolver: ViewResolver = ...
registry.viewResolver(resolver
}
}

Для забезпечення підтримки узгодження вмісту та візуалізації інших форматів через роздільну здатність подання (крім HTML), можна налаштувати одне подання або більше за замовчуванням на основі реалізації HttpMessageWriterView, яка приймає будь-який з доступних кодеків із spring-web. У цьому прикладі показано, як це зробити:

@Configuration
@EnableWebFlux
public class WebConfig implements WebFluxConfigurer {
@Override
public void configureViewResolvers(ViewResolverRegistry registry) {
registry.freeMarker();
Jackson2JsonEncoder encoder = new Jackson2JsonEncoder();
registry.defaultViews(new HttpMessageWriterView(encoder));
}
// ...
}

@Configuration
@EnableWebFlux
class WebConfig : WebFluxConfigurer {
override fun configureViewResolvers(registry: ViewResolverRegistry) {
registry.freeMarker()
val encoder = Jackson2JsonEncoder()
registry.defaultViews(HttpMessageWriterView(encoder))
}
// ...
}

Статичні ресурси

Ця опція забезпечує зручний спосіб обробки статичних ресурсів зі списку розташування на основі Resource.

У наступному прикладі, якщо запит починається з /resources, відносний шлях використовується для пошуку та обробки статичних ресурсів щодо /static у classpath. Ресурси обробляються із закінченням терміну дії один рік, щоб забезпечити максимальне використання кеша браузера і скоротити кількість HTTP-запитів, що виконуються браузером. Також обчислюється заголовок Last-Modified і якщо він є, то повертається код стану 304. У наступному лістингу показаний приклад:

@Configuration
@EnableWebFlux
public class WebConfig implements WebFluxConfigurer {
@Override
public void addResourceHandlers(ResourceHandlerRegistry registry) {
registry.addResourceHandler("/resources/**")
        .addResourceLocations("/public", "classpath:/static/")
        .setCacheControl(CacheControl.maxAge(365, TimeUnit.DAYS));
}
}

@Configuration
@EnableWebFlux
class WebConfig : WebFluxConfigurer {
override fun addResourceHandlers(registry: ResourceHandlerRegistry) {
registry.addResourceHandler("/resources/**")
        .addResourceLocations("/public", "classpath:/static/")
        .setCacheControl(CacheControl.maxAge(365, TimeUnit.DAYS))
}
}

Обробник ресурсів також підтримує ланцюжок реалізацій ResourceResolver та реалізацій ResourceTransformer, які можна використати для створення набору інструментальних засобів для роботи з оптимізованими ресурсами.

Ти можеш використовувати VersionResourceResolver для версійних URL-адрес ресурсів на основі хеша MD5, отриманого з вмісту, незмінної версії програми або іншої інформації. ContentVersionStrategy (хеш MD5) є продуманим вибором, але з деякими помітними винятками (наприклад, ресурси JavaScript, які використовуються із завантажувачем модулів).

У наступному прикладі показано, як використовувати VersionResourceResolver у конфігурації Java:

@Configuration
@EnableWebFlux
public class WebConfig implements WebFluxConfigurer {
@Override
public void addResourceHandlers(ResourceHandlerRegistry registry) {
registry.addResourceHandler("/resources/**")
        .addResourceLocations("/public/")
        .resourceChain(true)
        .addResolver(new VersionResourceResolver().addContentVersionStrategy("/**"));
}
}

@Configuration
@EnableWebFlux
class WebConfig : WebFluxConfigurer {
override fun addResourceHandlers(registry: ResourceHandlerRegistry) {
registry.addResourceHandler("/resources/**")
        .addResourceLocations("/public/")
        .resourceChain(true)
        .addResolver(VersionResourceResolver().addContentVersionStrategy("/**"))
}
}

Можна використовувати ResourceUrlProvider для перезапису URL-адреси та застосування повного ланцюжка розпізнавачів та перетворювачів (наприклад, для вставки версій). Конфігурація WebFlux передбачає ResourceUrlProvider, який можна впроваджувати в інші біни.

На відміну від Spring MVC, зараз у WebFlux немає можливості прозоро переписувати статичні URL-адреси ресурсів, оскільки немає технологій подання, які могли б використовувати неблокуючий ланцюжок розпізнавачів та перетворювачів. При обробці тільки локальних ресурсів обхідним рішенням є використання ResourceUrlProvider безпосередньо (наприклад, через кастомний елемент) та блокування.

Зверни увагу, що при використанні як EncodedResourceResolver (наприклад, з кодуванням Gzip, Brotli), так і VersionedResourceResolver, їх необхідно реєструвати в такому порядку, який забезпечить надійне обчислення версій на основі вмісту некодованого файлу.

WebJars також підтримуються за допомогою WebJarsResourceResolver, яка автоматично реєструється за наявності бібліотеки org.webjars: webjars-locator-core у classpath. Розпізнавач може переписувати URL-адреси, щоб включити до складу версію jar, а також зіставляти вхідні URL-адреси без версій — наприклад, /jquery/jquery.min.js /jquery/1.2 .0/jquery.min.js.

@Configuration
@EnableWebFlux
public class WebConfig implements WebFluxConfigurer {
@Override
public void configurePathMatch(PathMatchConfigurer configurer) {
configurer
    .setUseCaseSensitiveMatch(true)
    .setUseTrailingSlashMatch(false)
    .addPathPrefix("/api",
            HandlerTypePredicate.forAnnotation(RestController.class));
}
}

@Configuration
@EnableWebFlux
class WebConfig : WebFluxConfigurer {
@Override
fun configurePathMatch(configurer: PathMatchConfigurer) {
configurer
    .setUseCaseSensitiveMatch(true)
    .setUseTrailingSlashMatch(false)
    .addPathPrefix("/api",
            HandlerTypePredicate.forAnnotation(RestController::class.java))
}
}

WebSocketService

У Java-конфігурації WebFlux оголошується бін WebSocketHandlerAdapter, що забезпечує підтримку виклику обробників WebSocket. Це означає, що для обробки запиту на підтвердження встановлення зв'язку за протоколом WebSocket залишається лише зіставити WebSocketHandler з URL-адресою через SimpleUrlHandlerMapping.

У деяких випадках може потрібно створити бін WebSocketHandlerAdapter з передбаченою службою WebSocketService, яка дозволяє налаштовувати властивості сервера, що працює з протоколом WebSocket. Наприклад:

@Configuration
@EnableWebFlux
public class WebConfig implements WebFluxConfigurer {
@Override
public WebSocketService getWebSocketService() {
TomcatRequestUpgradeStrategy strategy = new TomcatRequestUpgradeStrategy();
strategy.setMaxSessionIdleTimeout(0L);
return new HandshakeWebSocketService(strategy);
}
}

@Configuration
@EnableWebFlux
class WebConfig : WebFluxConfigurer {
@Override
fun webSocketService(): WebSocketService {
val strategy = TomcatRequestUpgradeStrategy().apply {
    setMaxSessionIdleTimeout(0L)
}
return HandshakeWebSocketService(strategy)
}
}

@Configuration
public class WebConfig extends DelegatingWebFluxConfiguration {
// ...
}

@Configuration
class WebConfig : DelegatingWebFluxConfiguration {
// ...
}}