异步下载文件到客户端

我很难完成某件事。

我正在使用 asp.net MVC 4 构建邮件客户端。

我现在必须将与消息（而不是附件）相关的图像下载到客户端浏览器。

现在我有这个设置：

客户端浏览器->控制器/后端->邮件服务器

澄清一下：我有一个客户端请求，其中包含图像的内容 ID、正确的邮箱、消息等。有了这些信息，我可以从邮件服务器下载图像并将其上传到客户端。 现在最困难的部分来了：我想异步执行此操作。我希望能够从邮件服务器下载 512 KB 的块，解码该部分，然后将其发送到客户端.. 获取 - 解码 - 发送.. 只要浏览器获得图像的所有数据即可。

我只是不想首先将所有数据下载到服务器，然后使用所有数据创建一个新的内存流并将其作为文件结果返回。我只是太害怕内存中的文件太大并阻止其他进程等。

我也计划使用这种方法来上传真实的附件（可能是数百MB）。所以我稍后会需要这个方法。

现在我只是不知道如何实现这一点，因为我有一个到邮件服务器的连接，并且我有一个到客户端的连接。我必须将数据传递到新流或其他东西才能完成此任务。

有人可以帮帮我吗？

编辑：澄清一下：不，我无法引用邮件服务器上的文件。我必须通过套接字将文件下载到服务器。

Edit2：http chunked 可以作为解决方案吗？如果是的话，你能给我一个小例子吗？

您只需要将数据从一个流（到邮件服务器的 tcp 连接）复制到另一个流（到浏览器的 http 连接），对吗？如果你想扩展，你需要使用非阻塞 IO，如本文 http://msdn.microsoft.com/en-us/magazine/cc337900.aspx。因此，您需要从 IHttpAsyncHandler 实现调用该文章中的代码。你最终会得到这样的结果：

class MyHandler : IHttpAsyncHandler
{
    public IAsyncResult BeginProcessRequest(HttpContext context, AsyncCallback cb, object extraData)
    {
        Stream src = null; // remote data source
        Stream dst = context.Response.OutputStream;

        // set content type, etc

        var res = new MyResult();

        AsynchCopy(src, dst, () =>
            {
                ((ManualResetEvent)res.AsyncWaitHandle).Set();
                cb(res);
                src.Close();
                dst.Flush();
            });

        return res;
    }

    public void EndProcessRequest(IAsyncResult result)
    {
    }

    public bool IsReusable
    {
        get { return true; }
    }

    public void ProcessRequest(HttpContext context)
    {
        throw new NotImplementedException();
    }

    class MyResult : IAsyncResult
    {
        public MyResult()
        {
            AsyncWaitHandle = new ManualResetEvent(false);
        }

        public object AsyncState
        {
            get { return null; }
        }

        public WaitHandle AsyncWaitHandle
        {
            get;
            private set;
        }

        public bool CompletedSynchronously
        {
            get { return false; }
        }

        public bool IsCompleted
        {
            get { return AsyncWaitHandle.WaitOne(0); }
        }
    }

    public static void AsynchCopy(Stream src, Stream dst, Action done)
    {
        byte[] buffer = new byte[2560];
        AsyncCallback readCallback = null, writeCallback = null;

        readCallback = (readResult) =>
        {
            int read = src.EndRead(readResult);
            if (read > 0)
            {
                dst.BeginWrite(buffer, 0, read, writeCallback, null);
            }
            else
            {
                done();
            }
        };

        writeCallback = (writeResult) =>
        {
            dst.EndWrite(writeResult);
            src.BeginRead(buffer, 0, buffer.Length, readCallback, null);
        };

        src.BeginRead(buffer, 0, buffer.Length, readCallback, null);
    }
}

上面的代码未经测试，也不包含错误处理，但它应该可以帮助您入门。