首先不多说，最终实现界面如下，可以通过点击启动服务，开启TCP服务器：
开启TCP服务器之后，可以通过点击客户端，打开一个独立的TCP客户端，打开客户端之后，输入正确的IP地址和端口号，可以进行连接服务器，这里可以同时开启多个客户端：
每个客户端连接成功后，服务器的列表中会多出一个EndPoint，连接成功后，服务器和客户端之间就可以*通话了，可以发送消息，也可以发送文件。
其实这就是QQ等即时通信工具的雏形，如果两个客户端之间需要通信，就通过服务器进行中转。
由于服务器代码量较大，下面上传一下客户端的代码，仅供参考：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.IO;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms; namespace MyTCPServer
{
delegate void FileSaveDelegate(byte[] bt,int length); public partial class FrmClient : Form
{
public FrmClient()
{
InitializeComponent(); //委托对象绑定方法
MyShowMsg += ShowMsg; MyFileSave += FileSave;
} //运行标志位
private bool IsRun = true; //创建连接服务器的Socket
Socket sockClient = null; //创建接收服务器消息的线程
Thread thrClient = null; //创建委托对象
ShowMsgDelegate MyShowMsg; FileSaveDelegate MyFileSave; private void btnConnect_Click(object sender, EventArgs e)
{
//获取IP对象
IPAddress address = IPAddress.Parse(this.txtIp.Text.Trim()); //根据IP对象和端口号创建网络节点对象
IPEndPoint endPoint = new IPEndPoint(address, int.Parse(this.txtPort.Text.Trim())); //创建负责连接的套接字，注意其中参数：[IPV4地址，字节流，TCP协议]
sockClient = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); try
{
Invoke(MyShowMsg, "与服务器连接中......");
sockClient.Connect(endPoint);
}
catch (Exception ex)
{
MessageBox.Show("建立连接失败：" + ex.Message, "建立连接");
return;
} Invoke(MyShowMsg, "与服务器连接成功！"); thrClient = new Thread(ReceiveMsg);
thrClient.IsBackground = true;
thrClient.Start(); this.btnConnect.Enabled = false;
} private void FileSave(byte[] arrMsgRec, int length)
{
try
{
SaveFileDialog sfd = new SaveFileDialog(); if (sfd.ShowDialog(this) == DialogResult.OK)
{ string fileSavePath = sfd.FileName;// 获得文件保存的路径；
// 创建文件流，然后根据路径创建文件；
using (FileStream fs = new FileStream(fileSavePath, FileMode.Create))
{
fs.Write(arrMsgRec, , length - );
Invoke(MyShowMsg, "文件保存成功：" + fileSavePath);
}
}
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
} } private void ReceiveMsg()
{
while(IsRun)
{
// 定义一个2M的缓存区
byte[] arrMsgRec = new byte[ * * ]; // 将接受到的数据存入到输入 arrMsgRec中
int length = -;
try
{
length = sockClient.Receive(arrMsgRec); // 接收数据，并返回数据的长度；
}
catch (SocketException)
{
return;
}
catch (Exception e)
{
Invoke(MyShowMsg, "连接断开：" + e.Message);
return;
}
if (arrMsgRec[] == ) // 表示接收到的是消息数据；
{
string strMsg = System.Text.Encoding.UTF8.GetString(arrMsgRec, , length - );// 将接受到的字节数据转化成字符串；
Invoke(MyShowMsg, strMsg);
}
if (arrMsgRec[] == ) // 表示接收到的是文件数据；
{
Invoke(MyFileSave, arrMsgRec, length);
}
}
} private void ShowMsg(string str)
{
txtMsg?.AppendText(str + Environment.NewLine);
} private void btnSend_Click(object sender, EventArgs e)
{
string strMsg = txt_Name.Text.Trim() + Environment.NewLine + " -->" + txtMsgSend.Text.Trim() + Environment.NewLine;
byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(strMsg);
byte[] arrSendMsg = new byte[arrMsg.Length + ];
arrSendMsg[] = ; // 用来表示发送的是消息数据
Buffer.BlockCopy(arrMsg, , arrSendMsg, , arrMsg.Length);
sockClient.Send(arrSendMsg); // 发送消息；
Invoke(MyShowMsg, strMsg);
txtMsgSend.Clear();
} private void btnSendFile_Click(object sender, EventArgs e)
{
if (string.IsNullOrEmpty(txtSelectFile.Text))
{
MessageBox.Show("请选择要发送的文件！！！");
}
else
{
// 用文件流打开用户要发送的文件；
using (FileStream fs = new FileStream(txtSelectFile.Text, FileMode.Open))
{
//在发送文件以前先给好友发送这个文件的名字+扩展名，方便后面的保存操作；
string fileName = System.IO.Path.GetFileName(txtSelectFile.Text);
string fileExtension = System.IO.Path.GetExtension(txtSelectFile.Text);
string strMsg = "发送的文件为： " + fileName + Environment.NewLine;
byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(strMsg);
byte[] arrSendMsg = new byte[arrMsg.Length + ];
arrSendMsg[] = ; // 用来表示发送的是消息数据
Buffer.BlockCopy(arrMsg, , arrSendMsg, , arrMsg.Length);
sockClient.Send(arrSendMsg); // 发送消息； byte[] arrFile = new byte[ * * ];
int length = fs.Read(arrFile, , arrFile.Length); // 将文件中的数据读到arrFile数组中；
byte[] arrFileSend = new byte[length + ];
arrFileSend[] = ; // 用来表示发送的是文件数据；
Buffer.BlockCopy(arrFile, , arrFileSend, , length);
// 还有一个 CopyTo的方法，但是在这里不适合； 当然还可以用for循环自己转化；
sockClient.Send(arrFileSend);// 发送数据到服务端；
txtSelectFile.Clear();
}
}
} private void btnSelectFile_Click(object sender, EventArgs e)
{
OpenFileDialog ofd = new OpenFileDialog();
ofd.InitialDirectory = "D:\\";
if (ofd.ShowDialog() == System.Windows.Forms.DialogResult.OK)
{
txtSelectFile.Text = ofd.FileName;
}
} private void FrmClient_FormClosing(object sender, FormClosingEventArgs e)
{
IsRun = false;
sockClient?.Close();
}
}
}
如果大家还有什么不明白的地方，可以关注一下微信公众号：dotNet工控上位机