📼 ☁️ 🍊 Node.js वेबसैट के माध्यम से प्रॉक्सी डेटा सर्वर के रूप में 🧔 🚢 🐓

लगभग किसी भी डेटा सर्वर और ब्राउज़र के बीच एक स्थिर अतुल्यकालिक डेटा स्ट्रीम बनाने के लिए ~~धूम्रपान छोड़ने का~~ एक आसान तरीका के बारे में एक और बाइक।

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

यह कार्य जितनी जल्दी और कम से कम संभव हो सके पूरा किया गया: साधारण php स्क्रिप्ट्स को लिखा गया था जो GPS डेटा प्रोसेसिंग सर्वर से जुड़ते हैं, एक अनुरोध देते हैं, एक प्रतिक्रिया की प्रतीक्षा करते हैं, और वेब क्लाइंट को प्रतिक्रिया लौटाते हैं। तदनुसार, एक साधारण ग्राहक बनाया गया था, जो कि व्यवस्थित रूप से, टाइमर के अनुसार, अच्छे पुराने $ के माध्यम से .ajax () ने php लिपियों के लिए POST अनुरोध दिए और उत्तर -वर्ती अद्भुत वेक्टर ऑन-लाइन मैप्स पर उत्तर को खूबसूरती से चित्रित किया।

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

ऐसी योजना प्रबंधन के काफी अनुकूल है - उत्पाद सफलतापूर्वक शुरू हुआ, उपयोगकर्ताओं ने वेब क्लाइंट का उपयोग करने के लिए स्विच किया। लेकिन कार्यान्वित समाधान मुझे हर चीज के प्रेमी के रूप में सुंदर और सामंजस्यपूर्ण नहीं लगा।

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

और यहां Node.js और SockJS पुस्तकालय बचाव में आए , जो एक अतुल्यकालिक वेब सॉकेट कनेक्शन के सफल अनुकरण को लागू करता है और यह सॉकेट से कहीं बेहतर है। यह उस समय के बारे में पहले से ही लिखा गया था।

आगे देखते हुए, मैं तुरंत कहता हूं कि मैं इस बारे में क्यों लिख रहा हूं - नीचे वर्णित समाधान के कार्यान्वयन ने सर्वर पर लोड को लगभग तीस गुना कम कर दिया है , यह सभी आधुनिक ब्राउज़रों में काम करता है (बेशक, मेरा मतलब IE6-7 नहीं है, हालांकि यह पहले से ही IE8 में काम करता है) और एक बहुत ही उच्च गति प्रदान करता है। डेटा ट्रांसफर। समाधान काफी सार्वभौमिक है, एक ही विधि अतुल्यकालिक डेटा (वेबसाइट पार्सिंग, चैट सर्वर, ऑन-लाइन खिलौना, रोवर कंट्रोल सिस्टम ...) के लगभग किसी भी स्ट्रीम के प्रसंस्करण को व्यवस्थित कर सकती है और गहन प्रोग्रामिंग ज्ञान की आवश्यकता नहीं है, इसलिए इसे किसी भी पर्याप्त रूप से प्रशिक्षित द्वारा जल्दी से तैनात किया जा सकता है। एनकोडर।

तो, एक सर्वर जो डेटा सर्वर से जानकारी संसाधित करेगा और इसे वेब सॉकेट कनेक्शन के माध्यम से वेब क्लाइंट के लिए अतुल्यकालिक रूप से स्थानांतरित करेगा:

Node.js

var http = require('http'), net = require('net'), sockjs = require('sockjs'), ADDR_GPS = "127.0.0.1", //   ,  - PORT_GPS = 3201, //   server = sockjs.createServer(); server.on('connection', function(conn) { //         - SockJS   //   ,      , //     ,     var com = new Commander(ADDR_GPS, PORT_GPS, conn, function(e){ console.log("! We had an Error in socket: ", e, "at ", new Date()); conn.close(); }); conn.on('data', function(data) { //         JSON //        var dat = JSON.parse(data); if(dat.command == "@auth") { //    , com.auth(dat.param.log, dat.param.pwd); } else if(dat.command == "@bye") { // -      com.bye(); conn.close(); } }); conn.on('close', function() { console.log("Websocket connection closed"); com = null; }); }); //  -HTTP-        // SockJS,    http://mydomen.com:8081/data var srv = http.createServer(); server.installHandlers(srv, {prefix:'/data'}); srv.listen(8081, '0.0.0.0'); var Commander = function (adr, port, clientConn, onError) { //        var self = this; this.status = 0; this.chunk = ""; //     this.answers = []; //      this.connection = clientConn; //    , //        this.client = new net.Socket(); //      this.client.connect(port,adr,function(){ //     console.log("New connect to created..."); }); this.client.on('data', function(data) { //         - self.onData(data); }); this.client.on('error', function(e) { //      onError(e); self.client.destroy(); }); }; Commander.prototype.auth = function(login, pass) { //            console.log("written auth for "+ login); this.client.write('(auth "'+login+'" "'+pass+'")\n'); }; Commander.prototype.bye = function() { //     this.client.write('(exit)\n'); }; Commander.prototype.onData = function(data) { //       ,      , //    -,      //    ,       //   -        var pos; this.chunk+=data.toString(); pos=this.chunk.indexOf('\n'); if(pos > -1) { this.connection.write(this.chunk.substring(0,pos)); this.chunk = this.chunk.substring(pos); } };

