如何在c#服务器和Java客户端之间恢复中断的下载
本文关键字:恢复 之间 中断 下载 客户端 Java 服务器 | 更新日期: 2023-09-27 18:06:25
我有一个用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值是客户端已经接收到的文件部分的长度。
但是这似乎根本不起作用,我从服务器收到一个空流。
有没有人知道如何让这段代码工作,或者有更好的方法?
我最终采用本教程中的示例解决了我的问题。
对于那些对我的解决方案感兴趣的人,我修改了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;
}