मिनट में आपकी साइट पर रीयलटाइम

खेल के विकास के दौरान, हमें उपयोगकर्ताओं के बीच अधिकतम रियलटाइम डेटा विनिमय सुनिश्चित करने की आवश्यकता का सामना करना पड़ा, जिसमें विभिन्न धूमकेतु पुस्तकालयों के साथ प्रयोग किए गए थे।
पहली बाइक dklab realplexor पर बनाई गई थी, जो कि, जैसा कि उम्मीद थी, इसे इस्तेमाल करने का अगला प्रयास था। शायद हमारे हाथ टेढ़े हैं, लेकिन, दुर्भाग्यवश, हम 5-10-15 सेकंड की देरी के बिना घटनाओं को प्राप्त करने में सफल नहीं हुए।
एक नखरे के साथ नृत्य लंबे समय तक चला, जिसके परिणामस्वरूप हमने nginx_http_push_module पर रुकने का फैसला किया, और बिताया गया समय अभी भी इसके लायक था।

इस मॉड्यूल के साथ काम करते समय आने वाली मुख्य समस्याएं:

• एक अक्षम कैश घटनाओं की हानि को रोकता है (250 पास का एक चक्र ग्राहक को केवल 3 इवेंट देता है)।
• शामिल कैश अंतिम ईवेंट की पुनरावर्ती पुनर्प्राप्ति को पूरा करता है।

कमियों के बीच, पुस्तकालय के स्तर पर एक साथ कई चैनलों पर संदेश भेजने की असंभवता को दूर किया जा सकता है, जो कि वास्तविक स्थिति में है, साथ ही साथ चैनल में आने वाली कई घटनाओं को कम समय (पुनर्निर्माण समय) में संग्रहीत करने की कमी है।

जेएसगल ने जेएस फ़ंक्शन को खोजने में मदद की, जिसने पहली नज़र में, समस्या को हल किया:

function Listener(url, successCallback, failureCallback) { var scope = this; var etag = 0, lastModified = 0; var launched = false; var failure = false; this.successTimeout = 0; this.failureTimeout = 5000; var getTimeout = function () { return failure ? this.failureTimeout : this.successTimeout; }; var listen = function () { $.ajax(scope.ajaxOptions); } var beforeSend = function (jqXHR) { jqXHR.setRequestHeader("If-None-Match", etag); jqXHR.setRequestHeader("If-Modified-Since", lastModified); }; var complete = function (jqXHR) { var timeout = getTimeout(); etag = jqXHR.getResponseHeader('Etag'); lastModified = jqXHR.getResponseHeader('Last-Modified'); var timeout = jqXHR.statusText == 'success' ? scope.successTimeout : scope.failureTimeout; if (timeout > 0) { setTimeout(listen, timeout); } else { listen(); } }; this.ajaxOptions = { url : url, type : 'GET', async : true, error : failureCallback, success : successCallback, dataType : 'json', complete : complete, beforeSend : beforeSend, timeout: 1000 * 60 * 60 * 24 }; this.start = function (timeout) { if (!launched) { if (typeof(timeout) == 'undefined' || timeout == 0) { listen(); } else { setTimeout(listen, timeout); } launched = true; } }; } 

तम्बुओं के साथ कुछ नृत्यों ने यह स्पष्ट कर दिया कि उसे कोठरी में उसके कंकाल भी मिले हैं:

• यदि क्लाइंट के लिए कई ईवेंट आए हैं, और उसके तुरंत बाद एक पेज रिफ्रेश होना चाहिए - वे आपके पास फिर से (कैश से) आ जाएंगे।
• यदि टैब लंबे समय से निष्क्रिय है, तो अनुरोध मर गया और अब पृष्ठ ताज़ा होने तक संसाधित नहीं हुआ।

