客户端
桌面
MyClient client;public Form1(){InitializeComponent();}// 进入聊天室按钮方法private void button1_Click(object sender, EventArgs e){if (!string.IsNullOrEmpty(textBox1.Text)){// 开始连接服务器 封装一个自定义客户端类client = new MyClient(); // 给client委托赋值updateLabelclient.LabelInfo = updateLabel;}else{MessageBox.Show("请输入你的名字");}}public List<string> list1 = new List<string>() { "拼命加载中", "拼命加载中.", "拼命加载中..", "拼命加载中..." };int index = 0;// 封装一个更新label的方法public void updateLabel(string str){this.Invoke((Action)(() =>{if (string.IsNullOrEmpty(str))// 正在连接中{label1.Text = list1[index];index++;if (index == list1.Count) index = 0;}else // 证明连接有结果时候{this.label1.Text = str;// 需要判断如果连接成功了 需要进入聊天室}}));}MyClient.cs
internal class MyClient{// 定义委托类型public delegate void UpdatLabelHandle(string str = "");// 声明委托变量public UpdatLabelHandle LabelInfo;// 接受和发送消息 创建连接对象写在异步里面Thread thConnect; // 连接服务器的线程TcpClient client; // 全局客户端对象public bool IsConnect;public MyClient() {thConnect = new Thread(ConnetServer);thConnect.Start();}public void ConnetServer(){client = new TcpClient();// 开启一个异步的连接// 参数1 ip地址// 2 端口号// 3 回调函数 看一判断是否连接成功// 4 传递回调函数的参数client.BeginConnect(IPAddress.Parse("192.168.107.72"),3333,requestCallBack,client);float num = 0;while (IsConnect == false){// 证明没有连接成功num += 0.1f;if (LabelInfo != null) LabelInfo(); // 不传参数的目的if (num >= 10f){return;//超时连接 10s连接不上就连接失败}Thread.Sleep(100);}}// IAsyncResult 异步结果的类// BeginConnect 的回调函数 不管成功与否都执行public void requestCallBack(IAsyncResult ar){TcpClient t = ar.AsyncState as TcpClient;// 通过AsyncState异步状态属性获取参数if (t.Connected) // 如果连接成功了{IsConnect = true;LabelInfo("连接成功");t.EndConnect(ar); // 结束挂起的状态}else{// 连接失败 LabelInfo("连接失败");}LabelInfo = null;}}
