Как передать изображение через netty?

Question

[Sinus_314]

Я уже скоро буду готов душу отдать за знание, как передать изобажениее или файл через netty.
Пытался написать свои обработчик - получаются костыли, которые еще и не работают, пытался в объект обернуть и в нем передать - так сервер просто ничего не получает, еще пробовал через SimpleChannelInboundHandler(), но ситуация такая же.

Молю, не дайте мне умереть, памагити

Comments

[Сергей Горностаев]

Для начала стоит определиться с тем, что именно значит "передать".

[Sinus_314]

Сергей Горностаев, отправить с клиента на сервер

[Сергей Горностаев]

Sinus_314, понятнее не стало. Netty в качестве кого выступает? Клиента? Сервера? С обеих сторон Netty? А протокол какой используется для передачи?

[Sinus_314]

Сергей Горностаев, Да, с обеих сторон. Собственно говоря, Ваш код я и пытался преобразовать под изображение: Как передать объект через netty?

[Сергей Горностаев]

Sinus_314, код из того ответа про передачу объекта Java, а файлы, в том числе изображения - это совсем другая история.

Answer 1

[Сергей Горностаев]

Грубый набросок хэндлера серверной части:

public class FileServerHandler extends SimpleChannelInboundHandler<String> {
    @Override
    public void messageReceived(ChannelHandlerContext ctx, String fileName) throws Exception {
        RandomAccessFile file = new RandomAccessFile(fileName, "r");
        ctx.write(new DefaultFileRegion(file.getChannel(), 0, file.length()));
    }
}

Comments

[Sinus_314]

Мне кажется здесь что-то неверно: во-первых, метода messageReceived, мы не можем его переписать, во-вторых, я не понимаю, почему мы в генерик кидаем строку(extends SimpleChannelInboundHandler<String>)

Попробовал собрать на основе этого кода простейший организм, но проблема таже - сервер просто ничего не получает. Вероятно у меня стоят неверные декодеры и энкодеры

SimpleServer.java

public class SimpleServer {
    public static void main(String[] args) throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            new ServerBootstrap().group(group)
                    .channel(NioServerSocketChannel.class)
                    .childHandler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel socketChannel) {
                            ChannelPipeline pipeline = socketChannel.pipeline();
                            pipeline.addLast(new ObjectEncoder());
                            pipeline.addLast(new ObjectDecoder(ClassResolvers.cacheDisabled(null)));
                            pipeline.addLast(new SimpleChannelInboundHandler<RandomAccessFile>() {
                                @Override
                                protected void channelRead0(ChannelHandlerContext channelHandlerContext, RandomAccessFile randomAccessFile) throws Exception {
                                    System.out.println("GOD DAMN, I GOT IT");
                                }
                            });
                        }
                    })
                    .bind("localhost", 8080)
                    .sync()
                    .channel()
                    .closeFuture()
                    .syncUninterruptibly();

        } finally {
            group.shutdownGracefully();
        }
    }
}

Client.java

public class Client {
    public static void main(String[] args) throws Exception {
        EventLoopGroup group = new NioEventLoopGroup();
        try {
            new Bootstrap().group(group)
                    .channel(NioSocketChannel.class)
                    .handler(new ChannelInitializer<SocketChannel>() {
                        @Override
                        public void initChannel(SocketChannel socketChannel) {
                            ChannelPipeline pipeline = socketChannel.pipeline();
                            pipeline.addLast(new ObjectEncoder());
                            pipeline.addLast(new ObjectDecoder(ClassResolvers.cacheDisabled(null)));
                            pipeline.addLast(new SimpleChannelInboundHandler<RandomAccessFile>() {
                                @Override
                                public void channelActive(ChannelHandlerContext ctx) throws Exception {
                                    RandomAccessFile file = new RandomAccessFile("C:/Users/Панк/Desktop/screen.png", "r");
                                    ctx.write(new DefaultFileRegion(file.getChannel(), 0, file.length()));
                                    System.out.println("here active");

                                }
                                @Override
                                protected void channelRead0(ChannelHandlerContext channelHandlerContext, RandomAccessFile randomAccessFile) throws Exception {
                                    System.out.println("client got message");
                                }

                            });
                        }
                    })
                    .connect("localhost", 8080)
                    .sync()
                    .channel()
                    .closeFuture()
                    .sync();

        } finally {
            group.shutdownGracefully();
        }
    }
}

[Сергей Горностаев]

Sinus_314,

во-первых, метода messageReceived, мы не можем его переписать

В вашей версии Netty это будет channelRead0

во-вторых, я не понимаю, почему мы в генерик кидаем строку

Потому что в моём наброске сервер принимает имя файла, который нужно отдать клиенту. Если ваш замысел иной, можете передавать что-нибудь другое.

Вероятно у меня стоят неверные декодеры и энкодеры

Ещё раз: объектные кодеки тут не при чём. Они используют только тогда, когда вам нужно сериализовать java-объект.

[Sinus_314]

Сергей Горностаев, Окей, клиент отправляет серверу название файла, а сервер в ответ кидает клиенту сам файл - схема рабочая, пуская так. Тогда на клиенте будет, получается

pipeline.addLast(new SimpleChannelInboundHandler<DefaultFileRegion>() {
                                @Override
                                protected void channelRead0(ChannelHandlerContext channelHandlerContext, DefaultFileRegion defaultFileRegion ) throws Exception {
                                    System.out.println("GOD DAMN, I GOT A FILE");
                                }
                            });

Какие же здесь тогда использовать кодеки? Нет ведь DefaultFileRegionDecoder, а без них работать ничего не будет

[Сергей Горностаев]

Sinus_314, нет, клиенту прилетят просто байты, так что кодеки для преобзрадования ByteBuf во что-то другое не нужны.