What I want to do is in essence what How to use MDC with thread pools? is asking, but with Netty. I want MDC information associated per Channel. What options are there for Netty? If I need to rese...

I have created a game server using netty 3.5.8. At first, there is not any problem with sending data from server to client. But when server operates for a while, there are many exceptions [java.nio...

What is the main difference between Jetty and Netty? Netty is part of Jboss, but is it the default web server container? Does Netty support Servlets 3.0?

ERROR GServerHandler - java.io.IOException: Connection reset by peer java.io.IOException: Connection reset by peer at sun.nio.ch.FileDispatcher.read0(Native Method) at sun.nio.ch.SocketDispatcher...

What version of gRPC are you using? 1.13.1 I am using java 8 to build an executable jar. Below is the java version: $ /usr/lib/jvm/java-1.8.0-openjdk-amd64/jre/bin/java -version openjdk version ...

I want to write a netty based client. It should have method public String send(String msg); which should return response from the server or some future - doesen't matter. Also it should be multithr...

I have a netty server running the atmosphere framework for a real-time notification system over websockets. The system works perfectly on my local machine, but when I deploy it on EC2, It just doe...

I'd like to create an SSL/TLS connection using the Netty framework which will send a SNI header together during handshake. My current code looks like this: SslContext creation: TrustManagerFacto...

When I upgraded the Java from 8 to 11, I got an error from Netty about the "jdk.internal.misc.Unsafe", the details are below: I knew it is a debug level message, and I can change the level of the ...

I have together 6 containers running in docker swarm. Kafka+Zookeeper, MongoDB, A, B, C and Interface. Interface is the main access point from public - only this container publish the port - 5683. ...

I have a desktop app made in Java/Kotlin with Firebase (specifically Firestore realtime) connection. It works properly in my notebook (Windows via Parallels) and in some others Windows tested. But...

I'm using Gradle shadow jar plugin to produce a fat jar for selenium. The following code is declared in Gradle kts: dependencies { val seleniumV = "4.1.4" val phantomJSV = "1.5.0&...

How to get a byte array from ByteBuf efficiently in the code below? I need to get the array and then serialize it. package testingNetty; import io.netty.buffer.ByteBuf; import io.netty.channel.Cha...

I am running a batch job in AWS which consumes messages from a SQS queue and writes them to a Kafka topic using akka. I've created a Sqs Async Client with the following parameters: private static S...

I am currently developing using spring boot webflux. I am using websocket clients and APIs clients, but this error occurs a few hours after deployment. I couldn't figure out where this error was co...

Its new topic for me. I'm able to connect as plaintext. public ManagedChannel getChannel(String serviceName){ TSServiceClientManager scm = TSServiceManagementFactory.getInstance().getServiceClien...

Is there a way to convert a netty ByteBuf to a String and vice versa? public String toString(ByteBuf b){ //return b enconded to a String } public Bytebuf ToByteBuff(String s){ //return s deco...

Hi i'm trying to understand why so memory consumption in my app so i have downloaded a heapdump with visualjvm and then have analysed it with eclipse mat. It have found the following problem: One ...

I have an existing micro-service in production which has a restful endpoint. For new customers, as well as well from a long term objective, we would like to support grpc. I would like to understand...

I'm using Web-flux/Reactive and Webclient, running it on Tomcat and spring-boot. Everything works fine. I read a lot about it. The problem seems to be that whenever you use Webclient, you have to r...

As far as I know netty handle exceptions by override method exceptionCaught(). But what I want is a Handler that can handler all exceptions in or out. So, the pipeline should be like : InboundExce...

I am in the middle of learning Netty an started some tutorials using spring boot. My goal is to create an application which set up a tcp port for receiving messages and to present them over a rest ...

I'm really confused about the number of threads for a boss group. I can't figure out a scenario where we need more than one boss thread. In do we need more than a single thread for boss group? the ...

I was looking for a way to avoid StacklessClosedChannelException, but I didn't find anything. I suppose it's not safe and it shouldn't happen, how to avoid it?

My GRPC service is only accessible to applications on the local machine. I assume it would perform faster if the clients would connect over Unix domain socket, rather then localhost:port I'm tyri...