Я пытаюсь подключиться к api, который возвращает JSON в кодировке GZip, из службы WCF (служба WCF в службу WCF). Я использую HTTPClient для подключения к API и могу вернуть объект JSON в виде строки. Однако мне нужно иметь возможность хранить эти возвращенные данные в базе данных, и поэтому я решил, что лучшим способом было бы вернуть и сохранить объект JSON в массиве или байте или что-то в этом роде.
У меня проблемы с распаковкой кодировки GZip, и я пробовал много разных примеров, но все еще не могу его получить.
В приведенном ниже коде показано, как я устанавливаю свое соединение и получаю ответ, это код, который возвращает строку из API.
public string getData(string foo)
{
string url = "";
HttpClient client = new HttpClient();
HttpResponseMessage response;
string responseJsonContent;
try
{
client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
response = client.GetAsync(url + foo).Result;
responseJsonContent = response.Content.ReadAsStringAsync().Result;
return responseJsonContent;
}
catch (Exception ex)
{
System.Windows.Forms.MessageBox.Show(ex.Message);
return "";
}
}
Я следил за несколькими разными примерами, такими как StackExchange API , MSDN и парочка на stackoverflow, но мне не удалось заставить ни один из них работать на меня.
Как лучше всего добиться этого? На правильном ли я пути?
Спасибо ребята.
Ответы:
Просто создайте экземпляр HttpClient следующим образом:
HttpClientHandler handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate }; using (var client = new HttpClient(handler)) { // your code }
Обновление от 19 июня 2020 г .: не рекомендуется использовать httpclient в блоке using, поскольку это может вызвать исчерпание порта.
private static HttpClient client = null; ContructorMethod() { if(client == null) { HttpClientHandler handler = new HttpClientHandler() { AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate }; client = new HttpClient(handler); } // your code }
Если вы используете .Net Core 2.1+, подумайте об использовании IHttpClientFactory и вставьте подобное в свой код запуска.
var timeout = Policy.TimeoutAsync<HttpResponseMessage>( TimeSpan.FromSeconds(60)); services.AddHttpClient<XApiClient>().ConfigurePrimaryHttpMessageHandler(() => new HttpClientHandler { AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate }).AddPolicyHandler(request => timeout);
источник
HttpClient
НЕ следует использовать внутриusing
Хорошо, в конце концов я решил свою проблему. Если есть способы получше, дайте мне знать :-)
public DataSet getData(string strFoo) { string url = "foo"; HttpClient client = new HttpClient(); HttpResponseMessage response; DataSet dsTable = new DataSet(); try { //Gets the headers that should be sent with each request client.DefaultRequestHeaders.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json")); //Returned JSON response = client.GetAsync(url).Result; //converts JSON to string string responseJSONContent = response.Content.ReadAsStringAsync().Result; //deserializes string to list var jsonList = DeSerializeJsonString(responseJSONContent); //converts list to dataset. Bad name I know. dsTable = Foo_ConnectAPI.ExtentsionHelpers.ToDataSet<RootObject>(jsonList); //Returns the dataset return dsTable; } catch (Exception ex) { System.Windows.Forms.MessageBox.Show(ex.Message); return null; } } //deserializes the string to a list. Utilizes JSON.net. RootObject is a class that contains the get and set for the JSON elements public List<RootObject> DeSerializeJsonString(string jsonString) { //Initialized the List List<RootObject> list = new List<RootObject>(); //json.net deserializes string list = (List<RootObject>)JsonConvert.DeserializeObject<List<RootObject>>(jsonString); return list; }
RootObject содержит набор для получения значений JSON.
public class RootObject { //These string will be set to the elements within the JSON. Each one is directly mapped to the JSON elements. //This only takes into account a JSON that doesn't contain nested arrays public string EntityID { get; set; } public string Address1 { get; set; } public string Address2 { get; set; } public string Address3 { get; set; } }
Самый простой способ создать вышеуказанный класс (классы) - использовать json2charp, который отформатирует его соответствующим образом, а также предоставит правильные типы данных.
Следующее - из другого ответа на Stackoverflow, опять же, он не принимает во внимание вложенный JSON.
internal static class ExtentsionHelpers { public static DataSet ToDataSet<T>(this List<RootObject> list) { try { Type elementType = typeof(RootObject); DataSet ds = new DataSet(); DataTable t = new DataTable(); ds.Tables.Add(t); try { //add a column to table for each public property on T foreach (var propInfo in elementType.GetProperties()) { try { Type ColType = Nullable.GetUnderlyingType(propInfo.PropertyType) ?? propInfo.PropertyType; t.Columns.Add(propInfo.Name, ColType); } catch (Exception ex) { System.Windows.Forms.MessageBox.Show(ex.Message); } } } catch (Exception ex) { System.Windows.Forms.MessageBox.Show(ex.Message); } try { //go through each property on T and add each value to the table foreach (RootObject item in list) { DataRow row = t.NewRow(); foreach (var propInfo in elementType.GetProperties()) { row[propInfo.Name] = propInfo.GetValue(item, null) ?? DBNull.Value; } t.Rows.Add(row); } } catch (Exception ex) { System.Windows.Forms.MessageBox.Show(ex.Message); } insert.insertCategories(t); return ds. } catch (Exception ex) { System.Windows.Forms.MessageBox.Show(ex.Message); return null; } } };
Затем, наконец, чтобы вставить вышеуказанный набор данных в таблицу со столбцами, которые были сопоставлены с JSON, я использовал массовую копию SQL и следующий класс
public class insert { public static string insertCategories(DataTable table) { SqlConnection objConnection = new SqlConnection(); //As specified in the App.config/web.config file objConnection.ConnectionString = System.Configuration.ConfigurationManager.ConnectionStrings["foo"].ToString(); try { objConnection.Open(); var bulkCopy = new SqlBulkCopy(objConnection.ConnectionString); bulkCopy.DestinationTableName = "dbo.foo"; bulkCopy.BulkCopyTimeout = 600; bulkCopy.WriteToServer(table); return ""; } catch (Exception ex) { System.Windows.Forms.MessageBox.Show(ex.Message); return ""; } finally { objConnection.Close(); } } };
Таким образом, приведенное выше работает для вставки JSON из webAPI в базу данных. Это то, над чем я работаю. Но я ни в коем случае не ожидаю, что он будет идеальным. Если у вас есть какие-либо улучшения, обновите его соответствующим образом.
источник
HttpClient
и свойHttpResponse
внутреннийusing()
оператор, чтобы обеспечить надлежащее, своевременное удаление и закрытие базовых потоков.Я использовал код из ссылки ниже, чтобы распаковать поток GZip. Затем использовал распакованный массив байтов, чтобы получить требуемый объект JSON. Надеюсь, это поможет кому-нибудь.
var readTask = result.Content.ReadAsByteArrayAsync().Result; var decompressedData = Decompress(readTask); string jsonString = System.Text.Encoding.UTF8.GetString(decompressedData, 0, decompressedData.Length); ResponseObjectClass responseObject = Newtonsoft.Json.JsonConvert.DeserializeObject<ResponseObjectClass>(jsonString);
https://www.dotnetperls.com/decompress
static byte[] Decompress(byte[] gzip) { using (GZipStream stream = new GZipStream(new MemoryStream(gzip), CompressionMode.Decompress)) { const int size = 4096; byte[] buffer = new byte[size]; using (MemoryStream memory = new MemoryStream()) { int count = 0; do { count = stream.Read(buffer, 0, size); if (count > 0) { memory.Write(buffer, 0, count); } } while (count > 0); return memory.ToArray(); } } }
источник