当前位置： 首页 > ds >正文

Socket网络编程

ds 2025/8/25 7:33:54

一．socket简介

套接字（socket） 是 Linux 下的一种进程间通信机制（socket IPC），在前面的内容中已经给大家提到过，使用 socket IPC 可以使得在不同主机上的应用程序之间进行通信（网络通信），当然也可以是同一台主机上的不同应用程序。socket IPC 通常使用客户端<—>服务器这种模式完成通信，多个客户端可以同时连接到服务器中，与服务器之间完成数据交互。

二．socket编程接口介绍

本篇介绍socket 编程中使用到的一些接口函数。使用 socket 接口需要在我们的应用程序
代码中包含两个头文件：

#include <sys/types.h> /* See NOTES */

#include <sys/socket.h>

1. socket()函数

socket()函数原型如下所示：

#include <sys/types.h> /* See NOTES */

#include <sys/socket.h>

int socket(int domain, int type, int protocol);

socket()函数类似于 open()函数，它用于创建一个网络通信端点（打开一个网络通信），如果成功则返回一个网络文件描述符，通常把这个文件描述符称为 socket 描述符（socket descriptor），这个 socket 描述符跟文件描述符一样，后续的操作都有用到它，把它作为参数，通过它来进行一些读写操作。

该函数包括 3 个参数，如下所示：

domain

参数 domain 用于指定一个通信域；这将选择将用于通信的协议族。可选的协议族如下表所示：

对于 TCP/IP 协议来说，通常选择 AF_INET 就可以了，当然如果你的 IP 协议的版本支持 IPv6，那么可以选择 AF_INET6。

type

参数 type 指定套接字的类型，当前支持的类型有：

 

protocol

参数 protocol 通常设置为 0，表示为给定的通信域和套接字类型选择默认协议。当对同一域和套接字类型支持多个协议时，可以使用 protocol 参数选择一个特定协议。在 AF_INET 通信域中，套接字类型为SOCK_STREAM 的默认协议是传输控制协议（Transmission Control Protocol，TCP 协议）。

在 AF_INET 通信域中，套接字类型为 SOCK_DGRAM 的默认协议时 UDP。

调用 socket()与调用 open()函数很类似，调用成功情况下，均会返回用于文件 I/O 的文件描述符，只不过对于 socket()来说，其返回的文件描述符一般称为 socket 描述符。当不再需要该文件描述符时，可调用close()函数来关闭套接字，释放相应的资源。

如果 socket()函数调用失败，则会返回-1，并且会设置 errno 变量以指示错误类型。

使用示例

int socket_fd = socket(AF_INET, SOCK_STREAM, 0);//打开套接字

if (0 > socket_fd) {

 perror("socket error");

 exit(-1);

}

close(socket_fd); //关闭套接字

2. bind()函数

bind()函数原型如下所示：

int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

bind()函数用于将一个 IP 地址或端口号与一个套接字进行绑定（将套接字与地址进行关联）。将一个客户端的套接字关联上一个地址没有多少新意，可以让系统选一个默认的地址。一般来讲，会将一个服务器的套接字绑定到一个众所周知的地址—即一个固定的与服务器进行通信的客户端应用程序提前就知道的地址（注意这里说的地址包括 IP 地址和端口号）。因为对于客户端来说，它与服务器进行通信，首先需要知道服务器的 IP 地址以及对应的端口号，所以通常服务器的 IP 地址以及端口号都是众所周知的。

调用 bind()函数将参数 sockfd 指定的套接字与一个地址 addr 进行绑定，成功返回 0，失败情况下返回-1，并设置 errno 以提示错误原因。

参数 addr 是一个指针，指向一个 struct sockaddr 类型变量，如下所示：

struct sockaddr {

 sa_family_t sa_family;

 char sa_data[14];

}

第二个成员 sa_data 是一个 char 类型数组，一共 14 个字节，在这 14 个字节中就包括了 IP 地址、端口号等信息，这个结构对用户并不友好，它把这些信息都封装在了 sa_data 数组中，这样使得用户是无法对sa_data 数组进行赋值。事实上，这是一个通用的 socket 地址结构体。

一般我们在使用的时候都会使用 struct sockaddr_in 结构体，sockaddr_in 和 sockaddr 是并列的结构（占用的空间是一样的），指向 sockaddr_in 的结构体的指针也可以指向 sockadd 的结构体，并代替它，而且sockaddr_in 结构对用户将更加友好，在使用的时候进行类型转换就可以了。该结构体内容如下所示：

struct sockaddr_in {

 sa_family_t sin_family; /* 协议族 */

