Java 类org.apache.http.client.fluent.Request 实例源码

项目：kiqr 文件：GenericBlockingRestKiqrClientImpl.java

private <U> U execute(URISupplier<URI> uriSupplier, MappingFunction<byte[], U> responseMapper, Supplier<U> notFoundMapper) {
    try {
        URI uri = uriSupplier.get();
        Request request = Request.Get(uri);
        HttpResponse response = request.execute().returnResponse();

        if (response.getStatusLine().getStatusCode() == 200) {
            byte[] returnJson = EntityUtils.toByteArray(response.getEntity());

            return responseMapper.apply(returnJson);


        } else if (response.getStatusLine().getStatusCode() == 404) {
            return notFoundMapper.get();
        } else if (response.getStatusLine().getStatusCode() == 400) {
            throw new IllegalArgumentException("Bad Request");
        } else {
            throw new QueryExecutionException("Something went wrong, status code: " + response.getStatusLine().getStatusCode());
        }


    } catch (URISyntaxException | IOException e) {
        throw new ConnectionException("Error creating connection", e);
    }

}

项目：DiscordDevRant 文件：DevRant.java

/**
 * Make a GET-request to the devRant server.
 *
 * @param url The url to make the request to.
 * @return A {@link JsonObject} containing the response.
 */
JsonObject get(String url, NameValuePair... params) {
    StringBuilder finalUrl = new StringBuilder(url).append('?');
    List<NameValuePair> paramList = getParameters(params);

    // Add all parameters.
    try {
        for (NameValuePair param : paramList)
            finalUrl.append('&').append(param.getName()).append('=').append(URLEncoder.encode(param.getValue(), "UTF-8"));
    } catch (UnsupportedEncodingException e) {
        // This never happens.
        LOGGER.error("Unsupported encoding while trying to encode parameter value.", e);
    }

    return executeRequest(Request.Get(BASE_URL + finalUrl.toString()));
}

项目：framework 文件：PayManager.java

/**
 * post 请求
 *
 * @param url
 * @param xml
 * @return
 */
private static String post(String url, String xml) {
    try {
        HttpEntity entity = Request.Post(url).bodyString(xml, ContentType.create("text/xml", Consts.UTF_8.name())).execute().returnResponse().getEntity();
        if (entity != null) {
            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
            entity.writeTo(byteArrayOutputStream);
            return byteArrayOutputStream.toString(Consts.UTF_8.name());
        }
        return null;
    } catch (Exception e) {
        logger.error("post请求异常，" + e.getMessage() + "\npost url:" + url);
        e.printStackTrace();
    }
    return null;
}

项目：framework 文件：HttpUtils.java

/**
 * 下载文件
 *
 * @param url URL
 * @return 文件的二进制流，客户端使用outputStream输出为文件
 */
public static byte[] getFile(String url) {
    try {
        Request request = Request.Get(url);
        HttpEntity resEntity = request.execute().returnResponse().getEntity();
        return EntityUtils.toByteArray(resEntity);
    } catch (Exception e) {
        logger.error("postFile请求异常，" + e.getMessage() + "\n post url:" + url);
        e.printStackTrace();
    }
    return null;
}

项目：attics 文件：Item.java

private void loadMetadata() {
    String requestUrl = "http://archive.org/metadata/" + identifier;

    try {
        // get the metadata for the item as a json stream
        InputStream jsonStream = Request.Get(requestUrl).execute().returnContent().asStream();

        BufferedReader streamReader = new BufferedReader(new InputStreamReader(jsonStream));

        StringBuilder result = new StringBuilder();
        String line;

        // read each line of the stream
        while ((line = streamReader.readLine()) != null) {
            result.append(line);
        }
        streamReader.close();

        JsonReader jsonReader = Json.createReader(new StringReader(result.toString()));
        metadata = jsonReader.readObject();
    } catch (IOException e) {
        e.printStackTrace();
    }
}

项目：trident 文件：Test.java

public static void main(String[] args) throws Exception {

        // URL白名单组件测试
        CheckURL urlCheck = new CheckURL();
        String[] urlWList = {"joychou.com", "joychou.me"};
        Boolean ret = urlCheck.checkUrlWlist("http://test.joychou.org", urlWList);
        System.out.println(ret);

        // SSRF组件测试
        SSRF check = new SSRF();
        String url = "http://127.0.0.1.xip.io";
        ret = check.checkSSRF(url);
        if (ret){
            String con = Request.Get(url).execute().returnContent().toString();
            System.out.println(con);
        }
        else {
            System.out.println("Bad boy. The url is illegal");
        }

        // 获取客户端IP测试


    }

项目：simpleauth 文件：ExampleHttpFluent.java

private static void doRequest(final String uri, final String sign) {
    System.out.println("--- Signature: " + sign);
    try {
        final Request req = Request.Get(uri).connectTimeout(5000).socketTimeout(5000);
        if (sign != null) {
            req.setHeader(SimpleAuth.HTTP_HEADER, SimpleAuth.SCHEME + " " + sign);
        }
        final HttpResponse res = req.execute().returnResponse();
        final String status = String.valueOf(res.getStatusLine());
        final String body = EntityUtils.toString(res.getEntity()).trim();
        System.out.println("head> " + status);  // HTTP Status
        System.out.println("body> " + body);    // Body
    } catch (IOException e) {
        System.out.println("Unable to connect: " + e);
    }
}

项目：joal 文件：BitTorrentClient.java

@VisibleForTesting
void addHeadersToRequest(final Request request, final URL trackerAnnounceURI) {
    final int port = trackerAnnounceURI.getPort();
    // Add Host header first to prevent Request appending it at the end
    request.addHeader("Host", trackerAnnounceURI.getHost() + (port == -1 ? "" : ":" + port));

    //noinspection SimplifyStreamApiCallChains
    this.headers.stream().forEachOrdered(header -> {
        final String name = header.getKey();
        final String value = header.getValue()
                .replaceAll("\\{java}", System.getProperty("java.version"))
                .replaceAll("\\{os}", System.getProperty("os.name"))
                .replaceAll("\\{locale}", Locale.getDefault().toLanguageTag());

        request.addHeader(name, value);
    });

    // if Connection header was not set, we append it. Apache HttpClient will add it what so ever, so prefer "Close" over "keep-alive"
    final boolean hasConnectionHeader = this.headers.stream()
            .anyMatch(header -> "Connection".equalsIgnoreCase(header.getKey()));
    if (!hasConnectionHeader) {
        request.addHeader("Connection", "Close");
    }
}