A Complete TCP Server/Client Communication and RMI Framework - Usage

using System;
using System.IO;
using System.Runtime.Serialization;
using System.Runtime.Serialization.Formatters.Binary;
using Hik.Communication.Scs.Communication.Messages;

namespace Hik.Communication.Scs.Communication.Protocols
{
    /// <summary>
    /// Default communication protocol between server and clients to send and receive a message.
    /// It uses .NET binary serialization to write and read messages.
    /// </summary>
    internal class BinarySerializationProtocol : IScsWireProtocol
    {
        /// <summary>
        /// Writes a message to a stream.
        /// </summary>
        /// <param name="message">Message to write</param>
        /// <param name="stream">Stream that is used to write message</param>
        public void WriteMessage(IScsMessage message, Stream stream)
        {
            new BinaryFormatter().Serialize(stream, message);
        }

        /// <summary>
        /// Reads a message from a stream.
        /// </summary>
        /// <param name="stream">Stream taht is used to read message</param>
        /// <returns>Message that is read from stream</returns>
        public IScsMessage ReadMessage(Stream stream)
        {
            var binaryFormatter = new BinaryFormatter
            {
                AssemblyFormat = System.Runtime.Serialization.Formatters.FormatterAssemblyStyle.Simple,
                Binder = new DeserializationAppDomainBinder()
            };
            return (IScsMessage)binaryFormatter.Deserialize(stream);
        }

        /// <summary>
        /// This class is used in deserializing to allow deserializing objects that are defined
        /// in assemlies that are load in runtime (like PlugIns).
        /// </summary>
        private sealed class DeserializationAppDomainBinder : SerializationBinder
        {
            public override Type BindToType(string assemblyName, string typeName)
            {
                var toAssemblyName = assemblyName.Split(',')[0];
                foreach (var assembly in AppDomain.CurrentDomain.GetAssemblies())
                {
                    if (assembly.FullName.Split(',')[0] == toAssemblyName)
                    {
                        return assembly.GetType(typeName);
                    }
                }

                return null;
            }
        }
    }
}