C#仿QQ聊天程序v1.0(客户端管理类)


C#仿QQ聊天程序v1.0(客户端管理类)

[原创]C#仿QQ聊天程序v1.0(客户端管理类)

ChatClientLib类是本程序相当重要的一个类,包括监听消息,用户管理,发送消息及处理未读消息等功能。请结合其它类来认真学习这个程序。



/// <summary>
/// 聊天程序管理类
/// </summary>
public class ChatClientLib
{

        private IConnectionList _Connections = null; //联系人列表

        private ChatConnection _CurrentConnection = null; //当前联系人对象

        private IList _SendMsgProxyList = new ArrayList(); //与用户聊天打开的聊天窗口

        private ArrayList _NotifyList = new ArrayList();//收到未查看消息列表

        private TcpListener _ServerListener = null; //本地消息监听

        private Thread _ServerListenerThread = null; //监听使用的线程      

        private bool _ServerRunning = false;//运行服务器标志

 

        private IPAddress _LocalServerIP; //本地服务器地址

        private int _LocalServerPort = 5858;//本地服务器端口


//CSFramework原创作品,如转载请注明出处 by C/S框架网 www.csframework.com 

        private IMessageContainer _MessageHistory = new NullLog();

        public IMessageContainer MessageHistory { get { return _MessageHistory; } set { _MessageHistory = value; } }

 

        //构造器

        public ChatClientLib(IConnectionList Connections)

        {

            _LocalServerIP = Dns.GetHostAddresses(Dns.GetHostName())[0];

            _Connections = Connections;

            _CurrentConnection = new ChatConnection(Loginer.Current.AccountName, Loginer.Current.Account,
Loginer.Current.FactoryCode, _LocalServerIP.ToString(), _LocalServerPort, ChatState.Online);

        }

 

        //未读消息列表

        public ArrayList NotifyList { get { return _NotifyList; } }

 

        //在线用户列表

        public IConnectionList Connections { get { return _Connections; } set { _Connections = value; } }

 

        //当前用户连接(登录的用户)

        public ChatConnection CurrentConnection { get { return _CurrentConnection; } }

 

        private frmShowMessage _ShowMsgForm = new frmShowMessage();

        private void ShowMessage(string msg)

        {

            _ShowMsgForm.ShowMessage(msg);

            ChatCommon.ShowWindow(_ShowMsgForm.Handle, 1);

            ChatCommon.SetForegroundWindow(_ShowMsgForm.Handle);

        }


   
   //启动聊天服务器程序. 参数说明 ip:本地消息服务器IP地址; port:端口
   public void StartMessageServer(string localServerIp, int localServerPort)
   {
      if (_ServerRunning) return;
      
      _LocalServerIP = IPAddress.Parse(localServerIp);
      _LocalServerPort = localServerPort;
      
      //构建监听
      _ServerListener = new TcpListener(_LocalServerIP, _LocalServerPort);
      _ServerListener.Start(255);
      _ServerRunning = true;
      
      //启动线程
      _ServerListenerThread = new Thread(new ThreadStart(DoStartServerListener));
      _ServerListenerThread.IsBackground = true;
      _ServerListenerThread.Start();
      
      this.UpdateOnlineState(1);
      
   }
   
   //关闭聊天服务器程序.
   public void StopMessageServer()
   {
      _ServerRunning = false;
      _ServerListener.Stop();
      _ServerListenerThread.Abort("101");
      _ServerListenerThread = null;
      
      //登出,删除在线记录
      this.UpdateOnlineState(0);
   }
   
