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

संचालन का सिद्धांत

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

ग्राहक पक्ष:

यह इस तरह से किसी भी तरह जोड़ता है:

 <script type="text/javascript" src="MWS_meloman.js"></script>

"सुनना" सुनो फ़ंक्शन द्वारा शुरू किया गया है, एक पैरामीटर इसे पास किया गया है - प्रारूप में एक स्ट्रिंग
< -> : < >
हैंडलर फंक्शन इस पोर्ट पर कुछ आते ही शुरू हो जाएगा, और यह "कुछ" तुरंत एक ऑब्जेक्ट (संपत्ति: मूल्य, ...) के रूप में इसे पास कर दिया जाएगा।
उदाहरण के लिए

 meloman.Listen('handler1:5') //  meloman.Listen('handler1:5-7') //    meloman.Listen('handler1:5-7; handler2 : 8-10; handler3 : 11-20');

यदि किसी कारण से आपको सुनना बंद करने की आवश्यकता है, तो सुनिए आपको एक खाली लाइन पास करने की आवश्यकता है:

 //  meloman.Listen(''); //  : meloman.Listen(); // , ,   :)

यदि कुछ ऐसा है जिसे सर्वर को "पता" करने की आवश्यकता है और जो ग्राहक इस पोर्ट को सुनते हैं, तो यह "ऑब्जेक्ट" को ऑब्जेक्ट में "पैक" करता है और इसे बदलकर फ़ंक्शन में भेजता है, "पोर्ट" पैरामीटर को पहले पैरामीटर के रूप में निर्दिष्ट करता है।
उदाहरण के लिए:

 var some = { 'name' : 'Mr.Smith', 'message' : 'Find Neo'} meloman.Change( 5, some );

इसे तुरंत सर्वर को भेज दिया जाता है और आपके पर्ल फ़ंक्शन को पास कर दिया जाता है, जो जानता है कि इसके साथ क्या करना है, हैश के रूप में।

कई सेटिंग्स गुण हैं:

minReconnectTime - मिलीसेकंड में समय, अधिक से अधिक बार आप सर्वर को अनुरोध नहीं भेज सकते,

रीकनेक्टटाइम - मिलीसेकंड में समय जिसके बाद एक नया अनुरोध सर्वर को भेजा जाता है,

WaitTimeOut - सर्वर से प्रतिक्रिया की प्रतीक्षा करने के लिए अधिकतम समय,

WaitTimeOutHandler - एक ऐसा कार्य जो उस स्थिति को संभालता है जब प्रतीक्षा समय के दौरान सर्वर से कोई प्रतिक्रिया प्राप्त नहीं हुई थी,

connectionErrorHandler - एक फ़ंक्शन जो सर्वर त्रुटियों को संसाधित करता है (यदि सर्वर से प्रतिक्रिया 200 ठीक नहीं है),

pathToChange - सर्वर स्क्रिप्ट के लिए पथ जिसे ऑब्जेक्ट फ़ंक्शन द्वारा स्थानांतरित किया जाएगा,

pathToListen - सर्वर स्क्रिप्ट का पथ जो निर्दिष्ट पोर्ट (ओं) को "सुनेंगे" और संचारित होगा, जिस स्थिति में, ग्राहक को जानकारी,

IgnMyChanges - यदि गलत है, तो परिवर्तन फ़ंक्शन द्वारा किए गए परिवर्तन को सर्वर पर एक नई घटना के रूप में माना जाएगा,

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

सर्वर साइड:

Patefon.pm मॉड्यूल डाउनलोड किया गया है, कहीं पर कॉपी किया गया है, उदाहरण के लिए, ./lib और कनेक्टेड:

 use lib "./.libs"; use Patefon;

मॉड्यूल निर्यात करता है & change_the_plate और & सुनो_the_plate फ़ंक्शन और सेटिंग हैश % patefons_knobs। (अब बीटा संस्करण थोड़ा और निर्यात करता है (डिबगिंग के लिए), लेकिन यह अगले संस्करण में तय किया जाएगा।)

मेरा सुझाव है कि आप सर्वर पर दो अलग-अलग स्क्रिप्ट बनाएं, एक सुनने के लिए, एक क्लाइंट से "प्राप्त" करने के लिए। हालांकि कोई भी बुरा नहीं होगा अगर सब कुछ एक ही स्क्रिप्ट में crammed है।
जो "सुनता है" वह सुनता है और सुनता है, वह पैरामीटर के बिना शुरू होता है। शुरू करने से पहले, आपको सभी आवश्यक बंदरगाहों के लिए हैंडलर फ़ंक्शन निर्दिष्ट करना होगा।

$patefons_knobs{handlers}{< >} = < ->;

उदाहरण के लिए, इस तरह:

 $patefons_knobs{handlers}{1} = \&handler_1;

