私の連絡先情報
郵便メール:
2024-07-12
한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina
最新のソフトウェア開発では、データの取得や送信など、リモート サーバーとの通信が必要になることがよくあります。 Apache HttpClient は、HTTP リクエストの開始と応答の処理を簡素化する、一般的な Java HTTP クライアント ライブラリです。この記事ではカスタムの使い方を紹介します。 HttpClientUtils Apache HttpClient を使用して POST リクエストを開始し、接続プールを管理してパフォーマンスを最適化するクラス。
public class HttpClientUtils {
// 静态常量和变量声明
private static final int MAX_TOTAL_CONN = 600;
private static final int MAX_CONN_PER_HOST = 300;
private static final int SOCKET_TIMEOUT = 5000;
private static final int CONNECTION_TIMEOUT = 200;
private static final int CONNECTION_MANAGER_TIMEOUT = 100;
private static CloseableHttpClient httpclient;
private static PoolingHttpClientConnectionManager connMrg;
private static String encoding = StandardCharsets.UTF_8.name();
private static Logger log = LoggerFactory.getLogger(HttpClientUtils.class);
private static final ScheduledExecutorService scheduledService = Executors.newScheduledThreadPool(2);
// 静态代码块，用于初始化 HttpClient 和连接管理器，并设置 JVM 退出时关闭 HttpClient
static {
init();
destroyByJvmExit();
}
// 初始化连接管理器和 HttpClient
private static void init() {
connMrg = new PoolingHttpClientConnectionManager();
connMrg.setMaxTotal(MAX_TOTAL_CONN);
connMrg.setDefaultMaxPerRoute(MAX_CONN_PER_HOST);
httpclient = HttpClients.custom()
.setConnectionManager(connMrg)
.setDefaultRequestConfig(HttpClientUtils.defaultRequestConfig())
.build();
// 定时任务，定期清理过期和空闲连接
scheduledService.scheduleAtFixedRate(() -> {
connMrg.closeExpiredConnections();
connMrg.closeIdleConnections(CONNECTION_MANAGER_TIMEOUT, TimeUnit.MILLISECONDS);
}, 0, CONNECTION_MANAGER_TIMEOUT, TimeUnit.MILLISECONDS);
}
// JVM 退出时关闭 HttpClient
private static void destroyByJvmExit() {
Runtime.getRuntime().addShutdownHook(new Thread(() -> {
try {
httpclient.close();
} catch (IOException e) {
log.error("Error closing HttpClient: {}", e.getMessage());
}
}));
}
// 创建 HttpClientContext
private static HttpClientContext createContext() {
return HttpClientContext.create();
}
// 创建默认的 RequestConfig
private static RequestConfig defaultRequestConfig() {
return RequestConfig.custom()
.setConnectTimeout(CONNECTION_TIMEOUT)
.setSocketTimeout(SOCKET_TIMEOUT)
.setConnectionRequestTimeout(CONNECTION_MANAGER_TIMEOUT)
.build();
}
// 发起带参数的 POST 表单请求，返回字符串结果
public static String postWithParamsForString(String url, List<NameValuePair> params) {
HttpPost httpPost = new HttpPost();
try {
URI uri = new URIBuilder(url).build();
httpPost.setURI(uri);
httpPost.setEntity(new UrlEncodedFormEntity(params, StandardCharsets.UTF_8));
return executeRequest(httpPost);
} catch (URISyntaxException | IOException e) {
log.error("Error executing POST request: {}", e.getMessage());
} finally {
httpPost.releaseConnection();
}
return null;
}
// 发起 GET 请求，返回字符串结果
public static String get(String url, List<NameValuePair> params) {
HttpGet httpGet = new HttpGet();
try {
URI uri = new URIBuilder(url).setParameters(params).build();
httpGet.setURI(uri);
return executeRequest(httpGet);
} catch (URISyntaxException | IOException e) {
log.error("HTTP GET request failed", e);
} finally {
httpGet.releaseConnection();
}
return null;
}
// 发起 Post 请求，返回字符串结果
public static String post(String url, List<NameValuePair> params) {
HttpPost httpPost = new HttpPost();
try {
httpPost.setURI(new URI(url));
httpPost.setEntity(new UrlEncodedFormEntity(params, StandardCharsets.UTF_8));
return executeRequest(httpPost);
} catch (URISyntaxException | IOException e) {
log.error("HTTP POST request failed", e);
} finally {
httpPost.releaseConnection();
}
return null;
}
// 执行 HTTP 请求并处理响应
private static String executeRequest(HttpUriRequest request) throws IOException {
try (CloseableHttpResponse response = httpclient.execute(request, createContext())) {
int statusCode = response.getStatusLine().getStatusCode();
if (statusCode == HttpStatus.SC_OK) {
HttpEntity entity = response.getEntity();
if (entity != null) {
return EntityUtils.toString(entity, encoding);
} else {
log.warn("Empty response entity");
}
} else {
log.error("HTTP request failed with status code: {}", statusCode);
}
} catch (IOException e) {
log.error("HTTP request execution failed: {}", e.getMessage());
throw e;
}
return null;
}
}
静的定数と変数:
初期化と破棄:
HttpClient と接続マネージャーPoolingHttpClientConnectionManager。ScheduledExecutorService 期限切れの接続とアイドル状態の接続を定期的にクリーンアップします。destroyByJvmExit このメソッドでは、JVM 終了フックが登録され、JVM のシャットダウン時にフックが閉じられるようになります。HttpClient。HTTPリクエストメソッド:
postWithParamsForString メソッドは、パラメーターを使用して POST リクエストを実行するために使用されます。HttpPost リクエストを作成し、URL とリクエストパラメータを設定して、最後に呼び出します。executeRequest メソッド実行リクエスト。リクエストを実行し、レスポンスを処理する:
executeRequest メソッド受信HttpUriRequest、HTTP リクエストを実行し、応答を処理します。使用 HttpClientUtils クラスを使用すると、HTTP リクエストの作成と管理を簡素化できます。具体的な手順は次のとおりです。
public class Main {
public static void main(String[] args) {
List<NameValuePair> params = new ArrayList<>();
params.add(new BasicNameValuePair("param1", "value1"));
params.add(new BasicNameValuePair("param2", "value2"));
String response = HttpClientUtils.postWithParamsForString("http://example.com/api", params);
if (response != null) {
System.out.println("Response: " + response);
} else {
System.err.println("Failed to execute POST request");
}
}
}
上記の学習を通じて、使用方法を理解できるはずです。 HttpClientUtils HTTP クライアントを管理し、リクエストを開始するクラス。このアプローチは、Java アプリケーションで HTTP 通信をより効率的に処理するのに役立ち、同時に接続プーリングと定期的なクリーンアップ メカニズムを通じてパフォーマンスと安定性を向上させることができます。
彼は 30 年以上テクノロジーの研究に専念しており、Java、linux、javascript、php、css などのさまざまな言語に堪能であり、オープンソース分野で多くの貢献を行っています。将来の参考のために技術開発におけるいくつかの問題を共有する開発者ドキュメント ステーション。
郵便メール: