WSHCommon/Common/Pomelo/PomeloShare/FastStream.cs

using CommonLang.Property;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Pomelo
{
    public class FastStreamConfig
    {
        public int port = 3360;
    }
    public interface IFastSession
    {
        string ConnectorId { get; }

		void doClose();

		bool IsConnected();

		string GetDescribe();
	}
    /// <summary>
    /// morefunFastStream管理器
    /// </summary>
    public abstract class FastStream
    {
        private static FastStream _instance;

        public static void init(string class_name)
        {
            if (string.IsNullOrEmpty(class_name))
            {
                class_name = typeof(FuckFastStream).FullName;
            }
            _instance = ReflectionUtil.CreateInstance(ReflectionUtil.GetType(class_name)) as FastStream; 
        }

        /// <summary>
        /// 单件实例
        /// </summary>
        /// <returns></returns>
        public static FastStream instance()
        {
            return _instance;
        }

        public abstract IFastSession GetSessionByID(string sessionID);

        /// <summary>
        /// 初始化
        /// </summary>
        /// <param name="config">配置</param>   
        public abstract void Start(FastStreamConfig config, IZone zone);

        /// <summary>
        /// 停止服务
        /// </summary>
        public abstract void Stop();

        /// <summary>
        /// 发送数据到connector服务器
        /// </summary>
        /// <param name="session"></param>
        /// <param name="uid"></param>
        /// <param name="data"></param>
        public abstract void Send(IFastSession session, string uid, string instanceId,ArraySegment<byte> data);
    }


}