WCF REST के आधार पर पुश सूचना सेवा का निर्माण

एक परिचय के रूप में

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

WsDualHttpBinding का उपयोग करते हुए मानक दृष्टिकोण

WCF द्वारा एक पुश तंत्र बनाने की क्षमता भी प्रदान की जाती है। यह ढांचा आपको wsDualHttpBinding अनुबंध का उपयोग करके एक धक्का सेवा बनाने की अनुमति देता है। ऐसा अनुबंध कॉलबैक पद्धति को निर्धारित करने के लिए प्रत्येक अनुरोध के लिए अनुमति देता है जिसे एक घटना होने पर बुलाया जाएगा।
यदि हम इस तंत्र को मैसेजिंग सिस्टम पर लागू करते हैं, तो हमें निम्नलिखित एल्गोरिथ्म मिलते हैं:

- नए संदेशों के लिए प्रत्येक अनुरोध के लिए, एक कॉलबैक बनाया जाता है, जो नए संदेशों के लिए ग्राहकों की सूची में संग्रहीत होता है।
- एक नया संदेश प्राप्त होने पर, सिस्टम सब्सक्राइबर्स की सूची से गुजरता है और हमें उस संदेश प्राप्तकर्ता को ढूंढता है जिसकी हमें आवश्यकता है (और इसलिए वांछित कॉलबैक)।
- हमें जिस कॉलबैक विधि की आवश्यकता होती है, उसे हम कॉल करते हैं।
निम्नलिखित WCF सेवा के लिए wsDualHttpBinding का उपयोग करने का एक उदाहरण है:

- नए संदेशों का अनुरोध करने के लिए कॉलबैक विधि बनाएं

interface IMessageCallback { [OperationContract(IsOneWay = true)] void OnMessageAdded(int senderId, string message, DateTime timestamp); } 

- हम एक सेवा अनुबंध बनाते हैं

 [ServiceContract(CallbackContract = typeof(IMessageCallback))] public interface IMessageService { [OperationContract] void AddMessage(int senderId, int recipientId, string message); [OperationContract] bool Subscribe(); } 

- हम सेवा स्वयं बनाते हैं

 Public class MessageService : IMessageService { private static List<IMessageCallback> subscribers = new List<IMessageCallback>(); public bool Subscribe(int id) { try { IMessageCallback callback = OperationContext.Current.GetCallbackChannel<IMessageCallback>(); callback.id = id; if (!subscribers.Contains(callback)) subscribers.Add(callback); return true; } catch { return false; } } public void AddMessage(int senderId, int recipientId, string message) { subscribers.ForEach(delegate(IMessageCallback callback) { if ((((ICommunicationObject)callback).State == CommunicationState.Opened) && (callback.id == recipientId)) { callback.OnMessageAdded(recipientId, message, DateTime.Now); } else { subscribers.Remove(callback); } }); } } 

- web.config फ़ाइल में सेवा को कॉन्फ़िगर करें

 <system.serviceModel> <services> <service name="WCFPush.MessageService" behaviorConfiguration="Default"> <endpoint address ="" binding="wsDualHttpBinding" contract="WCFPush.IMessage"> </endpoint> </service> </services> <behaviors> <serviceBehaviors> <behavior name="Default"> <serviceMetadata httpGetEnabled="True"/> <serviceDebug includeExceptionDetailInFaults="False" /> </behavior> </serviceBehaviors> </behaviors> </system.serviceModel> 

सेवा तैयार है।

हालाँकि, यह मॉडल तभी काम करता है जब सर्वर और सब्सक्राइबर दोनों .NET एप्लीकेशन हों।

एक ईमानदार दृष्टिकोण का उपयोग करना

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

इसलिए, हम पिछले एक की कार्यक्षमता में समान सेवा बनाएंगे, जो केवल REST पर आधारित है।
एसिंक्रोनस मॉडल के मामले में, अनुरोध में दो भाग होते हैं: BeginRequestName और EndRequestName।

