एरांग पर कॉमेट सर्वर

लोगों के लिए एक लेख अभी शुरू हो रहा है erlang जानने के लिए: कैसे एक साधारण धूमकेतु सर्वर लिखने के लिए।

यहां तैयार कोड: github.com/maxlapshin/comet

विवरण

धूमकेतु सर्वर को काउबॉय, टिनिअम और जैबस्क्रिप्ट के एक टुकड़े का उपयोग करके लिखा जाएगा।

कोड जीथब पर टैग के साथ पोस्ट किया गया है। मुख्य चरणों को टैग किया गया है, आप यह देखने के लिए रोल कर सकते हैं कि वास्तव में एक समय या किसी अन्य पर क्या किया गया था।

लेख स्वयं कोड के समानांतर लिखा गया है, जो गीता में इतिहास से ध्यान देने योग्य है।

तर्क यह है: हम HTTP के माध्यम से सर्वर को एक संदेश भेजते हैं, यह संदेश कतार में पड़ता है, जहां क्लाइंट इसे लंबे समय के सर्वेक्षण के माध्यम से बाहर निकालता है।



Erlang दो चीजों में अच्छा है:
1) संदेशों को स्मृति में रखने की क्षमता
2) अनुत्तरित अनुरोधों को सस्ते में लाखों (!) रखने की क्षमता, अर्थात्। क्लाइंट खड़ा है, एक उत्तर की प्रतीक्षा कर रहा है, सर्वर थोड़ी देर बाद इसका जवाब देगा।

शुरुआत करने के लिए सुंदरियां

सबसे पहले, हर दिनचर्या की आवश्यकता है: rebar, निर्भरता।

mkdir comet cd comet git init wget https://github.com/basho/rebar/wiki/rebar chmod +x rebar 

अगला, निर्भरताएँ स्थापित करने के लिए rebar.config बनाएँ।

 {lib_dirs, ["apps", "deps"]}. {sub_dirs, [ "apps/comet" ]}. {erl_opts, [ debug_info, warn_format, warn_export_vars, warn_obsolete_guard, warn_bif_clash ]}. {deps, [ {cowboy, "0.6.*", {git, "git://github.com/extend/cowboy.git", {tag, "0.6.1"}}}, {tinymq, ".*", {git, "git://github.com/evanmiller/tinymq.git", "386813add4"}} ]}. 

टिनिअम में लेख के लेखन के दौरान, एपीआई में परिवर्तन किए गए थे। एक विशिष्ट प्रतिबद्धताओं को लॉक करने की सिफारिश की जाती है!

और निर्भरता को बाहर निकालना:

 ./rebar get-deps 

तुरंत एक Emakefile बनाएँ। कई लोग ईमेक का उपयोग करने से इंकार करते हैं, लेकिन मैं ऐसा नहीं करता और बाद में दिखाता हूं कि मैं ऐसा क्यों करता हूं।

 {"apps/comet/src/*", [debug_info, {outdir, "apps/comet/ebin"}, {i, "apps/comet/src"}]}. {"deps/cowboy/src/*", [debug_info, {outdir, "deps/cowboy/ebin"}, {i, "deps/cowboy/src"}]}. {"deps/tinymq/src/*", [debug_info, {outdir, "deps/tinymq/ebin"}, {i, "deps/tinymq/src"}]}. 

अब यह हमारे आवेदन के लिए रीढ़ बनाने के लिए बना हुआ है और सब कुछ ठीक होगा।

 mkdir -p apps/comet cd apps/comet ../../rebar create-app appid=comet cd - 

.Signignore में deps और ebin जोड़ें और जो हुआ उसका संकलन करें:

 ./rebar compile 

पल को v1 टैग किया गया है।

लांच

इरलांग पर एप्लिकेशन को चलाने के तरीके के संदर्भ में कुछ भ्रम और उलझा हुआ है। बुनियादी ढांचे को कैसे लॉन्च किया जाए, इस अर्थ में।

मैं आमतौर पर रन नियम के साथ विकास के लिए एक मेकफाइल करता हूं जिसमें मैं निम्नलिखित निर्दिष्ट करता हूं:

 ERL_LIBS=apps:deps erl +K true -name comet@127.0.0.1 -boot start_sasl -s comet_app -sasl errlog_type error 

