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

जावा HTTP अनुरोधानाम् आरम्भार्थं HttpClientUtils इत्यस्य उपयोगं कथं करोति

2024-07-12

한어Русский язык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-सञ्चारं अधिक-कुशलतया नियन्त्रयितुं साहाय्यं कर्तुं शक्नोति, तथा च संयोजन-पूलिंग्-आवधिक-सफाई-तन्त्राणां माध्यमेन कार्यक्षमतां स्थिरतां च सुदृढं कर्तुं शक्नोति