using System;
using System.IO;
using NewLife.Messaging;
using NewLife.Log;

namespace NewLife.PeerToPeer.Messages
{
    /// <summary>
    /// 消息服务器
    /// </summary>
    public abstract class MessageServer : DisposeBase
    {
        #region 构造
        static MessageServer()
        {
            P2PMessage.Init();
        }

        /// <summary>
        /// 实例化
        /// </summary>
        public MessageServer()
        {
            P2PMessage.Received += new EventHandler<EventArgs<Message, Stream>>(OnReceived);
        }

        ///// <summary>
        ///// 析构，取消事件注册
        ///// </summary>
        //~MessageServer()
        //{
        //    P2PMessage.Received -= new EventHandler<EventArgs<Message, Stream>>(OnReceived);
        //}

        /// <summary>
        /// 取消事件注册
        /// </summary>
        /// <param name="disposing"></param>
        protected override void OnDispose(bool disposing)
        {
            base.OnDispose(disposing);

            P2PMessage.Received -= new EventHandler<EventArgs<Message, Stream>>(OnReceived);
        }
        #endregion

        #region 处理
        /// <summary>
        /// 消息到达时
        /// </summary>
        /// <param name="sender"></param>
        /// <param name="e"></param>
        protected abstract void OnReceived(object sender, EventArgs<Message, Stream> e);
        #endregion

        #region 日志
        /// <summary>
        /// 写日志
        /// </summary>
        /// <param name="message"></param>
        protected static void WriteLog(String message)
        {
            XTrace.WriteLine(message);
        }

        /// <summary>
        /// 写日志
        /// </summary>
        /// <param name="format"></param>
        /// <param name="args"></param>
        protected static void WriteLog(String format, params Object[] args)
        {
            XTrace.WriteLine(format, args);
        }
        #endregion
    }
}