निम्नलिखित को समझना महत्वपूर्ण है: एर्लैंग का कोई विकास और उत्पादन नहीं है। यह सभी बिलियर्ड्स, जो कई चौखटे के चारों ओर मूर्ख हैं, गायब है।

अब विकल्पों के बारे में अधिक।

ERL_LIBS=apps:deps पुस्तकालयों की खोज करने के लिए Erlang निर्देशिकाओं को बताता है। एक पुस्तकालय एक निर्देशिका है जो इसमें ईबिन है।

+K true इंगित करता है कि epoll / kqueue का उपयोग किया जा सकता है

-name comet@127.0.0.1 - एक स्पष्ट नाम के साथ एक लंबा नाम

-boot start_sasl - याद रखें और दोहराएं

-s comet_app - धूमकेतु_प्प मॉड्यूल से प्रारंभ / 0 फ़ंक्शन चलाएं (फिलहाल यह अभी तक नहीं है)

-sasl errlog_type error आपको अनावश्यक संदेशों से बैराज को हटाने की अनुमति देती है कि सब कुछ ठीक है।

अब, सब कुछ शुरू करने के लिए, आपको प्रारंभ / 0 फ़ंक्शन को धूमकेतु_रेल में जोड़ने की आवश्यकता है:

 -export([start/0]). start() -> application:start(comet). 

उसके बाद हम सब कुछ संकलित करते हैं:

 > ./rebar compile > make run ERL_LIBS=apps:deps erl +K true -name comet@127.0.0.1 -boot start_sasl -s comet_app -sasl errlog_type error Erlang R15B (erts-5.9) [source] [64-bit] [smp:4:4] [async-threads:0] [hipe] [kernel-poll:true] Eshell V5.9 (abort with ^G) (comet@127.0.0.1)1> 

यानी हमारा खाली आवेदन शुरू हो गया है। इसे Ctrl + c या पड़ाव () से बाहर निकालें। कंसोल में।

V2 टैग

वेब सर्वर लॉन्च

हमने बुनियादी ढांचे को समाप्त कर दिया है, चलो वेब सर्वर लॉन्च करने के लिए आगे बढ़ते हैं।

हमारे आवेदन की शुरुआत से, हम कई हैंडलर के साथ काउबॉय शुरू करेंगे, लेकिन इसके लिए हमें स्थिर फ़ाइलों को सही ढंग से प्रस्तुत करने के लिए पहले एक और mimetypes एप्लिकेशन (https://github.com/spawngrid/mimetypes) को जोड़ना होगा।

लाइन {mimetypes, ".*", {git, "git://github.com/spawngrid/mimetypes.git"}} //github.com/spawngrid/mimetypes.git {mimetypes, ".*", {git, "git://github.com/spawngrid/mimetypes.git"}} को rebar.config में जोड़ें और बाहर खींचें: ./rebar get-deps

हम धूमकेतु_app.erl में आवश्यक कोड लिखते हैं , www / index.html में न्यूनतम कोड जोड़ते हैं और इसे चलाते हैं।
रन बनाएं और लोकलहोस्ट पर जाएं : 8080 /

टैग v3

कतार से संदेश लिखें

Jquery, form और url / sendmessage के लिए एक अलग sendmessage_handler हैंडलर जोड़ें

मॉड्यूल स्वयं चरवाहे के निर्देशों के अनुसार स्पष्ट रूप से लिखा गया है।

एक चरवाहे के साथ, एक को याद रखना बहुत महत्वपूर्ण है, बहुत महत्वपूर्ण बात: चरवाहे एपीआई के सभी कार्य एक प्रतिक्रिया और एक नया राज्य लौटाते हैं। यह अनुरोध पर सभी डेटा को पार्स करने के लिए किया जाता है।
यह महत्वपूर्ण है कि आप हमेशा एक नए राज्य का उपयोग करें, अन्यथा ठंडा करने का एक मौका है।

अब आपको यह बताना जरूरी है कि Emakefile क्यों। विकास में कोड को फिर से कोड कैसे करें, इसके अलग-अलग तरीके हैं। मुझे केवल नियमित make:all([load]). पसंद है make:all([load]).

अन्य विकल्प रीलोडर या सिंक हैं। उन सभी को बुरा लगता है कि वे शैतान को कब, और क्या नरक में कोड करते हैं। ssl के साथ कुछ समस्याओं के कारण क्रस्ट करना आसान है। यह कार्यशील बनाने के लिए है: सभी ([लोड])। (यह कमांड एर्लांग कंसोल में चलाया जाना चाहिए) और Emakefile किया

इसके बाद, संदेश कतार चालू करें। हम इसे हमारे धूमकेतु_सुपर अनुप्रयोग के पर्यवेक्षक में जोड़ देंगे।

अब आप सीधे धूमकेतु तर्क जोड़ सकते हैं:

  {Post, Req2} = cowboy_http_req:body_qs(Req), {<<"body">>, Body} = lists:keyfind(<<"body">>, 1, Post), tinymq:push(<<"default_channel">>, Body), 

V4 टैग

कतार से संदेश घटाएं

धूमकेतु में निम्नलिखित स्थितियां संभव हैं:
1) आया, और कतार में हमारे लिए पहले से ही संदेश हैं
2) आ गए हैं, कोई संदेश नहीं है, हम इंतजार कर रहे हैं कि वे कब दिखाई दें।

