Проблема передачи файла Java ICAP, файл поврежден - PullRequest
Новая
       54

Проблема передачи файла Java ICAP, файл поврежден

0 голосов
/ 19 октября 2018

Я работаю с проектом github ICAP, расположенным здесь , который основан на кодеках JBoss Netty.Моя текущая проблема, которая, вероятно, связана с моей неспособностью правильно понимать обработчики netty и Httpchunks, а также с недостатком навыков программирования, заключается в том, что я не знаю, как успешно записать данные, возвращенные в файл.По сути, мой код до сих пор может выдвигать содержимое в файл, но файл всегда поврежден, независимо от того, пропущены ли у меня данные, неправильно они выполняются или неправильно составлены, я не совсем уверен.Код ниже.Любые предложения или помощь, которую я хотел бы.Заранее спасибо. 

package ch.mimo.netty.example.icap.preview;

import org.jboss.netty.channel.ChannelHandlerContext;
import org.jboss.netty.channel.MessageEvent;
import org.jboss.netty.channel.SimpleChannelUpstreamHandler;

import ch.mimo.netty.handler.codec.icap.DefaultIcapResponse;
import ch.mimo.netty.handler.codec.icap.IcapChunk;
import ch.mimo.netty.handler.codec.icap.IcapChunkTrailer;
import ch.mimo.netty.handler.codec.icap.IcapRequest;
import ch.mimo.netty.handler.codec.icap.IcapResponse;
import ch.mimo.netty.handler.codec.icap.IcapResponseStatus;
import ch.mimo.netty.handler.codec.icap.IcapVersion;

public class IcapServerHandler extends SimpleChannelUpstreamHandler {

    private boolean continueWasSent;

    @Override
    public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
        Object msg = e.getMessage();
        if(msg instanceof IcapRequest) {
            IcapRequest request = (IcapRequest)e.getMessage();
            System.out.println(request.toString());
        } else if(msg instanceof IcapChunkTrailer) {
            System.out.println(msg.toString());
            if(!continueWasSent) {
                continueWasSent = true;
                // sending 100 continue in order to receive the rest of the message
                IcapResponse response = new DefaultIcapResponse(IcapVersion.ICAP_1_0,IcapResponseStatus.CONTINUE);
                ctx.getChannel().write(response);
            } else {
                // sending 204 No Content response
                IcapResponse response = new DefaultIcapResponse(IcapVersion.ICAP_1_0,IcapResponseStatus.NO_CONTENT);
                ctx.getChannel().write(response);
            }
        } else if(msg instanceof IcapChunk) {
            IcapChunk request3 = (IcapChunk)e.getMessage();
           System.out.println(request3.getContent().toString(Charset.defaultCharset()));
            testfile = "C:\\Users\\dan\\Desktop\\iso\\netty\\" + output;
            buffer = request3.getContent();
            ByteBuffer nioBuffer = buffer.toByteBuffer();
            FileOutputStream fos = new FileOutputStream(testfile);
            FileChannel channel = fos.getChannel();
            while (nioBuffer.hasRemaining()) {
                channel.write(nioBuffer);
            }
            fos.flush();
            fos.close();
            System.out.println(msg);
        } 
    }

}

Кроме того, я должен сказать, что для небольших текстовых файлов я могу успешно восстановить файл локально.Однако, скажем, с большими файлами .docx, когда я пытаюсь создать файл, я не получаю полный размер, и файл поврежден.На данный момент я действительно не уверен, что попробовать дальше.

...