想要解压缩从 API 获取的 GZipped 响应。尝试了下面的代码,它总是返回类似:-
\u001f�\b\0\0\0\0\0\0\0�Y]o........
我的代码是:
private string GetResponse(string sData, string sUrl)
{
try
{
string script = null;
try
{
string urlStr = @"" + sUrl + "?param=" + sData;
Uri url = new Uri(urlStr, UriKind.Absolute);
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
request.Method = "GET";
request.AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate;
using (HttpWebResponse response = (HttpWebResponse)request.GetResponse())
using (StreamReader reader = new StreamReader(response.GetResponseStream()))
{
script = reader.ReadToEnd();
}
}
catch (System.Net.Sockets.SocketException)
{
// The remote site is currently down. Try again next time.
}
catch (UriFormatException)
{
// Only valid absolute URLs are accepted
}
return script;
}
catch (Exception ex)
{
throw new Exception(ex.ToString());
}
}
我从许多自动解压的参考资料中找到了上面的代码。但最终,它对我不起作用。为了解压缩压缩的数据,我尝试了下面的功能,
private string DecompressGZIP(string compressedText)
{
byte[] gZipBuffer = Convert.FromBase64String(compressedText);
using (var memoryStream = new MemoryStream())
{
int dataLength = BitConverter.ToInt32(gZipBuffer, 0);
memoryStream.Write(gZipBuffer, 4, gZipBuffer.Length - 4);
var buffer = new byte[dataLength];
memoryStream.Position = 0;
using (var gZipStream = new GZipStream(memoryStream, CompressionMode.Decompress))
{
gZipStream.Read(buffer, 0, buffer.Length);
}
return Encoding.UTF8.GetString(buffer);
}
}
但是,由于以下异常,它在第一行代码本身也失败了:
System.FormatException:'输入不是有效的 Base-64 字符串,因为它包含非 Base 64 字符、两个以上的填充字符或填充字符中的非法字符。 '
由于我是初学者,希望你们指导我......提前致谢......
这是负责解码 gzip 压缩流的重要部分:
var clientHandler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate };
var client = new HttpClient(clientHandler);
只需按如下方式更改我的功能,这对我来说非常有效:
private JObject PostingToPKFAndDecompress(string sData, string sUrl)
{
var jOBj = new JObject();
try
{
try
{
string urlStr = @"" + sUrl + "?param=" + sData;
HttpWebRequest request = (HttpWebRequest)WebRequest.Create(urlStr);
HttpWebResponse response = (HttpWebResponse)request.GetResponse();
Stream resStream = response.GetResponseStream();
var t = ReadFully(resStream);
var y = Decompress(t);
using (var ms = new MemoryStream(y))
using (var streamReader = new StreamReader(ms))
using (var jsonReader = new JsonTextReader(streamReader))
{
jOBj = (JObject)JToken.ReadFrom(jsonReader);
}
}
catch (System.Net.Sockets.SocketException)
{
// The remote site is currently down. Try again next time.
}
}
catch (Exception ex)
{
throw new Exception(ex.ToString());
}
return jOBj;
}
public static byte[] ReadFully(Stream input)
{
byte[] buffer = new byte[16 * 1024];
using (MemoryStream ms = new MemoryStream())
{
int read;
while ((read = input.Read(buffer, 0, buffer.Length)) > 0)
{
ms.Write(buffer, 0, read);
}
return ms.ToArray();
}
}
public static byte[] Decompress(byte[] data)
{
using (var compressedStream = new MemoryStream(data))
using (var zipStream = new GZipStream(compressedStream, CompressionMode.Decompress))
using (var resultStream = new MemoryStream())
{
zipStream.CopyTo(resultStream);
return resultStream.ToArray();
}
}
这是我使用 AutomaticDecompression 的 Gzip、Deflate、Brotli 或 All
的解决方案string url = "https://my.example.com";
using HttpClientHandler handler = new HttpClientHandler();
/// Set the AutomaticDecompression property to DecompressionMethods.GZip
handler.AutomaticDecompression = DecompressionMethods.GZip;
// handler.AutomaticDecompression = DecompressionMethods.Deflate;
// handler.AutomaticDecompression = DecompressionMethods.Brotli;
// handler.AutomaticDecompression = DecompressionMethods.All;
/// Create an instance of HttpClient with the handler
using HttpClient client = new HttpClient(handler);
/// Send a GET request to a URL that returns compressed content
using HttpResponseMessage response = await client.GetAsync(url);
/// Check if the response is successful
if (response.IsSuccessStatusCode)
{
/// Read the response content as a string
/// The content will be automatically decompressed by the handler
string content = await response.Content.ReadAsStringAsync();
Console.WriteLine(content);
HtmlDocument htmlDocument = new();
htmlDocument.LoadHtml(content);
List<HtmlNode> allRows = htmlDocument.DocumentNode.Descendants("div").ToList();
Console.WriteLine(allRows[0]);
}
else
{
/// Handle the error
_logger.LogError($"Error accessing the URL. Is TSETMC server down? Status: {response.StatusCode}");
}