MTP2.0_CSharp/Muchinfo.MTPClient/Fx4.0/Main/05.Services/Muchinfo.TASClient.Service/LinkProxy/LinkManager.cs

using Muchinfo.TASClient.Adapter.Factory;
using Muchinfo.TASClient.Service.LinkProxy.Enum;
using Muchinfo.TASClient.Service.LinkProxy.TCP;

namespace Muchinfo.TASClient.Service.LinkProxy
{
    public class LinkManagerParameters
    {
        public string TradeHost { get; set; }
        public int TradePort { get; set; }
        public string QuotationHost { get; set; }
        public int QuotationPort { get; set; }
        public LinkType TradeLinkeType { get; set; }
        public DatagramType TradeDatagramType { get; set; }
    }

    public class LinkManager
    {
        #region Public Fields
        /// <summary>
        /// 链路参数
        /// </summary>
        public LinkManagerParameters Parameters { get; set; }

        /// <summary>
        /// 业务对象数据转换器
        /// </summary>
        /// <value>The biz adapter factory.</value>
        public AdapterFactory TradeAdapterFactory { get; private set; }

        /// <summary>
        /// Gets or sets the trade TCP link proxy.
        /// </summary>
        /// <value>The trade TCP link proxy.</value>
        public TradeTcpLinkProxy TradeTcpLinkProxy { get; set; }

        /// <summary>
        /// Gets or sets the quotation TCP link proxy.
        /// </summary>
        /// <value>The quotation TCP link proxy.</value>
        public QuotationTcpLinkProxy QuotationTcpLinkProxy { get; set; }

        #endregion

        #region Singalton
        private static LinkManager _instance;
        private static object _lock = new object();

        public static LinkManager Instance
        {
            get
            {
                if (null == _instance)
                {
                    lock (_lock)
                    {
                        if (null == _instance)
                        {
                            _instance = new LinkManager();
                        }
                    }
                }
                return _instance;
            }
        }

        private LinkManager() { }

        #endregion

        /// <summary>
        /// 链路初始化
        /// </summary>
        /// <param name="parameters">The parameters.</param>
        public void Initialize(LinkManagerParameters parameters)
        {
            Parameters = parameters;
            if (null == Parameters) return;

            switch (Parameters.TradeDatagramType)
            {
                case DatagramType.Protobuf:
                    TradeAdapterFactory = new ProtobufFactory();
                    break;
                case DatagramType.Json:
                    TradeAdapterFactory = new JsonFactory();
                    break;
            }

#if DEBUG

#else
            switch (Parameters.TradeLinkeType)
            {
                case LinkType.TCP:
                    TradeTcpLinkProxy = new TradeTcpLinkProxy(Parameters.TradeHost, Parameters.TradePort);
                    break;
                default:
                    //todo
                    break;
            }
#endif
            //QuotationTcpLinkProxy = new QuotationTcpLinkProxy(Parameters.QuotationHost, Parameters.QuotationPort);
        }
    }
}