使用 HttpClient 从流中发布多部分/表单数据文件

本文关键字:表单 数据 文件 布多部 HttpClient 使用 | 更新日期: 2023-09-27 17:56:13

>问题:是否可以使用 httpclient 将 HttpPostedFileBase(仅在内存中可用,而不是在磁盘上)发布到另一个端点?

我尝试过:

我有以下控制器,我们正在从前端发布到一个文件中,它绑定到 file 参数。

public class HomeController : Controller
{
    [System.Web.Http.HttpPost]
    public async Task<Stream> Index(HttpPostedFileBase file)
    {
        //file is not null here, everything works as it should.
        //Here im preparing a multipart/form-data request to my api endpoint
        var fileStreamContent = new StreamContent(file.InputStream);
        using (var client = new HttpClient())
        using (var formData = new MultipartFormDataContent())
        {
            formData.Add(fileStreamContent);
            var response = await client.PostAsync("http://restapi.dev/api/files/add", formData);
            var result = await response.Content.ReadAsStreamAsync();
            return result;
        }
    }
}

我需要将此请求传递给另一个不公开可用的应用程序(因此我们不能直接从客户端发布)该控制器如下所示:

[RoutePrefix("api/files")]
public class FilesController : ApiController
{
    [HttpPost]
    [Route("add")]
    public async Task<HttpResponseMessage> Add(HttpPostedFileBase file)
    {
        //This is the problem, file is always null when I post from my backend.
        var files = HttpContext.Current.Request.Files.Count > 0 ? HttpContext.Current.Request.Files[0] : null;
        return Request.CreateResponse(HttpStatusCode.OK);
    }
}

file始终为空,files 也是如此。我错过了什么?当我使用邮递员并直接发布到 API 端点时,它可以工作。所以我猜我在HomeController做错了什么?

使用 HttpClient 从流中发布多部分/表单数据文件

您可以使用更新的技术对此进行改进。

在 webapi 中,您可以编写如下的控制器方法:

//[Route("api/Foo")] //maybe?
[HttpPost]
public async Task<HttpResponseMessage> MyResourceProxy(HttpRequestMessage request)

现在,您可以接受该请求并重写其RequestUri属性:

request.RequestUri = new Uri(blah);

新建HttpClient并转发请求:

HttpClient client = new HttpClient();
//make sure that this fails if it's hung for more than 30 seconds
var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));
try
{
    response = await client.SendAsync(request,
                                      HttpCompletionOption.ResponseHeadersRead, 
                                      cts.Token);
}
catch (TaskCanceledException)
{
    response = new HttpResponseMessage(HttpStatusCode.GatewayTimeout);
}

确保所有内容都已处理:

request.RegisterForDispose(new IDisposable[] {request, client, cts, response});

然后返回response

return response;

我添加了一个超时机制,可能不适合您的需求。