 in_port_t sin_port; /* 端口号 */

 struct in_addr sin_addr; /* IP 地址 */

 unsigned char sin_zero[8];

};

这个结构体的第一个字段是与 sockaddr 结构体是一致的，而剩下的字段就是 sa_data 数组连续的 14 字节信息里面的内容，只不过从新定义了成员变量而已，sin_port 字段是我们需要填写的端口号信息，sin_addr字段是我们需要填写的 IP 地址信息，剩下 sin_zero 区域的 8 字节保留未用。

最后一个参数 addrlen 指定了 addr 所指向的结构体对应的字节长度。

使用示例

struct sockaddr_in socket_addr;

memset(&socket_addr, 0x0, sizeof(socket_addr)); //清零

//填充变量

socket_addr.sin_family = AF_INET;

socket_addr.sin_addr.s_addr = htonl(INADDR_ANY);

socket_addr.sin_port = htons(5555);

//将地址与套接字进行关联、绑定

bind(socket_fd, (struct sockaddr *)&socket_addr, sizeof(socket_addr));

Tips： 代码中的 htons 和 htonl 并不是函数，只是一个宏定义，主要的作用在于为了避免大小端的问题，需要这些宏需要在我们的应用程序代码中包含头文件<netinet/in.h>。

Tips：bind()函数并不是总是需要调用的，只有用户进程想与一个具体的 IP 地址或端口号相关联的时候才需要调用这个函数。如果用户进程没有这个必要，那么程序可以依赖内核的自动的选址机制来完成自动地址选择，通常在客户端应用程序中会这样做。

3. listen()函数

listen()函数只能在服务器进程中使用，让服务器进程进入监听状态，等待客户端的连接请求，listen()函数在一般在 bind()函数之后调用，在 accept()函数之前调用，它的函数原型是：

int listen(int sockfd, int backlog);

无法在一个已经连接的套接字（即已经成功执行 connect()的套接字或由 accept()调用返回的套接字）上执行 listen()。

参数 backlog 用来描述 sockfd 的等待连接队列能够达到的最大值。在服务器进程正处理客户端连接请求的时候，可能还存在其它的客户端请求建立连接，因为 TCP 连接是一个过程，由于同时尝试连接的用户过多，使得服务器进程无法快速地完成所有的连接请求，那怎么办呢？直接丢掉其他客户端的连接肯定不是一个很好的解决方法。因此内核会在自己的进程空间里维护一个队列，这些连接请求就会被放入一个队列中，服务器进程会按照先来后到的顺序去处理这些连接请求，这样的一个队列内核不可能让其任意大，所以必须有一个大小的上限，这个 backlog 参数告诉内核使用这个数值作为队列的上限。而当一个客户端的连接请求到达并且该队列为满时，客户端可能会收到一个表示连接失败的错误，本次请求会被丢弃不作处理。

4. accept()函数

服务器调用 listen()函数之后，就会进入到监听状态，等待客户端的连接请求，使用 accept()函数获取客户端的连接请求并建立连接。函数原型如下所示：

int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);

为了能够正常让客户端能正常连接到服务器，服务器必须遵循以下处理流程：

① 调用 socket()函数打开套接字；

② 调用 bind()函数将套接字与一个端口号以及 IP 地址进行绑定；

③ 调用 listen()函数让服务器进程进入监听状态，监听客户端的连接请求；

④ 调用 accept()函数处理到来的连接请求。

accept()函数通常只用于服务器应用程序中，如果调用 accept()函数时，并没有客户端请求连接（等待连接队列中也没有等待连接的请求），此时 accept()会进入阻塞状态，直到有客户端连接请求到达为止。当有客户端连接请求到达时，accept()函数与远程客户端之间建立连接，accept()函数返回一个新的套接字。这个套接字与 socket()函数返回的套接字并不同，socket()函数返回的是服务器的套接字（以服务器为例），而accept()函数返回的套接字连接到调用 connect()的客户端，服务器通过该套接字与客户端进行数据交互，譬如向客户端发送数据、或从客户端接收数据。

所以，理解 accept()函数的关键点在于它会创建一个新的套接字，其实这个新的套接字就是与执行

connect()（客户端调用 connect()向服务器发起连接请求）的客户端之间建立了连接，这个套接字代表了服务器与客户端的一个连接。如果 accept()函数执行出错，将会返回-1，并会设置 errno 以指示错误原因。

参数 addr 是一个传出参数，参数 addr 用来返回已连接的客户端的 IP 地址与端口号等这些信息。

参数addrlen 应设置为 addr 所指向的对象的字节长度，如果我们对客户端的 IP 地址与端口号这些信息不感兴趣，可以把 arrd 和 addrlen 均置为空指针 NULL。

5. connect()函数

connect()函数原型如下所示：

int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

该函数用于客户端应用程序中，客户端调用 connect()函数将套接字 sockfd 与远程服务器进行连接，参数 addr 指定了待连接的服务器的 IP 地址以及端口号等信息，参数 addrlen 指定了 addr 指向的 struct sockaddr对象的字节大小。

客户端通过 connect()函数请求与服务器建立连接，对于 TCP 连接来说，调用该函数将发生 TCP 连接的握手过程，并最终建立一个 TCP 连接，而对于 UDP 协议来说，调用这个函数只是在 sockfd 中记录服务器IP 地址与端口号，而不发送任何数据。

函数调用成功则返回 0，失败返回-1，并设置 errno 以指示错误原因。

6. 发送和接收函数

一旦客户端与服务器建立好连接之后，我们就可以通过套接字描述符来收发数据了（对于客户端使用socket()返回的套接字描述符，而对于服务器来说，需要使用 accept()返回的套接字描述符），这与我们读写普通文件是差不多的操作，譬如可以调用 read()或 recv()函数读取网络数据，调用 write()或 send()函数发送数据。

read()函数

read()函数大家都很熟悉了，通过 read()函数从一个文件描述符中读取指定字节大小的数据并放入到指定的缓冲区中，read()调用成功将返回读取到的字节数，此返回值受文件剩余字节数限制，当返回值小于指定的字节数时并不意味着错误；这可能是因为当前可读取的字节数小于指定的字节数（比如已经接近文件结尾，或者正在从管道或者终端读取数据，或者 read()函数被信号中断等），出错返回-1 并设置 errno，如果在调 read 之前已到达文件末尾，则这次 read 返回 0。

套接字描述符也是文件描述符，所以使用 read()函数读取网络数据时，read()函数的参数 fd 就是对应的套接字描述符。

recv()函数

recv()函数原型如下所示：

ssize_t recv(int sockfd, void *buf, size_t len, int flags);

不论是客户端还是服务器都可以通过 revc()函数读取网络数据，它与 read()函数的功能是相似的。参数sockfd 指定套接字描述符，参数 buf 指向了一个数据接收缓冲区，参数 len 指定了读取数据的字节大小，参数 flags 可以指定一些标志用于控制如何接收数据。

函数 recv()与 read()很相似，但是 recv()可以通过指定 flags 标志来控制如何接收数据，这些标志

如下所示：

 

通常一般我们将 flags 参数设置为 0，当然，你可以根据自己的需求设置该参数。

当指定 MSG_PEEK 标志时，可以查看下一个要读取的数据但不真正取走它，当再次调用 read 或 recv函数时，会返回刚才查看的数据。

对于 SOCK_STREAM 类型套接字，接收的数据可以比指定的字节大小少。MSG_WAITALL 标志会阻止这种行为，知道所请求的数据全部返回，recv 函数才会返回。对于 SOCK_DGRAM 和 SOCK_SEQPACKET套接字，MSG_WAITALL 标志并不会改变什么行为，因为这些基于报文的套接字类型一次读取就返回整个报文。

如果发送者已经调用 shutdown 来结束传输，或者网络协议支持按默认的顺序关闭并且发送端已经关闭，那么当所有的数据接收完毕后，recv 会返回 0。recv 在调用成功情况下返回实际读取到的字节数。

write()函数

通过 write()函数可以向套接字描述符中写入数据，函数调用成功返回写入的字节数，失败返回-1，并设置 errno 变量。

send()函数

函数原型如下所示：

ssize_t send(int sockfd, const void *buf, size_t len, int flags);

send 和 write 很相似，但是 send 可以通过参数 flags 指定一些标志，来改变处理传输数据的方式。这些标志如下所示：

 

即使 send()成功返回，也并不表示连接的另一端的进程就一定接收了数据，我们所能保证的只是当 send成功返回时，数据已经被无错误的发送到网络驱动程序上。

7. close()关闭套接字

当不再需要套接字描述符时，可调用 close()函数来关闭套接字，释放相应的资源。

三Socket编程实例