   /// <summary>
   ///启动聊天服务器程序.
   /// </summary>
   private void DoStartServerListener()
   {
      try
      {
         //监听客户连线请求
         while (_ServerRunning)
         {
            if (_ServerListener == null) return; //防止其它地方关闭监听
            
            Socket socket = _ServerListener.AcceptSocket(); //有客户请求连接
            if (socket == null) continue;
            
            byte[] buffer = new Byte[socket.ReceiveBufferSize];
            int i = socket.Receive(buffer); //接收请求数据.
            if (i <= 0) continue;
            
            //处理对象流
            if (ChatCommon.IsObjectStream(buffer))
            {
               _MessageHistory.AddMessage("接受到服务器发送的对象数据.");
               DoAnalyzeObject(buffer);
               socket.Close();
               continue;
            }
            socket.Close();
         }
      }
      catch (Exception ex)
      {
         if (ex is ThreadAbortException)
         {
            if ((ex as ThreadAbortException).ExceptionState.ToString() == "101")
            _ServerRunning = false;
         }
      }
   }
   
   /// <summary>
   /// 获取用户头像
   /// </summary>
   /// <param name="account"></param>
   /// <returns></returns>
   private System.Drawing.Image GetUserPhoto(string account)
   {
      return ChatCommon.GetImage("chat_woman.ico");
   }
   
   /// <summary>
   /// 发送消息
   /// </summary>
   public void SendToClient(ChatConnection conn, cmdBase message)
   {
      TcpClient client = new TcpClient();
      ChatCommon.TryConnect(client, conn.IP, conn.Port);
      byte[] data = ChatCommon.GetObjectArray(message);
      if (client.Connected) client.Client.Send(data);
      client.Close();
   }
   
   /// <summary>
   /// 分析接受到的数据(字节数组)
   /// </summary>
   /// <param name="buffer"></param>
   private void DoAnalyzeObject(byte[] buffer)
   {
      object o = ChatCommon.GetObject(buffer);
      
      if (o is cmdMessage)//普通消息
      {
         cmdMessage msg = o as cmdMessage;
         
         _MessageHistory.AddMessage(msg.Sender + "说:" + msg.Content);
         
         //当收到消息,如果有打开与发送者聊天的窗口,则显示消息.否则闪烁图标.
         ISendMsgProxy proxy = GetSendMsgProxy(msg.Sender);
         if (proxy == null)
         {
            _Connections.AddReceivedMessage(msg.Sender, msg.Content);
            _Connections.FlashConnection(msg.Sender);
            _NotifyList.Add(new NotifyItem(NotifyType.Message, msg.Sender));
         }
         else
         {
            proxy.ShowMessage(ShowMessageType.ShowTargetMessage, msg.Content);
         }
      }
      else if (o is cmdNotifyOnline) //好友通知上线
      {
         cmdNotifyOnline msg = o as cmdNotifyOnline;
         ChatConnection conn = new ChatConnection(msg.NickName, msg.Sender, msg.FactoryCode, msg.IP,
msg.Port, ChatState.Online);
         _Connections.AddConnection(conn);
      }
      else if (o is cmdExit) //好友通知上线
      {
         _Connections.RemoveConnection((o as cmdExit).Sender);
      }
   }
   
   //增加发送消息窗体
   public void AddSendMsgProxy(ISendMsgProxy proxy)
   {
      if (_SendMsgProxyList.IndexOf(proxy) < 0)
      _SendMsgProxyList.Add(proxy);
   }
   
   //获取发送消息窗体
   private ISendMsgProxy GetSendMsgProxy(string account)
   {
      for (int i = 0; i <= _SendMsgProxyList.Count - 1; i++)
      {
         ISendMsgProxy proxy = _SendMsgProxyList[i] as ISendMsgProxy;
         if (proxy.TargetConnection.Account == account) return proxy;
      }
      return null;
   }
   
   //增加一个用户连接
   private void AddClient(ChatConnection client)
   {
      //有相同的IP存在,不加载
      object o = _Connections.GetConnection(client.Account);
      if (o == null)
      _Connections.AddConnection(client);
   }
   
