Click here to Skip to main content
Click here to Skip to main content
Add your own
alternative version

A Remoting Event (Simple and Efficient for Enterprise Solutions)

, 21 Aug 2006 CPOL
This article contains the simplest solutions for: the security problem for DelegateSerializationHolder, the IO problem, and the messaging speed problem. Note: Messaging speed problem will appear when your application has worked for a long time.
using System;
using System.Collections.Generic;
using System.Text;
using System.Runtime.Remoting;
using System.Runtime.InteropServices;
using System.Runtime.Remoting.Messaging;


namespace Remotable
{
    /// <summary>
    /// Represents the method that will handle the Remotable.RemoteClass.MessageReceived event.
    /// </summary>
    /// <param name="message">Received message</param>
    [Serializable]
    [ComVisible(true)]
    public delegate void MessageHandler(string message);

    /// <summary>
    /// Shared remoting class that orchestrate messaging tasks 
    /// </summary>
    public class RemoteClass : MarshalByRefObject
    {

        /// <summary>
        /// Occurs when a broadcast message received.
        /// </summary>
        public event MessageHandler MessageReceived;

        /// <summary>
        /// For call asynchronously
        /// </summary>
        private MessageHandler messageDelegate;

        /// <summary>
        /// Initializes a new instance of the Remotable.RemoteClass class.
        /// </summary>
        public RemoteClass()
        {
            messageDelegate = new MessageHandler(Send);
        }

        /// <summary>
        /// Obtains a lifetime service object to control the lifetime policy for this
        /// instance.
        /// </summary>
        /// <returns>
        ///An object of type System.Runtime.Remoting.Lifetime.ILease used to control
        ///the lifetime policy for this instance. This is the current lifetime service
        ///object for this instance if one exists; otherwise, a new lifetime service
        ///object initialized to the value of the System.Runtime.Remoting.Lifetime.LifetimeServices.LeaseManagerPollTime
        ///property.
        ///null value means this object has to live forever.
        /// </returns>
        public override object InitializeLifetimeService()
        {
            return null;
        }

        private delegate void WrapperDelegate(string message, MessageHandler messageDelegate);
        /// <summary>
        /// Broadcast message to all clients
        /// </summary>
        /// <param name="message">message string</param>
        public void Send(string message)
        {
            if (MessageReceived != null)
            {
                MessageHandler messageDelegate = null;
                Delegate[] invocationList_ = null;
                try
                {
                    invocationList_ = MessageReceived.GetInvocationList();
                }
                catch (MemberAccessException ex)
                {
                    throw ex;
                }
                if (invocationList_ != null)
                {
                    lock (this)
                    {
                        foreach (Delegate del in invocationList_)
                        {
                            messageDelegate = (MessageHandler)del;
                            WrapperDelegate wrDel = new WrapperDelegate(BeginSend);
                            AsyncCallback callback = new AsyncCallback(EndSend);
                            wrDel.BeginInvoke(message, messageDelegate, callback, wrDel);
                        }
                    }
                }
            }
        }

        private void BeginSend(string message, MessageHandler messageDelegate)
        {
            try
            {
                System.Threading.Thread.Sleep(8000);
                messageDelegate(message);

            }
            catch (Exception e)
            {
                MessageReceived -= messageDelegate;
            }
        }

        private void EndSend(IAsyncResult result)
        {
            WrapperDelegate wrDel = (WrapperDelegate)result.AsyncState;
            wrDel.EndInvoke(result);
        }

    }


    

}

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)

Share

About the Author

Hossein Ghahvei Araghi
Program Manager System Group
Iran (Islamic Republic Of) Iran (Islamic Republic Of)
Hossein Ghahvei Araghi
Birth date: 1978
Birth place: Iran
Academic Credentials : BS(Tehran University)
Microsoft Credentials : MCP, MCAD, MCTS 2.0, MCTS 3.5, MCPD 2.0, MCPD 3.5
Follow on   Twitter   Google+

| Advertise | Privacy | Terms of Use | Mobile
Web01 | 2.8.150331.1 | Last Updated 21 Aug 2006
Article Copyright 2006 by Hossein Ghahvei Araghi
Everything else Copyright © CodeProject, 1999-2015
Layout: fixed | fluid