2024-07-12
한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina
आधुनिकसॉफ्टवेयरविकासे प्रायः दूरस्थसर्वरैः सह संवादः आवश्यकः भवति, यथा दत्तांशं प्राप्तुं वा दत्तांशं प्रेषयितुं वा । Apache HttpClient इति लोकप्रियं Java HTTP क्लायन्ट् पुस्तकालयं यत् HTTP अनुरोधानाम् आरम्भं प्रतिक्रियाप्रक्रियाकरणं च सरलीकरोति ।अस्मिन् लेखे कस्टम् इत्यस्य उपयोगः कथं करणीयः इति परिचयः भविष्यतिHttpClientUtils
POST अनुरोधं आरभ्य कार्यक्षमतां अनुकूलितुं संयोजनपूलं प्रबन्धयितुं Apache HttpClient इत्यस्य उपयोगं कर्तुं वर्गः ।
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 क्लायन्ट् प्रबन्धयितुं अनुरोधं च आरभ्यतुं वर्गः । एषः उपायः जावा-अनुप्रयोगेषु HTTP-सञ्चारं अधिक-कुशलतया नियन्त्रयितुं साहाय्यं कर्तुं शक्नोति, तथा च संयोजन-पूलिंग्-आवधिक-सफाई-तन्त्राणां माध्यमेन कार्यक्षमतां स्थिरतां च सुदृढं कर्तुं शक्नोति