WSHCommon/Common/CommonServer.ICE/Session/TcpSessionManager.cs

using CommonLang.Log;
using CommonServer.Server;
using CommonServer_ICE.Server;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace CommonServer_ICE.Session
{
    /// <summary>
    /// TCP通讯方式会话管理器
    /// </summary>
    internal class TcpSessionManager : Glacier2.SessionManagerDisp_
    {
        private static Logger log = LoggerFactory.GetLogger("TcpSessionManager");
        // 所有会话保存对象
        private Dictionary<string, ISession> sessionIdKeyMap = new Dictionary<string, ISession>();
        // TCP服务器对象
        private IceTcpServer tcpServer;

        public TcpSessionManager(IceTcpServer tcpServer)
        {
            this.tcpServer = tcpServer;
            tcpServer.TcpSessionManager = this;
        }

        /// <summary>
        /// 创建会话
        /// </summary>
        /// <param name="userId">用户名（忽略不用）</param>
        /// <param name="control">会话控制器</param>
        /// <param name="current">上下文</param>
        /// <returns>会话</returns>
        public override Glacier2.SessionPrx create(string userId, Glacier2.SessionControlPrx control, Ice.Current current)
        {
            Ice.TCPConnectionInfo tcpConInfo = (Ice.TCPConnectionInfo)current.con.getInfo();
            IceServerIoSession session = new IceServerIoSession(tcpServer);
            session.TcpSessionManager = this;
            session.RemoteIp = tcpConInfo.remoteAddress;
            session.ClientSentDataPort = tcpConInfo.remotePort;
            sessionIdKeyMap.Add(session.ID, session);

            // 通知新会话建立
            try
            {
                tcpServer.OnNewSessionConnected(session);
            }
            catch (Exception e)
            {
                log.Error("建立新会话发生异常：" + e.Message);
            }

            Ice.ObjectPrx objectPrx = current.adapter.addWithUUID(session);
            session.ClientIdentity = objectPrx.ice_getIdentity();

            return Glacier2.SessionPrxHelper.uncheckedCast(current.adapter.addWithUUID(session));
        }

        /// <summary>
        /// 清除会话
        /// </summary>
        /// <param name="session">会话</param>
        public void RemoveSession(IceServerIoSession session)
        {
            sessionIdKeyMap.Remove(session.ID);
        }

        /// <summary>
        /// 获取会话键
        /// </summary>
        /// <param name="ip">IP</param>
        /// <param name="port">端口</param>
        /// <returns>会话键</returns>
        private string getSessionKey(string ip, int port)
        {
            return ip + ":" + port;
        }

        /// <summary>
        /// 获取会话数量
        /// </summary>
        /// <returns></returns>
        public int getSessionCount()
        {
            return sessionIdKeyMap.Count;
        }

        /// <summary>
        /// 获取所有会话
        /// </summary>
        /// <returns>会话一览</returns>
        public List<ISession> getAllSession()
        {
            return sessionIdKeyMap.Values.ToList();
        }

        /// <summary>
        /// 判断序列号为键的会话是否存在
        /// </summary>
        /// <param name="sessionId">序列号键</param>
        /// <returns></returns>
        public ISession getSession(string sessionId)
        {
            ISession ret;
            if (sessionIdKeyMap.TryGetValue(sessionId, out ret))
            {
                return ret;
            }
            return null;
        }

        /// <summary>
        /// 根据IP地址和端口判断是否存在某个会话
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        public ISession getSession(String ip, int port)
        {
            return null;
        }

        /// <summary>
        /// 判断指定序列号的会话是否存在
        /// </summary>
        /// <param name="sessionId"></param>
        /// <returns></returns>
        public bool hasSession(string sessionId)
        {
            if (sessionIdKeyMap.ContainsKey(sessionId))
            {
                return true;
            }
            return false;
        }

        /// <summary>
        /// 判断传入会话对象是否存在
        /// </summary>
        /// <param name="session"></param>
        /// <returns></returns>
        public bool hasSession(ISession session)
        {
            return hasSession(session.ID);
        }

        /// <summary>
        /// IP地址和端口为键获取会话
        /// </summary>
        /// <param name="ip"></param>
        /// <param name="port"></param>
        /// <returns></returns>
        public bool hasSession(String ip, int port)
        {
            return false;
        }
    }
}