异步下载文件到客户端

Question

我很难完成某件事。

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

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

现在我有了这个设置：

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

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

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

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

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

有人可以帮帮我吗？

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

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

Answer 1

您只需要将数据从一个流（到邮件服务器的 tcp 连接）复制到另一个（到浏览器的 http 连接），对吗？如果要扩展，则需要使用this article 中所述的非阻塞 IO。因此，您需要从 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);
    }
}

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