Обслуживание файла с помощью Netty - ответ усекается на один байт - PullRequest
Новая
       10

Обслуживание файла с помощью Netty - ответ усекается на один байт

0 голосов
/ 12 января 2012

Я отправляю файлы из ресурсов Android через сервер Netty (изображения, html). Текстовые файлы, такие как html, сохраняются как .mp3, чтобы отключить сжатие (мне нужен InputStream!)

Мой конвейер выглядит так: 

    pipeline.addLast("decoder", new HttpRequestDecoder());
    pipeline.addLast("aggregator", new HttpChunkAggregator(65536));
    pipeline.addLast("encoder", new HttpResponseEncoder());
    pipeline.addLast("chunkedWriter", new ChunkedWriteHandler());

    pipeline.addLast("handler", new AssetsServerHandler(context));

Мой обработчик: 

public class AssetsServerHandler extends SimpleChannelUpstreamHandler {

    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) {

        // some checks

        final FileInputStream is;
        final AssetFileDescriptor afd;
        try {
            afd = assetManager.openFd(path);
            is = afd.createInputStream();   
        } catch(IOException exc) {
            sendError(ctx, NOT_FOUND);
            return;
        }

        final long fileLength = afd.getLength();

        HttpResponse response = new DefaultHttpResponse(HTTP_1_1, OK);
        setContentLength(response, fileLength);

        final Channel ch = e.getChannel();
        final ChannelFuture future;
        ch.write(response);
        future = ch.write(new ChunkedStream(is));
        future.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture future) throws Exception {
                future.getChannel().close();
            }
        });
        if (!isKeepAlive(request)) {
            future.addListener(ChannelFutureListener.CLOSE);
        }
    }
    // other stuff
}

С этим обработчиком мои урезанные данные урезаны как минимум на один байт. Если я изменю ChunkedStream на ChunkedNioFile (и, следовательно, использую is.getChannel() вместо is в качестве конструктора) - все работает отлично.

Пожалуйста, помогите мне понять, что не так с ChunkedStream.

1 Ответ

1 голос
/ 12 января 2012

Ваш код выглядит мне правильно. Содержит ли возвращенный FileInputStream AssetFileDescriptor «все байты»? Вы можете проверить это с помощью модульного теста. Если в нем нет ошибок, то это ошибка в netty. Я интенсивно использую ChunkInputStream, и у меня никогда не было такой проблемы, но, возможно, она действительно зависит от природы InputStream.

Было бы неплохо, если бы вы могли написать тестовый пример и открыть вопрос на github netty.

...