   //登出
   public void Logout()
   {
      IList list = _Connections.GetConnections();
      cmdExit msg = new cmdExit(_CurrentConnection.Account);
      //通知所有好友
      foreach (ChatConnection conn in list)
      {
         if (conn == _CurrentConnection) continue;
         if (conn.ConnectionState == ChatState.Online)
         SendToClient(conn, msg);
      }
      
      _Connections.CloseAll(false);//关闭所有连接
      
      if (_MessageHistory != null) _MessageHistory.AddMessage("登出成功!");
   }
   
   //发送消息给所有用户
   public void SendToAllClient(cmdBase message)
   {
      IList list = _Connections.GetConnections();
      foreach (ChatConnection conn in list)
      {
         if (conn.Account == Loginer.Current.Account) continue;
         if (conn.ConnectionState != ChatState.Online) continue;
         
         SendToClient(conn, message);
      }
   }
   
   //显示发送消息窗体
   public void ShowSendMsgForm(ChatConnection conn)
   {
      ISendMsgProxy proxy = GetSendMsgProxy(conn.Account);
      if (proxy == null)
      {
         proxy = frmSendMessage.Execute(this, this.CurrentConnection, conn);
         AddSendMsgProxy(proxy);
      }
      
      //有未读消息
      if (conn.ReceivedMessage.Count > 0)
      {
         proxy.ShowMessage(ShowMessageType.ShowTargetMessage, conn.ReceivedMessage);
         conn.ReceivedMessage.Clear();
         _Connections.StopFlash(conn.Account);
      }
      
      proxy.ShowMe();
   }
   
   //处理系统通知.优先处理最后一个消息.处理完毕删除通知.
   public void ProcessNotify()
   {
      NotifyItem item = _NotifyList[_NotifyList.Count - 1] as NotifyItem;//先处理最后的消息
      
      if (item.NotifyType == NotifyType.Information)
      {
         ShowMessage(item.Content.ToString());
      }
      else if (item.NotifyType == NotifyType.Message)
      {
         string account = item.Content.ToString();
         ChatConnection conn = _Connections.GetConnection(account);
         if (conn != null) ShowSendMsgForm(conn);
      }
      _NotifyList.RemoveAt(_NotifyList.Count - 1); //删除最后一个通知
   }
   
   //删除发送消息窗体
   public void RemoveSendMsgProxy(ISendMsgProxy frmSendMessage)
   {
      _SendMsgProxyList.Remove(frmSendMessage);
   }
   
   //显示连接消息
   public void ShowConnection(ChatConnection conn)
   {
      frmConnectionInfo.ShowConnection(conn);
   }
   
   //加载用户列表
   public void LoadUserList(ShowUser type)
   {
      DataTable dt = ChatDAL.GetOnlineUsers();
      IList list = new ArrayList();
      _Connections.CloseAll();
      _Connections.ShowUserType = type;
      
      foreach (DataRow row in dt.Rows)
      {
         ChatConnection conn = CreateChatConnection(row);
         
         //当前处理的连接对象是自己,放第一行显示
         if (row["Account"].ToString() == Loginer.Current.Account)
         _Connections.AddConnection(0, conn);
         else
         _Connections.AddConnection(conn);
      }
   }
   
   //DataRow转换为ChatConnection对象
   private ChatConnection CreateChatConnection(DataRow row)
   {
      ChatConnection conn = new ChatConnection();
      conn.Account = row["Account"].ToString();
      conn.ConnectionState = ChatState.Online;
      conn.DisplayName = row["AccountName"].ToString();
      conn.IP = row["NativeIP"].ToString();
      conn.Port = int.Parse(row["NativePort"].ToString());
      conn.FactoryCode = row["FactoryCode"].ToString();
      return conn;
   }
   
   //更新用户状态.
   public void UpdateOnlineState(int state)
   {
      //保存用户在线记录
      ChatDAL.UpdateOnlineState(Loginer.Current.Account, _LocalServerIP.ToString(), _LocalServerPort, state);
   }
   
}

//CSFramework原创作品,如转载请注明出处 by C/S框架网 www.csframework.com 


