之前因为忙一直没时间关注博客，非常抱歉没能及时回答到大家的问题，针对大家遇到的一些问题我对推文里的socket服务器端和客户端进行了一些改进。
改动如下（如果是第一次看这篇博客的话可以直接忽略这段文字）：
- 针对多个客户端连接服务器端会出现客户端被覆盖问题：使用了List来存放连接到服务器的客户端，并将客户端信息（ip和端口号）不同的客户端ip可能一样但是端口号不一样，放进comBox组件里面，可以在comBox里面选择想要发送信息的客户端。
【这里补充个知识点：在服务器端使用listen(value)来监听客户端，value值是想要连接的客户端数量，如果没有使用accept()方法的话，value值是多少，服务器端就最多只能连接上value个客户端；如果使用了accept()方法的话，客户端队列会被存放在其他地方，listen(value)中的value值就会失去作用，服务器可以连接超过value值的客户端】- 针对发送中文乱码问题：使用Encoding.UTF8.GetBytes()进行编码，相应的使用Encoding.UTF8.GetString()进行解码。
- 对UI进行了小改动，服务器端添加了客户端列表，添加了接收框清除按钮。
- 代码都进行了更新。
说明：本篇推文侧重讲解C#的Socket编程实现，里面有完整实现的GIF动图，大家可以先去看一下，Socket原理介绍的不多，可能有很多不足的地方，原理方面大家可以去找其他资料看一下。
Socket编程这部分我主要着重介绍了Socket编程用到的一些相关类、方法以及实现步骤，不断地分步骤介绍，是为了能够加深印象也方便大家理解并复刻这款简单软件，大家学会了可以自己去拓展功能或者嵌入其他项目中，socket相关类和方法可能会有点冗余，大家可以直接跳到完整的实现代码去研究学习。
套接字(Socket)，是对网络中不同主机上的应用进程之间进行双向通信的端点的抽象。一个套接字就是网络上进程通信的一端，提供了应用层进程利用网络协议交换数据的机制。从所处的地位来讲，套接字上联应用进程，下联网络协议栈，是应用程序通过网络协议进行通信的接口，是应用程序与网络协议栈进行交互的接口，Socket所处的位置大概是下面这样的。
我们可以将Socket联想成是由两个Socket对象搭建的成的一根通信管道，管道的两端是这两个Socket对象，而这根管道的连接的是两台主机的应用进程。假设A、B两台主机上的应用进程要互相发送数据，那么我们就可以用Socket打造一条连接A、B主机进程的管道，A主机进程使用Socket对象把数据往管道里面一丢，然后B主机进程就可以使用Socket对象把数据给拿出来，反之当B主机进程要给A主机进程发送数据的时候也是通过操作Socket对象就可以简单实现数据的发送和接收。
学过计算机网络的同学都知道数据在因特网上传输并不像上面说的那么简单，根据经典的五层协议体系结构（如下图），一个报文从一个进程传输到另一个进程需要经过自上到下层层协议的封装，然后转换成比特流通过物理层，途径多个路由，最后才能到到达目的主机【这里要用到的IP来标定网络上特定的主机】，然后再在目的主机上经过层层解析最终根据端口号把报文传输到目的进程，而使用Socket就不需要我们自己层层封装信息，也不用管信息是如何在网络上传输的，我们只需要绑定IP地址和应用进程号，使用Socket对象就可以实现进程之间数据的发送和接收，大大缩减了我们的工作，非常的nice。
【这里推荐一个计算机网络课程，图文并茂讲计算机网络巨通俗易懂】
https://www.bilibili.com/video/BV1c4411d7jb?share_source=copy_web
通过上面的简单介绍，我们能大致了解Socket的作用是完成两个应用程序之间的数据传输，我们只要知道要通信的两台主机的IP地址和进程的端口号，然后可以用Socket让这两个进程进行通信，接下来我们就进入正题，使用C#进行Socket编程，完成本地两个进程的通信
根据上面的流程图可以知道使用socket实现通信大致需要完成以下几个步骤：
服务器端：
第一步：建立一个用于通信的Socket对象
第二步：使用bind绑定IP地址和端口号
第三步：使用listen监听客户端
第四步：使用accept中断程序直到连接上客户端
第五步：接收来自客户端的请求
第六步：返回客户端需要的数据
第七步：如果接收到客户端已关闭连接信息就关闭服务器端
客户端：
第一步：建立一个用于通信的Socket对象
第二步：根据指定的IP和端口connet服务器
第三步：连接成功后向服务器端发送数据请求
第四步：接收服务器返回的请求数据
第五步：如果还需要请求数据继续发送请求
第六步：如果不需要请求数据就关闭客户端并给服务器发送关闭连接信息
(1) IPAddress：包含了一个IP地址[提供 Internet 协议 (IP) 地址]
//这里的IP是long类型的,这里使用Parse()可以将string类型数据转成IPAddress所需要的数据类型
IPAddress IP = IPAddress.Parse();
(2) IPEndPoint：包含了一对IP地址和端口号
/*public IPEndPoint(IPAddress address, int port);*/
IPEndPoint endPoint = new IPEndPoint(ip,port); //处理IP地址和端口的封装类
(3)Encoding.ASCII:编码转换
Encoding.ASCII.GetBytes() //将字符串转成字节
Encoding.ASCII.GetString() //将字节转成字符串
（4）获取当前时间
DateTime.Now.ToString("yy-MM-dd hh:mm:ss ")
Socket ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
Socket ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
Socket构造函数参数
- AddressFamily指定Socket用来解析地址的寻址方案
- SocketType定义要打开的Socket的类型
- ProtocolType:向Windows Sockets API通知所请求的协议
ServerSocket.Bind(new IPEndPoint(ip,port));
或者
IPEndPoint ipEndPoint = new IPEndPoint(ip,port)
ServerSocket.Bind(ipEndPoint);
ServerSocket.Listen(10);
ClientSocket.Connect(ipEndPoint);
Socket socket = ServerSocket.Accept();
//Encoding.ASCII.GetBytes()将字符串转成字节
//byte[] message = Encoding.ASCII.GetBytes("Connect the Server"); //通信时实际发送的是字节数组，所以要将发送消息转换字节
byte[] message = Encoding.UTF8.GetBytes("Connect the Server"); //防止中文乱码使用该方法对字符串进行编码
ClientSocket.Send(message);
socket.Send(message);
byte[] receive = new byte[1024];
int length = ClientSocket.Receive(receive); // length 接收字节数组长度
int length = socket.Receive(receive);
socket.Close()
ClientSocket.Close()
| 类型 | 函数 |
|---|---|
| 服务器socket | Bind() Listen() Accept() |
| 客户端socket | Connect() |
| 公共socket | Receive() Send() Close() |
服务器端：
客户端：
下面是我给各组件设置的name值，客户端和服务器端除了Button有一个不一样其他组件设置的name值都是一样的
| 组件 | Name |
|---|---|
| TextBox | textBox_Addr textBox_Port |
| RichTextBox | richTextBox_Receive richTextBox_Send |
| Button | button_Accpet button_Connect button_Close button_Send |
| ComBox | comBox_Clients |
实现步骤：
第一步：创建一个用于监听连接的Socket对象；
Socket ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建用于监听连接的套接字
第二步：用指定的端口号和服务器的ip建立一个IPEndPoint对象；
IPAddress IP = IPAddress.Parse(textBox_Addr.Text); //获取输入的IP地址
int Port = int.Parse(textBox_Port.Text); //获取输入的端口号
//IPAddress ip = IPAddress.Any;
IPEndPoint iPEndPoint = new IPEndPoint(IP, Port);
第三步：用socket对象的Bind()方法绑定IPEndPoint；
ServerSocket.Bind(iPEndPoint);
第四步：用socket对象的Listen()方法开始监听；
ServerSocket.Listen(10);
第五步：建立与客户端的连接，用socket对象的Accept()方法创建用于和客户端进行通信的socket对象;（因为accept会中断程序，所以我使用线程来实现客户端的接入）
Socket socket = socketAccept.Accept();
第六步：接收来自客户端的信息（我是使用线程来实现数据的接收）
byte[] recieve = new byte[1024];
int len = socket.Receive(recieve);
richTextBox_Recieve.Text += Encoding.UTF8.GetString(recieve, 0, len); //将字节数据根据ASCII码转成字符串
第七步：向客户端发送信息
byte[] send = new byte[1024];
send = Encoding.UTF8.GetBytes(richTextBox_Send.Text); //将字符串转成字节格式发送
socket.Send(send); //调用Send()向客户端发送数据
第八步：关闭Socket
socket.Close(); //关闭用于通信的套接字
ServerSocket.Close(); //关闭用于连接的套接字
socketAccept.Close(); //关闭与客户端绑定的套接字
th1.Abort(); //关闭线程1
具体实现代码：
（1）因为有使用线程，为了防止出错，在初始化的时候关闭检测
private void Form1_Load(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false; //执行新线程时跨线程资源访问检查会提示报错，所以这里关闭检测
}
（2）建立连接，首先创建一个ServerSocket将连接需要的参数都设置好并监听连接，然后创建线程Accept客户的连接
/*****************************************************************/
#region 连接客户端（绑定按钮事件）
private void button_Accpet_Click(object sender, EventArgs e)
{
ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建用于通信的套接字
richTextBox_Receive.Text += "正在连接...\n";
button_Accpet.Enabled = false; //禁止操作接收按钮
//1.绑定IP和Port
IPAddress IP = IPAddress.Parse(textBox_Addr.Text);
int Port = int.Parse(textBox_Port.Text);
//IPAddress ip = IPAddress.Any;
IPEndPoint iPEndPoint = new IPEndPoint(IP, Port);
try
{
//2.使用Bind()进行绑定
ServerSocket.Bind(iPEndPoint);
//3.开启监听
//Listen(int backlog); backlog:监听数量
ServerSocket.Listen(10);
/*
* tip：
* Accept会阻碍主线程的运行，一直在等待客户端的请求，
* 客户端如果不接入，它就会一直在这里等着，主线程卡死
* 所以开启一个新线程接收客户单请求
*/
//开启线程Accept进行通信的客户端socket
th1 = new Thread(Listen); //线程绑定Listen函数
th1.IsBackground = true; //运行线程在后台执行
th1.Start(ServerSocket); //Start里面的参数是Listen函数所需要的参数，这里传送的是用于通信的Socket对象
Console.WriteLine("1");
}
catch
{
MessageBox.Show("服务器出问题了");
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 建立与客户端的连接
void Listen(Object sk)
{
try
{
while (true)
{
//GNFlag如果为1就进行中断连接，使用在标志为是为了保证能够顺利关闭服务器端
/*
* 当客户端关闭一次后，如果没有这个标志位会使得服务器端一直卡在中断的位置
* 如果服务器端一直卡在中断的位置就不能顺利关闭服务器端
*/
//4.阻塞到有client连接
Socket Client = ServerSocket.Accept(); //声明用于与某一个客户端通信的套接字
socketsList.Add(Client); //将连接的客户端存进List
//获取客户端信息将不同客户端并存进comBox
string client = Client.RemoteEndPoint.ToString();
comboBox_Clients.Items.Add(client);
CFlag = 0; //连接成功，将客户端关闭标志设置为0
SFlag = 1; //当连接成功，将连接成功标志设置为1
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + client + "连接成功";
richTextBox_Receive.Text += "\r\n";
//开启第二个线程接收客户端数据
th2 = new Thread(Receive); //线程绑定Receive函数
th2.IsBackground = true; //运行线程在后台执行
th2.Start(Client); //Start里面的参数是Listen函数所需要的参数，这里传送的是用于通信的Socket对象
}
}
catch
{
//MessageBox.Show("没有连接上客户端");
}
}
#endregion
/*****************************************************************/
（3）连接上客户端后，使用线程接收客户端数据，参数是Accept到的Socket对象
/*****************************************************************/
#region 接收客户端数据
void Receive(Object sk)
{
Socket socket = sk as Socket; //创建用于通信的套接字(这里是线程传过来的client套接字)
while (true)
{
try
{
if (CFlag == 0 && SFlag == 1)
{
//5.接收数据
byte[] recieve = new byte[1024];
int len = socket.Receive(recieve);
//6.打印接收数据
if (recieve.Length > 0)
{
//如果接收到客户端停止的标志
if (Encoding.UTF8.GetString(recieve, 0, len) == "*close*")
{
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "客户端已退出" + "\n";
CFlag = 1; //将客户端关闭标志设置为1
break; //退出循环
}
//打印接收数据
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ");
richTextBox_Receive.Text += "\r\n";
richTextBox_Receive.Text += "接收" + socket.RemoteEndPoint.ToString() + "：";
//richTextBox_Receive.Text += Encoding.ASCII.GetString(recieve, 0, len); //将字节数据根据ASCII码转成字符串
richTextBox_Receive.Text += Encoding.UTF8.GetString(recieve, 0, len); //接收中文不会乱码
}
}
else
{
break; //跳出循环
}
}
catch
{
MessageBox.Show("收不到信息");
}
}
}
#endregion
/*****************************************************************/
（4）向客户端发送数据
/*****************************************************************/
#region 向客户端发送数据
private void button_Send_Click(object sender, EventArgs e)
{
//SFlag标志连接成功，同时当客户端是打开的时候才能发送数据
if(SFlag == 1 && CFlag == 0)
{
byte[] send = new byte[1024];
send = Encoding.UTF8.GetBytes(richTextBox_Send.Text); //将字符串转成字节格式发送
socket.Send(send); //调用Send()向客户端发送数据
//打印发送时间和发送的数据
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "发送：";
richTextBox_Receive.Text += richTextBox_Send.Text + "\n";
richTextBox_Send.Clear(); //清除发送框
}
}
#endregion
/*****************************************************************/
（5）关闭服务器端
/*****************************************************************/
#region 关闭服务器端
private void button_Close_Click(object sender, EventArgs e)
{
//若连接上了客户端需要关闭线程2和socket，没连接上客户端直接关闭线程1和其他套接字
if(CFlag == 1)
{
th2.Abort(); //关闭线程2
socket.Close(); //关闭用于通信的套接字
}
ServerSocket.Close(); //关闭用于连接的套接字
socketAccept.Close(); //关闭与客户端绑定的套接字
th1.Abort(); //关闭线程1
CFlag = 0; //将客户端标志重新设置为0,在进行连接时表示是打开的状态
SFlag = 0; //将连接成功标志程序设置为0，表示退出连接
button_Accpet.Enabled = true;
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ");
richTextBox_Receive.Text += "服务器已关闭" + "\n";
MessageBox.Show("服务器已关闭");
}
#endregion
/*****************************************************************/
第一步：建立一个Socket对象；
Socket ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //声明负责通信的套接字
第二步：用指定的端口号和服务器的ip建立一个IPEndPoint对象；
IPAddress IP = IPAddress.Parse(textBox_Addr.Text); //获取设置的IP地址
int Port = int.Parse(textBox_Port.Text); //获取设置的端口号
IPEndPoint iPEndPoint = new IPEndPoint(IP,Port); //指定的端口号和服务器的ip建立一个IPEndPoint对象
第三步：用socket对像的Connect()方法以上面建立的EndPoint对象做为参数，向服务器发出连接请求；
ClientSocket.Connect(iPEndPoint);
第四步：如果连接成功，就用socket对象的Send()方法向服务器发送信息；
byte[] send = new byte[1024];
send = Encoding.UTF8.GetBytes(richTextBox_Send.Text); //将文本内容转换成字节发送
ClientSocket.Send(send); //调用Send()函数发送数据
第五步：用socket对象的Receive()方法接受服务器的信息 ;
byte[] receive = new byte[1024];
ClientSocket.Receive(receive); //调用Receive()接收字节数据
第六步：通信结束后关闭socket；
ClientSocket.Close(); //关闭套接字
具体代码实现
（1）使用线程，为了防止出错，在初始化的时候关闭检测
private void Form1_Load(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false; //执行新线程时跨线程资源访问检查会提示报错，所以这里关闭检测
}
（2）建立与服务器端的连接
/*****************************************************************/
#region 连接服务器端
private void button_Connect_Click(object sender, EventArgs e)
{
ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //声明负责通信的套接字
richTextBox_Recieve.Text += "正在连接...\n";
IPAddress IP = IPAddress.Parse(textBox_Addr.Text); //获取设置的IP地址
int Port = int.Parse(textBox_Port.Text); //获取设置的端口号
IPEndPoint iPEndPoint = new IPEndPoint(IP,Port); //指定的端口号和服务器的ip建立一个IPEndPoint对象
try
{
ClientSocket.Connect(iPEndPoint); //用socket对象的Connect()方法以上面建立的IPEndPoint对象做为参数，向服务器发出连接请求
SFlag = 1; //若连接成功将标志设置为1
richTextBox_Recieve.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + textBox_Addr.Text + "连接成功" + "\n";
button_Connect.Enabled = false; //禁止操作连接按钮
//开启一个线程接收数据
th1 = new Thread(Receive);
th1.IsBackground = true;
th1.Start(ClientSocket);
}
catch
{
MessageBox.Show("服务器未打开");
}
}
#endregion
/*****************************************************************/
（3）若连接成功，创建线程实现接收服务器端的数据
/*****************************************************************/
#region 接收服务器端数据
void Receive(Object sk)
{
Socket socketRec = sk as Socket;
while (true)
{
//5.接收数据
byte[] receive = new byte[1024];
ClientSocket.Receive(receive); //调用Receive()接收字节数据
//6.打印接收数据
if (receive.Length > 0)
{
richTextBox_Recieve.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "接收："; //打印接收时间
richTextBox_Recieve.Text += Encoding.UTF8.GetString(receive); //将字节数据根据ASCII码转成字符串
richTextBox_Recieve.Text += "\r\n";
}
}
}
#endregion
/*****************************************************************/
（4）向服务器端发送数据（于send按钮进行事件绑定）
/*****************************************************************/
#region 向服务器端发送数据
private void button_Send_Click(object sender, EventArgs e)
{
//只有连接成功了才能发送数据，接收部分因为是连接成功才开启线程，所以不需要使用标志
if (SFlag == 1)
{
byte[] send = new byte[1024];
send = Encoding.UTF8.GetBytes(richTextBox_Send.Text); //将文本内容转换成字节发送
ClientSocket.Send(send); //调用Send()函数发送数据
richTextBox_Recieve.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "发送："; //打印发送数据的时间
richTextBox_Recieve.Text += richTextBox_Send.Text + "\n"; //打印发送的数据
richTextBox_Send.Clear(); //清空发送框
}
}
#endregion
/*****************************************************************/
（5）关闭客户端
/*****************************************************************/
#region 关闭客户端
private void buttonClose_Click(object sender, EventArgs e)
{
//保证是在连接状态下退出
if (SFlag == 1)
{
byte[] send = new byte[1024];
send = Encoding.ASCII.GetBytes("*close*"); //关闭客户端时给服务器发送一个退出标志
ClientSocket.Send(send);
th1.Abort(); //关闭线程
ClientSocket.Close(); //关闭套接字
button_Connect.Enabled = true; //允许操作按钮
SFlag = 0; //客户端退出后将连接成功标志程序设置为0
richTextBox_Recieve.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ");
richTextBox_Recieve.Text += "客户端已关闭" + "\n";
MessageBox.Show("已关闭连接");
}
}
#endregion
/*****************************************************************/
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
namespace Server
{
public partial class Form1 : Form
{
//这里声明多个套接字是为了在连接，接收数据，发送数据的函数中不发生混乱，同时方便关闭
public Socket ServerSocket; //声明用于监听的套接字
public static List<Socket> socketsList = new List<Socket>(); //创建一个全局的List用来存放不同的Client套接字
public static int SFlag = 0; //连接成功标志
public static int CFlag = 0; //客户端关闭的标志
Thread th1; //声明线程1
Thread th2; //声明线程2
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
//comboBox_Clients.SelectedIndex = 0;
Control.CheckForIllegalCrossThreadCalls = false; //执行新线程时跨线程资源访问检查会提示报错，所以这里关闭检测
}
/*****************************************************************/
#region 连接客户端
private void button_Accpet_Click(object sender, EventArgs e)
{
ServerSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //创建用于通信的套接字
richTextBox_Receive.Text += "正在连接...\n";
button_Accpet.Enabled = false; //禁止操作接收按钮
//1.绑定IP和Port
IPAddress IP = IPAddress.Parse(textBox_Addr.Text);
int Port = int.Parse(textBox_Port.Text);
//IPAddress ip = IPAddress.Any;
IPEndPoint iPEndPoint = new IPEndPoint(IP, Port);
try
{
//2.使用Bind()进行绑定
ServerSocket.Bind(iPEndPoint);
//3.开启监听
//Listen(int backlog); backlog:监听数量
ServerSocket.Listen(10);
/*
* tip：
* Accept会阻碍主线程的运行，一直在等待客户端的请求，
* 客户端如果不接入，它就会一直在这里等着，主线程卡死
* 所以开启一个新线程接收客户单请求
*/
//开启线程Accept进行通信的客户端socket
th1 = new Thread(Listen); //线程绑定Listen函数
th1.IsBackground = true; //运行线程在后台执行
th1.Start(ServerSocket); //Start里面的参数是Listen函数所需要的参数，这里传送的是用于通信的Socket对象
Console.WriteLine("1");
}
catch
{
MessageBox.Show("服务器出问题了");
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 建立与客户端的连接
void Listen(Object sk)
{
try
{
while (true)
{
//GNFlag如果为1就进行中断连接，使用在标志为是为了保证能够顺利关闭服务器端
/*
* 当客户端关闭一次后，如果没有这个标志位会使得服务器端一直卡在中断的位置
* 如果服务器端一直卡在中断的位置就不能顺利关闭服务器端
*/
//4.阻塞到有client连接
Socket Client = ServerSocket.Accept(); //声明用于与某一个客户端通信的套接字
socketsList.Add(Client); //将连接的客户端存进List
//获取客户端信息将不同客户端并存进comBox
string client = Client.RemoteEndPoint.ToString();
comboBox_Clients.Items.Add(client);
comboBox_Clients.SelectedIndex = 0;
CFlag = 0; //连接成功，将客户端关闭标志设置为0
SFlag = 1; //当连接成功，将连接成功标志设置为1
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + client + "连接成功";
richTextBox_Receive.Text += "\r\n";
//开启第二个线程接收客户端数据
th2 = new Thread(Receive); //线程绑定Receive函数
th2.IsBackground = true; //运行线程在后台执行
th2.Start(Client); //Start里面的参数是Listen函数所需要的参数，这里传送的是用于通信的Socket对象
}
}
catch
{
//MessageBox.Show("没有连接上客户端");
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 接收客户端数据
void Receive(Object sk)
{
Socket socket = sk as Socket; //创建用于通信的套接字(这里是线程传过来的client套接字)
while (true)
{
try
{
if (CFlag == 0 && SFlag == 1)
{
//5.接收数据
byte[] recieve = new byte[1024];
int len = socket.Receive(recieve);
//6.打印接收数据
if (recieve.Length > 0)
{
//如果接收到客户端停止的标志
if (Encoding.UTF8.GetString(recieve, 0, len) == "*close*")
{
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "客户端已退出" + "\n";
CFlag = 1; //将客户端关闭标志设置为1
break; //退出循环
}
//打印接收数据
richTextBox_Receive.Text += "*" + DateTime.Now.ToString("yy-MM-dd hh:mm:ss ");
richTextBox_Receive.Text += "接收" + socket.RemoteEndPoint.ToString() + "：";
//richTextBox_Receive.Text += Encoding.ASCII.GetString(recieve, 0, len); //将字节数据根据ASCII码转成字符串
richTextBox_Receive.Text += Encoding.UTF8.GetString(recieve, 0, len); //接收中文不会乱码
richTextBox_Receive.Text += "\r\n";
}
}
else
{
break; //跳出循环
}
}
catch
{
MessageBox.Show("收不到信息");
}
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 向客户端发送数据
private void button_Send_Click(object sender, EventArgs e)
{
//SFlag标志连接成功，同时当客户端是打开的时候才能发送数据
if(SFlag == 1 && CFlag == 0)
{
byte[] send = new byte[1024];
//send = Encoding.ASCII.GetBytes(richTextBox_Send.Text); //将字符串转成字节格式发送
send = Encoding.UTF8.GetBytes(richTextBox_Send.Text);
/*
* 上面将每一个连接的client的套接字信息（ip和端口号）存放进了combox
* 我们可以在combox中选择需要通信的客户端
* 通过comboBox_Clients.SelectedIndex获取选择的index，此index对于List中的socket对象
* 从而实现对选择的客户端发送信息
*/
int i = comboBox_Clients.SelectedIndex;
string client = comboBox_Clients.Text;
socketsList[i].Send(send); //调用Send()向客户端发送数据
//打印发送时间和发送的数据
richTextBox_Receive.Text += "*" + DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "向" + client + "发送：";
richTextBox_Receive.Text += richTextBox_Send.Text + "\n";
richTextBox_Send.Clear(); //清除发送框
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 关闭服务器端
private void button_Close_Click(object sender, EventArgs e)
{
//若连接上了客户端需要关闭线程2和socket，没连接上客户端直接关闭线程1和其他套接字
if(CFlag == 1)
{
th2.Abort(); //关闭线程2
foreach(Socket s in socketsList)
s.Close(); //关闭用于通信的套接字
}
ServerSocket.Close(); //关闭用于连接的套接字
//socketAccept.Close(); //关闭与客户端绑定的套接字
th1.Abort(); //关闭线程1
CFlag = 0; //将客户端标志重新设置为0,在进行连接时表示是打开的状态
SFlag = 0; //将连接成功标志程序设置为0，表示退出连接
button_Accpet.Enabled = true;
richTextBox_Receive.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ");
richTextBox_Receive.Text += "服务器已关闭" + "\n";
MessageBox.Show("服务器已关闭");
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 点击enter发送数据
private void richTextBox_Send_KeyDown(object sender, KeyEventArgs e)
{
if (e.KeyCode == Keys.Enter)//如果输入的是回车键
{
this.button_Send_Click(sender, e);//触发button事件
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 点击清除接收框
private void button_Clear_Click(object sender, EventArgs e)
{
richTextBox_Receive.Clear();
}
#endregion
/*****************************************************************/
}
}
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
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 Client
{
public partial class Form1 : Form
{
public static Socket ClientSocket; //声明负责通信的socket
public static int SFlag = 0; //连接服务器成功标志
Thread th1; //声明一个线程
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
Control.CheckForIllegalCrossThreadCalls = false; //执行新线程时跨线程资源访问检查会提示报错，所以这里关闭检测
}
/*****************************************************************/
#region 连接服务器端
private void button_Connect_Click(object sender, EventArgs e)
{
ClientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); //声明负责通信的套接字
richTextBox_Recieve.Text += "正在连接...\n";
IPAddress IP = IPAddress.Parse(textBox_Addr.Text); //获取设置的IP地址
int Port = int.Parse(textBox_Port.Text); //获取设置的端口号
IPEndPoint iPEndPoint = new IPEndPoint(IP,Port); //指定的端口号和服务器的ip建立一个IPEndPoint对象
try
{
ClientSocket.Connect(iPEndPoint); //用socket对象的Connect()方法以上面建立的IPEndPoint对象做为参数，向服务器发出连接请求
SFlag = 1; //若连接成功将标志设置为1
richTextBox_Recieve.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + textBox_Addr.Text + "连接成功" + "\n";
button_Connect.Enabled = false; //禁止操作连接按钮
//开启一个线程接收数据
th1 = new Thread(Receive);
th1.IsBackground = true;
th1.Start(ClientSocket);
}
catch
{
MessageBox.Show("服务器未打开");
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 接收服务器端数据
void Receive(Object sk)
{
Socket socketRec = sk as Socket;
while (true)
{
//5.接收数据
byte[] receive = new byte[1024];
ClientSocket.Receive(receive); //调用Receive()接收字节数据
//6.打印接收数据
if (receive.Length > 0)
{
richTextBox_Recieve.Text += "*" + DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "接收："; //打印接收时间
//richTextBox_Recieve.Text += Encoding.ASCII.GetString(receive); //将字节数据根据ASCII码转成字符串
richTextBox_Recieve.Text += Encoding.UTF8.GetString(receive); //使用UTF8编码接收中文不会乱码
richTextBox_Recieve.Text += "\r\n";
}
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 向服务器端发送数据
private void button_Send_Click(object sender, EventArgs e)
{
//只有连接成功了才能发送数据，接收部分因为是连接成功才开启线程，所以不需要使用标志
if (SFlag == 1)
{
byte[] send = new byte[1024];
//send = Encoding.ASCII.GetBytes(richTextBox_Send.Text); //将文本内容转换成字节发送
send = Encoding.UTF8.GetBytes(richTextBox_Send.Text); //解决中文乱码问题
ClientSocket.Send(send); //调用Send()函数发送数据
richTextBox_Recieve.Text += "*" + DateTime.Now.ToString("yy-MM-dd hh:mm:ss ") + "发送："; //打印发送数据的时间
richTextBox_Recieve.Text += richTextBox_Send.Text + "\n"; //打印发送的数据
richTextBox_Send.Clear(); //清空发送框
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 关闭客户端
private void buttonClose_Click(object sender, EventArgs e)
{
//保证是在连接状态下退出
if (SFlag == 1)
{
byte[] send = new byte[1024];
send = Encoding.ASCII.GetBytes("*close*"); //关闭客户端时给服务器发送一个退出标志
ClientSocket.Send(send);
th1.Abort(); //关闭线程
ClientSocket.Close(); //关闭套接字
button_Connect.Enabled = true; //允许操作按钮
SFlag = 0; //客户端退出后将连接成功标志程序设置为0
richTextBox_Recieve.Text += DateTime.Now.ToString("yy-MM-dd hh:mm:ss ");
richTextBox_Recieve.Text += "客户端已关闭" + "\n";
MessageBox.Show("已关闭连接");
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 点击enter发送数据
private void richTextBox_Send_KeyDown(object sender, KeyEventArgs e)
{
if (e.KeyCode == Keys.Enter)//如果输入的是回车键
{
this.button_Send_Click(sender, e);//触发button事件
}
}
#endregion
/*****************************************************************/
/*****************************************************************/
#region 点击清除接收框
private void button_Clear_Click(object sender, EventArgs e)
{
richTextBox_Recieve.Clear();
}
#endregion
/*****************************************************************/
}
}
我在使用omniauth/openid时遇到了一些麻烦。在尝试进行身份验证时，我在日志中发现了这一点:OpenID::FetchingError:Errorfetchinghttps://www.google.com/accounts/o8/.well-known/host-meta?hd=profiles.google.com%2Fmy_username:undefinedmethod`io'fornil:NilClass重要的是undefinedmethodio'fornil:NilClass来自openid/fetchers.rb，在下面的代码片段中:moduleNetclass
我有一个用户工厂。我希望默认情况下确认用户。但是鉴于unconfirmed特征，我不希望它们被确认。虽然我有一个基于实现细节而不是抽象的工作实现，但我想知道如何正确地做到这一点。factory:userdoafter(:create)do|user,evaluator|#unwantedimplementationdetailshereunlessFactoryGirl.factories[:user].defined_traits.map(&:name).include?(:unconfirmed)user.confirm!endendtrait:unconfirmeddoenden
几个月前，我读了一篇关于rubygem的博客文章，它可以通过阅读代码本身来确定编程语言。对于我的生活，我不记得博客或gem的名称。谷歌搜索“ruby编程语言猜测”及其变体也无济于事。有人碰巧知道相关gem的名称吗？ 最佳答案 是这个吗:http://github.com/chrislo/sourceclassifier/tree/master 关于ruby-寻找通过阅读代码确定编程语言的rubygem？，我们在StackOverflow上找到一个类似的问题：
华为OD机试题本篇题目：明明的随机数题目输入描述输出描述：示例1输入输出说明代码编写思路最近更新的博客华为od2023|什么是华为od，od薪资待遇，od机试题清单华为OD机试真题大全，用Python解华为机试题|机试宝典【华为OD机试】全流程解析+经验分享,题型分享,防作弊指南华为o
C#实现简易绘图工具一.引言实验目的:通过制作窗体应用程序(C#画图软件),熟悉基本的窗体设计过程以及控件设计,事件处理等,熟悉使用C#的winform窗体进行绘图的基本步骤,对于面向对象编程有更加深刻的体会.Tutorial任务设计一个具有基本功能的画图软件**·包括简单的新建文件,保存,重新绘图等功能**·实现一些基本图形的绘制,包括铅笔和基本形状等,学习橡皮工具的创建**·设计一个合理舒适的UI界面**注明:你可能需要先了解一些关于winform窗体应用程序绘图的基本知识,以及关于GDI+类和结构的知识二.实验环境Windows系统下的visualstudio2017C#窗体应用程序三.
网络编程套接字网络编程基础知识理解源`IP`地址和目的`IP`地址理解源MAC地址和目的MAC地址认识端口号理解端口号和进程ID理解源端口号和目的端口号认识`TCP`协议认识`UDP`协议网络字节序socket编程接口`sockaddr``UDP`网络程序服务器端代码逻辑：需要用到的接口服务器端代码`udp`客户端代码逻辑`udp`客户端代码`TCP`网络程序服务器代码逻辑多个版本服务器单进程版本多进程版本多线程版本线程池版本服务器端代码客户端代码逻辑客户端代码TCP协议通讯流程TCP协议的客户端/服务器程序流程三次握手（建立连接）数据传输四次挥手（断开连接）TCP和UDP对比网络编程基础知识
目录前言滤波电路科普主要分类实际情况单位的概念常用评价参数函数型滤波器简单分析滤波电路构成低通滤波器RC低通滤波器RL低通滤波器高通滤波器RC高通滤波器RL高通滤波器部分摘自《LC滤波器设计与制作》，侵权删。前言最近需要学习放大电路和滤波电路，但是由于只在之前做音乐频谱分析仪的时候简单了解过一点点运放，所以也是相当从零开始学习了。滤波电路科普主要分类滤波器：主要是从不同频率的成分中提取出特定频率的信号。有源滤波器：由RC元件与运算放大器组成的滤波器。可滤除某一次或多次谐波，最普通易于采用的无源滤波器结构是将电感与电容串联，可对主要次谐波（3、5、7）构成低阻抗旁路。无源滤波器：无源滤波器，又称
MIMO技术的优缺点优点通过下面三个增益来总体概括：阵列增益。阵列增益是指由于接收机通过对接收信号的相干合并而活得的平均SNR的提高。在发射机不知道信道信息的情况下，MIMO系统可以获得的阵列增益与接收天线数成正比复用增益。在采用空间复用方案的MIMO系统中，可以获得复用增益，即信道容量成倍增加。信道容量的增加与min(Nt,Nr)成正比分集增益。在采用空间分集方案的MIMO系统中，可以获得分集增益，即可靠性性能的改善。分集增益用独立衰落支路数来描述，即分集指数。在使用了空时编码的MIMO系统中，由于接收天线或发射天线之间的间距较远，可认为它们各自的大尺度衰落是相互独立的，因此分布式MIMO
@作者:SYFStrive @博客首页:HomePage📜：微信小程序📌：个人社区（欢迎大佬们加入）👉：社区链接🔗📌：觉得文章不错可以点点关注👉：专栏连接🔗💃：感谢支持,学累了可以先看小段由小胖给大家带来的街舞👉微信小程序（🔥）目录自定义组件-behaviors 1、什么是behaviors 2、behaviors的工作方式 3、创建behavior 4、导入并使用behavior 5、behavior中所有可用的节点 6、同名字段的覆盖和组合规则总结最后自定义组件-behaviors 1、什么是behaviorsbehaviors是小程序中，用于实现
遍历文件夹我们通常是使用递归进行操作，这种方式比较简单，也比较容易理解。本文为大家介绍另一种不使用递归的方式，由于没有使用递归，只用到了循环和集合，所以效率更高一些！一、使用递归遍历文件夹整体思路1、使用File封装初始目录，2、打印这个目录3、获取这个目录下所有的子文件和子目录的数组。4、遍历这个数组，取出每个File对象4-1、如果File是否是一个文件，打印4-2、否则就是一个目录，递归调用代码实现publicclassSearchFile{publicstaticvoidmain(String[]args){//初始目录Filedir=newFile("d:/Dev");Datebeg