क्लाइंट, SockJS हैंडलर मॉड्यूल कनेक्शन की आवश्यकता है। शीट के लिए क्षमा करें, लेकिन समझने के लिए उदाहरण के लिए फ़ाइलों को स्क्रिप्ट / स्क्रिप्ट पोस्ट करना, IMHO, कोई ज़रूरत नहीं है

index.html

 <!DOCTYPE html> <html lang="ru"> <head> <meta charset="utf-8"> <title>   </title> <style> body { padding:0; margin: 0; font: 10pt sans-serif, Arial, Tahoma; } h1 { font-size: 2em; margin: 0.8em 0; } h3 { font-size:1.5em; margin: 0.1em; } #content { position: relative; margin: 0 auto; width:960px; min-width:800px; } #left { position:absolute; top:0px; left:0px; padding:2px; width:220px; height:560px; } #right { position:absolute; top:0px; left:250px; padding:2px; width:710px; height:560px; } #scroller { position:relative; width: 400px; height:90%; overflow-y:auto; border:1px dotted black; padding:5px; margin-top:10px; } .off { color:red; } .on { color: green; } .inBottom { position: absolute; bottom: 20px; } </style> <script src="sockjs-0.3.4.min.js" type="text/javascript"></script> <script> var sock;stat = document.getElementById("status"); function connect() { //      sock = new SockJS('http://mysite.com:8081/data'); var l = document.getElementById("login").value, p = document.getElementById("passw").value stat = document.getElementById("status"); setTimeout(function(){ //    ,       sock.send(toJSON("@auth", { log: l, pwd: p })); },2000); sock.onopen = function() { //   ,     stat.innerHTML = "ON"; stat.className = "on"; }; sock.onmessage = function(e) { //   ,     ,   //       "data" document.getElementById("scroller").innerHTML += "<p>"+e.data+"</p>"; }; sock.onclose = function() { //    ,     stat.innerHTML = "OFF"; stat.className = "off"; }; } function disconnect() { //   if(sock !== undefined) { sock.send(toJSON("@bye", {})); } } function toJSON (com, param){ return JSON.stringify({ command: com, param: param }); } </script> </head> <body> <div id="content"> <div id="left"> <p style="width:100%;"> <input type="text" id="login" style="float:right;"></p> <p style="width:100%;"> <input type="password" id="passw" style="float:right;"></p> <button onclick="connect();"></button><button onclick="disconnect();"></button><br> <p class="inBottom">: <span id="status"></span></p> </div> <div id="right"> <div id="scroller"></div> </div> </div> </body> </html>

मैंने सभी प्रमुख बिंदुओं पर टिप्पणियों के साथ कोड प्रदान करने का प्रयास किया। मैं लाइव ऑन-लाइन डेमो नहीं दे सकता - वास्तविक संगठनों का डेटा जो अपने वाहनों पर इस तरह के करीब ध्यान से खुश नहीं होंगे, वे मेरे सर्वर पर घूम रहे हैं। हालाँकि यह देखने के लिए मज़ेदार है कि हार्वेस्टर कैसे काम करता है - आधे दिन में खेत का एक टुकड़ा नक्शे पर छायांकित होता है और निकटतम गाँव की दिशा में परिशिष्ट स्पष्ट रूप से दिखाई देता है जब हार्वेस्टर कप्तान दोपहर का भोजन करना चाहता है।

मुझे आपकी टिप्पणियों, प्रश्नों और सुझावों की प्रतीक्षा है।

Node.js वेबसैट के माध्यम से प्रॉक्सी डेटा सर्वर के रूप में

More articles: