C#之Socket(套接字)通信
一、Socket是什么
Socket是应用层与tcp/IP协议族通信的中间软件抽象层,它是一组接口。在设计模式中,Socket其实就是一个门面模式,它把复杂的TCP/IP协议族隐藏在Socket接口后面,对用户来说,一组简单的接口就是全部,让Socket去组织数据,以符合指定的协议。所以,我们无需深入理解tcp/udp协议,socket已经为我们封装好了,我们只需要遵循socket的规定去编程,写出的程序自然就是遵循tcp/udp标准的。
二、套接字的工作流程
先从服务器端说起。服务器端先初始化Socket,然后与端口绑定(bind),对端口进行监听(listen),调用accept阻塞,等待客户端连接。在这时如果有个客户端初始化一个Socket,然后连接服务器(connect),如果连接成功,这时客户端与服务器端的连接就建立了。客户端发送数据请求,服务器端接收请求并处理请求,然后把回应数据发送给客户端,客户端读取数据,最后关闭连接,一次交互结束。
三、服务端
private void btnListen_Click(object sender, EventArgs e)
{
IPEndPoint point = new IPEndPoint(IPAddress.Any, 13000);//IPAddress.Any本机任何网卡IP。本机端口查看netstat -an
//服务端Socket定义
Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
socket.Bind(point); //绑定IP
socket.Listen(10);//启动监听。最大监听数,同一个时间点过来10个客户端,排队
ShowMsg("服务器开始监听");
Thread thread = new Thread(AcceptInfo);
thread.Start(socket);
}
//记录通信用的Socket
Dictionary<string, Socket> dic = new Dictionary<string, Socket>();
// private Socket client;
void AcceptInfo(object o)
{
Socket socket = o as Socket;
while (true)
{
//通信用socket
try
{
Socket clientSocket = socket.Accept();//如果客户端有请求,生成一个新的Socket
string point = clientSocket.RemoteEndPoint.ToString();
ShowMsg(point + "连接客户端成功!");
dic.Add(point, clientSocket);
//接收消息
Thread th = new Thread(ReceiveMsg);
th.Start(clientSocket);
}
catch (Exception ex)
{
break;
}
}
socket.Close();
}
//接收消息
void ReceiveMsg(object socket)
{
Socket clientSocket = socket as Socket;
while (true)
{
//接收客户端发送过来的数据
try
{
//定义byte数组存放从客户端接收过来的数据
byte[] buffer = new byte[1024 * 1024];
int n = clientSocket.Receive(buffer);//将接收过来的数据放到buffer中,并返回实际接受数据的长度
//将字节转换成字符串
string Words = Encoding.Unicode.GetString(buffer, 0, n);
Console.WriteLine(clientSocket.RemoteEndPoint.ToString() + ":" + words);
byte[] msg = Encoding.Unicode.GetBytes(words);
clientSocket.Send(msg);//发送数据,字节数组
}
catch (Exception ex)
{
break;
}
}
clientSocket.Shutdown(SocketShutdown.Both);//禁止发送和接受数据
clientSocket.Close();//关闭socket,释放资源
}
四、客户端
Socket clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
IPEndPoint point = new IPEndPoint("127.0.0.1", 13000));//连接到的服务端IP
clientSocket.Connect(point);//连接到服务器
ShowMsg("连接成功");
ShowMsg("服务器" + client.RemoteEndPoint.ToString());
ShowMsg("客户端:" + client.LocalEndPoint.ToString());
Thread th = new Thread(ReceiveMsg);//连接成功后,就可以接收服务器发送的信息了
th.IsBackground = true;
th.Start();
clientSocket.Shutdown(SocketShutdown.Both);//禁止发送和接受数据
clientSocket.Close();//关闭socket,释放资源
五、Socket对象的成员
1、属性
名称 | 说明 |
---|---|
AddressFamily | 获取 Socket 的地址族。 |
Available | 获取已经从网络接收且可供读取的数据量。 |
Blocking | 获取或设置一个值,该值指示 Socket 是否处于阻止模式。 |
Connected | 获取一个值,该值指示 Socket 是在上次 Send 还是 Receive 操作时连接到远程主机。 |
Handle | 获取 Socket 的操作系统句柄。 |
LocalEndPoint | 获取本地终结点。 |
RemoteEndPoint | 获取远程终结点。 |
ProtocolType | 获取 Socket 的协议类型。 |
SocketType | 获取 Socket 的类型。 |
ReceiveBufferSize | 获取或设置一个值,它指定 Socket 接收缓冲区的大小。 |
ReceiveTimeout | 获取或设置一个值,该值指定之后同步 Receive 调用将超时的时间长度。 |
SendBufferSize | 获取或设置一个值,该值指定 Socket 发送缓冲区的大小。 |
SendTimeout | 获取或设置一个值,该值指定之后同步 Send 调用将超时的时间长度。 |
2、方法
Accept
名称 | 说明 |
---|---|
Accept() | 为新建连接创建新的 Socket。 |
BeginAccept(AsyncCallback, Object) | 开始一个异步操作来接受一个传入的连接尝试。 |
EndAccept(Byte[], IAsyncResult) | 异步接受传入的连接尝试,并创建新的 Socket 对象来处理远程主机通信。 此方法返回包含所传输的初始数据的缓冲区。 |
AcceptAsync(SocketAsyncEventArgs) | 开始一个异步操作来接受一个传入的连接尝试。 |
Connect
名称 | 说明 |
---|---|
Connect(EndPoint) | 与远程主机建立连接。 |
BeginConnect(EndPoint, AsyncCallback, Object) | 开始一个对远程主机连接的异步请求。 |
EndConnect(IAsyncResult) | 结束挂起的异步连接请求。 |
ConnectAsync(SocketAsyncEventArgs) | 开始一个对远程主机连接的异步请求。 |
Disconnect
名称 | 说明 |
---|---|
Disconnect(Boolean) | 关闭套接字连接并允许重用套接字。 |
BeginDisconnect(Boolean, AsyncCallback, Object) | 开始异步请求从远程终结点断开连接。 |
EndDisconnect(IAsyncResult) | 结束挂起的异步断开连接请求。 |
DisconnectAsync(SocketAsyncEventArgs) | 关闭套接字连接并允许重用套接字。 |
Receive
名称 | 说明 |
---|---|
Receive(Byte[]) | 从绑定的 Socket 套接字接收数据,将数据存入接收缓冲区。 |
BeginReceive(Byte[], Int32, Int32, SocketFlags, AsyncCallback, Object) | 开始从连接的 Socket 中异步接收数据。 |
EndReceive(IAsyncResult) | 结束挂起的异步读取。 |
ReceiveAsync(SocketAsyncEventArgs) | 开始一个异步请求以便从连接的 Socket 对象中接收数据。 |
ReceiveFrom
名称 | 说明 |
---|---|
ReceiveFrom(Byte[], EndPoint) | 将数据报接收到数据缓冲区并存储终结点。 |
BeginReceiveFrom(Byte[], Int32, Int32, SocketFlags, EndPoint, AsyncCallback, Object) | 开始从指定网络设备中异步接收数据。 |
EndReceiveFrom(IAsyncResult, EndPoint) | 结束挂起的、从特定终结点进行异步读取。 |
ReceiveFromAsync(SocketAsyncEventArgs) | 开始从指定网络设备中异步接收数据。 |
ReceiveMessageFrom
名称 | 说明 |
---|---|
ReceiveMessageFrom(Byte[], Int32, Int32, SocketFlags, EndPoint, IPPacketInfORMation) | 使用指定的 SocketFlags 将指定字节数的数据接收到指定的数据缓冲区位置,并存储终结点和数据包信息。 |
BeginReceiveMessageFrom(Byte[], Int32, Int32, SocketFlags, EndPoint, AsyncCallback, Object) | 开始使用指定的 SocketFlags 将指定字节数的数据异步接收到数据缓冲区的指定位置,然后存储终结点和数据包信息。 |
EndReceiveMessageFrom(IAsyncResult, SocketFlags, EndPoint, IPPacketInformation) | 结束挂起的、从特定终结点进行异步读取。 此方法还显示有关数据包而不是 EndReceiveFrom(IAsyncResult, EndPoint) 的更多信息。 |
ReceiveMessageFromAsync(SocketAsyncEventArgs) | 开始使用指定的 SocketFlags 将指定字节数的数据异步接收到数据缓冲区的指定位置,并存储终结点和数据包信息。 |
Send
名称 | 说明 |
---|---|
Send(Byte[]) | 将数据发送到连接的 Socket。 |
BeginSend(Byte[], Int32, Int32, SocketFlags, AsyncCallback, Object) | 将数据异步发送到连接的 Socket。 |
EndSend(IAsyncResult) | 结束挂起的异步发送。 |
SendAsync(SocketAsyncEventArgs) | 将数据异步发送到连接的 Socket 对象。 |
SendFile
名称 | 说明 |
---|---|
SendFile(String) | 使用 Socket 传输标志,将文件 fileName 发送到连接的 UseDefaultWorkerThread 对象。 |
BeginSendFile(String, AsyncCallback, Object) | 使用 Socket 标志,将文件 fileName 发送到连接的 UseDefaultWorkerThread 对象。 |
EndSendFile(IAsyncResult) | 结束文件的挂起异步发送。 |
SendTo
名称 | 说明 |
---|---|
SendTo(Byte[], EndPoint) | 将数据发送到指定的终结点。 |
BeginSendTo(Byte[], Int32, Int32, SocketFlags, EndPoint, AsyncCallback, Object) | 以异步方式将数据发送到特定远程主机。 |
EndSendTo(IAsyncResult) | 结束挂起的、向指定位置进行的异步发送。 |
SendToAsync(SocketAsyncEventArgs) | 以异步方式将数据发送到特定远程主机。 |
其它
名称 | 说明 |
---|---|
Select(IList, IList, IList, Int32) | 确定一个或多个套接字的状态。 |
SendPacketsAsync(SocketAsyncEventArgs) | 将文件集合或者内存中的数据缓冲区以异步方法发送给连接的 Socket 对象。 |
Bind(EndPoint) | 使 Socket 与一个本地终结点相关联。 |
Listen(Int32) | 将 Socket 置于侦听状态。 |
CancelConnectAsync(SocketAsyncEventArgs) | 取消一个对远程主机连接的异步请求。 |
GetSocketOption(SocketOptionLevel, SocketOptionName) | 返回指定的 Socket 选项的值,表示为一个对象。 |
SetSocketOption(SocketOptionLevel, SocketOptionName, Boolean) | 将指定的 Socket 选项设置为指定的 Boolean 值。 |
SetIPProtectionLevel(IPProtectionLevel) | 设置套接字的 IP 保护级别。 |
Shutdown(SocketShutdown) | 禁用某 Socket 上的发送和接收。 |
Close() | 关闭 Socket 连接并释放所有关联的资源。 |
Dispose() | 释放 Socket 类的当前实例所使用的所有资源。 |
到此这篇关于C#之Socket(套接字)通信的文章就介绍到这了。希望对大家的学习有所帮助,也希望大家多多支持。
相关文章