CoronaSDK, Gideros, Moai पर मल्टीप्लेयर के लिए सरल प्रकाशन-सदस्यता

एक बार, एक सहयोगी को कोरोनाएसडीके पर रियलटाइम मल्टीप्लेयर को लागू करने की समस्या का सामना करना पड़ा। पहले तो हमने pubnub.com सेवा की कोशिश की, लेकिन अंततः महसूस किया कि उनकी विलंबता (उनके पास http के माध्यम से सब कुछ है) और कीमतें उनके अनुरूप नहीं थीं। कुछ भी बेहतर नहीं मिलने पर, उन्होंने Node.js (या स्कूटर के बजाय, क्योंकि पूरा सर्वर कोड टिप्पणियों के साथ 90 लाइनों में फिट होता है) पर एक बाइक को चलाने का फैसला किया।

उन्होंने मजाक में नोबहब कहा। WTFPL लाइसेंस के तहत वितरित किया गया।


बात बहुत तेजी से निकली और, उपयोगकर्ताओं की समीक्षाओं को देखते हुए, बिना रीस्टार्ट और मेमोरी लीक के सर्वर पर महीनों तक घूमने में सक्षम है। सिस्टम आवश्यकताएँ: Node.js 0.6.x और उच्चतर (मानक Ubuntu पैकेज में शामिल), कोई अतिरिक्त मॉड्यूल की आवश्यकता नहीं है।
यदि आप कोरोनाएसडीके, मोई या गिडरोस का उपयोग करके लुआ पर एक मोबाइल मल्टीप्लेयर एप्लिकेशन लिख रहे हैं, तो अच्छी खबर है: ग्राहक इन एसडीके के साथ ठीक काम करता है, इसे ले लो और इसका उपयोग करें।

कुछ तथ्य:

• विभिन्न डेवलपर्स के कई दर्जनों एप्लिकेशन जारी किए गए हैं, हर कोई प्रशंसा करता है (मूक करने के लिए कुछ भी नहीं है)। उदाहरण के लिए, रूसी शीर्ष, ड्यूरक एचडी का लगातार अतिथि
• सॉकेट्स के साथ किसी भी भाषा के लिए अपने क्लाइंट को लिखना आसान है
• Lua कोड LuaSocket के साथ काम करने के एक उदाहरण के रूप में काम कर सकता है
• डेमो प्रोजेक्ट में, मेरा परीक्षण सर्वर हार्डकोड किया गया है, इसलिए यहां तक ​​कि परीक्षण के लिए कुछ भी नहीं उठाया जाना है (परीक्षकों की संख्या समय-समय पर 200 CCU तक बढ़ जाती है। मुझे आशा है कि कोई भी गलती से इसका उत्पादन में उपयोग नहीं करता है, केवल 64 एमबी रैम पर ...

के उपयोग

हमने सर्वर शुरू किया:
$ node server.js
क्लाइंट पर एक ऑब्जेक्ट बनाया गया था:

 hub = noobhub.new({ server = "127.0.0.1"; port = 1337; }); 

चैनल में सदस्यता ली, कॉलबैक फ़ंक्शन में हम अन्य प्रतिभागियों के संदेश को संसाधित करते हैं:

 hub:subscribe({ channel = "hello-world"; callback = function(message) if(message.action == "ping") then print("Pong!") end; end; }); 

संदेश भेजा गया:

  hub:publish({ message = { action = "ping", timestamp = system.getTimer() } }); 

बोरिंग विवरण

Node.js स्क्रिप्ट का एक मुख्य तत्व सर्वर ऑब्जेक्ट है, जो पोर्ट पर सुनता है और कनेक्शन पर प्रतिक्रिया करता है। उनमें से प्रत्येक के लिए, बाद में खोज और यदि आवश्यक हो तो हटाने के लिए एक अद्वितीय हैश के साथ एक सॉकेट बनाया जाता है।
सॉकेट्स, बदले में, डेटा रिसेप्शन और कनेक्शन क्लोजर घटनाओं के लिए सुनते हैं।
वे दो प्रकार के संदेशों को पहचानते हैं: __SUBSCRIBE____ENDSUBSCRIBE__ - चैनल की सदस्यता,
__JSON__START_ <_MESSAGE> __JSON__END__ - एक मनमाना संदेश। सदस्यता लेते समय, सॉकेट को CHANNELNAME पूल में जोड़ा जाता है और बाद में इस चैनल पर आने वाले सभी संदेश नए चेहरे पर प्रसारित किए जाएंगे। दूसरे मामले में, संदेश के शरीर को CHANNELNAME के सभी ग्राहकों को संबोधित किया जाएगा। डिस्कनेक्ट करने के लिए, बस क्लाइंट साइड पर सॉकेट बंद करें, और फिर सर्वर को पता है कि डिसटर के साथ क्या करना है।
यह पता चला है कि एक EventLoop नोड डेटा प्राप्त करने और अपने ग्राहकों को सॉकेट में पैकेजिंग करने का सारा काम करता है। यदि कई ग्राहक हैं, तो एक समान रूप से बढ़ा हुआ चक्र संदेशों की डिलीवरी में देरी करेगा। बेशक, सवाल यह है कि कितने ग्राहकों को आपकी ज़रूरत है ताकि ड्रॉडाउन कम से कम कुछ ध्यान देने योग्य हो। 2k CCU के साथ, विलंबता कमियां नहीं देखी गईं (हमारे पास बस अधिक नहीं है), लेकिन मुझे संदेह है कि 20k एक ध्यान देने योग्य ड्राडाउन देगा।
क्लाइंट पर, सब कुछ बिल्कुल विपरीत है, क्लाइंट सॉकेट सर्वर से कनेक्ट होता है, चैनल की सदस्यता लेता है, और अन्य चैनल प्रतिभागियों के संदेशों को अतुल्यकालिक रूप से सुनता है।
ब्रेक के मामले में एक स्वचालित पुन: कनेक्ट और पुनर्विक्रय होता है (यह EDGE / 3G पर खराब कनेक्टिविटी वाले उपयोगकर्ताओं के लिए जीवन को आसान बनाता है)।

कुल: छोटी और मध्यम आकार की परियोजनाओं के लिए सरल प्रकाशन-सदस्यता लें।

सर्वर और क्लाइंट का स्रोत कोड: https://github.com/Overtorment/NoobHub