C# Winform利用Scoket实现实时更新

本文主要是介绍C# Winform利用Scoket实现实时更新，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

之前在网上看到的，关于如何在Winform上实时的更新数据，也看了其他的博客，其中提到了利用Timer去实现，还有就是利用Socket去实现。
关于Socket实现实时更新，他给出的理解是：
有一个Socket服务端,只负责接收多个客户端传过来的讯息,根据讯息内容去判断是否广播。这里每一个winform窗体程序就是一个Socket客户端,如果窗体上对数据库做了更新(例如增,删,改)操作就会调用一个方法,该方法主要是向Socket服务端发送一个字符串"1"，当Socket服务端接收到了字符串为"1"时,则广播给所有客户端一个字符串"1"，而当客户端接收到服务端传过来一个"1"时,则立即执行数据绑定的方法(重新将界面的DataGridVeiw数据绑定)。这样就实现了一有数据改变就实时刷新的效果。
稍作改善
每个人的方法都是适用于自己的，所以我在这个想法下做了修改。
他的思路用图描述是这样的：
在这里插入图片描述
我的思路：

他的作用对象是客户端，而我所显示的功能的作用对象是服务器，以下是实现的代码：（之后会加上动图，更易理解）

客户端

public partial class FrmLogin : Form{public FrmLogin(){InitializeComponent();}/// <summary>/// 客户端的Socket/// </summary>Socket clinet;private void FrmLogin_Load(object sender, EventArgs e){//创建socketCreateSocket();}private void CreateSocket(){//创建socketclinet = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//连接//获得ip和端口（读取配置文件）var app = System.Configuration.ConfigurationManager.AppSettings;IPEndPoint point = new IPEndPoint(IPAddress.Parse(app["ip"]), Convert.ToInt32(app["port"]));//连接服务器try{clinet.Connect(point);}catch{}

注意引用：
在这里插入图片描述

服务器

public partial class FrmNetwork : Form{public FrmNetwork(){InitializeComponent();}//创建数据库对象Data get = new okCooperation.Data();//已连接上的客户端集合List<Socket> clinetSockets;//服务器Socket socket;//设置数据缓冲区private byte[] result = new byte[1024];private void FrmNetwork_Load(object sender, EventArgs e){//初始化clinetSockets = new List<Socket>();//创建socket对象socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);//获取ip地址和端口IPAddress ip = IPAddress.Parse(txtIPAddress.Text.Trim());int port = Convert.ToInt32(txtPort.Text.Trim());IPEndPoint point = new IPEndPoint(ip, port);//绑定ip和端口socket.Bind(point);//设置最大连接数socket.Listen(20);listBox1.Items.Add("服务器已开启，等待客户端连接中.....");//开启新线程监听Thread serverThread = new Thread(ListenClientConnect);serverThread.IsBackground = true;serverThread.Start(socket);} /// <summary>/// 监听传入/// </summary>/// <param name="ar"></param>private void ListenClientConnect(object ar){//设置标志bool flag = true;//获得服务器的SocketSocket serverSocket = ar as Socket;//轮询while (flag){//获得连入的客户端socketSocket clientSocket = serverSocket.Accept();//将新加入的客户端加入列表中clinetSockets.Add(clientSocket);//向listBox中写入消息listBox1.Invoke(new Action(() => { listBox1.Items.Add(string.Format("客户端{0}已成功连接到服务器\r\n", clientSocket.RemoteEndPoint)); }));//开启新的线程，进行监听客户端消息var mReveiveThread = new Thread(ReceiveClient);mReveiveThread.IsBackground = true;mReveiveThread.Start(clientSocket);}}/// <summary>/// 接收客户端传来的数据/// </summary>/// <param name="obj"></param>private void ReceiveClient(object obj){//获取当前客户端//因为客户端不止一个，所有需要使用var实例化新对象var mClientSocket = (Socket)obj;//循环标志位bool flag = true;while (flag){//try//{//获取数据长度int receiveLength = mClientSocket.Receive(result);//获取客户端消息string clientMessage = Encoding.UTF8.GetString(result, 0, receiveLength);if (clientMessage == "1"){//自身进行更新RefTable();}//向listbox中写入信息listBox1.Invoke(new Action(() => { listBox1.Items.Add(string.Format("客户端{0}发来消息{1}", mClientSocket.RemoteEndPoint, clientMessage)); }));}}

注意引用：
在这里插入图片描述