Resultados de la búsqueda a petición "project-reactor"

1 la respuesta

¿Cómo “gestionas” realmente el número máximo de hilos web utilizando la Programación Reactiva de Spring 5?

Al usar un enfoque clásico de Tomcat, puede darle a su servidor un número máximo de hilos que puede usar para manejar las solicitudes web de los usuarios. Usando el paradigma de Programación Reactiva y Reactor en Spring 5, podemos escalar mejor ...

2 la respuesta

Spring 5 Web Reactive - ¿Cómo podemos usar WebClient para recuperar datos transmitidos en un Flux?

La documentación actual de hitos (M4) muestra un ejemplo sobre cómo recuperar unMono utilizandoWebClient: WebClient webClient = WebClient.create(new ReactorClientHttpConnector()); ClientRequest<Void> request ...

1 la respuesta

El método publishingOn of Flux no funciona como se esperaba

Estoy tratando de integrar un consumidor de bloqueo comoFlujosuscriptor en Reactor Aluminium-SR1. Me gustaría usar un paraleloProgramador, para ejecutar las operaciones de bloqueo al mismo tiempo. Implementé una clase principal para describir mi ...

3 la respuesta

Cómo leer correctamente Flux <DataBuffer> y convertirlo en una sola entrada

Estoy usandoWebClient y personalizadoBodyExtractorclase para mi aplicación de arranque de primavera WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(MediaType.APPLICATION.XML) .exchange() .flatMap(response -> { ...

2 la respuesta

¿Cómo recopilar respuestas API paginadas usando Spring WebClient de arranque?

Tengo una respuesta paginada de una URL, quiero seguir presionando la URL de la página siguiente que obtengo de la respuesta anterior y seguir recolectando elementos hasta que no tenga una URL de "nextPage" en mi respuesta. ¿Cómo lograr esto de ...

6 la respuesta

Cómo registrar cuerpos de solicitud y respuesta en Spring WebFlux

Quiero tener un registro centralizado de solicitudes y respuestas en mi API REST en Spring WebFlux con Kotlin. Hasta ahora he intentado este enfoque @Bean fun apiRouter() = router { (accept(MediaType.APPLICATION_JSON) and "/api").nest { ...

1 la respuesta

¿Cómo crear un Spring Reactor Flux a partir del flujo de integración Http?

Tengo una pregunta muy parecida a esta.¿Cómo crear un Spring Reactor Flux a partir de una cola ActiveMQ? [https://stackoverflow.com/questions/43126775/how-to-create-a-spring-reactor-flux-from-a-activemq-queue] Con una diferencia, los mensajes ...

3 la respuesta

¿Cómo hacer una secuencia de operaciones y asegurar que una operación se complete antes de la siguiente en la aplicación web Spring Reactor?

Tengo la aplicación web Spring Boot 2 en la que necesito identificar al visitante del sitio mediante cookies y recopilar estadísticas de visualización de la página. Entonces necesito interceptar cada solicitud web. El código que tuve que escribir ...

3 la respuesta

Cómo convertir Mono <List <String>> en Flux <String>

Estoy convirtiendo un pequeño proyecto escrito en RxJava 1.x a Reactor 3.x. Todo está bien, excepto que no pude encontrar cómo reemplazarflatMap(Observable::from) con la contraparte apropiada. yo tengoMono<List<String>> y necesito convertirlo ...

1 la respuesta

¿Es realmente necesario usar Hystrix con la aplicación reactiva spring boot 2?

Estoy trabajando en un proyecto en el que estamos trasladando algunos de nuestros microservicios de Spring-MVC a Spring-Webflux para probar el paradigma reactivo. Buscando ayuda en el repositorio github de hystrix, hemos notado que el proyecto ...