यह हैंडलर फ़ंक्शन पहले पैरामीटर को रूम-पोर्ट नंबर के रूप में स्वीकार करने के लिए तैयार होना चाहिए जिसमें कुछ बदल गया है, और दूसरा (यदि इसकी आवश्यकता है) नए प्लेइंग रिकॉर्ड की संख्या। इस सब के साथ कुछ (और, संभवतः, न केवल इस के साथ) करने के लिए, और ग्राहक को भेजा जाना चाहिए कि हैश लौटें।

इस सब से पहले, आपको "कमरे-बंदरगाहों" के साथ फ़ोल्डर में पथ निर्दिष्ट करना होगा:

 $patefons_knobs{path_to_rooms} = './.rooms/';

प्रत्येक पोर्ट के लिए इस फ़ोल्डर में एक ही नाम वाला एक फ़ोल्डर होना चाहिए, ऐसे प्रत्येक फ़ोल्डर में एक डोर फाइल होनी चाहिए (कोई बात नहीं वहां क्या लिखा है, यह ठीक काम करेगा) इसका उपयोग "पोर्ट-रूम" को ब्लॉक करने के लिए किया जाता है, इस समय कुछ परिवर्तन होता है। फ़ंक्शन और change_the_plate (उस समय जब क्लाइंट से कुछ सर्वर पर आया था)।
नमूना निर्देशिका योजना। / कक्ष:

 ./.rooms/
      ./1/
           ./door
      ./2/
           ./door

आदि

जो स्क्रिप्ट सुन रहा है वह & change_the_plate फ़ंक्शन का उपयोग करता है। इसे शुरू करने से पहले, आपको "पोर्ट-रूम" के लिए पथ निर्दिष्ट करना होगा:

 $patefons_knobs{path_to_rooms} = './.rooms/';

और हैंडलर कार्य:
$patefons_knobs{ChngHandlers}{<>} = < ->;

फंक्शन को हैंडलर के पास भेजा जाएगा जो क्लाइंट से आए हैश का संदर्भ देगा।

उसके बाद, उसके साथ कुछ करने के बाद, उसे एक मूल्य वापस करना होगा जिसे उदाहरण के रूप में सच माना जा सकता है 1।

यह भी महत्वपूर्ण है कि सभी हस्तांतरित हैश / वस्तुएं एक-आयामी होनी चाहिए।

 // ,  : var some = { 'name' : 'Mr.Smith', 'message' : 'Find Neo!', 'time' : 'Now!' }; //   : var some = { 'name' : 'Mr.Smith', 'action' : { 'message' : 'Find Neo!', 'time' : 'Now!' } };

सेटिंग्स के हैश में, "कमरे" को हैंडलर और पथ निर्दिष्ट करने के अलावा, आप निम्नलिखित हैंडल को मोड़ सकते हैं:

patefons_knobs {sample_rate} - सेकंड में वह समय जिसके बाद पोर्ट स्थिति को पोल किया जाएगा, डिफ़ॉल्ट रूप से 1।
patefons_knobs {maxSleeping} - सेकंड में समय जिसके बाद सुनने की स्क्रिप्ट डिफ़ॉल्ट रूप से 20 तक अपना काम पूरा करती है।

