विशेषताएँ java.net का HttpUrlConnection

स्वागत

आज मैं इस बारे में बात करने की कोशिश करूंगा कि आप कैसे एक अनुरोध भेज सकते हैं और जेआरई लाइब्रेरी से URLConnection का उपयोग करके HTTP सर्वर से प्रतिक्रिया पढ़ सकते हैं।

वर्तमान में हम जावा को ऑनलाइन सीख रहे हैं। हमारी पूरी टीम काम और संचार के लिए स्लैक का उपयोग करती है। उपयोगकर्ताओं के बारे में जानकारी के लिए, हम स्लैक एपीआई का उपयोग करते हैं। एपीआई के बारे में लंबे समय तक बात नहीं करने के लिए (यह एक अलग लेख के लिए एक विषय है), मैं संक्षेप में कहूंगा: स्लैक एपीआई को एचटीटीपी प्रोटोकॉल पर बनाया गया है, उपयोगकर्ताओं के बारे में जानकारी प्राप्त करने के लिए, आपको एक यूआरआई के साथ एक अनुरोध भेजने की आवश्यकता है जिसमें एपीआई से होस्ट पता एपीआई के लिए एक विधि का नाम होना चाहिए । slack.com यहाँ कुछ तरीकों की एक सूची है:

• users.list
• chat.postMessage
• conversations.create
• files.upload
• im.open

उपयोगकर्ता सूची पाने के लिए, आपको उपयोक्ताओं की सूची चाहिए। विधि। हम अनुरोध निकाय में URI - /api/users.list बनाते हैं । फॉर्म एप्लीकेशन / x-www-form-urlencoded में एक प्रमाणीकरण टोकन होना चाहिए, अर्थात, अनुरोध कुछ इस तरह दिखना चाहिए (लेकिन एक विकल्प है जो निम्न होगा):

GET /users.list HTTP/1.1 Content-Type: application/x-www-form-urlencoded token=xoxp-1234567890-098765-4321-a1b2c3d4e5 

मैं अपाचे HttpCompords पुस्तकालय के बारे में जानता था, लेकिन अनुसंधान उद्देश्यों के लिए हम मानक जावा 8 पुस्तकालय में उपलब्ध उपकरणों का उपयोग करेंगे, अर्थात् java.net.URLConnection का कार्यान्वयन।

URLConnection इकाई प्राप्त करने के लिए, आपको java.net.URL वर्ग की वस्तु का उपयोग करने की आवश्यकता है, इसका निर्माता स्ट्रिंग प्रकार लेता है, जहां सब कुछ के अलावा, प्रोटोकॉल को निर्दिष्ट किया जाना चाहिए - हमारे मामले में, https।

URL इकाई प्राप्त करने के बाद, हम OpenConnection () पद्धति को कॉल करते हैं जो HttpsUrlConnection इकाई को लौटाएगी।

 String url = “https://slack.com/api/users.list”; URLConnection connection = new URL(url).openConnection(); 

इस स्थिति में, आपको MalformedUrlException और IOException को संभालना या फेंकना होगा।

उसके बाद, कनेक्शन चर HttpsUrlConnectionImpl ऑब्जेक्ट के लिए एक संदर्भ संग्रहीत करेगा। डिफ़ॉल्ट रूप से, एक GET अनुरोध उत्पन्न होगा। एक हेडर जोड़ने के लिए, हम setRequestProperty () विधि का उपयोग करते हैं, जो कुंजी और मान को स्वीकार करता है। हमें यहां एक सामग्री-प्रकार स्थापित करने की आवश्यकता है जिसमें मूल्य अनुप्रयोग / x-www-form-urlencoded है । खैर, और हम करते हैं!

 connection.setRequestProperty(“Content-Type”, “application/x-www-form-urlencoded”); 

अब यह केवल हमारे टोकन लिखने और शरीर में सीमित करने के लिए अनुरोध भेजने के लिए रहता है। ऐसा करने के लिए, कनेक्शन ऑब्जेक्ट के doOutput फ़ील्ड को setDoOutput () विधि का उपयोग करके सही पर सेट करें;

 connection.setDoOutput(true); 

अगला, सबसे दिलचस्प हिस्सा - आपको किसी तरह से हमारे शरीर को आउटपुटस्ट्रीम में भेजने की आवश्यकता है। हम OutputStreamWriter का उपयोग करेंगे:

 OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream()); 

