Questions tagged [reactor-netty]

Reactor over the Netty client server framework

Filter by
Sorted by
Tagged with
-1 votes
1 answer
50 views

How to fix CVE-2023-34062: Path Traversal HTTP functionality for the Reactor Netty library 1.1.12 on spring webflux

I am running a spring boot application on spring webflux. Works well but I'd want to update the Reactor Netty HTTP Server to fix this issue https://spring.io/security/cve-2023-34062 I am trying to ...
James's user avatar
  • 103
0 votes
1 answer
30 views

Unable to access H2 console in spring-boot in reactive mode with Netty server

I am building a new Spring boot application with h2 db in WebFlux stack along with Netflix DGS. I want to access h2 DB console. I have used following configuration but I am not able to access my H2 DB ...
springbootlearner's user avatar
0 votes
0 answers
19 views

Could not use javax.servlet.http.HttpServletRequest after excluding tomcat from spring boot web

My web service is implementing webclient from springboot webflux. In the meantime, it is also using javax.servlet.http.HttpServletRequestin some functions (see below). @GetMapping("/app-info&...
Zoey Long's user avatar
0 votes
0 answers
12 views

How to skip some specified Handler in netty or the correct handler usage with reactor-netty?

Summary I am new to netty and plan to demonstrate a rtsp online desktop share application for practise . now i get puzzled that when i request the desktop share frame via rtsp , it should be decode ...
Peng's user avatar
  • 752
-2 votes
0 answers
15 views

Is there some best practice that could bind some metadata to connection channel in reactor netty?

Scenario i wanna build a desktop share application via reactor netty and different client should send a meeting room key for that when anyone share its desktop frame data ,server could accorging ...
Peng's user avatar
  • 752
0 votes
0 answers
33 views

Spring cloud gateway intermittent delay at proxy request and response handling with reactor netty

I am using Spring Cloud Gateway, observing intermittent delay while sending request or receiving response from the downstream applications. The notable delay occurs in about 15% of the requests (more ...
Mukesh's user avatar
  • 1
0 votes
0 answers
13 views

Netty Reactive Web Server Connections Stuck in CLOSE_WAIT

We have a Spring Boot REST application that takes requests from various sources. The web server is Netty Reactor. There are not a lot of clients, usually only two. The application uses Swagger UI for ...
SteveB's user avatar
  • 503
0 votes
0 answers
34 views

Reactor Netty log entire request at once using httpClient

So the query is I have a webclient call to be made. Under the hood, I have configured something like this for logging the request and response using httpClient's wiretap method. But I believe this ...
Deekshith Anand's user avatar
0 votes
0 answers
12 views

Spring WebClient annotated connectexception" connection refused " and going indefinatatly in the logs

please help us on this issue we have two services a, b a is trying to call b service when is down and now a continuously logging error indefinitely.it should not do it should only log once, its keep ...
reddy krishna's user avatar
0 votes
0 answers
30 views

Getting [io.netty.handler.ssl.SslClosedEngineException: SSLEngine closed already] for HTTP/2.0 with TLS on netty

I am getting below error for almost 1% of my total requests under high load e.g. 1k-2k/s requests. ERROR org.springframework.web.server.adapter.HttpWebHandlerAdapter - [9899f030-1528794] Error [io....
Suhas Khot's user avatar
1 vote
0 answers
82 views

Spring reactive webclient doesn't throw ReadTimeoutException at the configured time

In our service we are using Spring Boot 2.7.16 with Kotlin. In our http calls we are using the reactive webclient wrapped with coroutines (async await). The webclient configuration for all client are ...
karacalio's user avatar
0 votes
0 answers
44 views

Unable to send Flux messages to the mock ReactorNettyWebSocketClient

In my Java Spring boot application, I am using reactive libraries to connect and stream from a websocket. I have the following dependencies in my pom.xml file <dependency> &...
Chaitanya's user avatar
  • 3,598
0 votes
0 answers
239 views

io.netty.handler.ssl.StacklessSSLHandshakeException: Connection closed while SSL/TLS handshake was in progress

The idea is to create a WebClient bean with OAuth2 filter, which using bearer token, when running certain request to the file upload service. The issue is, that locally everything works with same ...
yungbroccoli's user avatar
0 votes
0 answers
42 views

Reactor Netty custom access log, missing connected user details

In a Spring Cloud Gateway application, I'm trying to understand how I can add the connected user in my access log. The user property in AccessLogArgProvider is always at the default value (-). I'm ...
Flanfl's user avatar
  • 514
0 votes
0 answers
22 views

Netty client sends TCP RST

I see strange behaviour in Netty HTTP Client. It establishes connection to server fine, has some traffic but then sends RST out of blue. What could cause such behaviour? 22:20:03.954242 IP 10.15.12....
yurybubnov's user avatar
0 votes
0 answers
99 views

Reactor Netty HTTP client opens new connection in Pool mode

Set up: Java 17 Spring Cloud Gateway 4.0.7 Netty client propetrties spring.cloud.gateway.httpclient.connect-timeout=3000 spring.cloud.gateway.httpclient.pool.type=fixed spring.cloud.gateway.httpclient....
yurybubnov's user avatar
0 votes
1 answer
52 views

How do you to detect a drop in connection from the client with Spring Webflux and Reactor Netty?

I'm dealing with an issue where I'm not able to surface any kind of error exception my server is disconnected from my client. I want my code to be able to detect that the client no longer has a ...
Farhan Islam's user avatar
0 votes
1 answer
51 views

Handle slow producer with Project Reactor/WebFlux to avoid overloading it

Backpressure is a mechanism that allows the consumer to slow down the producer when it cannot keep up with the producer rates. Can we do it in the opposite way? This is the scenario: There is an high ...
SGiux's user avatar
  • 658
0 votes
0 answers
17 views

WebClient issue with JAVA_OPTS

I encountered an issue where I couldn't retrieve proxy settings provided via JAVA_OPTS for my WebClient running in PCF, currently I must add the configuration programmatically. However, the ...
Micheal Jackson's user avatar
0 votes
0 answers
152 views

Pubsub messages are getting dropped before reaching to our internal microservices

We are using google cloud pub sub pull mechanism, from past couple of days we are seeing the below error in our service logs- io.grpc.StatusRuntimeException: RESOURCE_EXHAUSTED: Abrupt GOAWAY closed ...
Thanos's user avatar
  • 1
0 votes
0 answers
40 views

how to close close_wait Statuc connections in netty spring cloud gateway

We are sping cloud gateway with netty on VSI servers. when we run the below linux command on lunux box ,it is showing large number of connections with status as CLOSE-WAIT **please find the following ...
user2777452's user avatar
0 votes
1 answer
38 views

spring 3 webClient mock server

i'am using a service that wraps a webClient of spring and I want to test it , mock a server and set http call expectations and mock responses . i have the following code : this service that behind the ...
Ares's user avatar
  • 91
0 votes
0 answers
81 views

Reactor Netty HttpClient connect timeout is not working on Linux

I have been debugging connection timeout issues we have been having. I created a unit test and then noticed that when running on my Macbook (M1), the connect timeout works as expected. But when ...
athom's user avatar
  • 1,458
0 votes
1 answer
92 views

How can we implement client-side load balancing with reactive netty?

My microservice is required to direct requests between 2 different servers via TCP connection. Using the current TCPClient, we are required to provide the host & port numbers which means that I ...
roroWorld's user avatar
0 votes
0 answers
17 views

Is there a way to pad incoming ByteBuf?

I'm doing Base64 decoding, so I'm reading the input in 4 byte chunks. To make this work, I've added DelimiterBasedFrameDecoder as mentioned in the documentation of Base64Decoder. I'm concerned what ...
Aaron Digulla's user avatar
0 votes
1 answer
228 views

Need Netty server properties for Spring Boot and Spring Webflux

We have migrated Zuul gateway application to spring cloud gateway. Spring cloud gateway is running on reactive Netty server. We want to replace below tomcat properties with Netty server properties. ...
user2777452's user avatar
0 votes
0 answers
168 views

Log HTTP request/response in Netty

I'm trying to produce logging for Netty Reactor and finding it very hard to get what I want. The wiretap functionality has much of the information that I need, but the content is messy and spread ...
Steve's user avatar
  • 702
0 votes
1 answer
146 views

Spring cloud sleuth with spring cloud gateway

I'm using spring cloud sleuth with spring cloud gateway (webflux based) I would like to only "log" TraceId and SpanId without propagating in http request Given this scenario : client --> ...
obe6's user avatar
  • 1,773
0 votes
0 answers
50 views

How to close the connection to return a Mono<byte[]> while using Reactive Netty connect() without blocking?

I am creating an application that receives http requests and requires to connect with a tcp server to get the response. At the rest controller, I am returning a Mono<byte[]>. In the service ...
roroWorld's user avatar
1 vote
1 answer
227 views

Reactive Mono not propagating Custom Exception

In our service calling function getXXResponse where XX is API partner returning Mono. Just in case of success and mono.error in case of error. Below is a snippet from code: void abc() throws ...
Nalini Wanjale's user avatar
0 votes
0 answers
54 views

Reactor-netty is reserving file descriptors for the whole pool (eventfd, timerfd, eventpoll)

I have a problem with increased number of file descriptors after moving to WebClient that uses netty-reactor, httpclient and epoll on Unix. From what I've found, Netty is creating a pool of threads to ...
Przemysław Bezat's user avatar
0 votes
0 answers
268 views

Reactor netty http server metrics and connection limit

For reactor netty http server not able to figure-out couple of info : How to get max number of http server connection by default and how to modify them ? [Tried going over this but didn't find proper ...
Arpit's user avatar
  • 458
0 votes
0 answers
378 views

Getting java.lang.NoClassDefFoundError: reactor/util/context/ContextView when using reactor-core and reactor-netty-http:1.0.9

Getting java.lang.NoClassDefFoundError: reactor/util/context/ContextView when using reactor-core 3.4.14 and reactor-netty-http:1.0.9 one the last line of code below. The version weems to be compatible ...
fernando-ta's user avatar
0 votes
0 answers
76 views

Spring Reactive Client Websocket - ReactorNettyWebSocketClient reconnect & close codes

I am trying to use Spring Webflux Websockets - ReactorNettyWebSocketClient to be exact to connect my service to other service. I have done the implementation but I am seeing several things that I cant ...
alext's user avatar
  • 708
0 votes
0 answers
34 views

How to understand Reactive encoding and decoding

Reactor also supports non-blocking inter-process communication with the reactor-netty project. Suited for Microservices Architecture, Reactor Netty offers backpressure-ready network engines for HTTP (...
coolxp's user avatar
  • 3
2 votes
1 answer
1k views

After upgrading spring boot to 3.0.6, getting Failed to resolve for the oauth endpoints from Webclient in Mac M1

After upgrading to spring boot 3.0.6, replacing the usages of RestTemplate to WebClient, starting to see : org.springframework.web.reactive.function.client.WebClientRequestException: Failed to resolve ...
Anthony Vinay's user avatar
0 votes
1 answer
684 views

Validation query for R2DBC remains Idle when connection pool created using io.r2dbc.pool.ConnectionPoolConfiguration

I have a spring webflux application integrated with AWS Aurora Postgres. spring-boot-starter-webflux:2.6.6 spring-boot-starter-data-r2dbc:2.6.6 This brings in the below dependencies: io.r2dbc:r2dbc-...
Amol Kshirsagar's user avatar
0 votes
1 answer
105 views

How can I remove auto generated headers from a request before sending it in reactor-netty?

Is it possible to remove all auto generated headers from a request before it is sent in reactor-netty? I have a use case where i need to remove all auto generated headers in my request. In apache ...
Aditya lahiri's user avatar
1 vote
0 answers
138 views

javax.net.ssl|ERROR|83|reactor-http-nio-12|TransportContext.java:363|Fatal (INTERNAL_ERROR): closing inbound before receiving peer's close_notify (

What I am trying to achieve: Send a high volume of http requests to a third party server Issue: Intermittently, I am facing this issue I am having a hard time understanding. Again, this is ...
PatPanda's user avatar
  • 3,860
1 vote
0 answers
194 views

SSLSocketImpl.java:595|SSLSocket duplex close failed. Debug info only. Exception details java.net.SocketException: Socket is closed

In my application which is just a Spring Webflux Webclient, I am trying to send data to a third party server I have no control over, which has SSL enabled. I am using this code to send requests to ...
PatPanda's user avatar
  • 3,860
0 votes
1 answer
340 views

HTTP Proxy Setup does not work if not done at create() time

I am setting up a HttpClient to use a proxy. This works if I do it at the time that the httpClient is created. HttpClient httpClient = HttpClient.create() .proxy(proxy -> proxy....
awhig's user avatar
  • 537
0 votes
0 answers
88 views

How to separate several HttpClient instances metrics in reactor-netty

I have multiple HttpClient instances with different pools, and I would like to see how much direct memory they consume. I have enabled metrics as stated in reference guide, and I do indeed have ...
B.Gen.Jack.O.Neill's user avatar
0 votes
0 answers
212 views

Webclient chunked response status 400 but empty response body

I'm currently running this usecase : calling the same http endpoint x3 times using Spring Weclient with different request body I'm using Spring not reactive, so I use .block() each call is executed ...
Archange's user avatar
  • 407
1 vote
0 answers
195 views

Sleuth TraceId missing in Netty HttpClient WRITE event if same 'reactor-http-nio' thread is used

Lately after Spring Boot 2.7.6 (corresponding netty release), Sleuth TraceId is missing in the WRITE event of our custom LoggingHandler if same reactor-http-nio thread is used. First request using the ...
Rayyan's user avatar
  • 119
1 vote
1 answer
395 views

Reactor Netty - keepalive

I have an application that uses Webflux and I'm trying to enable keepalive on the server. I did the following: @Component public class ServerConfiguration implements WebServerFactoryCustomizer<...
TheSQLGoat's user avatar
1 vote
0 answers
388 views

WebClient maxConnection pool and pendingAcquireMaxCount limit?

Lets imagine I need a netty server(reactive/non blocking), and I need to process at maximum 50 http requests at the same time. But I now that these requests have to use a WebClient(netty reactive http ...
fernando1979's user avatar
  • 1,787
0 votes
1 answer
319 views

Threads reactor-http-nio compute something for a long time and consume CPU and memory

We have a service to which we connect via websocket and receive messages from it. We have updated dependencies for Spring Boot 3.0.6, reactor: 1.1.6, reactor-core 3.5.5 services. After connecting to ...
Roman's user avatar
  • 1
0 votes
0 answers
429 views

Spring Webflux WebClient stops sending requests after blocking timeout error

I have a Spring Boot Project that uses Spring WebFlux WebClient to make Http Requests to another service. public APIResponse getResponse( APIRequest request) { return webClient ...
Saniya's user avatar
  • 59
0 votes
0 answers
113 views

Reactor Netty custom channel handlers are not invoked

I cloned the UDP Tutorial from here, with purpose of creating a simple junit test for: Accept Datagram Packet and decode it into some type (currently is simple string) Then after decode, it will ...
Lynx777's user avatar
  • 332
2 votes
1 answer
67 views

Spring boot HttpClient logging

Can you help me re-write the below snippet as the bootstrap and HttpClient.from(tcp) are deprecated: TcpClient.bootstrap(bootstrap -> BootstrapHandlers.updateLogSupport(bootstrap, new ...
Srini's user avatar
  • 21

1
2 3 4 5
11