Direct Http

Features

1. DSL Style Programming
2. Reusable Http Connection
3. Http Connections Pool
4. Async Request

1. DSL Style

Response response = DirectHttp.newRequest("host")
    .encoding("utf-8")
    .contentType("application/json")
    .compression("gzip")
    .cookie(CookieObject... cookies)
    .header("name1", "value").header("name2", "value")
    .queryString("name1", "value").queryString("name2", "value")
    .formField("name1", "value").formField("name2", "value")
    .multipart("file", InputStream) // upload
    .multipart("partname", "text")
    .body("JSON/XML/FORM-FIELDS/ANY-OTHERS")
    .post("relative-path")
    .get("relative-path")
    .put("relative-path")
    .patch("relative-path")
    .send("method", "relative-path");

response.getBody().asJSON(); // compatiable with JSON lib
response.getBody().asString(); // same as toString()
response.getBody().asInputStream(); // download
response.getCookies(); // receive from http response header
response.getHeaders();
response.getStatusCode();

// close request
response.getRequest().close();

try (Request request = DirectHttp.newRequest("host")) {
    Response response = request.body("JSON/XML/FORM-FIELDS/ANY-OTHERS").post("relative-path");

    response.getBody().asJSON(); // compatiable with JSON lib
    response.getBody().asString(); // same as toString()
    response.getBody().asInputStream(); // download
    response.getCookies(); // receive from http response header
    response.getHeaders();
    response.getStatusCode();
}

host would be like that "http://uri" or "https://uri"

2. Reusable Http Connection

// unsafe Request (NOT thread safe)
try (Request request = DirectHttp.newRequest("host")) {
    Response response = request.body("JSON/XML/FORM-FIELDS/ANY-OTHERS").post("relative-path");
    // ... response ...

    Response response2 = request.formField("name", "value").post("relative-path");
    // ... response2 ...

    assert response.getRequest() == response2.getRequest(); 
}

3. Http Connections Pool

PooledRequest pool = DirectHttp.pooledRequest("host");
try (Request request = pool.getRequest()) {
    Response response = request.body("JSON/XML/FORM-FIELDS/ANY-OTHERS").post("relative-path");
    // ... response ...

    Response response2 = request.formField("name", "value").post("relative-path");
    // ... response2 ...

    assert response.getRequest() == response2.getRequest(); 
}
// pool.close(); close the pooled request immediately

Global http connections pool configuration

DirectHttp.globalPooledConfig().max(int).min(int).idle(TimeUnit).lifetime(TimeUnit);

4. Async Request

PooledRequest pooled = DirectHttp.newPooledRequest("host");
pooled.getRequest().asyncPost("http://IP/mysite/users/@{id}", req -> {
        req.addPathParam("id", "0123456789");
        req.addQueryParam("version", "1.0");
        req.addFormParam("type", "file");
        
        req.addHeader("Authentication", "...");
        req.addHeader("X-Date", "2021-05-09");
        req.addHeader("X-Repeat", Arrays.asList("1", "2", "3", "4"));
        
        req.setBody("JSON/XML/FORM-FIELDS/ANY-OTHERS");
    }).fail(err -> {
        
    }).success(resp -> {
        
    }).done((resp, err) -> {
        if (err != null) {
            // process error
            return;
        }
        // process resp
    });