ASP.NET MVC 5中跨请求回显POST附件至GET请求的技术咨询

这个需求确实跳出了MVC常规的请求响应模式，但核心是要实现挂起的Get请求等待Post请求的文件数据，我们可以通过异步长连接+内存会话存储的方式来搞定，具体步骤和代码如下：

核心思路 #

1. 为每个等待的Get请求生成唯一会话ID，用TaskCompletionSource创建一个可触发的等待任务，把会话ID和任务关联存储在内存中。
2. IoT设备携带该会话ID发起Post请求上传文件，后端找到对应的等待任务，把文件数据注入任务结果。
3. 挂起的Get请求收到任务结果后，返回文件内容并清理会话数据。

具体实现 #

1. 内存会话存储类（单例） #

用来安全地存储会话ID和对应的等待任务，处理并发访问：

public static class RequestSessionStore
{
    private static readonly Dictionary<string, TaskCompletionSource<byte[]>> _sessionMap = new();
    private static readonly object _lockObj = new();

    public static void AddSession(string sessionId, TaskCompletionSource<byte[]> tcs)
    {
        lock (_lockObj)
        {
            _sessionMap[sessionId] = tcs;
        }
    }

    public static bool TryGetSession(string sessionId, out TaskCompletionSource<byte[]> tcs)
    {
        lock (_lockObj)
        {
            return _sessionMap.TryGetValue(sessionId, out tcs);
        }
    }

    public static void RemoveSession(string sessionId)
    {
        lock (_lockObj)
        {
            _sessionMap.Remove(sessionId);
        }
    }
}

2. 处理挂起的Get请求 #

这个Action会先返回会话ID给前端（如果没有传入），然后等待IoT设备的Post请求：

public async Task<ActionResult> WaitForFile(string sessionId)
{
    // 第一步：生成新会话ID返回给前端，让前端传递给IoT设备
    if (string.IsNullOrEmpty(sessionId))
    {
        sessionId = Guid.NewGuid().ToString();
        var tcs = new TaskCompletionSource<byte[]>();
        RequestSessionStore.AddSession(sessionId, tcs);
        return Content(sessionId);
    }

    // 第二步：根据会话ID等待文件数据
    if (RequestSessionStore.TryGetSession(sessionId, out var tcs))
    {
        try
        {
            // 设置5分钟超时，避免请求永久挂起
            var fileBytes = await tcs.Task.WithTimeout(TimeSpan.FromMinutes(5));
            // 返回文件，这里可以根据实际文件类型修改Content-Type和文件名
            return File(fileBytes, "application/octet-stream", "received-file.bin");
        }
        catch (TimeoutException)
        {
            RequestSessionStore.RemoveSession(sessionId);
            return Content("请求超时，未收到文件");
        }
        finally
        {
            RequestSessionStore.RemoveSession(sessionId);
        }
    }

    return BadRequest("无效的会话ID");
}

3. 处理IoT设备的Post文件上传 #

这个Action接收文件，找到对应的会话并触发等待任务：

[HttpPost]
public ActionResult UploadFile(string sessionId)
{
    if (string.IsNullOrEmpty(sessionId) || !Request.Files.Any())
    {
        return BadRequest("必须提供会话ID和上传文件");
    }

    var uploadedFile = Request.Files[0];
    using var memoryStream = new MemoryStream();
    uploadedFile.InputStream.CopyTo(memoryStream);
    var fileBytes = memoryStream.ToArray();

    if (RequestSessionStore.TryGetSession(sessionId, out var tcs))
    {
        // 触发等待的Get请求，传递文件数据
        tcs.TrySetResult(fileBytes);
        return Ok("文件已接收并转发");
    }

    return BadRequest("会话ID不存在或已过期");
}

4. 超时扩展方法 #

给Task添加超时功能，避免请求无限挂起：

public static async Task<T> WithTimeout<T>(this Task<T> task, TimeSpan timeout)
{
    var timeoutTask = Task.Delay(timeout);
    var completedTask = await Task.WhenAny(task, timeoutTask);
    
    if (completedTask == timeoutTask)
    {
        throw new TimeoutException();
    }
    
    return await task;
}

关键配置与注意事项 #

• 文件大小限制：默认ASP.NET会限制上传文件大小，需要在web.config中修改：

<system.web>
    <!-- 单位：KB，这里设置为1GB -->
    <httpRuntime maxRequestLength="1048576" />
</system.web>
<system.webServer>
    <security>
        <requestFiltering>
            <!-- 单位：Bytes，这里设置为1GB -->
            <requestLimits maxAllowedContentLength="1073741824" />
        </requestFiltering>
    </security>
</system.webServer>

• 多服务器场景：如果你的应用部署在多台服务器上，内存存储会失效，需要改用分布式缓存（比如Redis）配合消息队列（比如RabbitMQ）来实现跨服务器的请求通知。
• 资源清理：务必在请求完成或超时后清理会话存储，避免内存泄漏。
• 并发安全：内存字典的操作必须加锁，否则会出现多线程冲突问题。

前端流程示例 #

1. 用户打开页面，发起GET /Home/WaitForFile请求，后端返回唯一会话ID。
2. 前端把会话ID传递给IoT设备（比如通过WebSocket、MQTT或者预先约定的接口）。
3. IoT设备发起POST /Home/UploadFile?sessionId=xxx请求，携带附件文件。
4. 挂起的Get请求收到文件数据后，返回文件给用户浏览器，两个请求同时关闭。

内容的提问来源于stack exchange，提问作者Keivan