- एक सेवा सेवा के लिए एक ServiceContract को परिभाषित करें

 [ServiceContract] public interface IMessageService { [WebGet(UriTemplate = "AddMessage?senderId={senderId}&recipientId={recipientId}&message={message}")] [OperationContract ] bool AddMessage(int senderId, int recipientId, string message); [WebGet(UriTemplate = "Subscribe?id={id}")] [OperationContract(AsyncPattern = true)] IAsyncResult BeginGetMessage(int id, AsyncCallback callback, object asyncState); ServiceMessage EndGetMessage(IAsyncResult result); } 

नोट: EndGetMessage ऑपरेशनकॉन्टैक्ट विशेषता के साथ चिह्नित नहीं है।

- अतुल्यकालिक परिणाम के लिए एक वर्ग बनाएं जो IAsyncResult इंटरफ़ेस को लागू करता है

 public class MessageAsyncResult : IAsyncResult { public AsyncCallback Callback { get; set; } private readonly object accessLock = new object(); private bool isCompleted = false; private ServiceMessage result; private int recipientId; private object asyncState; public MessageAsyncResult(object state) { asyncState = state; } public int RecipientId { get { lock (accessLock) { return recipientId; } } set { lock (accessLock) { recipientId = value; } } } public ServiceMessage Result { get { lock (accessLock) { return result; } } set { lock (accessLock) { result = value; } } } public bool IsCompleted { get { lock (accessLock) { return isCompleted; } } set { lock (accessLock) { isCompleted = value; } } } public bool CompletedSynchronously { get { return false; } } public object AsyncState { get { return asyncState; } } public WaitHandle AsyncWaitHandle { get { return null; } } } 

इंटरफ़ेस के कार्यान्वयन के अलावा, यह वर्ग संदेश प्राप्तकर्ता (प्राप्तकर्ता) के आईडी को भी संग्रहीत करता है, साथ ही संदेश को स्वयं भी भेजता है, जो प्रेषक (परिणाम) को वितरित किया जाएगा।

- अब हम सेवा को स्वयं लागू करते हैं

 [ServiceBehavior( InstanceContextMode = InstanceContextMode.PerCall, ConcurrencyMode = ConcurrencyMode.Multiple)] public class MessageService : IMessageService { private static List<MessageAsyncResult> subscribers = new List<MessageAsyncResult>(); public bool AddMessage(int senderId, int recipientId, string message) { subscribers.ForEach(delegate(MessageAsyncResult result) { if (result.RecipientId == recipientId) { result.Result = new ServiceMessage(senderId, recipientId, message, DateTime.Now); result.IsCompleted = true; result.Callback(result); subscribers.Remove(result); } }); return true; } public IAsyncResult BeginGetMessage(int id, AsyncCallback callback, object asyncState) { MessageAsyncResult asyncResult = new MessageAsyncResult(asyncState); asyncResult.Callback = callback; asyncResult.RecipientId = id; subscribers.Add(asyncResult); return asyncResult; } public ServiceMessage EndGetMessage(IAsyncResult result) { return (result as MessageAsyncResult).Result; } } 

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

- यह web.config फ़ाइल में सेवा को कॉन्फ़िगर करने के लिए बनी हुई है

 <system.serviceModel> <bindings> <webHttpBinding> <binding name="webBinding"> </binding> </webHttpBinding> </bindings> <services> <service name=" WCFPush.MessageService" behaviorConfiguration="Default"> <endpoint address="" contract="WCFPush.IMessageService" behaviorConfiguration="web" bindingConfiguration="webBinding" binding="webHttpBinding"> </endpoint> </service> </services> <behaviors> <endpointBehaviors> <behavior name="web"> <webHttp /> </behavior> </endpointBehaviors> <serviceBehaviors> <behavior name="Default"> <serviceMetadata httpGetEnabled="true" /> <serviceDebug includeExceptionDetailInFaults="false" /> </behavior> </serviceBehaviors> </behaviors> <serviceHostingEnvironment multipleSiteBindingsEnabled="true" /> </system.serviceModel> 

सेवा तैयार है।

जाहिर है, जब सेवा से प्रतिक्रिया की प्रतीक्षा करने का समय समाप्त हो जाएगा, तो आपको नए संदेशों के लिए अनुरोध को फिर से भेजना होगा।

निष्कर्ष

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