C\#네트워크 파일 을 제한 적 으로 다운로드 하 는 방법 인 스 턴 스
12456 단어 C#속도 제한 다운로드
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using Common.Utils;
using Utils;
namespace
{
public partial class Form1 : Form
{
#region
/// <summary>
///
/// </summary>
private long completedCount = 0;
/// <summary>
///
/// </summary>
private bool isCompleted = true;
/// <summary>
///
/// </summary>
private ConcurrentQueue<MemoryStream> msQueue = new ConcurrentQueue<MemoryStream>();
/// <summary>
///
/// </summary>
private long range = 0;
/// <summary>
///
/// </summary>
private long total = 0;
/// <summary>
/// ,
/// </summary>
private long unitCount = 0;
/// <summary>
/// ,
/// </summary>
private DateTime lastTime = DateTime.MinValue;
/// <summary>
/// ,
/// </summary>
private long unitCountForLimit = 0;
/// <summary>
/// ,
/// </summary>
private DateTime lastTimeForLimit = DateTime.MinValue;
/// <summary>
/// sleep ,
/// </summary>
private int sleepTime = 1;
#endregion
#region Form1
public Form1()
{
InitializeComponent();
}
#endregion
#region Form1_Load
private void Form1_Load(object sender, EventArgs e)
{
lblMsg.Text = string.Empty;
lblByteMsg.Text = string.Empty;
lblSpeed.Text = string.Empty;
}
#endregion
#region Form1_FormClosing
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
}
#endregion
#region btnDownload_Click
private void btnDownload_Click(object sender, EventArgs e)
{
isCompleted = false;
btnDownload.Enabled = false;
string url = txtUrl.Text.Trim();
string filePath = CreateFilePath(url);
#region
Thread thread = new Thread(new ThreadStart(() =>
{
int tryTimes = 0;
while (!HttpDownloadFile(url, filePath))
{
Thread.Sleep(10000);
tryTimes++;
LogUtil.Log(" , " + tryTimes.ToString() + " ");
this.Invoke(new InvokeDelegate(() =>
{
lblMsg.Text = " , " + tryTimes.ToString() + " ";
}));
HttpDownloadFile(url, filePath);
}
}));
thread.IsBackground = true;
thread.Start();
#endregion
#region
thread = new Thread(new ThreadStart(() =>
{
while (!isCompleted)
{
MemoryStream ms;
if (msQueue.TryDequeue(out ms))
{
using (FileStream fs = new FileStream(filePath, FileMode.Open, FileAccess.Write))
{
fs.Seek(completedCount, SeekOrigin.Begin);
fs.Write(ms.ToArray(), 0, (int)ms.Length);
fs.Close();
}
completedCount += ms.Length;
}
if (total != 0 && total == completedCount)
{
Thread.Sleep(100);
isCompleted = true;
}
Thread.Sleep(1);
}
}));
thread.IsBackground = true;
thread.Start();
#endregion
#region /
thread = new Thread(new ThreadStart(() =>
{
while (!isCompleted)
{
Thread.Sleep(1000);
if (lastTime != DateTime.MinValue)
{
double sec = DateTime.Now.Subtract(lastTime).TotalSeconds;
double speed = unitCount / sec / 1024;
try
{
#region
if (speed < 1024)
{
this.Invoke(new InvokeDelegate(() =>
{
lblSpeed.Text = string.Format("{0}KB/S", speed.ToString("0.00"));
}));
}
else
{
this.Invoke(new InvokeDelegate(() =>
{
lblSpeed.Text = string.Format("{0}MB/S", (speed / 1024).ToString("0.00"));
}));
}
#endregion
#region
this.Invoke(new InvokeDelegate(() =>
{
string strTotal = (total / 1024 / 1024).ToString("0.00") + "MB";
if (total < 1024 * 1024)
{
strTotal = (total / 1024).ToString("0.00") + "KB";
}
string completed = (completedCount / 1024 / 1024).ToString("0.00") + "MB";
if (completedCount < 1024 * 1024)
{
completed = (completedCount / 1024).ToString("0.00") + "KB";
}
lblMsg.Text = string.Format(" :{0}/{1}", completed, strTotal);
lblByteMsg.Text = string.Format(" :{0}\r
:{1}", completedCount, total);
if (completedCount == total)
{
MessageBox.Show(" ");
}
}));
#endregion
}
catch { }
lastTime = DateTime.Now;
unitCount = 0;
}
}
}));
thread.IsBackground = true;
thread.Start();
#endregion
#region
thread = new Thread(new ThreadStart(() =>
{
while (!isCompleted)
{
Thread.Sleep(100);
if (lastTimeForLimit != DateTime.MinValue)
{
double sec = DateTime.Now.Subtract(lastTimeForLimit).TotalSeconds;
double speed = unitCountForLimit / sec / 1024;
try
{
#region /
double limitSpeed = 0;
if (double.TryParse(txtSpeed.Text.Trim(), out limitSpeed))
{
if (speed > limitSpeed && sleepTime < 1000)
{
sleepTime += 1;
}
if (speed < limitSpeed - 10 && sleepTime >= 2)
{
sleepTime -= 1;
}
}
else
{
this.Invoke(new InvokeDelegate(() =>
{
txtSpeed.Text = "100";
}));
}
#endregion
}
catch { }
lastTimeForLimit = DateTime.Now;
unitCountForLimit = 0;
}
}
}));
thread.IsBackground = true;
thread.Start();
#endregion
}
#endregion
#region HttpDownloadFile
/// <summary>
/// Http
/// </summary>
public bool HttpDownloadFile(string url, string filePath)
{
try
{
if (!File.Exists(filePath))
{
using (FileStream fs = new FileStream(filePath, FileMode.Create))
{
fs.Close();
}
}
else
{
FileInfo fileInfo = new FileInfo(filePath);
range = fileInfo.Length;
}
//
HttpWebRequest request = WebRequest.Create(url) as HttpWebRequest;
request.UserAgent = "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)";
request.Proxy = null;
//
HttpWebResponse response = request.GetResponse() as HttpWebResponse;
if (response.ContentLength == range)
{
this.Invoke(new InvokeDelegate(() =>
{
lblMsg.Text = " ";
}));
return true;
}
//
request = WebRequest.Create(url) as HttpWebRequest;
request.UserAgent = "Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 6.0; Trident/4.0)";
request.Proxy = null;
request.AddRange(range);
//
response = request.GetResponse() as HttpWebResponse;
// request.GetResponse() Post
Stream responseStream = response.GetResponseStream();
total = range + response.ContentLength;
completedCount = range;
MemoryStream ms = new MemoryStream();
byte[] bArr = new byte[1024];
lastTime = DateTime.Now;
lastTimeForLimit = DateTime.Now;
int size = responseStream.Read(bArr, 0, (int)bArr.Length);
unitCount += size;
unitCountForLimit += size;
ms.Write(bArr, 0, size);
while (!isCompleted)
{
size = responseStream.Read(bArr, 0, (int)bArr.Length);
unitCount += size;
unitCountForLimit += size;
ms.Write(bArr, 0, size);
if (ms.Length > 102400)
{
msQueue.Enqueue(ms);
ms = new MemoryStream();
}
if (completedCount + ms.Length == total)
{
msQueue.Enqueue(ms);
ms = new MemoryStream();
}
Thread.Sleep(sleepTime);
}
responseStream.Close();
return true;
}
catch (Exception ex)
{
LogUtil.LogError(ex.Message + "\r
" + ex.StackTrace);
return false;
}
}
#endregion
#region URL
private string CreateFilePath(string url)
{
string path = Application.StartupPath + "\\download";
if (!Directory.Exists(path))
{
Directory.CreateDirectory(path);
}
string fileName = Path.GetFileName(url);
if (fileName.IndexOf("?") > 0)
{
return path + "\\" + fileName.Substring(0, fileName.IndexOf("?"));
}
else
{
return path + "\\" + fileName;
}
}
#endregion
} //end Form1
}
테스트 캡 처:이상 이 바로 본 고의 모든 내용 입 니 다.여러분 의 학습 에 도움 이 되 고 저 희 를 많이 응원 해 주 셨 으 면 좋 겠 습 니 다.
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
WebView2를 Visual Studio 2017 Express에서 사용할 수 있을 때까지Evergreen .Net Framework SDK 4.8 VisualStudio2017에서 NuGet을 사용하기 때문에 패키지 관리 방법을 packages.config 대신 PackageReference를 사용해야...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.