TCP服务器端（tcpserver.c）

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8080
#define BUFFER_SIZE 1024
/*
1.创建服务器套接字(有对应的TCP协议)socket()
2.绑定套接字到指定地址和端口(有自己的网络信息)bind()
3.监听连接请求，监听服务端套接字（查看是否有客户端连接）listen()
4.接受客户端连接  accept()
5.接收客户端发送的数据 recv()
6.发送数据给客户端 send()
7.关闭套接字 close()
*/int main() {int serverSocket, clientSocket;struct sockaddr_in serverAddr, clientAddr;socklen_t clientAddrLen;char buffer[BUFFER_SIZE];// 创建服务端套接字serverSocket = socket(AF_INET, SOCK_STREAM, 0);if (serverSocket == -1) {perror("Failed to create socket");exit(EXIT_FAILURE);}// 设置服务器地址信息memset(&serverAddr, 0, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_port = htons(SERVER_PORT);serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);// 绑定套接字到指定地址和端口if (bind(serverSocket, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == -1) {perror("Failed to bind socket");exit(EXIT_FAILURE);}// 监听连接请求if (listen(serverSocket, 5) == -1) {perror("Failed to listen");exit(EXIT_FAILURE);}printf("Server listening on port %d...\n", SERVER_PORT);// 接受客户端连接clientAddrLen = sizeof(clientAddr);clientSocket = accept(serverSocket, (struct sockaddr *)&clientAddr, &clientAddrLen);if (clientSocket == -1) {perror("Failed to accept client connection");exit(EXIT_FAILURE);}printf("Client connected: %s\n", inet_ntoa(clientAddr.sin_addr));// 接收数据memset(buffer, 0, sizeof(buffer));if (recv(clientSocket, buffer, BUFFER_SIZE, 0) == -1) {perror("Failed to receive data");exit(EXIT_FAILURE);}printf("Client message: %s\n", buffer);// 发送响应strcpy(buffer, "Hello, Client!");if (send(clientSocket, buffer, strlen(buffer), 0) == -1) {perror("Failed to send data");exit(EXIT_FAILURE);}// 关闭套接字close(clientSocket);close(serverSocket);return 0;
}

 TCP客户端（tcpclient.c）

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8080
#define BUFFER_SIZE 1024
/*
1.创建服务器套接字(有对应的TCP协议)socket()
2.绑定套接字到指定地址和端口(有自己的网络信息)bind()
3. 连接到服务器 connect()
4.发送数据给客户端 send()
5.接收客户端发送的数据 recv()
6.关闭套接字 close()
*/
int main() {int clientSocket;struct sockaddr_in serverAddr;char buffer[BUFFER_SIZE];// 创建客户端套接字clientSocket = socket(AF_INET, SOCK_STREAM, 0);if (clientSocket == -1) {perror("Failed to create socket");exit(EXIT_FAILURE);}// 设置服务器地址信息memset(&serverAddr, 0, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_port = htons(SERVER_PORT);if (inet_pton(AF_INET, SERVER_IP, &(serverAddr.sin_addr)) <=0) {perror("Failed to set server IP");exit(EXIT_FAILURE);}// 连接到服务器if (connect(clientSocket, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == -1) {perror("Failed to connect to server");exit(EXIT_FAILURE);}printf("Connected to server %s:%d\n", SERVER_IP, SERVER_PORT);// 发送数据strcpy(buffer, "Hello, Server!");if (send(clientSocket, buffer, strlen(buffer), 0) == -1) {perror("Failed to send data");exit(EXIT_FAILURE);}// 接收响应memset(buffer, 0, sizeof(buffer));if (recv(clientSocket, buffer, BUFFER_SIZE, 0) == -1) {perror("Failed to receive data");exit(EXIT_FAILURE);}printf("Server response: %s\n", buffer);// 关闭套接字close(clientSocket);return 0;
}

UDP服务端（udpservice.c）

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8080
#define BUFFER_SIZE 1024
/*
1.创建服务器套接字(有对应的TCP协议)socket()
2.绑定套接字到指定地址和端口(有自己的网络信息)bind()
3.接收客户端发送的数据 recvfrom()
4.发送数据给客户端 sendto()
5.关闭套接字 close()
*/
int main() {int serverSocket;struct sockaddr_in serverAddr, clientAddr;socklen_t clientAddrLen;char buffer[BUFFER_SIZE];// 创建服务端套接字serverSocket = socket(AF_INET, SOCK_DGRAM, 0);if (serverSocket == -1) {perror("Failed to create socket");exit(EXIT_FAILURE);}// 设置服务器地址信息memset(&serverAddr, 0, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_port = htons(SERVER_PORT);serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);// 绑定套接字到指定地址和端口if (bind(serverSocket, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == -1) {perror("Failed to bind socket");exit(EXIT_FAILURE);}printf("Server listening on port %d...\n", SERVER_PORT);// 接收数据clientAddrLen = sizeof(clientAddr);memset(buffer, 0, sizeof(buffer));if (recvfrom(serverSocket, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&clientAddr, &clientAddrLen) == -1) {perror("Failed to receive data");exit(EXIT_FAILURE);}printf("Client message: %s\n", buffer);// 发送响应strcpy(buffer, "Hello, Client!");if (sendto(serverSocket, buffer, strlen(buffer), 0, (struct sockaddr *)&clientAddr, clientAddrLen) == -1) {perror("Failed to send data");exit(EXIT_FAILURE);}// 关闭套接字close(serverSocket);return 0;
}

