FluentHttpClient is a modern async HTTP client for REST APIs. Its fluent interface lets you send an HTTP request and parse the response in one go — hiding away the gritty details like deserialisation, content negotiation, optional retry logic, and URL encoding:
Blogresult=awaitnewFluentClient("https://example.org/api").GetAsync("blogs").WithArgument("id",15).WithBearerAuthentication(token).As<Blog>();Designed with discoverability and extensibility as core principles, just autocomplete to see which methods are available at each step.
.NET has a built-in HttpClient, and there are various higher-level HTTP clients. However:
- Using
HttpClientcan be tedious, with lots of repeated boilerplate code and low discoverability. Usage also varies depending on your .NET version (and it isn't available at all in some older versions), which makes multi-targeting harder. - Higher-level client libraries often reinvent the wheel. That means you can lose access to the
features, performance optimizations, best practices & patterns, and ecosystem of libraries which
come with using the built-in
HttpClient.
FluentHttpClient offers a middle ground: it's a thin wrapper around the .NET HttpClient which
greatly simplifies its API and makes it consistent across .NET versions, but you're still using the
official HttpClient with all the benefits that provides.
For example, this code using FluentHttpClient:
usingvarclient=using new FluentClient("https://example.org/api");
Blog result =awaitclient.GetAsync("blogs").WithArgument("search",searchText).WithBearerAuthentication(token).As<Blog>();Is equivalent to this code when using HttpClient directly:
usingvarclient=newHttpClient{BaseAddress=newUri("https://example.org/api/")};stringurl="blogs";if(searchText!=null)url+=$"?search={Uri.EscapeDataString(searchText)}";usingvarrequest=newHttpRequestMessage(HttpMethod.Get,url);request.Headers.UserAgent.Add(newProductInfoHeaderValue("ExampleClient","1.0.0"));// often required; a configurable user agent is added automatically by FluentHttpClientrequest.Headers.Authorization=newAuthenticationHeaderValue("Bearer",token);varresponse=awaitclient.SendAsync(request);response.EnsureSuccessStatusCode();stringjson=awaitresponse.Content.ReadAsStringAsync();Blogresult=JsonConvert.DeserializeObject<Blog>(json);And that's just a simple example; the HttpClient code can become much more complex if you want
any of the other features built-in to FluentHttpClient like content negotiation, retry logic,
error-handling, filters, etc.
Install it from NuGet:
Install-Package Pathoschild.Http.FluentClient
The client works on most platforms (including Linux, Mac, and Windows):
| platform | min version |
|---|---|
| .NET | 5.0 |
| .NET Core | 1.0 |
| .NET Framework | 4.5.2 |
| .NET Standard | 1.3 |
| Mono | 4.6 |
| Unity | 2018.1 |
| Universal Windows Platform | 10.0 |
| Xamarin.Android | 7.0 |
| Xamarin.iOS | 10.0 |
| Xamarin.Mac | 3.0 |
Just create the client and chain methods to set up the request/response. For example, this
sends a GET request and deserializes the response into a custom Item class based on content
negotiation:
Itemitem=awaitnewFluentClient().GetAsync("https://example.org/api/items/14").As<Item>();You can also reuse the client for many requests (which improves performance using the built-in connection pool), and set a base URL in the constructor:
usingvarclient=newFluentClient("https://example.org/api");Itemitem=awaitclient.GetAsync("items/14").As<Item>();The client provides methods for DELETE, GET, POST, PUT, and PATCH out of the box. You can
also use SendAsync to craft a custom HTTP request.
You can add any number of arguments to the request URL with an anonymous object:
awaitclient.PostAsync("items/14").WithArguments(new{page=1,search="some search text"});Or with a dictionary:
awaitclient.PostAsync("items/14").WithArguments(newDictionary<string,object>{ … });Or individually:
awaitclient.PostAsync("items/14").WithArgument("page",1).WithArgument("search","some search text");You can add a model body directly in a POST or PUT:
awaitclient.PostAsync("search",newSearchOptions(…));Or add it to any request:
awaitclient.GetAsync("search").WithBody(newSearchOptions(…));Or provide it in various formats:
| format | example |
|---|---|
| serialized model | WithBody(new ExampleModel()) |
| form URL encoded | WithBody(p => p.FormUrlEncoded(values)) |
| file upload | WithBody(p => p.FileUpload(files)) |
HttpContent | WithBody(httpContent) |
You can add any number of headers:
awaitclient.PostAsync("items/14").WithHeader("User-Agent","Some Bot/1.0.0").WithHeader("Content-Type","application/json");Or use methods for common headers like WithAuthentication, WithBasicAuthentication,
WithBearerAuthentication, and SetUserAgent.
(Basic headers like Content-Type and User-Agent will be added automatically if you omit them.)
You can parse the response by awaiting an As* method:
awaitclient.GetAsync("items").AsArray<Item>();Here are the available formats:
| type | method |
|---|---|
Item | As<Item>() |
Item[] | AsArray<Item>() |
byte[] | AsByteArray() |
string | AsString() |
Stream | AsStream() |
JToken | AsRawJson() |
JObject | AsRawJsonObject() |
JArray | AsRawJsonArray() |
The AsRawJson method can also return dynamic to avoid needing a model class:
dynamicitem=awaitclient.GetAsync("items/14").AsRawJsonObject();stringauthor=item.Author.Name;If you don't need the content, you can just await the request:
awaitclient.PostAsync("items",newItem(…));You can also read the HTTP response info before parsing the body:
IResponseresponse=awaitclient.GetAsync("items");if(response.IsSuccessStatusCode||response.Status==HttpStatusCode.Found)returnresponse.AsArray<Item>();By default the client will throw ApiException if the server returns an error code:
try{awaitclient.Get("items");}catch(ApiExceptionex){stringresponseText=awaitex.Response.AsString();thrownewException($"The API responded with HTTP {ex.Response.Status}: {responseText}");}If you don't want that, you can...
disable it for one request:
IResponseresponse=awaitclient.GetAsync("items").WithOptions(ignoreHttpErrors:true);
disable it for all requests:
client.SetOptions(ignoreHttpErrors:true);
You can customize the request/response flow using a few built-in options.
You can set an option for one request:
IResponseresponse=awaitclient.GetAsync("items").WithOptions(ignoreHttpErrors:true);Or for all requests:
client.SetOptions(ignoreHttpErrors:true);The available options are:
| option | default | effect |
|---|---|---|
ignoreHttpErrors | false | Whether HTTP error responses like HTTP 404 should be ignored (true) or raised as exceptions (false). |
ignoreNullArguments | true | Whether null arguments in the request body and URL query string should be ignored (true) or sent as-is (false). |
completeWhen | ResponseContentRead | When we should stop waiting for the response. For example, setting this to ResponseHeadersRead will let you handle the response as soon as the headers are received, before the full response body has been fetched. This only affects getting the IResponse; reading the response body (e.g. using a method like IResponse.As<T>()) will still wait for the request body to be fetched as usual. |
The client won't retry failed requests by default, but that's easy to configure:
client.SetRequestCoordinator(maxRetries:3,shouldRetry: request =>request.StatusCode!=HttpStatusCode.OK,getDelay:(attempt,response)=>TimeSpan.FromSeconds(attempt*5)// wait 5, 10, and 15 seconds);You can also wrap retry logic into IRetryConfig implementations:
/// <summary>A retry policy which retries with incremental backoff.</summary>publicclassRetryWithBackoffConfig:IRetryConfig{/// <summary>The maximum number of times to retry a request before failing.</summary>publicintMaxRetries=>3;/// <summary>Get whether a request should be retried.</summary>/// <param name="response">The last HTTP response received.</param>publicboolShouldRetry(HttpResponseMessageresponse){returnrequest.StatusCode!=HttpStatusCode.OK;}/// <summary>Get the time to wait until the next retry.</summary>/// <param name="attempt">The retry index (starting at 1).</param>/// <param name="response">The last HTTP response received.</param>publicTimeSpanGetDelay(intattempt,HttpResponseMessageresponse){returnTimeSpan.FromSeconds(attempt*5);// wait 5, 10, and 15 seconds}}Then you can add one or more retry policies, and they'll each be given the opportunity to retry a request:
client.SetRequestCoordinator(new[]{newTokenExpiredRetryConfig(),newDatabaseTimeoutRetryConfig(),newRetryWithBackoffConfig()});Note that there's one retry count across all retry policies. For example, if
TokenExpiredRetryConfig retries once before falling back to RetryWithBackoffConfig, the latter
will receive 2 as its first retry count. If you need more granular control, see custom
retry/coordination policy.
The client fully supports .NET cancellation tokens if you need to cancel requests:
usingvartokenSource=newCancellationTokenSource();awaitclient.PostAsync(…).WithCancellationToken(tokenSource.Token);tokenSource.Cancel();The cancellation token is used for the whole process, from sending the request to reading the
response. You can change the cancellation token on the response if needed, by awaiting the request
and calling WithCancellationToken on the response.
You can make changes directly to the HTTP request before it's sent:
client.GetAsync("items").WithCustom(request =>{request.Method=HttpMethod.Post;request.Headers.CacheControl=newCacheControlHeaderValue{MaxAge=TimeSpan.FromMinutes(30)};});The client is built around the async and await keywords, but you can use the client
synchronously. That's not recommended — it complicates error-handling (e.g. errors get wrapped
into AggregateException), and it's very easy to cause thread deadlocks when you do this (see
Parallel Programming with .NET: Await, and UI, and deadlocks! Oh my! and
Don't Block on Async Code).
If you really need to use it synchronously, you can just call the Result property:
Itemitem=client.GetAsync("items/14").Result;Or if you don't need the response:
client.PostAsync("items",newItem(…)).AsResponse().Wait();The client supports JSON and XML out of the box. If you need more, you can...
Add any of the existing media type formatters:
client.Formatters.Add(newYamlFormatter());
Create your own by subclassing
MediaTypeFormatter(optionally using the includedMediaTypeFormatterBaseclass).
You can read and change the underlying HTTP requests and responses by creating IHttpFilter
implementations. They can be useful for automating custom authentication or error-handling.
For example, the default error-handling is just a filter:
/// <summary>Method invoked just after the HTTP response is received. This method can modify the incoming HTTP response.</summary>/// <param name="response">The HTTP response.</param>/// <param name="httpErrorAsException">Whether HTTP error responses (e.g. HTTP 404) should be raised as exceptions.</param>publicvoidOnResponse(IResponseresponse,boolhttpErrorAsException){if(httpErrorAsException&&!response.Message.IsSuccessStatusCode)thrownewApiException(response,$"The API query failed with status code {response.Message.StatusCode}: {response.Message.ReasonPhrase}");}...which you can replace with your own:
client.Filters.Remove<DefaultErrorFilter>();client.Filters.Add(newYourErrorFilter());You can do much more with HTTP filters by editing the requests before they're sent or the responses before they're parsed:
/// <summary>Method invoked just before the HTTP request is submitted. This method can modify the outgoing HTTP request.</summary>/// <param name="request">The HTTP request.</param>publicvoidOnRequest(IRequestrequest){// example only — you'd normally use a method like client.SetAuthentication(…) instead.request.Message.Headers.Authorization=newAuthenticationHeaderValue("token","…");}You can implement IRequestCoordinator to control how requests are dispatched. For example, here's
a retry coordinator using Polly:
/// <summary>A request coordinator which retries failed requests with a delay between each attempt.</summary>publicclassRetryCoordinator:IRequestCoordinator{/// <summary>Dispatch an HTTP request.</summary>/// <param name="request">The response message to validate.</param>/// <param name="send">Dispatcher that executes the request.</param>/// <returns>The final HTTP response.</returns>publicTask<HttpResponseMessage>ExecuteAsync(IRequestrequest,Func<IRequest,Task<HttpResponseMessage>>send){HttpStatusCode[]retryCodes={HttpStatusCode.GatewayTimeout,HttpStatusCode.RequestTimeout};returnPolicy.HandleResult<HttpResponseMessage>(request =>retryCodes.Contains(request.StatusCode))// should we retry?.WaitAndRetryAsync(3, attempt =>TimeSpan.FromSeconds(attempt))// up to 3 retries with increasing delay.ExecuteAsync(()=>send(request));// begin handling request}}...and here's how you'd set it:
client.SetRequestCoordinator(newRetryCoordinator());(You can only have one request coordinator on the client; you should use HTTP filters instead for most overrides.)
For advanced scenarios, you can customise the underlying HttpClient and HttpClientHandler. See the next section for an example.
Here's how to create mock requests for unit testing using RichardSzalay.MockHttp:
// create mockvarmockHandler=newMockHttpMessageHandler();mockHandler.When(HttpMethod.Get,"https://example.org/api/items").Respond(HttpStatusCode.OK, testRequest =>newStringContent("[]"));// create clientvarclient=newFluentClient("https://example.org/api",newHttpClient(mockHandler));