Scoket 服务器和客户端之间的互通信

实现了： 指定客户端发送消息,发送闪屏,支持服务器监听客户端发送消息 具体的代码如下： 首先是服务器. //C# using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Net;//Endpoint using System.Net.Sockets;//包含套接字 using System.Text; using System.Windows.Forms; using System.Threading; using System.IO; namespace Server { public partial class Form1 : Form { public Form1() { InitializeComponent(); TextBox.CheckForIllegalCrossThreadCalls = false;//关闭跨线程修改控件检查 } Socket sokWatch = null;//负责监听 客户端段 连接请求的 套接字(女生宿舍的大妈) Thread threadWatch = null;//负责 调用套接字， 执行 监听请求的线程 //开启监听 按钮 private void btnStartListen_Click(object sender, EventArgs e) { //实例化 套接字 （ip4寻址协议，流式传输，TCP协议） sokWatch = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建 ip对象 IPAddress address = IPAddress.Parse(txtIP.Text.Trim()); //创建网络节点对象 包含 ip和port IPEndPoint endpoint = new IPEndPoint(address, int.Parse(txtPort.Text.Trim())); //将 监听套接字 绑定到 对应的IP和端口 sokWatch.Bind(endpoint); //设置 监听队列 长度为10(同时能够处理 10个连接请求) sokWatch.Listen(10); threadWatch = new Thread(StartWatch); threadWatch.IsBackground = true; threadWatch.Start(); txtShow.AppendText("启动服务器成功......\r\n"); } //Dictionary<string, Socket> dictSocket = new Dictionary<string, Socket>(); Dictionary<string, ConnectionClient> dictConn = new Dictionary<string, ConnectionClient>(); bool isWatch = true; #region 1.被线程调用 监听连接端口 /// <summary> /// 被线程调用 监听连接端口 /// </summary> void StartWatch() { while (isWatch) { //threadWatch.SetApartmentState(ApartmentState.STA); //监听 客户端 连接请求，但是，Accept会阻断当前线程 Socket sokMsg = sokWatch.Accept();//监听到请求，立即创建负责与该客户端套接字通信的套接字 ConnectionClient connection = new ConnectionClient(sokMsg, ShowMsg, RemoveClientConnection); //将负责与当前连接请求客户端 通信的套接字所在的连接通信类 对象 装入集合 dictConn.Add(sokMsg.RemoteEndPoint.ToString(), connection); //将 通信套接字 加入 集合，并以通信套接字的远程IpPort作为键 //dictSocket.Add(sokMsg.RemoteEndPoint.ToString(), sokMsg); //将 通信套接字的 客户端IP端口保存在下拉框里 cboClient.Items.Add(sokMsg.RemoteEndPoint.ToString()); ShowMsg("接收连接成功......"); //启动一个新线程，负责监听该客户端发来的数据 //Thread threadConnection = new Thread(ReciveMsg); //threadConnection.IsBackground = true; //threadConnection.Start(sokMsg); } } #endregion bool isRec = true;//与客户端通信的套接字 是否 监听消息 #region 发送消息 到指定的客户端 -btnSend_Click //发送消息 到指定的客户端 private void btnSend_Click(object sender, EventArgs e) { //byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(txtInput.Text.Trim()); //从下拉框中 获得 要哪个客户端发送数据 string connectionSokKey = cboClient.Text; if (!string.IsNullOrEmpty(connectionSokKey)) { //从字典集合中根据键获得 负责与该客户端通信的套接字，并调用send方法发送数据过去 dictConn[connectionSokKey].Send(txtInput.Text.Trim()); //sokMsg.Send(arrMsg); } else { MessageBox.Show("请选择要发送的客户端～～"); } } #endregion //发送闪屏！！ private void btnShack_Click(object sender, EventArgs e) { string connectionSokKey = cboClient.Text; if (!string.IsNullOrEmpty(connectionSokKey)) { dictConn[connectionSokKey].SendShake(); } else { MessageBox.Show("请选择要发送的客户端～～"); } } //群闪 private void btnShackAll_Click(object sender, EventArgs e) { foreach (ConnectionClient conn in dictConn.Values) { conn.SendShake(); } } #region 2 移除与指定客户端的连接 +void RemoveClientConnection(string key) /// <summary> /// 移除与指定客户端的连接 /// </summary> /// <param name="key">指定客户端的IP和端口</param> public void RemoveClientConnection(string key) { if (dictConn.ContainsKey(key)) { dictConn.Remove(key); cboClient.Items.Remove(key); } } #endregion //选择要发送的文件 private void btnChooseFile_Click(object sender, EventArgs e) { OpenFileDialog ofd = new OpenFileDialog(); if (ofd.ShowDialog() == System.Windows.Forms.DialogResult.OK) { txtFilePath.Text = ofd.FileName; } } //发送文件 private void btnSendFile_Click(object sender, EventArgs e) { //拿到下拉框中选中的客户端IPPORT string key = cboClient.Text; if (!string.IsNullOrEmpty(key)) { dictConn[key].SendFile(txtFilePath.Text.Trim()); } } #region 向文本框显示消息 -void ShowMsg(string msgStr) /// <summary> /// 向文本框显示消息 /// </summary> /// <param name="msgStr">消息</param> public void ShowMsg(string msgStr) { txtShow.AppendText(msgStr + "\r\n"); } #endregion private void btnSendMsgAll_Click(object sender, EventArgs e) { foreach (ConnectionClient conn in dictConn.Values) { conn.Send(txtInput.Text.Trim()); } } } } 至于控件的名字,这里不能贴图,只能给大家去猜了,因为命名还是很规范的. 在这里,我新建了一个与客户端的通信和线程的类(ConnectionClient) using System; using System.Collections.Generic; using System.Threading; using System.Net; using System.Net.Sockets; using System.Text; using System.IO; namespace Server { /// <summary> /// 与客户端的 连接通信类(包含了一个 与客户端 通信的 套接字，和线程) /// </summary> public class ConnectionClient { Socket sokMsg; DGShowMsg dgShowMsg;//负责 向主窗体文本框显示消息的方法委托 DGShowMsg dgRemoveConnection;// 负责 从主窗体 中移除 当前连接 Thread threadMsg; #region 构造函数 /// <summary> /// /// </summary> /// <param name="sokMsg">通信套接字</param> /// <param name="dgShowMsg">向主窗体文本框显示消息的方法委托</param> public ConnectionClient(Socket sokMsg, DGShowMsg dgShowMsg, DGShowMsg dgRemoveConnection) { this.sokMsg = sokMsg; this.dgShowMsg = dgShowMsg; this.dgRemoveConnection = dgRemoveConnection; this.threadMsg = new Thread(RecMsg); this.threadMsg.IsBackground = true; this.threadMsg.Start(); } #endregion bool isRec = true; #region 02负责监听客户端发送来的消息 void RecMsg() {