💡 🥛 🙆🏼 एक कार्यान्वयन में वेब, मोबाइल और डेस्कटॉप के लिए द्वैध अतुल्यकालिक डेटा विनिमय 🍗 🚶🏿 🚽

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

मैं तुरंत कहूंगा कि यह विज्ञापन नहीं है और मेरा डेवलपर्स से कोई लेना-देना नहीं है और मुझे अपने काम के लिए कोई पारिश्रमिक नहीं मिला है (नैतिक को छोड़कर, अपना अनुभव साझा करने के लिए)।

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

स्थापना पैकेज (वास्तव में संग्रहीत फ़ोल्डर) में पहले से ही एक डेमो लाइसेंस होता है, जिसके प्रतिबंध केवल 20 एक साथ जुड़े ग्राहकों के लिए कम हो जाते हैं, जो कि आप देखते हैं, विकास के लिए काफी पर्याप्त है, लेकिन यदि नहीं, तो आप 60 दिनों के प्रतिबंध के बिना मूल्यांकन का आदेश दे सकते हैं। यहां उपलब्ध लाइसेंस की एक सूची दी गई है।

स्थापना निर्देश /Lightstreamer/GETTING_STARTED.TXT में दिए गए हैं जो संग्रह के अंदर स्थित हैं। सब कुछ बेहद सरल है (मैं विंडोज के लिए इसका वर्णन करूंगा):

- अनपैक, अधिमानतः डिस्क की जड़ में क्योंकि संग्रह में फ़ाइलों के लिए काफी लंबा पथ है;

- टीसीपी पोर्ट निर्दिष्ट करें, जिस पर सर्वर /Lightstreamer/conf/lightstreamer_conf.xml, डिफ़ॉल्ट रूप से 8080 और 8888 द्वारा लटकाएगा;

JAVA_HOME चर में /Lightstreamer/bin/windows/LS.bat में इंगित करें कि JDK कहाँ स्थापित है (यदि स्थापित नहीं है, स्थापित करें);

- और सर्वर / लाइटस्ट्रीमर / बिन / विंडोज़ / Start_LS_as_Application.bat शुरू करें।

परीक्षण के लिए, http: // localhost: 8080 खोलें (वही पोर्ट निर्दिष्ट करें जो /Lightstreamer/conf/lightstreamer_conf.xml में निर्दिष्ट किया गया था) और अनइंस्टॉल किए गए डेमो के लिंक के साथ एक स्वागत पृष्ठ देखना चाहिए।

HTTP के बजाय HTTPS और क्लस्टरिंग का उपयोग लोडर के साथ करना संभव है

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

एडॉप्टर लेखन

/ लाइटस्ट्रीमर / डॉक्स-एसडीके / फ़ोल्डर में एसडीके होता है। .NET पर एडेप्टर लिखने के लिए, आपको लाइटस्ट्रीमर .Interfaces.Data.IDataProvider इंटरफ़ेस /Lightstreamer/DOCS-SDKs/sdk_adapter_dotnet/bib/DotNetAdapter_N2.dll से लागू करने की आवश्यकता है

using System; using System.Collections; using System.Threading; using Lightstreamer.Interfaces.Data; public class HelloWorldAdapter : IDataProvider { private IItemEventListener _listener; private volatile bool go; public void Init(IDictionary parameters, string configFile) { } public bool IsSnapshotAvailable(string itemName) { return false; } public void SetListener(IItemEventListener eventListener) { _listener = eventListener; } public void Subscribe(string itemName) { if (itemName.Equals("greetings")) { new Thread(new ThreadStart(Run)).Start(); } } public void Unsubscribe(string itemName) { if (itemName.Equals("greetings")) { go = false; } } public void Run() { go = true; int c = 0; Random rand = new Random(); while (go) { IDictionary eventData = new Hashtable(); eventData["message"] = c % 2 == 0 ? "Hello" : "World"; eventData["timestamp"] = DateTime.Now.ToString("s"); _listener.Update("greetings", eventData, false); c++; Thread.Sleep(1000 + rand.Next(2000)); } } }

एडॉप्टर लॉन्च