版权声明:本文为开发框架文库发布内容,转载请附上原文出处连接
C/S框架网
上一篇:C#仿QQ聊天程序v1.0(IConnectionList接口实现)
下一篇:创建TreeList及打开TreeListNode.Tag属性对应的窗体
评论列表

发表评论

评论内容
昵称:
关联文章

C#仿QQ聊天程序v1.0(客户管理)
[原创]C#仿QQ聊天程序(点对点无服务, P2P)
C#仿QQ聊天程序v1.0(IConnectionList接口实现)
C#实现QQ/MSN等客户聊天软件从右下角弹出窗体(Popup Window)
软件开发与设计 - MIS-管理信息系统-仿点点网轻博客系统 v1.2源码
C# 实现FTP客户
CSFramework.WebApi框架快速搭建后服务支持APP、B/S、C/S、微信小程序、公众号、Web客户
C/S快速开发框架旗舰版V5.1 - 客户运行环境需要的文件
C# Winform 软件用户授权注册系统V2.1 测试程序(Tester.exe)
微信小程序框架|微信公众号后框架(C# WebAPI)
CSFramework.WebApiV3.客户测试程序
CSFramework.WebApiV3.客户测试程序
客户测试程序(CS.WebApi.Tester)- CSFramework.WebApi后框架
CSFramework.WebApi后服务器框架:客户调用WebApi接口方式(签名+Token令牌)
软件开发与设计 - CMS内容管理系统-[CMS程序]逐迹工作室.NET(C#)内容管理系统 v1.1
软件开发与设计 - CMS内容管理系统(NETCMS V1.0.0 数据库表设计)
C/S框架主程序调用版本自动升级程序(CSFrameworkV5.AutoUpgrader)VersionCheckNEW
软件开发与设计 - CMS内容管理系统-[CMS程序]Rainbow v1.4.0.1778e RC4汉化版
C#SQL客户处理大文本数据通用接口
[原创]C#一键隐藏QQ/MSN,显示/隐藏系统托盘图标,获取托盘图标

热门标签
.NET5 .NET6 .NET7 APP Auth-软件授权注册系统 Axios B/S B/S开发框架 Bug Bug记录 C#加密解密 C#源码 C/S CHATGPT CMS系统 CodeGenerator CSFramework.DB CSFramework.EF CSFrameworkV1学习版 CSFrameworkV2标准版 CSFrameworkV3高级版 CSFrameworkV4企业版 CSFrameworkV5旗舰版 CSFrameworkV6.0 DAL数据访问层 Database datalock DbFramework Demo教学 Demo下载 DevExpress教程 DOM EF框架 Element-UI EntityFramework ERP ES6 Excel FastReport GIT HR IDatabase IIS JavaScript LINQ MES MiniFramework MIS NavBarControl Node.JS NPM OMS ORM PaaS POS Promise API Redis SAP SEO SQL SQLConnector TMS系统 Token令牌 VS2022 VSCode VUE WCF WebApi WebApi NETCore WebApi框架 WEB开发框架 Windows服务 Winform 开发框架 Winform 开发平台 WinFramework Workflow工作流 Workflow流程引擎 版本区别 报表 踩坑日记 操作手册 代码生成器 迭代开发记录 基础资料窗体 架构设计 角色权限 开发sce 开发技巧 开发教程 开发框架 开发平台 开发指南 客户案例 快速搭站系统 快速开发平台 秘钥 密钥 权限设计 软件报价 软件测试报告 软件简介 软件开发框架 软件开发平台 软件开发文档 软件体系架构 软件下载 软著证书 三层架构 设计模式 生成代码 实用小技巧 收钱音箱 数据锁 数据同步 微信小程序 未解决问题 文档下载 喜鹊ERP 喜鹊软件 系统对接 详细设计说明书 行政区域数据库 需求分析 疑难杂症 蝇量级框架 蝇量框架 用户管理 用户开发手册 用户控件 在线支付 纸箱ERP 智能语音收款机 自定义窗体 自定义组件 自动升级程序