पहली समस्या को काफी सरलता से प्रतिस्थापित करके हल किया गया था
var etag = 0, lastModified = 0;
पर
var etag = 0:
lastModified = LOAD_TIME;
जहां LOAD_TIME को इंडेक्स में एक स्थिरांक द्वारा सेट किया गया था, जैसे
var LOAD_TIME = "<?=date('r');?>";
दूसरी समस्या, मुझे उम्मीद थी कि इसे हल करने में उतना ही आसान होगा
timeout: 1000 * 60 * 60 * 24
पर
timeout: 1000 * 20
प्रत्येक एक्स सेकंड (हमारे मामले में, इष्टतम अंतराल 20 सेकंड था) नगनेक्स के लिए एक मजबूर पुनर्निर्माण बनाना।
लेकिन परीक्षण शुरू करने से, उसे पहले की तुलना में और भी अधिक टक्कर मिली - पुनर्निर्माण के बाद, घटनाओं की नारकीय बाढ़ शुरू हुई। स्थिति स्पष्ट करने के लिए धन्यवाद सांत्वना। समस्या यह थी कि जब क्विकर पुनर्निर्माण कर रहा था, तो पूरा हैंडलर हेडर डेटा को अपडेट करना जारी रखता था, इसलिए अगला अनुरोध आईफ-नो-मैच और इफ-मॉडिफाइड-चूंकि-रिक्त था।

अंत में, हमें सबसे स्थिर कार्य मिला:

 <script> var LOAD_TIME = "<?=date('r');?>"; /* * !        ,      ,   index.php,     JS ,    . */ function Listener(url, successCallback, failureCallback) { var scope = this; var etag = 0; var lastModified = LOAD_TIME; var launched = false; var failure = false; this.successTimeout = 1000; this.failureTimeout = 0; var getTimeout = function () { return failure ? this.failureTimeout : this.successTimeout; }; var listen = function () { $.ajax(scope.ajaxOptions); } var beforeSend = function (jqXHR) { jqXHR.setRequestHeader("If-None-Match", etag); jqXHR.setRequestHeader("If-Modified-Since", lastModified); cw("BEFORE None-Match : "+etag); cw("BEFORE Modified : "+lastModified); }; var complete = function (jqXHR) { var timeout = getTimeout(); if (jqXHR.getResponseHeader('Etag') != null && jqXHR.getResponseHeader('Last-Modified') != null) { etag = jqXHR.getResponseHeader('Etag'); lastModified = jqXHR.getResponseHeader('Last-Modified'); } var timeout = jqXHR.statusText == 'success' ? scope.successTimeout : scope.failureTimeout; if (timeout > 0) { setTimeout(listen, timeout); } else { listen(); } }; this.ajaxOptions = { url : url, type : 'GET', async : true, error : failureCallback, success : successCallback, dataType : 'json', complete : complete, beforeSend : beforeSend, timeout: 1000 * 20 }; this.start = function (timeout) { if (!launched) { if (typeof(timeout) == 'undefined' || timeout == 0) { listen(); } else { setTimeout(listen, timeout); } launched = true; } }; this.start(); } </script> 

ईवेंट हैंडलर कॉल कुछ इस तरह दिखती है:

 <script> $(document).ready(function() { Listener('/listener?cid=chanel_1', onSuccess, onError); }); /* *onSuccess  onError -   ( )    ,        . */ function onSuccess (data) { if (data) { $("#messages").prepend(data.time + " | " +data.msg); } else { console.log("EMPTY DATA"); } } function onError () { alert("ERROR"); } </script> 

चूंकि मॉड्यूल की साइट पर उदाहरणों में कोई कोड नहीं है जो एक ही बार में कई चैनलों को संदेश भेज सकता है, हमने अपना फ़ंक्शन लिखने का फैसला किया।
Php कार्यान्वयन:

 <? function push ($cids, $text) { /* * $cids - ID ,  ,     - ID  * $text - ,    */ $c = curl_init(); $url = 'http://server_name/publisher?cid='; $message = array( 'time' => time(), 'msg' => $text ); curl_setopt($c, CURLOPT_RETURNTRANSFER, true); curl_setopt($c, CURLOPT_POST, true); if (is_array($cids)) { foreach ($cids as $v) { curl_setopt($c, CURLOPT_URL, $url.$v); curl_setopt($c, CURLOPT_POSTFIELDS, json_encode($message)); $r = curl_exec($c); } } else { curl_setopt($c, CURLOPT_URL, $url.$cids); curl_setopt($c, CURLOPT_POSTFIELDS, json_encode($message)); $r = curl_exec($c); } curl_close($c); } // push (1, ""); // push (array(1, 2, 3), ""); // push (array('chanel_1' => 1, 'chanel_2' => 'user_100500', 'chanel_3' => 'global'), ""); 

