जेड पोल के लिए लंबी पोलिंग ए

नेटवर्क पर Nginx और जावास्क्रिप्ट का उपयोग करके लंबे मतदान को कैसे लागू किया जाए, बहुत सारी सामग्री है। लेकिन मुझे अभी तक पूरा गाइड नहीं मिला है। Nginx के तहत मॉड्यूल को संकलित करने में समस्याएं हैं, फिर ब्राउज़र में लंबे पोल अनुरोधों के लिए डाउनलोड आइकन। कट, पूर्ण सामग्री के तहत, आप इसे सही कैसे कर सकते हैं?

लिनक्स के तहत Nginx मॉड्यूल का संकलन

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

इससे पहले, आपके पास सभी आवश्यक पैकेज स्थापित होने चाहिए।

apt-get install git apt-get install make apt-get install g++ apt-get install libpcre3 libpcre3-dev libpcrecpp0 libssl-dev zlib1g-dev 

इसके बाद, आपको nginx- पुश-स्ट्रीम-मॉड्यूल, nginx मॉड्यूल को स्वयं डाउनलोड करना होगा और उन्हें एक साथ संकलित करना होगा।

जीआईटी से एक परियोजना का क्लोन

 git clone http://github.com/wandenberg/nginx-push-stream-module.git 

डाउनलोड करें और खोल नवीनतम nginx

 NGINX_PUSH_STREAM_MODULE_PATH=$PWD/nginx-push-stream-module wget http://nginx.org/download/nginx-1.2.6.tar.gz tar xzvf nginx-1.2.6.tar.gz 

कॉन्फ़िगर और संकलन nginx साथ nginx-धक्का-धारा मॉड्यूल

 cd nginx-1.2.6 ./configure --add-module=../nginx-push-stream-module make make install 

यदि कोई संकलन त्रुटियां नहीं हैं, तो आप कर रहे हैं। हम यह सत्यापित करेंगे कि हमने वास्तव में उस nginx को स्थापित किया है और अब उसके पास वास्तव में nginx-push-stream-मॉड्यूल है

 check: /usr/local/nginx/sbin/nginx -v test configuration: /usr/local/nginx/sbin/nginx -c $NGINX_PUSH_STREAM_MODULE_PATH/misc/nginx.conf -t 

इन आदेशों को निष्पादित करने के बाद, आपको यह देखना चाहिए:

 nginx version: nginx/1.2.6 the configuration file $NGINX_PUSH_STREAM_MODULE_PATH/misc/nginx.conf syntax is ok configuration file $NGINX_PUSH_STREAM_MODULE_PATH/misc/nginx.conf test is successful 

लॉन्ग पोलिंग कनेक्शन्स के लिए Nginx को कॉन्फ़िगर करना

लंबे मतदान समर्थन को कॉन्फ़िगर करने के लिए, Nginx कॉन्फ़िगरेशन में, कम से कम दो नियंत्रकों को पंजीकृत होना चाहिए। ग्राहकों के लिए पहला (जो संदेश प्राप्त करेंगे), दूसरा संदेश के प्रकाशन के लिए (जो संदेश भेजेंगे)।

