HTTP पर अतुल्यकालिक डेटा विनिमय

बहुत समय पहले, काम पर, मुझे जावा वेब एप्लिकेशन और क्लाइंट फ्रंट-एंड वेब एंड के बीच अतुल्यकालिक डेटा विनिमय के लिए एक तंत्र को लागू करने का काम सौंपा गया था। कार्य क्लाइंट के लिए न्यूनतम विलंब के साथ अपडेट प्राप्त करने के लिए था, जबकि अपडेट प्रति सेकंड 100 अपडेट की गति, और प्रति मिनट 1 अपडेट, अर्थात् हो सकता है। यह उचित है कि ग्राहक से अनावश्यक अनुरोध न भेजें।

सबसे पहले, मैंने एक परीक्षण सर्वलेट को स्केच किया जो क्लाइंट से भेजे गए अनुरोध पर तुरंत प्रतिक्रिया देता था, जिस पर यह अनुरोध हर सेकंड उत्पन्न होता था। बेशक, यह योजना आदर्श से बहुत दूर थी, इसलिए मैंने गूगल करना शुरू किया।


वैसे, जिस योजना से यह काम किया गया था:



और यहाँ कुछ क्लाइंट-साइड कोड (कुछ भी अलौकिक नहीं है: एक टाइमर + एक JSON अनुरोध भेजना):

function onLoad() { // Invoke request update each second intervalId = setInterval ( requestUpdate(), 1000 ); } function requestUpdate() { $.getJSON(URL, JSONParams, function(data) { $.each(data, function(key, val) { // Process data }) }).success(function(){ // Succes handler }).error(function(){ // Error handler }); }; function onUnload() { clearInterval(intervalID); }; $(document).ready(function() { // Disable caching for ajax $.ajaxSetup({ cache: false }); }); 

और सर्वर की ओर से (नैतिक पहलुओं के लिए, मैं आवेदन के व्यावसायिक तर्क के लिए जिम्मेदार कोड को विभाजित नहीं कर सकता, लेकिन लेख का बिंदु इसमें नहीं है):

 public void doGet(HttpServletRequest req, HttpServletResponse res) throws ServletException, IOException { //Get reqeust parameters JSONObject jsonObj = JSONObject.fromObject(req.getParameterMap()); //Some code //Get writer PrintWriter out = res.getWriter(); //Create json object for response Map<String, String[]> map = retriever.getUpdates(); JSONObject jsonObject = JSONObject.fromObject(map); //Send response out.println(jsonObject); //Finish response! out.close(); } 

पहली बात जो मुझे पता चली , वह थी लॉन्ग पोलिंग के बारे में लेख (मैंने तुरंत ही वेबस्कॉफ़्ट को बाहर कर दिया, क्योंकि सभी क्लाइंट के पास आधुनिक ब्राउज़र स्थापित नहीं हो सकते)। मुझे IBM Developerworks वेबसाइट पर एक लेख में बहुत दिलचस्पी थी, जो http प्रोटोकॉल का उपयोग करके सर्वर और क्लाइंट के बीच अतुल्यकालिक डेटा विनिमय के आयोजन के मुख्य बिंदुओं का विवरण देता है। लेख में, मैंने एक दिलचस्प उदाहरण पर ध्यान आकर्षित किया। मैं आपको इसके साथ खुद को परिचित करने की सलाह देता हूं (निश्चित रूप से, यदि आप रुचि रखते हैं)।

जैसा कि बाद में टॉमकैट में निकला, जो ग्राहकों द्वारा उपयोग किया जाता है, इसमें omet (Pushing) तंत्र का भी समर्थन है। यह CometProcessor इंटरफ़ेस को लागू करके लागू किया गया है। एक विस्तृत उदाहरण टॉमकैट वेबसाइट पर है, इसलिए मैं उदाहरणों के साथ प्रलेखन का संदर्भ देने की सलाह देता हूं।

नतीजतन, मैंने सर्वर पर इस इंजन को लागू करने का फैसला किया। मैं एक उदाहरण नहीं दूंगा, क्योंकि यह ऊपर से थोड़ा अलग है (लेखों के लिंक में)।

लंबे मतदान कनेक्शन के काम की योजना:



आपके द्वारा ऊपर देखी गई योजना से मुख्य अंतर यह है कि सर्वर तुरंत प्रतिक्रिया नहीं भेजता है, लेकिन किसी विशिष्ट घटना की प्रतीक्षा करता है। यह रिक्वेस्ट हैडर में की-लाइव टैग सेट करके हासिल किया जाता है। यह टैग सर्वर को समय से पहले डिस्कनेक्ट नहीं करने का कारण बनता है। प्रतिक्रिया भेजे जाने के बाद और ग्राहक को प्राप्त होने के बाद, ग्राहक फिर से एक अन्य अनुरोध भेजता है और प्रतिक्रिया का इंतजार करता है। अनिवार्य रूप से यहां हम एक पुनरावर्ती कॉल देख रहे हैं।

Javascpirt पर एक लंबे मतदान ग्राहक को लागू करना:

 function go(){ var url = "your url" var request = new XMLHttpRequest(); request.open("GET", url, true); request.setRequestHeader("Content-Type","application/x-javascript;"); request.onreadystatechange = function() { if (request.readyState == 4) { if (request.status == 200){ if (request.responseText) { //Something } } go(); } }; request.send(null); } 

और यह jQuery का उपयोग करके इस तरह दिखेगा:

 function poll(){ $.ajax({ url: "your url", success: function(data){ //Something }, dataType: "json", complete: poll, timeout: 30000 }); }); 

स्ट्रीम कनेक्शन की योजना:



यहां, जैसा कि आप देख सकते हैं, क्लाइंट बहुत शुरुआत में केवल 1 अनुरोध भेजता है। और फिर सर्वर प्रत्येक घटना के लिए ग्राहक को जानकारी का एक टुकड़ा भेजता है। यह इस तथ्य के कारण प्राप्त होता है कि प्रतिक्रिया में लेखक बंद नहीं करता है, भेजना केवल फ्लश () विधि के माध्यम से किया जाता है। इसके लिए धन्यवाद, क्लाइंट स्ट्रीम से जानकारी पढ़ना जारी रखता है।

जावास्क्रिप्ट क्लाइंट स्ट्रीम कार्यान्वयन:

 function switchXHRState() { switch (this.readyState) { case 0: $("#messages").append("open() has not been called yet."); break; case 1: $("#messages").append("send() has not been called yet."); break; case 2:$("#messages").append("send() has been called, headers and status are available."); break; case 3: if (this.status == 200) {Some lines of code} break; case 4: $("#messages").append("Complete!"); break; } }; function go() { var url = "comet"; var request = new XMLHttpRequest(); request.onreadystatechange = switchXHRState; request.open("GET", url, true); request.setRequestHeader("Content-Type", "application/x-javascript;"); request.setRequestHeader("Cache-Control", "no-cache"); request.setRequestHeader("Cache-Control", "no-store"); request.setRequestHeader("Cache-Control", "no-store"); request.send(null); } 

अतिरिक्त सामग्री:
1. पुश प्रौद्योगिकी पर विकिपीडिया लेख
2. अंग्रेजी में एक लेख , जहां से चित्र लिए गए थे
3. AJAX पैटर्न (नाम स्वयं के लिए बोलता है)
4. XMLHttpRequest विनिर्देशन