GitHub/netch
1
0
Fork 0
mirror of https://github.com/netchx/netch.git synced 2026-05-09 22:54:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

重写WebUtil

Browse Source
This commit is contained in:
ChsBuffer
2020-08-12 22:43:24 +08:00
parent 1f520b2f8f
commit c490e9f802
2 changed files with 28 additions and 53 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Netch/Controllers/UpdateChecker.cs
View File

@@ -25,14 +25,14 @@ namespace Netch.Controllers
public event EventHandler NewVersionFoundFailed;
public event EventHandler NewVersionNotFound;
public void Check(bool isPreRelease)
public async void Check(bool isPreRelease)
{
try
{
var updater = new GitHubRelease(Owner, Repo);
var url = updater.AllReleaseUrl;
var json = WebUtil.DownloadString(WebUtil.CreateRequest(url));
var json = await WebUtil.DownloadStringAsync(WebUtil.CreateRequest(url));
var releases = JsonConvert.DeserializeObject<List<Release>>(json);
var latestRelease = VersionUtil.GetLatestRelease(releases, isPreRelease);

77
Netch/Utils/WebUtil.cs
View File

@@ -26,76 +26,51 @@ namespace Netch.Utils
return req;
}
/// <summary>
/// 异步下载
/// </summary>
/// <param name="req"></param>
/// <returns></returns>
/// <exception cref="WebException"></exception>
public static async Task<string> DownloadStringAsync(HttpWebRequest req)
public static async Task<byte[]> DownloadBytesAsync(HttpWebRequest req)
{
string content;
var response = (HttpWebResponse) await req.GetResponseAsync();
using (var responseStream = response.GetResponseStream())
{
using (var sr = new StreamReader(responseStream, Encoding.GetEncoding("utf-8")))
{
content = await sr.ReadToEndAsync();
}
}
using var webResponse = (HttpWebResponse) await req.GetResponseAsync();
using var memoryStream = new MemoryStream();
using var input = webResponse.GetResponseStream();
response.Close();
return content;
await input.CopyToAsync(memoryStream);
return memoryStream.ToArray();
}
/// <summary>
/// 异步下载并编码为字符串
/// </summary>
/// <param name="req"></param>
/// <param name="encoding">编码，默认UTF-8</param>
/// <returns></returns>
/// <exception cref="WebException"></exception>
public static async Task<List<byte>> DownloadBytesAsync(HttpWebRequest req)
public static async Task<string> DownloadStringAsync(HttpWebRequest req, string encoding = "UTF-8")
{
var content = new List<byte>();
var buffer = new byte[1024];
var response = (HttpWebResponse) await req.GetResponseAsync();
using (var responseStream = response.GetResponseStream())
{
await responseStream.ReadAsync(buffer, 0, buffer.Length);
content.AddRange(buffer);
}
using var webResponse = await req.GetResponseAsync();
using var responseStream = webResponse.GetResponseStream();
using var streamReader = new StreamReader(responseStream, Encoding.GetEncoding(encoding));
response.Close();
return content;
}
/// <param name="req"></param>
/// <returns></returns>
/// <exception cref="WebException"></exception>
public static string DownloadString(HttpWebRequest req)
{
string content;
var response = (HttpWebResponse) req.GetResponse();
using (var responseStream = response.GetResponseStream())
{
using (var sr = new StreamReader(responseStream, Encoding.GetEncoding("utf-8")))
{
content = sr.ReadToEnd();
}
}
response.Close();
return content;
return await streamReader.ReadToEndAsync();
}
/// <summary>
/// 异步下载到文件
/// </summary>
/// <param name="req"></param>
/// <param name="fileFullPath"></param>
/// <exception cref="WebException"></exception>
/// <returns></returns>
public static async Task DownloadFileAsync(HttpWebRequest req, string fileFullPath)
{
using var webResponse = (HttpWebResponse) await req.GetResponseAsync();
var fileStream = File.OpenWrite(fileFullPath);
using (var input = webResponse.GetResponseStream())
{
await input.CopyToAsync(fileStream);
}
using var input = webResponse.GetResponseStream();
using var fileStream = File.OpenWrite(fileFullPath);
await input.CopyToAsync(fileStream);
fileStream.Flush();
fileStream.Close();
}
}
}