Чтение BLOB через IHttpAsyncHandler - PullRequest
0 голосов
/ 01 апреля 2010

Я храню изображения в базе данных SQL Server 2000 (тип BLOB). В моем приложении ASP.NET есть веб-страница, на которой конечному пользователю нужно показать много изображений, и я хочу обрабатывать запросы браузера на изображения через IHttpAsyncHandler. Я нашел сообщение для сравнения на codeproject «Асинхронный обработчик HTTP для асинхронного BLOB DataReader.» Но по некоторым причинам страница останавливается после завершения метода «BeginProcessRequest», а метод «EndProcessRequest» никогда не получает вызов. Может кто-нибудь взглянуть на этот пост и сообщить мне, что не так в этом посте? ИЛИ что мне нужно сделать, чтобы выполнить эту задачу (чтение BLOB через IHttpAsyncHandler)?

Исходный код в этом посте как под,

public IAsyncResult BeginProcessRequest(HttpContext context, AsyncCallback cb, object extraData)
{
    try
    {
        // image to retrieve
        // this needs to change if setup a different path schema in the httpHandles web.config
        string imgId = context.Request.Url.Segments[context.Request.Url.Segments.Length - 1];

        SqlConnection conn = new SqlConnection(ConfigurationManager.ConnectionStrings["LocalBLOB"].ConnectionString);
        conn.Open();
        SqlCommand cmd = conn.CreateCommand();
        cmd.CommandText = "select image from BLOBTest where imgId='" + imgId + "'";
        // store our Command to be later retrieved by EndProcessRequest
        context.Items.Add("cmd", cmd);

        // start async DB read
        return cmd.BeginExecuteReader(cb, context, 
            CommandBehavior.SequentialAccess |  // doesn't load whole column into memory
            CommandBehavior.SingleRow |         // performance improve since we only want one row
            CommandBehavior.CloseConnection);   // close connection immediately after read
    }
    catch (Exception exc)
    {
        // will return an image with the error text
        this.renderError(context, "ERROR: " + exc.Message);
        context.Response.StatusCode = 500;
        context.Response.End();
        // just to avoid compilation errors
        throw;
    }
}

/// <summary>
/// Provides an end method for an asynchronous process. 
/// </summary>
/// <param name="result">An IAsyncResult that contains information about the status of the process.</param>
public void EndProcessRequest(IAsyncResult result)
{
    HttpContext context = (HttpContext)result.AsyncState;

    try
    {
        // restore used Command
        SqlCommand cmd = (SqlCommand)context.Items["cmd"];
        // retrieve result
        using (SqlDataReader reader = cmd.EndExecuteReader(result))
        {
            this.renderImage(context, reader);
        }
    }
    catch (Exception exc)
    {
        // will return an image with the error text
        this.renderError(context, "ERROR: " + exc.Message);
        context.Response.StatusCode = 500;
    }
}

#endregion

#region IHttpHandler Members

public bool IsReusable
{
    get { return true; }
}

public void ProcessRequest(HttpContext context)
{
    // should never get called
    throw new Exception("The method or operation is not implemented.");
}

#endregion

/// <summary>
/// Render a BLOB field to the Response stream as JPEG
/// </summary>
/// <param name="context">HttpContext of current request</param>
/// <param name="myReader">open SqlDataReader to read BLOB from</param>
private void renderImage(HttpContext context, SqlDataReader myReader)
{
    // Size of the BLOB buffer.
    const int bufferSize = 1024;            
    long startIndex = 0;
    byte[] outbyte = new byte[bufferSize];
    long retval;

    myReader.Read();

    context.Response.Clear();
    context.Response.ContentType = "image/jpeg";

    do
    {
        retval = myReader.GetBytes(0, startIndex, outbyte, 0, bufferSize);
        // reposition the start index
        startIndex += bufferSize;
        // output buffer
        context.Response.BinaryWrite(outbyte);
        context.Response.Flush();
    } while (retval == bufferSize);
}

/// <summary>
/// Renders an Error image
/// </summary>
/// <param name="context">HttpContext of current request</param>
/// <param name="msg">message text to render</param>
private void renderError(HttpContext context, string msg)
{
    context.Response.Clear();
    context.Response.ContentType = "image/jpeg";
    // calculate the image width by message length
    Bitmap bitmap = new Bitmap(7 * msg.Length, 30);
    Graphics g = Graphics.FromImage(bitmap);
    // create a background filler
    g.FillRectangle(new SolidBrush(Color.DarkRed), 0, 0, bitmap.Width, bitmap.Height);
    // draw our message
    g.DrawString(msg, new Font("Tahoma", 10, FontStyle.Bold), new SolidBrush(Color.White), new PointF(5, 5));
    // stream it to the output
    bitmap.Save(context.Response.OutputStream, System.Drawing.Imaging.ImageFormat.Jpeg);
}

1 Ответ

0 голосов
/ 26 апреля 2011

Я знаю, что это очень поздний ответ, но, возможно, это может помочь некоторым другим парням.

Я надеюсь, что ваша строка подключения имеет асинхронную обработку = true.

Также вам необходимо добавить заголовок размещения контента в вашей функции RenderImage.

 context.Response.AddHeader("Content-Disposition", "attachment; filename=imagefilename.extension");

наконец, после цикла do while добавьте вызов Context.Response.End().

...