服务端完整代码
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace ServerSocket
{
public partial class Form1 : Form
{
//定义Socket对象
Socket serverSocket;
//定义监听线程
Thread listenThread;
//定义接收客户端数据线程
Thread threadReceive;
//定义双方通信
Socket socket;
string str;
public Form1()
{
InitializeComponent();
}
private void button1_Click(object sender, EventArgs e)
{
IPAddress ip = IPAddress.Parse(this.text_ip.Text.Trim());
serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try {
//绑定ip和端口
serverSocket.Bind(new IPEndPoint(ip, Convert.ToInt32(this.text_port.Text.Trim())));
//设置最多10个排队连接请求
serverSocket.Listen(10);
//开启线程循环监听
listenThread = new Thread(ListenClientConnect);
listenThread.Start();
this.button_start.Enabled = false;
} catch {
MessageBox.Show("监听异常", "监听异常");
}
}
//监听
private void ListenClientConnect()
{
while (true) {
//监听到客户端的连接,获取双方通信socket
socket = serverSocket.Accept();
//创建线程循环接收客户端发送的数据
threadReceive = new Thread(Receive);
//传入双方通信socket
threadReceive.Start(socket);
}
}
//接收客户端数据
private void Receive(object socket)
{
try {
Socket myClientSocket = (Socket)socket;
while (true) {
byte[] buff = new byte[20000];
int r = myClientSocket.Receive(buff);
str = Encoding.Default.GetString(buff, 0, r);
this.Invoke(new Action(() => { this.text_log1.Text = str; }));
}
} catch {
MessageBox.Show("接收数据失败", "接收数据失败");
}
}
//关闭
private void button_close_Click(object sender, EventArgs e)
{
//socket关闭
serverSocket.Close();
//线程关闭
listenThread.Abort();
threadReceive.Abort();
}
//发送
private void button_send_Click(object sender, EventArgs e)
{
try
{
string strMsg = this.text_log2.Text.Trim();
byte[] buffer = new byte[20000];
buffer = Encoding.Default.GetBytes(strMsg);
socket.Send(buffer);
}
catch
{
MessageBox.Show("发送数据失败", "发送数据失败");
}
}
}
}
客户端完整代码
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
using System.Windows.Forms;
namespace ClientSocket
{
public partial class Form1 : Form
{
//定义Socket对象
Socket clientSocket;
//创建接收消息的线程
Thread threadReceive;
//接收服务端发送的数据
string str;
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
}
private void button_connect_Click(object sender, EventArgs e)
{
IPAddress ip = IPAddress.Parse(this.text_ip.Text.Trim());
clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
try {
//连接服务端
clientSocket.Connect(ip, Convert.ToInt32(this.text_port.Text.Trim()));
//开启线程不停的接收服务端发送的数据
threadReceive = new Thread(new ThreadStart(Receive));
threadReceive.IsBackground = true;
threadReceive.Start();
//设置连接按钮在连接服务端后状态为不可点
this.button_connect.Enabled = false;
} catch {
MessageBox.Show("连接服务端失败,请确认ip和端口是否填写正确", "连接服务端失败");
}
}
//接收服务端消息的线程方法
private void Receive()
{
try {
while (true) {
byte[] buff = new byte[20000];
int r = clientSocket.Receive(buff);
str = Encoding.Default.GetString(buff,0,r);
this.Invoke(new Action(() => { this.text_log1.Text = str; }));
}
} catch {
MessageBox.Show("获取服务端参数失败","获取服务端参数失败");
}
}
private void button_close_Click(object sender, EventArgs e)
{
//clientSocket关闭
clientSocket.Close();
//threadReceive关闭
threadReceive.Abort();
}
private void button_send_Click(object sender, EventArgs e)
{
try {
string strMsg = this.text_log2.Text.Trim();
byte[] buffer = new byte[20000];
buffer = Encoding.Default.GetBytes(strMsg);
clientSocket.Send(buffer);
} catch {
MessageBox.Show("发送数据失败", "发送数据失败");
}
}
}
}
编译成功后点击发送效果图
具体步骤(思路)
服务器端:
第一步:创建一个用于监听连接的Socket对像;
第二步:用指定的端口号和服务器的ip建立一个EndPoint对像;
第三步:用socket对像的Bind()方法绑定EndPoint;
第四步:用socket对像的Listen()方法开始监听;
第五步:接收到客户端的连接,用socket对像的Accept()方法创建一个新的用于和客户端进行通信的socket对像;
第六步:通信结束后一定记得关闭socket;
客户端:
第一步:建立一个Socket对像;
第二步:用指定的端口号和服务器的ip建立一个EndPoint对像;
第三步:用socket对像的Connect()方法以上面建立的EndPoint对像做为参数,向服务器发出连接请求;
第四步:如果连接成功,就用socket对像的Send()方法向服务器发送信息;
第五步:用socket对像的Receive()方法接受服务器发来的信息 ;
第六步:通信结束后一定记得关闭socket;
https://blog.csdn.net/qq_42203978/article/details/80520299
本文参考链接:https://www.cnblogs.com/xihong2014/p/13677250.html