Error decoding client data about reactor-netty

[violetagg]

If you want to work only with Netty abstraction then you need some changes:

1. Ensure that you can see the uncompressed data. Change the code

.doOnChannelInit(((connectionObserver, channel, remoteAddress) -> {
    channel.pipeline()
            .addFirst("connect", new ChannelHandler(this.manager));
}))

with moving the handler at the end

.doOnChannelInit(((connectionObserver, channel, remoteAddress) -> {
	Connection.from(channel)
		.addHandlerLast("connect", new ChannelHandler());
}))

2. Work with Netty web socket API. Change the code

public class ChannelHandler extends SimpleChannelInboundHandler<ByteBuf> {

    @Override
    protected void channelRead0(@NotNull ChannelHandlerContext ctx, @NotNull ByteBuf msg) throws Exception {
        System.out.println(msg.toString(StandardCharsets.UTF_8));
        ctx.fireChannelRead(msg.copy());
    }
}

with handler that manipulates web socket frames

public class ChannelHandler extends SimpleChannelInboundHandler<WebSocketFrame> {

    @Override
    protected void channelRead0(@NotNull ChannelHandlerContext ctx, @NotNull WebSocketFrame msg) throws Exception {
        System.out.println(msg.content().toString(StandardCharsets.UTF_8));
        ctx.fireChannelRead(msg.copy());
    }
}

I'm closing this issue as it feels like this is a question that would be better suited to Gitter or Stack Overflow.

[violetagg]

@AdaMorgan Most probably in the logs you are seeing the compressed content. From the provided logs I can see that the client sends Sec-WebSocket-Extensions: permessage-deflate. Please provide a full reproducible example that we can run and see the problem.

[AdaMorgan]

ok, I hope this is enough. Next, I create a connection via Postman. I have attached the result.

public class ChannelHandler extends SimpleChannelInboundHandler<ByteBuf> {

    @Override
    protected void channelRead0(@NotNull ChannelHandlerContext ctx, @NotNull ByteBuf msg) throws Exception {
        System.out.println(msg.toString(StandardCharsets.UTF_8));
        ctx.fireChannelRead(msg.copy());
    }
}

public class Main {
    public static void main (String[] args) {
            public void run() {
        HttpServer.create()
                .host(this.config.getHost())
                .port(this.config.getPort())
                .protocol(HttpProtocol.HTTP11)
                .doOnChannelInit(((connectionObserver, channel, remoteAddress) -> {
                    channel.pipeline()
                            .addFirst("connect", new ChannelHandler(this.manager));
                }))
                .route(routes -> routes.ws("/chat", (in, out) -> {
                    return in.receive()
                            .publishOn(Schedulers.boundedElastic())
                            .flatMap(socket -> {
                                return out.send(Mono.fromCallable(() -> {
                                    return Unpooled.copiedBuffer("Hello client!", StandardCharsets.UTF_8);
                                }));
                            });
                }))
                .bindUntilJavaShutdown(Duration.ofSeconds(30), null);
    }
    }
}

GET /chat HTTP/1.1
Sec-WebSocket-Version: 13
Sec-WebSocket-Key: R/9dk94SqnkDP5aXBFabLQ==
Connection: Upgrade
Upgrade: websocket
Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits
Host: localhost:8080


?E��?�3-?_fy?Qa/?�1G?V}-?[tl?�? ?�3-?�~h?Mrj?�)-?vz!?�wl?���?

[violetagg]

@AdaMorgan You are adding the custom ChannelHandler at the beginning of the pipeline where you are still having a compressed data. Instead of this handler you can change, for example, the code above to this one:

...
					return in.receive()
--> decodes ByteBuf to String			.asString()
--> prints to System.out			.doOnNext(System.out::println)
						.publishOn(Schedulers.boundedElastic())
...

[AdaMorgan]

I just can’t read the data through the ChannelHandler? I know that it would be possible to read the data through the 'WebsocketInbound' class, but I was hoping that I would not have to do it this way, since it increases the size of the project, and reading through the 'SimpleChannelInboundHandler' is much more difficult for me easier

[AdaMorgan]

@violetagg Thank you very much, you helped a lot!