Tag: REACTOR-NETTY
Intento aprender la programación reactiva con Spring Reactor Webflux. Particularmente en el siguiente ejemplo, trato de entender cómo componer correctamente el flujo de procesamiento para consumir el flujo entrante de una conexión WebSocket utilizando ReactorNettyWebSocketClient. El siguiente fragmento de código funciona correctamente: WebSocketClient client = new ReactorNettyWebSocketClient(); client.execute( URI.create(“wss://stream.binance.com:9443/ws/btcusdt@trade”), session . . . Read more
Según la documentación: maxIdleTime – El tiempo después del cual el canal es elegible para ser cerrado cuando está inactivo (resolución: ms). Por defecto: el tiempo de inactividad máximo no está especificado. maxLifeTime – El tiempo de vida total después del cual el canal es elegible para ser cerrado (resolución: . . . Read more
La aplicación se está ejecutando en free bsd 8.x y es bastante simple internamente utiliza netty-client para realizar llamadas REST utilizando la biblioteca spring boot webclient y el framework spring reactor. Estoy bastante seguro de que desactivé el modo de servidor para la aplicación spring boot. Cuando ejecuto sockstat -l . . . Read more
¿Se puede proporcionar aquí un método de httpclient asincrónico no bloqueante? Después de que se devuelva la respuesta, el solicitante será notificado según el requestID en lugar de bloquear el hilo mientras la entrada/salida de red está esperando. Mono blockingWrapper = Mono.fromCallable(() -> { return /* realizar una llamada síncrona . . . Read more
Estamos utilizando ReactorNettyHttpTracing en nuestra aplicación Spring Web + Spring WebFlux + Spring Cloud Sleuth. El traceId / spanId generado cambia después de la llamada WebClient. Spring Boot v2.6.1 y Spring Cloud v3.1.0 ¿Cómo puedo mantener el mismo traceId y spanId para toda la solicitud de Spring Web? @Bean public . . . Read more