सभी को बधाई! कई डेवलपर्स नगीनेक्स वेब सर्वर के लिए उत्कृष्ट नगनेक्स पुश मॉड्यूल के बारे में जानते हैं। बहुतों ने इसे आजमाया, महसूस किया।

मॉड्यूल का कार्य Nginx वेब सर्वर को धूमकेतु सर्वर के रूप में कार्य करने की अनुमति देना है ।

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

इस लेख में, मैं चैनलों को नियंत्रित करने के संभावित तरीके का प्रदर्शन करते हुए एक छोटा सा उदाहरण लिखूंगा।

कार्य

हमें क्या चाहिए?

• एक नया चैनल बनाना
• किसी मौजूदा चैनल को बंद करना
• चैनल अस्तित्व की जांच
• चैनल को डेटा भेजना
• सभी चैनलों को डेटा भेजना

नतीजतन, प्रत्येक उपयोगकर्ता के लिए एक अद्वितीय चैनल आवंटित किया जाएगा (प्राधिकरण पारित करने के बाद, उदाहरण के लिए)।

नग्नेक्स पुश मॉड्यूल - सुरक्षित

Nginx Push Module हमें सुरक्षा प्रदान करने के लिए nginx config में कुछ निर्देश प्रदान करता है। केवल उन पर विचार करें जो मैंने लागू किया था:

• push_authorized_channels_only [पर | बंद]
  ऑन - क्लाइंट को उसके स्पष्ट निर्माण के बाद ही एक विशिष्ट चैनल को सुनने की अनुमति दें (प्रकाशक बिंदु पर एक पोस्ट या पीयूटी अनुरोध भेजना)। अन्यथा, जब आप बंद चैनल को सुनने की कोशिश करते हैं, तो प्रतिक्रिया 403 क्लाइंट को वापस कर दी जाती है।
  बंद - ग्राहक बंद चैनल को सुनना शुरू कर सकता है।
  
  
• push_max_channel_subscribers [संख्या]
  समवर्ती चैनल श्रोताओं की अधिकतम संख्या।
  

कार्यान्वयन

तो, आइए हमारे मॉड्यूल को एक नाम दें - चैनल। हम इसे रूबी में विकसित करेंगे (रेल में छोटे आवेषण भी लगेंगे)।
चैनलों का प्रबंधन करने के लिए ( बेसिक HTTP पुश रिले प्रोटोकॉल देखें ), हमें एक HTTP क्लाइंट की आवश्यकता है। मुझे पैट्रन पसंद है।
ओपन चैनल की एक सरणी को ओपन ओपन चैनल में संग्रहीत किया जाएगा। चैनल आईडी जनरेट_चैनल_आईडी विधि का उपयोग करके उत्पन्न किया जाएगा।

एक चैनल (ओपन मेथड) बनाना PUT अनुरोध को प्रकाशित बिंदु पर भेजकर किया जाता है (हमारे लिए यह सिर्फ / प्रकाशित है)। एक नए चैनल (स्थिति 200) के सफल निर्माण पर, जनरेट की गई आईडी को open_channels ऐरे में जोड़ा जाता है और वापस आ जाता है।
एक चैनल (क्लोज मेथड) को बंद करना प्रकाशित करने के लिए DELETE अनुरोध भेजकर किया जाता है।
चैनल के अस्तित्व की जाँच करना (मौजूद विधि?) प्रकाशित करने के लिए GET अनुरोध भेजकर किया जाता है। यदि सर्वर 200 लौटा है, तो चैनल खुला है, अन्यथा, सरणी से चैनल को हटा दें।
डेटा और सामग्री-प्रकार के साथ प्रकाशित करने के लिए POST अनुरोध भेजकर चैनल (पुश विधि) को डेटा भेजा जाता है । हम केवल चैनल खोलने के लिए डेटा भेजते हैं।

सभी HTTP अनुरोधों में एक चैनल पैरामीटर होना चाहिए (हमारे पास यह चैनल है)। स्वाभाविक रूप से, प्रकाशन-बिंदु को संरक्षित किया जाना चाहिए।

मॉड्यूल कोड:

module Channel @http_client = Patron::Session.new @http_client.base_url = "http://localhost/publish" @@opened_channels = [] mattr_accessor :opened_channels class << self def open id = generate_channel_id resp = @http_client.put(build_request_for_channel(id), "") if resp.status == 200 opened_channels << id id else false end end def close(id) resp = @http_client.delete(build_request_for_channel(id)) resp.status end def exist?(id) resp = @http_client.get(build_request_for_channel id) if resp.status == 200 true else opened_channels.delete id false end end def push(id, data, content_type) if exist? id puts "pushing to channel with id=#{id}..." resp = @http_client.post(build_request_for_channel(id), data, {"Content-Type" => content_type}) resp.status end end def push_to_all_channels(data, content_type="application/json") opened_channels.each { |c| push(c, data, content_type) } end private def generate_channel_id UUIDTools::UUID.timestamp_create.to_s end def build_request_for_channel(id) "/?channel=#{id}" end end end 

अनुरोध पर चैनल खोलने:

 def subscribe if channel_id = Channel::open render text: channel_id else render nothing: true, status: 500 end end 

डेटा भेजने का उदाहरण:

 user = current_user channel_id = user.channel_id msg = user.messages.last data = msg.to_json(only: [:created_at, :text]) status = Channel::push(channel_id, msg, "application/json")