शुरू करने के लिए, हमें एक सांत्वना aplikuha की आवश्यकता है

 using System; using System.Net.Sockets; using Lightstreamer.DotNet.Server; public class DataAdapterLauncher { public static void Main(string[] args) { string host = "localhost"; int reqrepPort = 6661; int notifPort = 6662; try { DataProviderServer server = new DataProviderServer(); server.Adapter = new HelloWorldAdapter(); TcpClient reqrepSocket = new TcpClient(host, reqrepPort); server.RequestStream = reqrepSocket.GetStream(); server.ReplyStream = reqrepSocket.GetStream(); TcpClient notifSocket = new TcpClient(host, notifPort); server.NotifyStream = notifSocket.GetStream(); server.Start(); System.Console.WriteLine("Remote Adapter connected to Lightstreamer Server."); System.Console.WriteLine("Ready to publish data..."); } catch (Exception e) { System.Console.WriteLine("Could not connect to Lightstreamer Server."); System.Console.WriteLine("Make sure Lightstreamer Server is started before this Adapter."); System.Console.WriteLine(e); } } }

एडाप्टर को सर्वर पर भरना

/ लाइटस्ट्रीमर / एडेप्टर / फ़ोल्डर में, एक नया फ़ोल्डर बनाएं और उसमें /Lightstreamer/DOCS-SDKs/sdk_adapter_remoting_infrastructure/lib/ls-proxy-adapters.jar कॉपी करें। वहां हम सामग्री के साथ एक नई फ़ाइल /lib/adapters.xml बनाते हैं

 <?xml version="1.0"?> <adapters_conf id="HelloWorld"> <metadata_provider> <adapter_class>com.lightstreamer.adapters.metadata.LiteralBasedProvider</adapter_class> </metadata_provider> <data_provider> <adapter_class>com.lightstreamer.adapters.remote.data.RobustNetworkedDataProvider</adapter_class> <classloader>log-enabled</classloader> <param name="request_reply_port"> 6661</param> <param name="notify_port"> 6662</param> </data_provider> </adapters_conf>

कोई भी नाम हरा सकता है - यह क्लाइंट को लिखते समय और उस पर इंगित किया जाएगा। जैसा कि आप देख सकते हैं, एडाप्टर शुरू करते समय पोर्ट समान होते हैं।

ग्राहक लेखन

उदाहरण के लिए, मैं सबसे सरल जावास्क्रिप्ट क्लाइंट दूंगा।

 <html> <head> <script src="http://cdnjs.cloudflare.com/ajax/libs/require.js/1.0.7/require.min.js"></script> <script src="https://code.jquery.com/jquery-2.1.0.min.js"></script> <script src="C:/Lightstreamer/DOCS-SDKs/sdk_client_javascript/lib/lightstreamer.js"></script> <script> require(["LightstreamerClient","Subscription","StaticGrid"],function(LightstreamerClient,Subscription,StaticGrid) { var lsClient = new LightstreamerClient("http://localhost:8080", "HelloWorld"); lsClient.connect(); var lsSubscription = new Subscription("MERGE",['greetings'],['greetings', 'message', 'timestamp']); lsSubscription.addListener({ onItemUpdate: function(updateObject) { $("#message").text('Message=' + updateObject.getValue("message")); $("#timestamp").text('TimeStamp=' + updateObject.getValue("timestamp")); } }); lsClient.subscribe(lsSubscription); }); </script> </head> <body> <span id="message"></span><br/> <span id="timestamp"> </span> </body> </html>

परिणाम

और अंत में, हमें क्लाइंट पर स्वचालित रूप से अपडेट किया गया डेटा प्राप्त हुआ:

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

 new Subscription("MERGE",['userID123'],['greetings', 'message', 'timestamp'])

आप न केवल एक पैरामीटर, बल्कि कई, एक अल्पविराम, बृहदान्त्र, आदि द्वारा अलग कर सकते हैं। और एडेप्टर के अनुसार यह सभी पार्सिंग है।

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

अंत में

Www.lightstreamer.com/doc एडेप्टर को देखते हुए लिखा जा सकता है:

जावा
नेट
नोड जे.एस.

ग्राहक प्लेटफार्मों की एक बड़ी सूची:

avaScript
एंड्रॉयड
आईओएस
विंडोज फोन
WinRT
ब्लैकबेरी
जावा एमई
फ़्लैश
फ्लेक्स
सिल्वरलाइट
नेट
जावा एसई
ओएस एक्स

पुनश्च

उदाहरण के लिए github ई पर एडाप्टर स्रोत।

एक कार्यान्वयन में वेब, मोबाइल और डेस्कटॉप के लिए द्वैध अतुल्यकालिक डेटा विनिमय