Questions tagged [reactor-netty]
Reactor over the Netty client server framework
512
questions
-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 ...
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 ...
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&...
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 ...
-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 ...
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 ...
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 ...
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 ...
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 ...
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....
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 ...
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>
&...
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 ...
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 ...
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....
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....
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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. ...
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 ...
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 --> ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 ...
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 (...
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 ...
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-...
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 ...
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 ...
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 ...
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....
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 ...
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 ...
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 ...
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<...
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 ...
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 ...
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
...
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 ...
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 ...