UDP客户端（udpclient.c）

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>#define SERVER_IP "127.0.0.1"
#define SERVER_PORT 8080
#define BUFFER_SIZE 1024
/*
1.创建服务器套接字(有对应的TCP协议)socket()
2.绑定套接字到指定地址和端口(有自己的网络信息)bind()
3.发送数据给客户端 send()
4.接收客户端发送的数据 recv()
5.关闭套接字 close()
*/
int main() {int clientSocket;struct sockaddr_in serverAddr;char buffer[BUFFER_SIZE];// 创建客户端套接字clientSocket = socket(AF_INET, SOCK_DGRAM, 0);if (clientSocket == -1) {perror("Failed to create socket");exit(EXIT_FAILURE);}// 设置服务器地址信息memset(&serverAddr, 0, sizeof(serverAddr));serverAddr.sin_family = AF_INET;serverAddr.sin_port = htons(SERVER_PORT);if (inet_pton(AF_INET, SERVER_IP, &(serverAddr.sin_addr)) <= 0) {perror("Failed to set server IP");exit(EXIT_FAILURE);}printf("Connected to server %s:%d\n", SERVER_IP, SERVER_PORT);// 发送数据strcpy(buffer, "Hello, Server!");if (sendto(clientSocket, buffer, strlen(buffer), 0, (struct sockaddr *)&serverAddr, sizeof(serverAddr)) == -1) {perror("Failed to send data");exit(EXIT_FAILURE);}// 接收响应memset(buffer, 0, sizeof(buffer));if (recvfrom(clientSocket, buffer, BUFFER_SIZE, 0, NULL, NULL) == -1) {perror("Failed to receive data");exit(EXIT_FAILURE);}printf("Server response: %s\n", buffer);// 关闭套接字close(clientSocket);return 0;
}
http://www.xdnf.cn/news/9861.html

相关文章：

  • Vue3 + Element Plus 实现树形结构的“单选 + 只选叶子节点 + 默认选中第一个子节点”
  • 微内核与宏内核有什么区别(GAI)
  • laya3的2d相机与2d区域
  • 2025.05.28-华为暑期实习第二题-200分
  • 尝鲜纯血鸿蒙，华为国际版本暂时不支持升级。如mateX6 国际版？为什么不支持？什么时候支持？
  • spark shuffle的分区支持动态调整，而hive不支持
  • Oracle MOVE ONLINE 实现原理
  • Java求职者面试题详解：计算机网络、操作系统、设计模式与数据结构
  • VR 电缆故障测试系统：技术革新​
  • 数控技术应用理实一体化平台VR实训系统
  • python中使用高并发分布式队列库celery的那些坑
  • 深入解析Java8核心新特性（Optional、新的日期时间API、接口增强）
  • Android AIDL Hal最低保证出现的问题
  • CSS基础巩固-选择
  • 【大模型02】Deepseek使用和prompt工程
  • PH热榜 | 2025-05-29
  • leetcode235.二叉搜索树的最近公共祖先：迭代法利用有序性高效寻根
  • 【音频处理】java流式调用ffmpeg命令
  • 《Python 应用中的蓝绿部署与滚动更新：持续集成中的实践与优化》
  • Java设计模式从基础到实际运用
  • 【redis实战篇】第六天
  • 一根网线连接两台电脑组建局域网
  • 不起火，不爆炸，高速摄像机、数字图像相关DIC技术在动力电池新国标安全性能测试中的应用
  • 代码随想录算法训练营第60期第五十一天打卡
  • R3GAN训练自己的数据集
  • Java中float和double的区别与用法解析
  • 华为OD机试真题——阿里巴巴找黄金宝箱(III)（2025A卷：100分）Java/python/JavaScript/C/C++/GO最佳实现
  • WPF 全局加载界面、多界面实现渐变过渡效果
  • DexWild：野外机器人策略的灵巧人机交互
  • 华为OD机试真题——简单的自动曝光平均像素（2025A卷：100分）Java/python/JavaScript/C/C++/GO最佳实现