यह समझने के लिए कि हमने संदेशों को पहले ही देख लिया है, आपको क्रमबद्ध पहचानकर्ताओं का उपयोग करने की आवश्यकता है। हमारे मामले में सबसे विश्वसनीय वास्तविक समय है। यह वास्तव में टिनिअम कैसे काम करता है।

धूमकेतु_हैंडलर जोड़ें, जो धूमकेतु को लागू करने के लिए विशेष चरवाहा चिप्स का उपयोग करेगा।

आइए देखें कि वास्तव में क्या हो रहा है।

1) ग्राहक के पास / धूमकेतु आता है, हाथ पर आखिरी टाइमस्टैम्प होने या न होने के कारण
2) हैंडलर ने टिनिअम के साथ जांच की: पोल कि क्या इस टाइमस्टैम्प की तुलना में कोई नए संदेश हैं।
3) अगर वहाँ है, यह संभाल / 2 के माध्यम से एक सरल तंत्र के साथ प्रतिक्रिया करता है
4) यदि इस तरह के कोई संदेश नहीं हैं, तो टिनिम्क के माध्यम से संदेश वितरण के लिए सदस्यता लें: एक लूप / 3 चक्र में खींचें और लटकाएं
5) जब वांछित संदेश आता है, तो इसे JSON में पैक करता है और क्लाइंट को नए टाइमस्टैम्प के साथ भेजता है

Json में पैकेजिंग के लिए mochijson2 मॉड्यूल जोड़ा गया

V5 टैग

इसके लिए केवल HTML संलग्न करना शेष है।

धूमकेतु के लिए HTML

बारीकियों का एक गुच्छा है जो सभी एक ही चीज़ के चारों ओर जाते हैं: सर्वर को बहुत बार-बार अनुरोध के साथ डंप करने के लिए कैसे नहीं। यानी एक आपातकालीन डिस्कनेक्ट के बाद, थोड़ा इंतजार करें। लेकिन हम बाद में यह सब छोड़ देंगे, पहले सिर्फ धूमकेतु की सदस्यता लें।

V6 टैग

आगे क्या है?

तो, मसौदे में, एक काम कर रहे धूमकेतु का न्यूनतम उदाहरण तैयार है। इस रूप में, आप उत्पादन में भाग नहीं सकते, आपको इसे पूरा करने की आवश्यकता है:
1) प्राधिकरण
2) चैनल संकेत

उसके बाद, यहां वर्णित कोड को उत्पादन के लिए रोल आउट किया जा सकता है। हां, एरलांग अच्छा है क्योंकि, एक नियम के रूप में, एक प्रोटोटाइप को लड़ाई में फेंक दिया जा सकता है।

साथ ही अगले लेख में हम वेब सॉकेट्स, प्रोडक्शन में लॉन्च आदि के बारे में बात करेंगे।