Socket 编程,一个服务器,多个客户端,互相通信(测试通过)--688IT编程网

Socket 编程，一个服务器，多个客户端，互相通信

关于一个 Scoket 通信的基本代码和一个基本的通信

实现一个服务器和N个客户端的互相聊天

一、Server:

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, 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作为键

//d

ictSocket.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

socket通信在哪一层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()

{

while (isRec)

{

try

{

byte[] arrMsg = new byte[1024 * 1024 * 2];

//接收对应客户端发来的消息

int length = sokMsg.Receive(arrMsg);

//将接收到的消息数组里真实消息转成字符串

string strMsg = System.Text.Encoding.UTF8.GetString(arrMsg, 0, length);

//通过委托显

示消息到窗体的文本框

dgShowMsg(strMsg);

}

catch (Exception ex)

{

isRec = false;

//从主窗体中移除下拉框中对应的客户端选择项，同时移除集合中对应的 ConnectionClient对象

dgRemoveConnection(sokMsg.RemoteEndPoint.ToString());

}

#endregion

#region 03向客户端发送消息

/// <summary>

/// 向客户端发送消息

// </summary>

/// <param name="strMsg"></param>

public void Send(string strMsg)

{

byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(strMsg);

byte[] arrMsgFinal = new byte[arrMsg.Length+1];

arrMsgFinal[0] = 0;//设置数据标识位等于0，代表发送的是文字

arrMsg.CopyTo(arrMsgFinal, 1);

sokMsg.Send(arrMsgFinal);

}

#endregion

#region 04向客户端发送文件数据 +void SendFile(string strPath)

/// <summary>

/// 04向客户端发送文件数据

/// </summary>

/// <param name="strPath">文件路径</param>

public void SendFile(string strPath)

{

//通过文件流读取文件内容

using (FileStream fs = new FileStream(strPath, FileMode.OpenOrCreate))

{

byte[] arrFile = new byte[1024 * 1024 * 2];

/读取文件内容到字节数组，并获得实际文件大小

int length = fs.Read(arrFile, 0, arrFile.Length);

//定义一个新数组，长度为文件实际长度 +1

byte[] arrFileFina = new byte[length + 1];

arrFileFina[0] = 1;//设置数据标识位等于1，代表发送的是文件

//将文件数据数组复制到新数组中，下标从1开始

//arrFile.CopyTo(arrFileFina, 1);

Buffer.BlockCopy(arrFile, 0, arrFileFina, 1, length);

//发送文件数据

sokMsg.Send(arrFileFina);//, 0, length + 1, SocketFlags.None);

}

#endregion

#region 05向客户端发送闪屏

/// <summary>

/// 向客户端发送闪屏

/// </summary>

/// <param name="strMsg"></param>

public void SendShake()

{

byte[] arrMsgFinal = new byte[1];

arrMsgFinal[0] = 2;

sokMsg.Send(arrMsgFinal);

}

#endregion

#region 06关闭与客户端连接

/// <summary>

/// 关闭与客户端连接

/// </summary>

public void CloseConnection()

{

isRec = false;

}

#endregion

}

三、Client:

using System;

using System.Collections.Generic;

using System.Co

mponentModel;

using System.Data;

using System.Drawing;

using System.Net.Sockets;

using System.Net;

using System.Threading;

using System.Windows.Forms;

using System.IO;

namespace Client

{

public partial class Form1 : Form

{

public Form1()

{

InitializeComponent();

TextBox.CheckForIllegalCrossThreadCalls = false;

}

Socket sokClient = null;//负责与服务端通信的套接字

Thread threadClient = null;//负责监听服务端发送来的消息的线程

bool isRec = true;//是否循环接收服务端数据

private void btnConnect_Click(object sender, EventArgs e)

{

//实例化套接字

sokClient = 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()));

//连接服务端监听套接字

sokClient.Connect(endpoint);

//创建负责接收服务端发送来数据的线程

threadClient = new Thread(ReceiveMsg);

threadClient.IsBackground = true;

//如果在win7下要通过某个线程来调用文件选择框的代码，就需要设置如下

threadClient.SetApartmentState(ApartmentState.STA);

threadClient.Start();

}

// <summary>

/// 接收服务端发送来的消息数据

/// </summary>

void ReceiveMsg()

{

while (isRec)

{

byte[] msgArr = new byte[1024 * 1024 * 1];//接收到的消息的缓冲区

int length=0;

//接收服务端发送来的消息数据

length =sokClient.Receive(msgArr);//Receive会阻断线程

if (msgArr[0] == 0)//发送来的是文字

{

string strMsg = System.Text.Encoding.UTF8.GetString(msgArr, 1, length - 1);

txtShow.AppendText(strMsg + "\r\n");

}

else if (msgArr[0] == 1) { //发送来的是文件

SaveFileDialog sfd = new SaveFileDialog();

//弹出文件保存选择框

if (sfd.ShowDialog() == System.Windows.Forms.DialogResult.OK)

{

//创建文件流

using (FileStream fs = new FileStream(sfd.FileName, FileMode.OpenOrCreate))

{

fs.Write(msgArr, 1, length - 1);

MessageBox.Show("文件保存成功！");

}

else if (msgArr[0] == 2) {

Shake

Window();

}

/// <summary>

/// 闪屏

/// </summary>

private void ShakeWindow()

{

Random ran = new Random();

//保存窗体原坐标

System.Drawing.Point point = this.Location;

for (int i = 0; i < 30; i++)

{

//随机坐标

this.Location = new System.Drawing.Point(point.X + ran.Next(8), point.Y + ran.Next(8));

System.Threading.Thread.Sleep(15);//休息15毫秒

this.Location = point;//还原原坐标(窗体回到原坐标)

System.Threading.Thread.Sleep(15);//休息15毫秒

}

//发送消息

private void btnSend_Click(object sender, EventArgs e)

{

byte[] arrMsg = System.Text.Encoding.UTF8.GetBytes(txtInput.Text.Trim());

sokClient.Send(arrMsg);

}

以上代码就能实现一个简单的 Scoket 通信

实现了一个服务器和N个客户端的交互，能做成一个简单的聊天程序

688IT编程网

Socket 编程,一个服务器,多个客户端,互相通信(测试通过)

发表评论

推荐文章

随机森林算法介绍及R语言实现

基于随机森林优化的神经网络算法在冬小麦产量预测中的应用研究_百度文 ...

基于正则化贪心森林算法的情感分析方法研究

随机森林算法和grandientboosting算法

基于随机森林的图像分类算法研究

热门文章

随机森林特征选择原理

自动驾驶系统中的随机森林算法解析

随机森林算法及其在生物信息学中的应用

监督学习中的随机森林算法解析(六)

随机森林算法在数据分析中的应用

机器学习——随机森林,RandomForestClassifier参数含义详解

随机森林的算法

随机森林算法作用

监督学习中的随机森林算法解析(十)

随机森林算法案例

随机森林案例

二分类问题常用的模型

绘制ssd框架训练流程

一种基于信息熵和DTW的多维时间序列相似性度量算法

SVM训练过程范文

如何使用支持向量机进行股票预测与交易分析

二分类交叉熵损失函数binary

tinybert_训练中文文本分类模型_概述说明

基于门控可形变卷积和分层Transformer的图像修复模型及其应用

人工智能开发技术的测试和评估方法

最新文章

基于随机森林的数据分类算法改进

人工智能中的智能识别与分类技术

基于人工智能技术的随机森林算法在医疗数据挖掘中的应用

随机森林回归模型的建模步骤

r语言随机森林预测模型校准曲线

《2024年随机森林算法优化研究》范文

标签列表

688IT编程网

Socket 编程,一个服务器,多个客户端,互相通信(测试通过)

发表评论

推荐文章

随机森林算法介绍及R语言实现

基于随机森林优化的神经网络算法在冬小麦产量预测中的应用研究_百度文 ...

基于正则化贪心森林算法的情感分析方法研究

随机森林算法和grandientboosting算法

基于随机森林的图像分类算法研究

热门文章

随机森林特征选择原理

自动驾驶系统中的随机森林算法解析

随机森林算法及其在生物信息学中的应用

监督学习中的随机森林算法解析(六)

随机森林算法在数据分析中的应用

机器学习——随机森林,RandomForestClassifier参数含义详解

随机森林 的算法

随机森林算法作用

监督学习中的随机森林算法解析(十)

随机森林算法案例

随机森林案例

二分类问题常用的模型

绘制ssd框架训练流程

一种基于信息熵和DTW的多维时间序列相似性度量算法

SVM训练过程范文

如何使用支持向量机进行股票预测与交易分析

二分类交叉熵损失函数binary

tinybert_训练中文文本分类模型_概述说明

基于门控可形变卷积和分层Transformer的图像修复模型及其应用

人工智能开发技术的测试和评估方法

最新文章

基于随机森林的数据分类算法改进

人工智能中的智能识别与分类技术

基于人工智能技术的随机森林算法在医疗数据挖掘中的应用

随机森林回归模型的建模步骤

r语言随机森林预测模型校准曲线

《2024年随机森林算法优化研究》范文

标签列表

随机森林的算法