WSNet2Serializer.cs

using System;
using System.Collections;
using System.Runtime.Serialization;

namespace WSNet2
{
    /// <summary>
    ///   型を保存するシリアライザ/デシリアライザ
    /// </summary>
    /// <remarks>
    ///   <para>
    ///     独自型の登録はこのクラスのstaticメソッドで行う。
    ///   </para>
    /// </remarks>
    public class WSNet2Serializer
    {
        public delegate object ReadFunc(SerialReader reader, object recycle);

        const int WRITER_BUFSIZE = 1024;

        static Hashtable registeredTypes = new Hashtable();
        static ReadFunc[] readFuncs = new ReadFunc[256];
        static SerialWriter writer;

        /// <summary>
        ///   SerialWriter新規作成
        /// </summary>
        /// <remarks>
        ///   <para>
        ///     使い回されることはない。
        ///   </para>
        /// </remarks>
        public static SerialWriter NewWriter(int size = WRITER_BUFSIZE)
        {
            return new SerialWriter(size, registeredTypes);
        }

        /// <summary>
        ///   使い回し用のSerialWriterを取得
        /// </summary>
        /// <remarks>
        ///   <para>
        ///     lockを取って使うこと。
        ///   </para>
        /// </remarks>
        public static SerialWriter GetWriter()
        {
            if (writer == null)
            {
                writer = new SerialWriter(WRITER_BUFSIZE, registeredTypes);
            }

            return writer;
        }

        /// <summary>
        ///   SerialReader
        /// </summary>
        public static SerialReader NewReader(byte[] buf)
        {
            return NewReader(new ArraySegment<byte>(buf));
        }

        /// <summary>
        ///   SerialReader
        /// </summary>
        public static SerialReader NewReader(ArraySegment<byte> buf)
        {
            return new SerialReader(buf, registeredTypes, readFuncs);
        }

        /// <summary>
        /// カスタム型を登録する
        /// </summary>
        /// <typeparam name="T">登録する型（IWSNet2Serializable）</typeparam>
        /// <param name="classID">クラス識別子</param>
        public static void Register<T>(byte classID) where T : class, IWSNet2Serializable, new()
        {
            var t = typeof(T);
            if (registeredTypes.ContainsKey(t))
            {
                var msg = string.Format("Type '{0}' is aleady registered as {1}", t, classID);
                throw new ArgumentException(msg);
            }

            if (readFuncs[classID] != null)
            {
                var msg = string.Format("ClassID '{0}' is aleady used for {1}", classID, t);
                throw new ArgumentException(msg);
            }

            registeredTypes[t] = classID;
            readFuncs[classID] = (reader, obj) => reader.ReadObject<T>(obj as T);
        }
    }

    /// <summary>
    /// Websocketで送受信するカスタム型はこのインターフェイスを実装する
    /// </summary>
    public interface IWSNet2Serializable
    {
        /// <summary>
        /// Serializeする.
        /// </summary>
        /// <param name="writer">writer</param>
        void Serialize(SerialWriter writer);

        /// <summary>
        /// Deserializeする.
        /// </summary>
        /// <param name="reader">reader</param>
        /// <param name="size">readerから利用可能なデータ長</param>
        void Deserialize(SerialReader reader, int size);
    }

    enum Type : byte
    {
        Null = 0,
        False,
        True,
        SByte,
        Byte,
        Char,
        Short,
        UShort,
        Int,
        UInt,
        Long,
        ULong,
        Float,
        Double,
        Decimal,
        Str8,
        Str16,
        Obj,
        List,
        Dict,

        Bools,
        SBytes,
        Bytes,
        Chars,
        Shorts,
        UShorts,
        Ints,
        UInts,
        Longs,
        ULongs,
        Floats,
        Doubles,
        Decimals,
    }

    [Serializable()]
    public class WSNet2SerializerException : Exception
    {
        public WSNet2SerializerException() : base()
        {
        }

        public WSNet2SerializerException(string message) : base(message)
        {
        }

        public WSNet2SerializerException(string message, Exception innerException) : base(message, innerException)
        {
        }
    }

}