public interface ICoreUserManager
    {
        /// <summary>
        /// 在线用户的数量。
        /// </summary>
        int UserCount { get; }

/// <summary>
        /// 获取目标在线用户的基础信息。
        /// </summary>
        /// <param name="userID">目标用户的ID</param>
        /// <returns>如果目标用户不在线，则返回null</returns>
        UserData GetUserData(string userID);

/// <summary>
        /// 获取所有在线用户的ID列表。
        /// </summary>        
        List<string> GetOnlineUserList();

/// <summary>
        /// 如果是基于tcp引擎，则当tcp连接上接收或发送数据抛出异常时，将关闭连接，并触发此事件。
        /// </summary>
        event CbGeneric<UserData> SomeOneDisconnected;

/// <summary>
        /// 如果是基于tcp引擎，当接收到新连接上的第一个消息时，将触发此事件。
        /// </summary>
        event CbGeneric<UserData> SomeOneConnected;
    }

public interface IUserManager : ICoreUserManager
    {
        /// <summary>
        /// 用户管理器依赖该属性显示所有在线用户的状态信息。    
        /// </summary>
        IUserDisplayer UserDisplayer { set; }

/// <summary>
        /// 在线用户的心跳检测器。
        /// </summary>
        IHeartBeatChecker HeartBeatChecker { set; }

/// <summary>
        /// 重登陆模式。
        /// </summary>
        RelogonMode RelogonMode { get; set; }

/// <summary>
        /// 初始化用户管理器。
        /// </summary>
        void Initialize();

/// <summary>
        /// 清除所有的在线用户。
        /// </summary>
        void Clear();  
          
        /// <summary>
        /// 激活心跳。
        /// </summary>        
        void ActivateUser(string userID);

/// <summary>
        /// 目标用户是否在线。
        /// </summary>       
        bool IsUserOnLine(string userID);

/// <summary>
        /// 从在线列表中移除目标用户（依据用户的地址）。
        /// </summary>        
        void UnregisterUser(IUserAddress address);

/// <summary>
        /// 从在线列表中移除目标用户。
        /// </summary>
        void UnregisterUser(string userID);

/// <summary>
        /// 根据在线用户的地址获取用户ID。
        /// </summary>        
        string GetUserID(IUserAddress address);

/// <summary>
        /// GetTimeLogon 获取目标在线用户的登录时间。
        /// </summary>       
        DateTime GetTimeLogon(string userID);

/// <summary>
        /// 用于统计发送给用户的消息。如果用户还未注册，则忽略。
        /// </summary>        
        void AfterSentMessageToUser(string userID, IUserAddress address, IMessage msg);

/// <summary>
        /// 如果用户不在线，返回null    
        /// </summary>  
        IUserAddress GetUserAddress(string userID);

/// <summary>
        /// 当用户已经注册过，如果RelogonMode为IgnoreNew，则不会更改其address，而是直接返回；如果RelogonMode为ReplaceOld，则使用新的连接取代旧的连接。
        /// </summary>       
        void RegisterUser(string userID, IUserAddress address); 
        
        /// <summary>
        /// 旧连接被挤掉。如果RelogonMode为ReplaceOld，并且当从另外一个新连接上收到一个同名ID用户的消息时将触发此事件。

/// </summary>
        event CbGeneric<UserData> SomeOneBeingPushedOut;

/// <summary>
        /// 新连接被忽略。如果RelogonMode为IgnoreNew，并且当从一个新连接上收到一个同名ID用户的消息时将触发此事件。   
        /// </summary>
        event CbGeneric<string ,IUserAddress> NewConnectionIgnored;

/// <summary>
        /// 用户超时。只有在该事件处理完毕后，才将其从用户列表中删除。
        /// 但是，用户对应的TCP连接可能并没有被释放 -- 所以，在该事件处理函数中最好主动关闭TCP连接(将触发SomeOneDisconnected事件)。       
        /// </summary>
        event CbGeneric<UserData> SomeOneTimeOuted;

/// <summary>
        /// 当在线用户数发生变化时，触发此事件。
        /// </summary>
        event CbGeneric<int> UserCountChanged;
    }

public interface IUserDisplayer 
    { 
        /// <summary>
        /// 清除所有。通常是通信引擎停止时被调用。
        /// </summary>
        void ClearAll() ;

/// <summary>
        /// 当用户状态更新时被调用。
        /// </summary>
        /// <param name="userID">用户ID</param>
        /// <param name="justServiceType">刚刚发送给用户的消息类型</param>
        /// <param name="totalDataLen">该用户下载的总的数据量</param>
        /// <param name="userAddress">用户的地址</param>
        /// <param name="totalReqCount">总的请求次数</param>
        void SetOrUpdateUserItem(string userID, int justServiceType, long totalDataLen, string userAddress, long totalReqCount);

/// <summary>
        /// 移除用户。通常在用户下线时被调用。
        /// </summary>       
        void RemoveUser(string userID ,string cause);
    }

StreamTcpEngine streamTcpEngine = ......;

IHeartBeatChecker heartBeatChecker = new ESBasic.Threading.Application.HeartBeatChecker(1, 30);//心跳超时设为30秒
    heartBeatChecker.Initialize();
    IUserManager userManager = new UserManager();
    userManager.HeartBeatChecker = heartBeatChecker;
    userManager.RelogonMode = RelogonMode.ReplaceOld;//设置重登陆模式
    userManager.Initialize();

UserManagerBridge userManagerBridge = new UserManagerBridge();
    userManagerBridge.UserManager = userManager;
    userManagerBridge.ServerEngine = streamTcpEngine;
    userManagerBridge.Initialize();