循序渐进做项目系列（3）：迷你QQ篇(1)——实现客户端互相聊天

编程入门行业动态更新时间:2024-10-24 16:21:42

循序渐进做项目系列（3）：迷你QQ篇(1)——实现客户端互相聊天

《循序渐进做项目系列迷你QQ篇》将陆续介绍客户端聊天，文件传输，加好友，群聊，包括语音聊天，视频聊天，远程桌面等等需求如何实现，感兴趣的朋友可以持续关注。考虑到某些需求较为复杂，本系列采用成熟的通信框架ESFramework来做，而不是从socket做起，当然这与本人才疏学浅也有莫大的关系，如果大家不嫌弃小弟写得太“low”，还请捧个人场，顺便给予鼓励！

言归正传，今天就是要实现一个最简单的功能：客户端互相聊天。

一·部署通信设备

参见循序渐进做项目系列（1）：最简单的C/S程序——让服务器来做加法

        static void Main(){Application.EnableVisualStyles();Application.SetCompatibleTextRenderingDefault(false); IRapidPassiveEngine clientEngine = RapidEngineFactory.CreatePassiveEngine();//创建客户端通信引擎 ClientHandler clientHandler = new ClientHandler();//创建客户端消息处理器        Form_Login loginForm = new Form_Login(clientEngine, clientHandler);       loginForm.ShowDialog();//登陆窗会话完成才能运行主窗体Form_Client clientForm = new Form_Client(clientEngine, loginForm.SelfUserID);clientHandler.ClientForm = clientForm;Application.Run(clientForm);}

二·登陆窗设计

    public partial class Form_Login : Form{private IRapidPassiveEngine clientEngine; private  ClientHandler clientHandler;public string SelfUserID//本人用户ID，该属性主要是为了暴露给主窗体用来标识用户
        {           
get { return this.textBox_UserID.Text; }}public Form_Login(IRapidPassiveEngine _clientEngine, ClientHandler _clientHandler){InitializeComponent();//传入通信引擎和消息处理器主要是为了登陆的时候进行通信引擎初始化操作this.clientEngine = _clientEngine;this.clientHandler = _clientHandler;           }private void button_login_Click(object sender, EventArgs e){//通信引擎初始化，与目标服务器建立TCP连接LogonResponse logonResponse = this.clientEngine.Initialize(this.textBox_UserID.Text, this.textBox_Password.Text, "127.0.0.1", 2000, clientHandler);if (logonResponse.LogonResult == LogonResult.Succeed){this.DialogResult = DialogResult.OK;}else{MessageBox.Show("登陆失败！" + logonResponse.LogonResult.ToString() + logonResponse.FailureCause);}}          }

三·客户端主窗体设计

    public partial class Form_Client : Form{private IRapidPassiveEngine clientEngine;private string selfUserID;public Form_Client(IRapidPassiveEngine _clientEngine,string _selfUserID){this.clientEngine = _clientEngine;this.selfUserID = _selfUserID;this.Text = _selfUserID;//在窗体上显示本用户ID
            InitializeComponent();}private void button_Send_Click(object sender, EventArgs e){string msg = this.textBox_Input.Text;//聊天消息Byte[] msgCode = Encoding.UTF8.GetBytes(msg);//转码以备发送string targetUserID = this.textBox_TargetUserID.Text;//从输入框读取待发送用户ID//利用通信引擎发送消息this.clientEngine.CustomizeOutter.Send(targetUserID, InformationType.Chat, msgCode);this.ShowChatMsg(this.selfUserID, msg);         }//将聊天消息按一定格式显示在界面上public void ShowChatMsg(string UserID, string msg){this.richTextBox_Output.AppendText(UserID + "  " + DateTime.Now.ToString() + "\n");this.richTextBox_Output.AppendText(msg + "\n");this.richTextBox_Output.ScrollToCaret();this.textBox_Input.Text = "";}}

四·客户端收到消息后进行处理

 public class ClientHandler: ICustomizeHandler{private Form_Client clientForm;//该属性是为了在外部将clientForm注入，之所以不在构造函数中传入是因为当时clientForm尚未创建public Form_Client ClientForm{get { return clientForm; }set { clientForm = value; }}public void HandleInformation(string sourceUserID, int informationType, byte[] info){if (informationType == InformationType.Chat){if (this.clientForm.InvokeRequired) //不是主线程时
               {//转换为主线程this.clientForm.Invoke(new ESBasic.CbGeneric<string, int, byte[]>(this.HandleInformation), sourceUserID, informationType, info);}else{string msg = Encoding.UTF8.GetString(info);//解析消息this.clientForm.ShowChatMsg(sourceUserID, msg);//显示消息
               }}}public byte[] HandleQuery(string sourceUserID, int informationType, byte[] info){throw new NotImplementedException();}