TCP通信实例包含客户端和服务端监听程序，以下是代码片段，想学习的可以参考以下 /// <s

文件名称: TCP通信实例

所属分类: C#

开发工具:

文件大小: 11kb

下载次数: 0

上传时间: 2014-08-22

提供者: bigh****

下载 (11kb)

不能下载？报告错误

详细说明：包含客户端和服务端监听程序，以下是代码片段，想学习的可以参考以下 ///
/// 监听客户端请求 ///
private void ListenClientConnect() { TcpClient newClient = null; while (true) { ListenClientDelegate d = new ListenClientDelegate(ListenClient); IAsyncResult result = d.BeginInvoke(out newClient, null, null); //使用轮询方式来判断异步操作是否完成 while (result.IsCompleted == false) { if ( isExit) break; Thread.Sleep(250); } //获取Begin 方法的返回值和所有输入/输出参数 d.EndInvoke(out newClient, result); if (newClient != null) { //每接受一个客户端连接，就创建一个对应的线程循环接收该客户端发来的信息 User user = new User(newClient); Thread threadReceive = new Thread(ReceiveData); threadReceive.Start(user); userList.Add(user); AddItemToListBox(string.Format("[{0}]进入", newClient.Client.RemoteEndPoint)); AddItemToListBox(string.Format("当前连接用户数：{0}", userList.Count)); } else { break; } } } private void ReceiveData(object userState) { User user = (User)userState; TcpClient client = user.client; while (!isExit) { string receiveString = null; ReceiveMessageDelegate d = new ReceiveMessageDelegate(ReceiveMessage); IAsyncResult result = d.BeginInvoke(user, out receiveString, null, null); //使用轮询方式来判断异步操作是否完成 while (!result.IsCompleted) { if (isExit) break; Thread.Sleep(250); } //获取Begin方法的返回值和所有输入/输出参数 d.EndInvoke(out receiveString, result); if (receiveString == null) { if (!isExit) { AddItemToListBox(string.Format("与{0}失去联系，已终止接收该用户信息", client.Client.RemoteEndPoint)); RemoveUser(user); } break; } AddItemToListBox(string.Format("来自[{0}]:{1}", user.client.Client.RemoteEndPoint, receiveString)); string[] splitString = receiveString.Split(','); switch (splitString[0]) { case "Login": user.userName = splitString[1]; AsyncSendToAllClient(user, receiveString); break; case "Logout": AsyncSendToAllClient(user, receiveString); RemoveUser(user); return; case "Talk": string talkString = receiveString.Substring(splitString[0].Length + splitString[1].Length + 2); AddItemToListBox(string.Format("{0}对{1}说：{2}", user.userName, splitString[1], talkString)); foreach (User target in userList) { if (target.userName == splitString[1]) { AsyncSendToClient(target, "talk," + user.userName + "," + talkString); break; } } break; default: AddItemToListBox("什么意思啊：" + receiveString); break; } } } ///
/// 异步发送信息给所有客户 ///
/// /// private void AsyncSendToAllClient(User user, string message) { string command = message.Split(',')[0].ToLower(); if (command == "login") { for (int i = 0; i < userList.Count; i++) { AsyncSendToClient(userList[i], message); if (userList[i].userName != user.userName) AsyncSendToClient(user, "login," + userList[i].userName); } } else if (command == "logout") { for (int i = 0; i < userList.Count; i++) { if (userList[i].userName != user.userName) AsyncSendToClient(userList[i], message); } } } ///
/// 异步发送message给user ///
/// /// private void AsyncSendToClient(User user, string message) { SendToClientDelegate d = new SendToClientDelegate(SendToClient); IAsyncResult result = d.BeginInvoke(user, message, null, null); while (result.IsCompleted == false) { if (isExit) break; Thread.Sleep(250); } d.EndInvoke(result); } private delegate void SendToClientDelegate(User user, string message); ///
/// 发送message给user ///
/// /// private void SendToClient(User user, string message) { try { //将字符串写入网络流，此方法会自动附加字符串长度前缀 user.bw.Write(message); user.bw.Flush(); AddItemToListBox(string.Format("向[{0}]发送：{1}", user.userName, message)); } catch { AddItemToListBox(string.Format("向[{0}]发送信息失败", user.userName)); } } ///
/// 移除用户 ///
/// private void RemoveUser(User user) { userList.Remove(user); user.Close(); AddItemToListBox(string.Format("当前连接用户数：{0}", userList.Count)); } delegate void ReceiveMessageDelegate(User user, out string receiveMessage); ///
/// 接收客户端发来的信息 ///
/// /// private void ReceiveMessage(User user, out string receiveMessage) { try { receiveMessage = user.br.ReadString(); } catch (Exception ex) { AddItemToListBox(ex.Message); receiveMessage = null; } } private delegate void ListenClientDelegate(out TcpClient client); ///
/// 接受挂起的客户端连接请求 ///
/// ...展开收缩