Response.Flush() не работает на странице асинхронных веб-форм ASP.NET

Я использую.Net Framework 4.8. Я создаю веб-страницу, которая при нажатии кнопки PostBack пересчитывает затраты на химические составы, получая данные из SQL Server. Затем вычисленные цены сохраняются обратно в SQL Server и отправляются через HttpClient в службу REST на сервере SAP Hana.

Поскольку формулировок больше 1000 (составленных из нескольких тысяч строк компонентов, иногда рекурсивно включающих другие формулировки), а цены должны отправляться в службу REST одну за другой, я решил сделать страницу многопоточной.

Все работает отлично, теперь я могу публиковать десятки цен одновременно, и весь процесс теперь намного быстрее, чем когда это было сделано синхронно. Что я не могу сделать, так это сообщить о ходе выполнения на веб-странице вызывающего абонента. Вот что я пробовал до сих пор:

<%@ Page language="c#" Inherits="..." CodeFile="..." Async="true" AutoEventWireup="true" EnableSessionState="False" %>

В коде позади:

protected async void BtUpdatePricesSAP_Click(object sender, EventArgs e)
{
    Response.Write(@"<!DOCTYPE HTML><html><head><title>Price update</title>...");
    Response.Flush();   // Not working!!!
    await ComputeEverything().ConfigureAwait(false);
    Response.Write("<p>Done</p></body></html>");
    Response.End();
}

private async Task ComputeEverything() {
    using var cn = new SqlConnection((string)Application["dataSource"]);
    //await cn.OpenAsync();    <= this does not work, throws an authentication error connecting to the db
    cn.Open();

    SqlCommand cmd = new SqlCommand("...", cn);

    using (SqlDataReader dr = await cmd.ExecuteReaderAsync())
    {
        while (await dr.ReadAsync())  { ... }
    
    ...
    // Here I store data in some collections, including a ConcurrentQueue<string> (name FormulationsIndex)
    // and a ConcurrentDictionary (named FormulationRows) containing an array 
    // with the raw materials with quantities and prices.
    }

    // Then, I prepare the threads that will pop the formulations from the queue
    // and call the recursive function that computes the costs:
    
    async void FormulaProcessor()   // local function
    {
        while (FormulationsIndex.TryDequeue(out string formulaCode))
            await ComputeFormulaCostAsync(formulaCode, FormulationRows[formulaCode], 1);
    }

    var tasks = new Task[15];
        for (int i = 0; i < tasks.Length; i++)
            tasks[i] = Task.Factory.StartNew(FormulaProcessor);
            
    Task.WaitAll(tasks);

    // here I update price to SQL from the ConcurrentDictionary where I stored them

    while (Errors.TryDequeue(out string s))  // Errors is another ConcurrentQueue where I store the errors I found
        Response.Write($"<p>{s}</p>");
}


private async Task<decimal> ComputeFormulaCostAsync(string formulaCode, Formula f, int recursionLevel)
{
    if (Interlocked.Increment(ref processedCount) % 50 == 0)
    {
        int perc = (processedCount * 100 / totalFormulCount);
        Response.Write($"<script>$('#progressBar').text('{perc}%').css('width','{perc}%').prop('aria-valuenow','{perc}');</script>");
        Response.Flush();         ////////////// THIS DOES NOT WORK
        // await Response.FlushAsync();     /////// THIS NEITHER!
    }

    decimal formulaCost = 0;
    ...
    // here I iterate the formula components, calling this function recursively if the component is also a formulation

    // Once done, I update the price of the current formulation in SAP
    SapItemPricesHandler.SapItemPrice ip = new SapItemPricesHandler.SapItemPrice(formulaCost); // helper class to prepare the json for the REST post
    
    var (httpStatusCode, responseContent) = 
        await SessionSL_Async.SendRequest($"Items('{formulaCode}')", new HttpMethod("PATCH"),
            ip.ToJson()).ConfigureAwait(false);
    // SessionSL_Async is a static class I wrote to handle the REST communications with Hana using HttpClient
    if (httpStatusCode != HttpStatusCode.NoContent)
        Errors.Enqueue($"Errore scrittura prezzo in SAP, formula <b>{formulaCode}</b>, {responseContent}");

    return formulaCost;  // result value helps in recursive formulations, not needed in the main caller
}

Я постарался максимально упростить код, чтобы было понятно. Страница работает нормально, я вижу все сообщения Хане в Fiddler. Только все отзывы, которые я получаю из Response.Write, происходят, когда вся обработка завершена (что в моей демонстрационной среде занимает пару минут). Я не понимаю, почему не работают флеши.

Источник

0 ответов

Другие вопросы по тегам