Dklab Realplexor की स्थापना के साथ, डेवलपर की वेबसाइट (http://dklab.ru/lib/dklab_realplexor) पर कोई समस्या उत्पन्न नहीं हुई और पूर्ण प्रलेखन उपलब्ध है।
हालाँकि, nginx_http_push_module के साथ , यह इतना सरल नहीं है, ईमानदार होने के लिए, एक तैयार पैकेज खोजना संभव नहीं था जिसमें CentOS पर यह मॉड्यूल शामिल है, इसलिए हमने स्रोत से सब कुछ एकत्र किया।

तो चलिए शुरू करते हैं:

एक डैडी बनाएं जहां हम सभी आवश्यक तत्व डाउनलोड करेंगे

 mkdir ~/nginx_push; cd ~/nginx_push; 

गितुब से नवीनतम स्रोत डाउनलोड करें:

 git clone git://github.com/slact/nginx_http_push_module.git 

Nginx का नवीनतम संस्करण डाउनलोड करें, हमारे मामले में यह nginx-1.1.15 है

 wget http://nginx.org/download/nginx-1.1.15.tar.gz; 

अतिरिक्त आवश्यक लाइब्रेरी डाउनलोड करें:

 wget ftp://ftp.csx.cam.ac.uk/pub/software/programming/pcre/pcre-8.21.tar.gz; wget http://zlib.net/zlib-1.2.6.tar.gz; 

अभिलेखागार को अनपैक करें:

 tar -zxf nginx-1.1.15.tar.gz; tar -zxf pcre-8.21.tar.gz tar -zxf zlib-1.2.6.tar.gz 

Nginx स्रोत फ़ोल्डर पर जाएं

 cd nginx-1.1.15; 

और nginx को कॉन्फ़िगर करें

 ./configure --prefix=/usr --sbin-path=/usr/sbin/nginx --conf-path=/etc/nginx/nginx.conf --error-log-path=/var/log/nginx/error.log --pid-path=/var/run/nginx/nginx.pid --lock-path=/var/lock/nginx.lock --user=nginx --group=nginx --with-http_ssl_module --with-http_gzip_static_module --http-log-path=/var/log/nginx/access.log --http-client-body-temp-path=/tmp/nginx/client/ --http-proxy-temp-path=/tmp/nginx/proxy/ --http-fastcgi-temp-path=/tmp/nginx/fcgi --with-pcre=../pcre-8.21 --with-zlib=../zlib-1.2.6 --with-http_perl_module --with-http_stub_status_module –add-module=../nginx_http_push_module/ 

तो

 make make install 

अब फाइल /etc/init.d/nginx बनाएं

 nano /etc/init.d/nginx; 

और निम्नलिखित स्क्रिप्ट वहां रखें:

 #!/bin/sh ### BEGIN INIT INFO # Provides: nginx # Required-Start: $local_fs $remote_fs $network $syslog # Required-Stop: $local_fs $remote_fs $network $syslog # Default-Start: 2 3 4 5 # Default-Stop: 0 1 6 # Short-Description: starts the nginx web server # Description: starts nginx using start-stop-daemon ### END INIT INFO PATH=/usr/local/sbin:/usr/local/bin:/sbin:/bin:/usr/sbin:/usr/bin DAEMON=/usr/sbin/nginx NAME=nginx DESC=nginx # Include nginx defaults if available if [ -f /etc/default/nginx ]; then . /etc/default/nginx fi test -x $DAEMON || exit 0 set -e . /lib/lsb/init-functions test_nginx_config() { if $DAEMON -t $DAEMON_OPTS >/dev/null 2>&1; then return 0 else $DAEMON -t $DAEMON_OPTS return $? fi } case "$1" in start) echo -n "Starting $DESC: " test_nginx_config # Check if the ULIMIT is set in /etc/default/nginx if [ -n "$ULIMIT" ]; then # Set the ulimits ulimit $ULIMIT fi start-stop-daemon --start --quiet --pidfile /var/run/$NAME.pid \ --exec $DAEMON -- $DAEMON_OPTS || true echo "$NAME." ;; stop) echo -n "Stopping $DESC: " start-stop-daemon --stop --quiet --pidfile /var/run/$NAME.pid \ --exec $DAEMON || true echo "$NAME." ;; restart|force-reload) echo -n "Restarting $DESC: " start-stop-daemon --stop --quiet --pidfile \ /var/run/$NAME.pid --exec $DAEMON || true sleep 1 test_nginx_config start-stop-daemon --start --quiet --pidfile \ /var/run/$NAME.pid --exec $DAEMON -- $DAEMON_OPTS || true echo "$NAME." ;; reload) echo -n "Reloading $DESC configuration: " test_nginx_config start-stop-daemon --stop --signal HUP --quiet --pidfile /var/run/$NAME.pid \ --exec $DAEMON || true echo "$NAME." ;; configtest|testconfig) echo -n "Testing $DESC configuration: " if test_nginx_config; then echo "$NAME." else exit $? fi ;; status) status_of_proc -p /var/run/$NAME.pid "$DAEMON" nginx && exit 0 || exit $? ;; *) echo "Usage: $NAME {start|stop|restart|reload|force-reload|status|configtest}" >&2 exit 1 ;; esac exit 0 

और अब

 chkconfig --add nginx chkconfig --level 345 nginx on 

वह सब है। इस पर, nginx स्थापना पूर्ण हो गई है, और आप nginx'a सेवा शुरू कर सकते हैं

 service nginx start 

अब सेटिंग्स पर चलते हैं:

/ प्रकाशक - चैनल को लिखने का कार्य करता है और यह केवल आपके सर्वर पर उपलब्ध होना चाहिए, अन्यथा कोई भी इसे लिख सकता है।

 location /publisher { //     ,     ?cid= set $push_channel_id $arg_cid; push_publisher; push_message_timeout 1m; //    push_message_buffer_length 20000; //   allow 127.0.0.1; deny all; } 

/ श्रोता - सभी के लिए सुलभ और चैनल ग्राहकों को संदेश वितरित करने के लिए कार्य करता है।

 location /listener { //     ,     ?cid= set $push_channel_id $arg_cid; push_subscriber; push_subscriber_concurrency broadcast; default_type text/plain; } 

यह सब सेटिंग्स के लिए है। समाधान सभी के लिए अच्छा है, लेकिन हमें क्रॉसडोमेन-एजैक्स स्थापित करने में कठिनाइयाँ हुईं, और फिलहाल मुख्य शाखा में मॉड्यूल में कोई जोंसप समर्थन नहीं है। लेकिन, इस कार्यक्षमता (https://github.com/Kronuz/nginx_http_push_module) के साथ एक कांटा मिला। इसकी स्थापना किसी भी तरह से मूल से भिन्न नहीं है।

स्थान / श्रोता अनुभाग में jsonp समर्थन को सक्षम करने के लिए आपको जोड़ना होगा

 //     /?callback= push_channel_jsonp_callback $arg_callback; 

अब, कॉलबैक पैरामीटर में डेटा पास करने के मामले में, मॉड्यूल डेटा को jsonp में लपेट देगा।

कोई अलग डेमो नहीं है, लेकिन वीके में पंजीकृत उपयोगकर्ता हमारे खेल में लाइव उदाहरण पर काम देख सकते हैं - vk.com/app2814545
इस तकनीक पर, लड़ाई पूरी तरह से निर्मित होती है (वास्तव में, उन्हें इस वास्तविक समय की आवश्यकता होती है), कैसीनो, संसाधनों को प्राप्त करने / खर्च करने और कई अन्य घटनाओं के बारे में संदेश।