एक चेतावनी है: जब हम getOutputStream () विधि कहते हैं, तो अनुरोध विधि POST में बदल जाती है, क्योंकि GET अनुरोध निकाय के लिए प्रदान नहीं करता है, लेकिन लाभ यह है कि स्लैक विधि पर सख्त प्रतिबंध नहीं लगाता है, इसलिए सब कुछ ठीक था। और इसलिए GET अनुरोध इस तरह दिखना चाहिए:

 GET /users.list?token=xoxp-1234567890-098765-4321-a1b2c3d4e5&limit=100 HTTP/1.1 Content-Type: application/x-www-form-urlencoded 

लेकिन मैंने इसे फिर से शुरू नहीं किया। और इसके बजाय, हमारा अनुरोध इस तरह निकला:

 POST /users.list HTTP/1.1 Content-Type: application/x-www-form-urlencoded token=xoxp-1234567890-098765-4321-a1b2c3d4e5 

(* कुछ हेडर स्वयं HttpsUrlConnection द्वारा निर्धारित किए गए हैं और वे यहां अनुपस्थित हैं)

और इसलिए, हमारे अनुरोध शरीर को लिखने के लिए, हम लिखने का उपयोग करते हैं ();

 String reqBody = “token=xoxp-1234567890-098765-4321-a1b2c3d4e5&limit=100”; writer.write(reqBody); writer.close(); 

उसके बाद, हमारा अनुरोध भेजा जाएगा, और हम प्राप्त प्रतिक्रिया को पढ़ सकते हैं। InputStream प्राप्त करने से पहले OutputStream को बंद करना या फ्लश करना महत्वपूर्ण है, अन्यथा डेटा बफर को नहीं छोड़ेगा (वैकल्पिक रूप से, आप PrintStream का उपयोग कर सकते हैं - Println () विधि में, flush () को डिफ़ॉल्ट रूप से कहा जाता है)। पढ़ने के लिए मैंने बफ़रडर का उपयोग किया:

 StringBuilder respBody = new StringBuilder(); BufferedReader reader = new BufferedReader(connection.getInputStream()); reader.lines().forEach(l -> respBody.append(l + “\r\n”); reader.close(); 

(* आउटपुट पर स्ट्रीम पाने के लिए () लाइनों का उपयोग करें; \ r \ n - CRLF वर्ण - एक नई लाइन में एक संक्रमण सम्मिलित करता है)

और, अगर हम सफलतापूर्वक प्रमाणित करते हैं, तो रिस्पॉन्स चर को सर्वर से हमारी प्रतिक्रिया को संग्रहित करना चाहिए, जो हमारे मामले में एक JSON ऑब्जेक्ट है। उसके बाद, इसे प्रसंस्करण के अगले चरण में भेजा जा सकता है।

कुछ अनुकूलन के बाद, सब कुछ इस तरह दिखता है:

 package main.java.com.bilichenko.learning; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStreamWriter; import java.net.HttpURLConnection; import java.net.MalformedURLException; import java.net.URL; import java.nio.charset.Charset; import java.util.Optional; import java.util.stream.Collectors; public class SlackClient { private static final String HOST = "https://api.slack.com"; private static final String GET_USERS_URI = "/api/users.list"; private static final String TOKEN = "xx-ooo-YOUR-TOKEN-HERE"; public static void main(String[] args) throws IOException { SlackClient slackClient = new SlackClient(); System.out.println(slackClient.getRawResponse(HOST + GET_USERS_URI, "application/x-www-form-urlencoded", "token=" + TOKEN).orElse("no response")); } public Optional<String> getRawResponse(String url, String contentType, String requestBody) throws MalformedURLException, IOException { HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection(); connection.setRequestProperty("Content-Type", contentType); connection.setConnectTimeout(10000); connection.setRequestMethod("POST"); connection.setDoOutput(true); try(OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream())) { writer.write(requestBody); } if (connection.getResponseCode() != 200) { System.err.println("connection failed"); return Optional.empty(); } try(BufferedReader reader = new BufferedReader( new InputStreamReader(connection.getInputStream(), Charset.forName("utf-8")))) { return Optional.of(reader.lines().collect(Collectors.joining(System.lineSeparator()))); } } } 

आशा है कि यह मददगार था!