शेष सर्वर मापदंडों के कॉन्फ़िगरेशन को स्वीकार करते हुए, कॉन्फ़िगरेशन फ़ाइल /usr/local/nginx/nginx.conf को इस तरह दिखना चाहिए:

 ... http { ... server { listen 80; server_name stream.example.com; charset utf-8; location /pub { push_stream_publisher admin; set $push_stream_channel_id $arg_id; allow 1.1.1.1 # ip     } location ~ /sub/(.*) { push_stream_subscriber long-polling; set $push_stream_channels_path $1; push_stream_last_received_message_tag $arg_tag; push_stream_last_received_message_time $arg_time; push_stream_longpolling_connection_ttl 25s; } } } 

इस उदाहरण में, / पब संदेशों को पोस्ट करने के लिए पता है, केवल आपका सर्वर (1.1.1.1) जहां से घटनाएं आ रही हैं, उसे देखना चाहिए, / उप उन ग्राहकों के लिए पता है जिन्हें संदेश भेजे जाएंगे। ग्राहकों की पहचान करने वाले पहचानकर्ता को उप / के बाद पास किया जाता है, और आईडी पैरामीटर / पब में स्वीकार किया जाता है।

जब हम जावास्क्रिप्ट पर स्पर्श करते हैं तो बहुत महत्वपूर्ण पैरामीटर push_stream_last_received_message_tag और push_stream_last_received_message_time नीचे चर्चा की जाएगी।

काम को समझने के लिए उदाहरण:
आप कॉल करके कई ग्राहक बना सकते हैं: stream.example.com/sub/1 , stream.example.com/sub/2 , stream.example.com/sub/3 । उनमें से प्रत्येक 25 सेकंड के लिए Nginx सर्वर पर "लटका" होगा (push_stream_longpolling_connection_ttp)। यदि हम POST अनुरोध को stream.example.com/pub?id=2 पर कॉल करते हैं और शरीर में "हेलो" संदेश भेजते हैं, तो सब्सक्राइबर / हैंग / ऑन / 2 पर प्रतिक्रिया "हैलो" प्राप्त होगी। फायरफॉक्स के लिए पोस्टर प्लगइन में इसे जांचना सुविधाजनक है।

जावास्क्रिप्ट में बनाया जा रहा है ग्राहकों

सबसे अधिक संभावना है, आपको ब्राउज़र में किसी भी डेटा को अपडेट करने के लिए लंबे मतदान का उपयोग करने की आवश्यकता है, और इसके लिए आपको जावास्क्रिप्ट क्लाइंट लिखने की आवश्यकता है।

मैं विभिन्न तरीकों की कोशिश की, लेकिन मानक के लिए चुना XMLHttpRequest । अन्य विधियों की तुलना में, इसके निम्नलिखित फायदे हैं:

• क्रोम ब्राउज़र, फ़ायर्फ़ॉक्स, ओपेरा, आईई 8, 9, 10 में महान काम करता है मील के पत्थर
• ब्राउज़र लटका नहीं है पेज लोड हो रहा है आइकन
• अलग डोमेन में कार्य करना (क्रॉस साइट अगर वहाँ सर्वर के लिए समर्थन है CORS )

चर को सब-वे करें - ग्राहक के लिए एक अद्वितीय मूल्य संग्रहीत है

 var LongPolling = { etag: 0, time: null, init: function () { var $this = this, xhr; if ($this.time === null) { $this.time = $this.dateToUTCString(new Date()); } if (window.XDomainRequest) { //  IE,     (-  IE8) setTimeout(function () { $this.poll_IE($this); }, 2000); } else { //  XMLHttpRequest  mcXHR = xhr = new XMLHttpRequest(); xhr.onreadystatechange = xhr.onload = function () { if (4 === xhr.readyState) { //    if (200 === xhr.status && xhr.responseText.length > 0) { //  Etag  Last-Modified  Header  $this.etag = xhr.getResponseHeader('Etag'); $this.time = xhr.getResponseHeader('Last-Modified'); //    $this.action(xhr.responseText); } if (xhr.status > 0) { //       $this.poll($this, xhr); } } }; //  long polling $this.poll($this, xhr); } }, poll: function ($this, xhr) { var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; // timestamp       xhr.open('GET', url, true); xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); xhr.send(); }, //      poll(),   IE poll_IE: function ($this) { var xhr = new window.XDomainRequest(); var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; xhr.onprogress = function () {}; xhr.onload = function () { $this.action(xhr.responseText); $this.poll_IE($this); }; xhr.onerror = function () { $this.poll_IE($this); }; xhr.open('GET', url, true); xhr.send(); }, action: function (event) { //  ,    -  ... }, valueToTwoDigits: function (value) { return ((value < 10) ? '0' : '') + value; }, //     UTC dateToUTCString: function () { var time = this.valueToTwoDigits(date.getUTCHours()) + ':' + this.valueToTwoDigits(date.getUTCMinutes()) + ':' + this.valueToTwoDigits(date.getUTCSeconds()); return this.days[date.getUTCDay()] + ', ' + this.valueToTwoDigits(date.getUTCDate()) + ' ' + this.months[date.getUTCMonth()] + ' ' + date.getUTCFullYear() + ' ' + time + ' GMT'; } } )। getTime (), var LongPolling = { etag: 0, time: null, init: function () { var $this = this, xhr; if ($this.time === null) { $this.time = $this.dateToUTCString(new Date()); } if (window.XDomainRequest) { //  IE,     (-  IE8) setTimeout(function () { $this.poll_IE($this); }, 2000); } else { //  XMLHttpRequest  mcXHR = xhr = new XMLHttpRequest(); xhr.onreadystatechange = xhr.onload = function () { if (4 === xhr.readyState) { //    if (200 === xhr.status && xhr.responseText.length > 0) { //  Etag  Last-Modified  Header  $this.etag = xhr.getResponseHeader('Etag'); $this.time = xhr.getResponseHeader('Last-Modified'); //    $this.action(xhr.responseText); } if (xhr.status > 0) { //       $this.poll($this, xhr); } } }; //  long polling $this.poll($this, xhr); } }, poll: function ($this, xhr) { var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; // timestamp       xhr.open('GET', url, true); xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); xhr.send(); }, //      poll(),   IE poll_IE: function ($this) { var xhr = new window.XDomainRequest(); var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; xhr.onprogress = function () {}; xhr.onload = function () { $this.action(xhr.responseText); $this.poll_IE($this); }; xhr.onerror = function () { $this.poll_IE($this); }; xhr.open('GET', url, true); xhr.send(); }, action: function (event) { //  ,    -  ... }, valueToTwoDigits: function (value) { return ((value < 10) ? '0' : '') + value; }, //     UTC dateToUTCString: function () { var time = this.valueToTwoDigits(date.getUTCHours()) + ':' + this.valueToTwoDigits(date.getUTCMinutes()) + ':' + this.valueToTwoDigits(date.getUTCSeconds()); return this.days[date.getUTCDay()] + ', ' + this.valueToTwoDigits(date.getUTCDate()) + ' ' + this.months[date.getUTCMonth()] + ' ' + date.getUTCFullYear() + ' ' + time + ' GMT'; } } सच); var LongPolling = { etag: 0, time: null, init: function () { var $this = this, xhr; if ($this.time === null) { $this.time = $this.dateToUTCString(new Date()); } if (window.XDomainRequest) { //  IE,     (-  IE8) setTimeout(function () { $this.poll_IE($this); }, 2000); } else { //  XMLHttpRequest  mcXHR = xhr = new XMLHttpRequest(); xhr.onreadystatechange = xhr.onload = function () { if (4 === xhr.readyState) { //    if (200 === xhr.status && xhr.responseText.length > 0) { //  Etag  Last-Modified  Header  $this.etag = xhr.getResponseHeader('Etag'); $this.time = xhr.getResponseHeader('Last-Modified'); //    $this.action(xhr.responseText); } if (xhr.status > 0) { //       $this.poll($this, xhr); } } }; //  long polling $this.poll($this, xhr); } }, poll: function ($this, xhr) { var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; // timestamp       xhr.open('GET', url, true); xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); xhr.send(); }, //      poll(),   IE poll_IE: function ($this) { var xhr = new window.XDomainRequest(); var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; xhr.onprogress = function () {}; xhr.onload = function () { $this.action(xhr.responseText); $this.poll_IE($this); }; xhr.onerror = function () { $this.poll_IE($this); }; xhr.open('GET', url, true); xhr.send(); }, action: function (event) { //  ,    -  ... }, valueToTwoDigits: function (value) { return ((value < 10) ? '0' : '') + value; }, //     UTC dateToUTCString: function () { var time = this.valueToTwoDigits(date.getUTCHours()) + ':' + this.valueToTwoDigits(date.getUTCMinutes()) + ':' + this.valueToTwoDigits(date.getUTCSeconds()); return this.days[date.getUTCDay()] + ', ' + this.valueToTwoDigits(date.getUTCDate()) + ' ' + this.months[date.getUTCMonth()] + ' ' + date.getUTCFullYear() + ' ' + time + ' GMT'; } } )। getTime (), var LongPolling = { etag: 0, time: null, init: function () { var $this = this, xhr; if ($this.time === null) { $this.time = $this.dateToUTCString(new Date()); } if (window.XDomainRequest) { //  IE,     (-  IE8) setTimeout(function () { $this.poll_IE($this); }, 2000); } else { //  XMLHttpRequest  mcXHR = xhr = new XMLHttpRequest(); xhr.onreadystatechange = xhr.onload = function () { if (4 === xhr.readyState) { //    if (200 === xhr.status && xhr.responseText.length > 0) { //  Etag  Last-Modified  Header  $this.etag = xhr.getResponseHeader('Etag'); $this.time = xhr.getResponseHeader('Last-Modified'); //    $this.action(xhr.responseText); } if (xhr.status > 0) { //       $this.poll($this, xhr); } } }; //  long polling $this.poll($this, xhr); } }, poll: function ($this, xhr) { var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; // timestamp       xhr.open('GET', url, true); xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); xhr.send(); }, //      poll(),   IE poll_IE: function ($this) { var xhr = new window.XDomainRequest(); var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; xhr.onprogress = function () {}; xhr.onload = function () { $this.action(xhr.responseText); $this.poll_IE($this); }; xhr.onerror = function () { $this.poll_IE($this); }; xhr.open('GET', url, true); xhr.send(); }, action: function (event) { //  ,    -  ... }, valueToTwoDigits: function (value) { return ((value < 10) ? '0' : '') + value; }, //     UTC dateToUTCString: function () { var time = this.valueToTwoDigits(date.getUTCHours()) + ':' + this.valueToTwoDigits(date.getUTCMinutes()) + ':' + this.valueToTwoDigits(date.getUTCSeconds()); return this.days[date.getUTCDay()] + ', ' + this.valueToTwoDigits(date.getUTCDate()) + ' ' + this.months[date.getUTCMonth()] + ' ' + date.getUTCFullYear() + ' ' + time + ' GMT'; } } सच); var LongPolling = { etag: 0, time: null, init: function () { var $this = this, xhr; if ($this.time === null) { $this.time = $this.dateToUTCString(new Date()); } if (window.XDomainRequest) { //  IE,     (-  IE8) setTimeout(function () { $this.poll_IE($this); }, 2000); } else { //  XMLHttpRequest  mcXHR = xhr = new XMLHttpRequest(); xhr.onreadystatechange = xhr.onload = function () { if (4 === xhr.readyState) { //    if (200 === xhr.status && xhr.responseText.length > 0) { //  Etag  Last-Modified  Header  $this.etag = xhr.getResponseHeader('Etag'); $this.time = xhr.getResponseHeader('Last-Modified'); //    $this.action(xhr.responseText); } if (xhr.status > 0) { //       $this.poll($this, xhr); } } }; //  long polling $this.poll($this, xhr); } }, poll: function ($this, xhr) { var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; // timestamp       xhr.open('GET', url, true); xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); xhr.send(); }, //      poll(),   IE poll_IE: function ($this) { var xhr = new window.XDomainRequest(); var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; xhr.onprogress = function () {}; xhr.onload = function () { $this.action(xhr.responseText); $this.poll_IE($this); }; xhr.onerror = function () { $this.poll_IE($this); }; xhr.open('GET', url, true); xhr.send(); }, action: function (event) { //  ,    -  ... }, valueToTwoDigits: function (value) { return ((value < 10) ? '0' : '') + value; }, //     UTC dateToUTCString: function () { var time = this.valueToTwoDigits(date.getUTCHours()) + ':' + this.valueToTwoDigits(date.getUTCMinutes()) + ':' + this.valueToTwoDigits(date.getUTCSeconds()); return this.days[date.getUTCDay()] + ', ' + this.valueToTwoDigits(date.getUTCDate()) + ' ' + this.months[date.getUTCMonth()] + ' ' + date.getUTCFullYear() + ' ' + time + ' GMT'; } } ',' var LongPolling = { etag: 0, time: null, init: function () { var $this = this, xhr; if ($this.time === null) { $this.time = $this.dateToUTCString(new Date()); } if (window.XDomainRequest) { //  IE,     (-  IE8) setTimeout(function () { $this.poll_IE($this); }, 2000); } else { //  XMLHttpRequest  mcXHR = xhr = new XMLHttpRequest(); xhr.onreadystatechange = xhr.onload = function () { if (4 === xhr.readyState) { //    if (200 === xhr.status && xhr.responseText.length > 0) { //  Etag  Last-Modified  Header  $this.etag = xhr.getResponseHeader('Etag'); $this.time = xhr.getResponseHeader('Last-Modified'); //    $this.action(xhr.responseText); } if (xhr.status > 0) { //       $this.poll($this, xhr); } } }; //  long polling $this.poll($this, xhr); } }, poll: function ($this, xhr) { var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; // timestamp       xhr.open('GET', url, true); xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); xhr.send(); }, //      poll(),   IE poll_IE: function ($this) { var xhr = new window.XDomainRequest(); var timestamp = (new Date()).getTime(), url = 'http://stream.example.com/sub/' + subID + '?callback=?&v=' + timestamp; xhr.onprogress = function () {}; xhr.onload = function () { $this.action(xhr.responseText); $this.poll_IE($this); }; xhr.onerror = function () { $this.poll_IE($this); }; xhr.open('GET', url, true); xhr.send(); }, action: function (event) { //  ,    -  ... }, valueToTwoDigits: function (value) { return ((value < 10) ? '0' : '') + value; }, //     UTC dateToUTCString: function () { var time = this.valueToTwoDigits(date.getUTCHours()) + ':' + this.valueToTwoDigits(date.getUTCMinutes()) + ':' + this.valueToTwoDigits(date.getUTCSeconds()); return this.days[date.getUTCDay()] + ', ' + this.valueToTwoDigits(date.getUTCDate()) + ' ' + this.months[date.getUTCMonth()] + ' ' + date.getUTCFullYear() + ' ' + time + ' GMT'; } } 

दो मापदंडों etag और समय का उल्लेख करना महत्वपूर्ण है।

 xhr.setRequestHeader("If-None-Match", $this.etag); xhr.setRequestHeader("If-Modified-Since", $this.time); 

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

निष्कर्ष में

इस विषय में वर्णित विधि का उपयोग किया जाता है और हमारे Cackle टिप्पणी प्रणाली में सफलतापूर्वक काम करता है । हर दिन हमारे पास लगभग 20,000 - 30,000 समवर्ती ग्राहक हैं, और हमने संदेश वितरण में कोई त्रुटि नहीं देखी है। उत्पादन समाधान के लिए, यह वही है जो आपको चाहिए।