Questions tagged [netty]

An open source asynchronous event-driven network application framework written in Java. It is a NIO client server framework which enables quick and easy development of network applications such as protocol servers and clients

-3
votes
1answer
19 views

Netty ByteBuf receive-size !=send-size

I have a little error wih my netty-server. I need to transfer different byteBuf sizes (the send-buffers capacity is dynamicly increased).byte[] buffer=text.getBytes();byteBuffer.writeInt(...
0
votes
2answers
20 views

PooledUnsafeDirectByteBuf not found in DirectMemory

I am using Netty 4.1.17-Final.I wrote the code to send and receive 100 MB random ASCII. Decoder does not read until ByteBuf becomes 100 MB.@Overridepublic void decode(ByteBuffer _in, List<...
0
votes
0answers
24 views

logging http requests in netty 4

I was building a netty proxy server to query Opentsdb, something like this: https://github.com/AllenDevelop/Netty-proxyIt works just fine. But for debugging purposes, I added a block of code to log ...
0
votes
1answer
34 views

Support for netty-tcnative in Spring Cloud Gateway 2.X

Is it possible to use netty-tcnative to improve SSL/TLS performance with the Spring Cloud gateway 2 starter? I have search documentation and Google without luck.I tested adding the uber jar as ...
0
votes
1answer
14 views

Netty as WebSocket server not starting in SpringBootTest

I'm trying to write a simple WebSocket server app based on on Spring and Netty.My application looks like this@SpringBootApplicationpublic class DemoReactiveWSApp {public static void main(...
0
votes
1answer
30 views

Netty, concurrent writeAndFlush

Lets say we have some kind of pub/sub protocol. When someone is connecting and subscribing, we can save channel in Map, List or ChannelGroup:@Overridepublic void channelActive(ChannelHandlerContext ...
0
votes
1answer
26 views

Netty Memory Leak about MpscAtomicArrayQueue

image: memory leak about MpscAtomicArrayQueueEnv: ElasticSearch 5.5.1I don't know why the object of MpscAtomicArrayQueue use so much memory and make OutOfMemory happened?please help meThanks!
1
vote
1answer
32 views

netty: why write() must get executed in Eventloop thread assigned to the channel?

It's common that the app exchanges data between channels.For example, for proxy server, each inbound connection would be associated with an outbound connection and data exchanged between them. In ...
0
votes
1answer
40 views

Netty HTTP 1.1 Pipelining Support

I need to send multiple async requests to a rest server through the same connection and get them executed in FIFO order, I think HTTP 1.1 pipelining is just perfect for this.I found some related ...
-2
votes
0answers
37 views

HTTP 1.1 pipelining vs HTTP 2 multiplexing

I'm dealing with an application that sends multiple requests to a rest server. Those requests must be executed in the same order I send them (FIFO), but there is no need to read the response of one ...
0
votes
1answer
25 views

netty client reuses serverside bootstrap results in the requests never finished

A Netty server requests to another server as a client for every request it receives. Almost like a proxy, except it does not forward the received message as it is. I tried to use the server ...
0
votes
0answers
13 views

Handling channel inactive/close scenarios gracefully for Netty

In my application, we are using netty 4.0.33.Final versionchannelInactive() is being called due to TCP network connectivity issues.Some connections are observed to be in 'CLOSE_WAIT' stateHow ...
0
votes
0answers
15 views

Will close connection with nginx will close client's connections?

I have some nginx instances backed by HTTP servers built by Netty.In some cases I need to close clients connection, so I close the channel I get.Does this help to close the client connection? It ...
1
vote
0answers
25 views

A error 'io.netty.channel.ChannelException: connection refused' when i use LocalServerChannel/LocalChannel?

server code:public void server() throws InterruptedException {final EchoServerHandler serverHandler=new EchoServerHandler();EventLoopGroup group=new DefaultEventLoop();try {...
7
votes
0answers
112 views
+100

Instrument Netty's EventLoop for deterministic execution of scheduled tasks

I'd like to instrument Netty's EventLoop in order to:Run tasks in a deterministic order.Grab the deadline of scheduled tasks.Fast-forward a virtual clock, triggering execution of deadlined tasks. ...

153050per page
angop.ao, elkhabar.com, noa.al, afghanpaper.com, bbc.com, time.com, cdc.gov, nih.gov, xnxx.com, github.com,