प्रौद्योगिकी साझेदारी

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

---

I. परिचयः

आधुनिकसॉफ्टवेयरविकासे प्रायः दूरस्थसर्वरैः सह संवादः आवश्यकः भवति, यथा दत्तांशं प्राप्तुं वा दत्तांशं प्रेषयितुं वा । Apache HttpClient इति लोकप्रियं Java HTTP क्लायन्ट् पुस्तकालयं यत् HTTP अनुरोधानाम् आरम्भं प्रतिक्रियाप्रक्रियाकरणं च सरलीकरोति ।अस्मिन् लेखे कस्टम् इत्यस्य उपयोगः कथं करणीयः इति परिचयः भविष्यतिHttpClientUtils POST अनुरोधं आरभ्य कार्यक्षमतां अनुकूलितुं संयोजनपूलं प्रबन्धयितुं Apache HttpClient इत्यस्य उपयोगं कर्तुं वर्गः ।

1.HttpClientUtils वर्ग अवलोकन

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;
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133

2. HttpClientUtils वर्गस्य विश्लेषणं कुर्वन्तु

1. स्थिरनित्याः चराः च:

   • अधिकतमसंयोजनसङ्ख्या, संयोजनसमयसमाप्तिः, Socketसमयसमाप्तिः इत्यादयः स्थिराः चराः च परिभाषयति ।

2. आरम्भीकरणं च विनाशः च:

   • स्थिरसङ्केतखण्डे आरब्धम् HttpClient तथा संयोजनप्रबन्धकःPoolingHttpClientConnectionManager。
   • उपयुञ्जताम्‌ ScheduledExecutorService नियमितरूपेण अवधिसमाप्तं निष्क्रियं च संयोजनं स्वच्छं कुर्वन्तु।
   • अस्ति destroyByJvmExit पद्धत्या JVM निर्गमन हुक् पञ्जीकृतः भवति यत् JVM निष्क्रियः भवति तदा सः बन्दः भवति इति सुनिश्चितं भवति ।HttpClient。

3. HTTP अनुरोधविधिः:

   • postWithParamsForString पैरामीटर् सह POST अनुरोधं कर्तुं विधिः उपयुज्यते ।
   • उपयुञ्जताम्‌ HttpPost अनुरोधं निर्माय URL तथा अनुरोधमापदण्डं सेट् कुर्वन्तु, अन्ते च आह्वानं कुर्वन्तुexecuteRequest विधि निष्पादन अनुरोध।

4. अनुरोधं निष्पादयन्तु प्रतिक्रियाः च संसाधयन्तु:

   • executeRequest विधि प्राप्तिHttpUriRequest, HTTP अनुरोधं कुर्वन्तु प्रतिक्रियाः च संसाधयन्ति ।
   • प्रतिक्रियायाः स्थितिसङ्केतं पश्यन्तु, यदि 200 (OK) अस्ति तर्हि प्रतिक्रियासत्तां पठित्वा स्ट्रिंग् मध्ये परिवर्त्य प्रत्यागच्छन्तु ।
   • भवतः कोडस्य दृढतां विश्वसनीयतां च सुनिश्चित्य त्रुटिं चेतावनीसन्देशं च अभिलेखयितुं लॉगिंग् इत्यस्य उपयोगं कुर्वन्तु ।

3. HttpClientUtils वर्गस्य उपयोगं कुर्वन्तु

उपयुञ्जताम्‌ 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");
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

उपर्युक्तशिक्षणद्वारा इदानीं भवद्भिः कथं उपयोगः कर्तव्यः इति अवगन्तव्यम् HttpClientUtils HTTP क्लायन्ट् प्रबन्धयितुं अनुरोधं च आरभ्यतुं वर्गः । एषः उपायः जावा-अनुप्रयोगेषु HTTP-सञ्चारं अधिक-कुशलतया नियन्त्रयितुं साहाय्यं कर्तुं शक्नोति, तथा च संयोजन-पूलिंग्-आवधिक-सफाई-तन्त्राणां माध्यमेन कार्यक्षमतां स्थिरतां च सुदृढं कर्तुं शक्नोति