एक सरणी है patefons_knobs {त्रुटियाँ} जिसमें सभी त्रुटियां जोड़ी जाती हैं, मॉड्यूल फ़ंक्शन, जिसे त्रुटियों के बिना निष्पादित किया गया था, त्रुटियों के साथ 1, रिटर्न - 0. इसका उपयोग किया जा सकता है, उदाहरण के लिए, लॉग में त्रुटियों को लिखने के लिए। इस तरह, उदाहरण के लिए:

 unless ( &change_the_plate ) { open LOG, ">>log"; $" = "\n"; print LOG qq(ERRORS: @{$patefons_knobs{errors}}); }

तो नीचे वादा किया गया आदिम चैट कोड है। ध्यान दें कि (ऑटोस्क्रॉलिंग और ध्वनि के रूप में किसी भी सीटी को छोड़कर) जावास्क्रिप्ट में केवल 16 लाइनें हैं (और यदि डिफ़ॉल्ट सेटिंग्स का उपयोग किया गया था, तो, सामान्य रूप से, 14)।

 <!DOCTYPE html> <html> <head> <meta http-equiv="Content-Type" content="text/html; charset=utf-8" /> <title> </title> <link rel="stylesheet" href="chat_style.css" type="text/css" media="screen"/> <script type="text/javascript" src="MWS_meloman.js"></script> <script> var mayScroll = true; meloman.ignoreMyChanges = true; meloman.routeToListen = 'ls.pl'; meloman.reconnectTime = 25000; meloman.routeToChange = 'ch.pl'; meloman.Listen('j3:1'); function j3 ( a ) { var string = ''; for ( var Name in a ) { string += Name + "\t" + a[Name] + "\n" } document.getElementById('chat').innerHTML += a['message']; playsound(); scrollchat(); }; function send_message () { var banderol = {}; banderol['message'] = document.getElementById('message').value; banderol['user'] = document.getElementById('user').value || 'Anonymous'; banderol['color'] = document.getElementById('color').value || '#333333'; if ( /\S+/.test( banderol['message'] ) && banderol['message'].length < 500 ) { meloman.Change( 1, banderol) } document.getElementById('message').value = ''; } function scrollchat () { if ( mayScroll ) document.getElementById('chat').scrollTop = 9999; } function playsound () { if ( document.getElementById('need_sound').checked ) { document.getElementById("snd").volume = 0.4; document.getElementById("snd").play(); } } </script> </head> <body> <div id="settings" > <span class="params">: <input type="text" size="20" id="user" autofocus /></span> <span class="params">: <input type="color" value="#00aa00" id="color" /></span> <span class="params">: <input type="checkbox" id="need_sound" /></span> </div> <div id="cont"> <div id="chat" onmouseover="mayScroll=false;" onmouseout="mayScroll=true"></div> <form onsubmit="send_message();return false;"> <div id="message_cont"> <input id="message" type="text" autocomplete="off" value="" spellcheck="false" /> </div> </form> </div> <audio id="snd"> <source src="beep.ogg" type="audio/ogg; codecs=vorbis"> <source src="beep.mp3" type="audio/mpeg"> </audio> </body> </html>

और सर्वर साइड:

"श्रवण" स्क्रिप्ट:

 #!/usr/bin/perl use strict; use warnings; use lib "./.libs"; use Patefon; $patefons_knobs{handlers}{1} = \&j_1; $patefons_knobs{path_to_rooms} = './.rooms/'; $patefons_knobs{maxSleeping} = 20; listen_the_plate(); sub j_1 { my $new = $_[1]; my $old = ( $new - $_[0] ) < 5 ? $_[0] : ( $new - 5 ); my $unreaden_messages; for ( my $i = ++$old; $i <= $new; $i++ ) { open F, "<utf8", "./general_chat/$i" or next; $unreaden_messages .= <F>; } my %hash = ( 'message' => $unreaden_messages ); return %hash; }

और "रिकॉर्ड बदलना":

 #!/usr/bin/perl use strict; use warnings; use lib "./.libs"; use Patefon; $patefons_knobs{path_to_rooms} = './.rooms/'; $patefons_knobs{ChngHandlers}{1} = \&j_1; unless ( &change_the_plate ) { open LOG, ">>log"; $" = "\n"; print LOG qq(ERRORS: @{$patefons_knobs{errors}}); } sub j_1 { my ( $room, $plate, $banderol ) = @_; return 0 if ( ${$banderol}{message} eq '' ); unless ( ${$banderol}{color} =~ /^#[0-9a-f]{3}$|^#[0-9a-f]{6}$/i ) { ${$banderol}{color} = '#FE5590' } # shield < and > for ( ${$banderol}{message}, ${$banderol}{user} ) { s/</</g; s/>/>/g } open F, ">", "./general_chat/$plate"; print F qq(<span class="name" style="color:${$banderol}{color};">${$banderol}{user}</span>: <span class="mess">${$banderol}{message}</span><br />) }

और वास्तविक चैट का लिंक:
<वह यहाँ थी, लेकिन वह अब वहाँ नहीं है। excuse me =)>

टॉय चेटिक्स के अलावा, ये मॉड्यूल मिल सकते हैं, मुझे लगता है, कई अलग-अलग अनुप्रयोग, उदाहरण के लिए, मैंने यह सब एक बहु-उपयोगकर्ता व्यवस्थापक पैनल के लिए किया।

"स्यूडो-वेब सॉकेट्स" के मॉड्यूल की यह प्रणाली केवल बीटा है, और यह अभी भी, शायद, बहुत कच्चा है, लेकिन पहले से ही काफी काम कर रहा है। मुझे अब तक कोई कीड़े नहीं मिले हैं, मैं उन लोगों के लिए आशा करता हूं जो इसका उपयोग करेंगे :)
यहाँ, bitbucket.org पर, स्रोत कोड उपलब्ध हैं। उपयोग करें, कांटा, बग रिपोर्ट लिखें या पत्थर फेंकें। मैं सभी "पत्थरों" को इकट्ठा करने के लिए खुश हूं और उन्हें टेप से हवा देने की कोशिश करता हूं, प्लास्टिसिन के साथ छड़ी करता हूं, मैचों के साथ वापस जाता हूं, या उन्हें स्नोट के साथ गोंद करता हूं।

छद्म वेब सॉकेट

संचालन का सिद्धांत

ग्राहक पक्ष:

सर्वर साइड:

More articles: