如何在c#服务器和Java客户端之间恢复中断的下载

Question

我有一个用Java运行的客户端应用程序，它向c#中的web服务发送HTTP REST命令。

客户端从服务器下载文件，它工作得很好。

下面是我的文件传输代码:

Java客户机

public void downloadFile(String fileUrl, String fileName, String filePath) throws IOException{
        int bytesRead;
        URL url = new URL(fileUrl);
        BufferedInputStream bis = new BufferedInputStream(conn.getInputStream());
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filePath));
        byte[] fileBuffer = new byte[1024];
        while ((bytesRead = bis.read(fileBuffer)) != -1) {
            bos.write(fileBuffer, 0, bytesRead);
        }
        bos.close();
        bis.close();
    }

c# web service

        [WebGet(UriTemplate = "SendFile/{clientID}/{fileName}")]
        public Stream sendFile(String clientID, String fileName)
        {
            WebOperationContext.Current.OutgoingResponse.Headers.Add(HttpResponseHeader.Expires, DateTime.UtcNow.ToString("ddd, dd MMM yyyy HH:mm:ss 'GMT'"));
            WebOperationContext.Current.OutgoingResponse.ContentType = "application/pdf";
            Stream ms = File.OpenRead(@jobRepPath + fileName.Replace("___", "."));
            return ms;
        }

现在，基于此，我想设置一些方法来恢复损坏的下载。

我试过这个代码:

Java客户机

public void resumeBrokenDownload(String fileUrl, String fileName, String filePath, long fileLength) throws IOException{
        int bytesRead;
        URL url = new URL(fileUrl);
        BufferedInputStream bis = new BufferedInputStream(conn.getInputStream());
        BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(filePath, true));
        byte[] fileBuffer = new byte[1024];     
        while ((bytesRead = bis.read(fileBuffer)) != -1) {
            bos.write(fileBuffer, 0, bytesRead);
        }
        bos.close();
        bis.close();
    }

c# web service

        [WebGet(UriTemplate = "ResumeDownload/{clientID}/{fileName}/{startByte}")]
        public Stream resumeDownload(String clientID, String fileName, String startByte)
        {
            Stream ms = File.OpenRead(@jobRepPath + fileName.Replace("___", "."));
            var memoryStream = new MemoryStream();
            ms.CopyTo(memoryStream);
            Byte[] byteFile = memoryStream.ToArray();
            MemoryStream stream = new MemoryStream();
            stream.Write(byteFile, Convert.ToInt32(startByte), byteFile.Length);
            WebOperationContext.Current.OutgoingResponse.Headers.Add(HttpResponseHeader.Expires, DateTime.UtcNow.ToString("ddd, dd MMM yyyy HH:mm:ss 'GMT'"));
            WebOperationContext.Current.OutgoingResponse.ContentType = "application/pdf";
            return stream;
        }

在REST URL中传递的startByte值是客户端已经接收到的文件部分的长度。

但是这似乎根本不起作用，我从服务器收到一个空流。

有没有人知道如何让这段代码工作，或者有更好的方法?

Answer 1

我最终采用本教程中的示例解决了我的问题。

对于那些对我的解决方案感兴趣的人，我修改了c# web服务的代码:

        [WebGet(UriTemplate = "ResumeDownload/{clientID}/{fileName}/{startByte}")]
        public Stream resumeDownload(String clientID, String fileName, String startByte)
        {
            MemoryStream responseStream = new MemoryStream();
            Stream fileStream = File.Open(@jobRepPath + fileName.Replace("___", "."), FileMode.Open);
            fileStream.Seek(Convert.ToInt32(startByte), SeekOrigin.Begin);
            int length = (int)(fileStream.Length - Convert.ToInt32(startByte));
            byte[] buffer = new byte[length];
            fileStream.Read(buffer, 0, length);
            responseStream.Write(buffer, 0, length);
            fileStream.Close();
            responseStream.Position = 0;
            return responseStream; 
        }