UDP流程补充:
recvfrom()
这是一个系统调用,用于从套接字接收数据的函数。该函数通常与无连接的数据报服务(如 UDP)一起使用,但也可以与其他类型的套接字使用。
函数原型为:
ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags,
struct sockaddr *src_addr, socklen_t *addrlen);
参数解释:
-
sockfd:一个已打开的套接字的描述符。
-
buf:一个指针,指向用于存放接收到的数据的缓冲区的发送地址。
-
len:缓冲区的大小(以字节为单位)。
-
flags:控制接收行为的标志。通常默认为0,其他用法为:
MSG_WAITALL
:尝试接收全部请求的数据。函数可能会阻塞,直到收到所有数据。MSG_PEEK
:查看即将接收的数据,但不从套接字缓冲区中删除它【1】。- 其他一些标志还可以影响函数的行为,但在大多数常规应用中很少使用。
-
src_addr:一个指针,指向一个
sockaddr
结构,用于保存发送数据的源地址。 -
addrlen:一个值-结果参数。开始时,它应该设置为
src_addr
缓冲区的大小。当recvfrom()
返回时,该值会被修改为实际地址的长度(以字节为单位)。
返回值:
1.成功返回接收到的字节数。
2.如果没有数据可读或套接字已经关闭,那么返回值为0。
3.出错时,返回 -1
,并设置全局变量 errno
以指示错误类型。
bind() 绑定ip
- sockfd:需要绑定的socket的描述符。
- my_addr:指向一个包含服务端用于通信的地址和端口的结构体指针。在Linux环境下,这个结构体通常是
struct sockaddr
或struct sockaddr_in
(用于IPv4)或struct sockaddr_in6
(用于IPv6)。 - addrlen:表示
my_addr
结构体的大小。可以使用sizeof
操作符获取这个值。
使用举例:实现客户端与服务器端双方通信,quit退出。
client.c
int c_fd = 0;
void child_handler(int signo)
{
close(c_fd);
printf("child--exit--\n");
exit(0);
}
void father_handler(int signo)
{
close(c_fd);
printf("father--exit--\n");
exit(0);
}
int main(int argc, const char *argv[])
{
//1.socket 创建通信的一端
int fd = socket(AF_INET,SOCK_DGRAM,0);
if (fd < 0)
{
perror("socket fail");
return -1;
}
printf("fd = %d\n",fd);
struct sockaddr_in seraddr;
seraddr.sin_family = AF_INET;
seraddr.sin_port = htons(50000);
seraddr.sin_addr.s_addr = inet_addr("192.168.1.135");
char buf[1024] = {0};
//区分任务
pid_t pid = fork();
if (pid < 0)
{
perror("fork fail");
return -1;
}
if (pid > 0)
{
signal(SIGCHLD,father_handler);
c_fd = fd;
while (1)
{
printf(">");
fgets(buf,sizeof(buf),stdin);
int ret = sendto(fd,buf,strlen(buf)+1,0,(const struct sockaddr *)&seraddr,sizeof(seraddr));
printf("ret = %d\n",ret);
if (strncmp(buf,"quit",4) == 0)
{
kill(pid,SIGUSR1);
wait(NULL);
close(fd);
exit(0);
}
}
}else if (pid == 0)
{
c_fd = fd;
signal(SIGUSR1,child_handler);
while (1)
{
recvfrom(fd,buf,sizeof(buf),0,NULL,NULL);
printf("buf = %s\n",buf);
if (strncmp(buf,"quit",4) == 0)
{
close(fd);
exit(0);
}
}
}
//close(fd);
return 0;
}
server.c
int c_fd = 0;
void child_handler(int signo)
{
close(c_fd);
printf("child--exit--\n");
exit(0);
}
void father_handler(int signo)
{
close(c_fd);
printf("father--exit--\n");
exit(0);
}
int main(int argc, const char *argv[])
{
//1.socket 创建通信的一端
int fd = socket(AF_INET,SOCK_DGRAM,0);
if (fd < 0)
{
perror("socket fail");
return -1;
}
struct sockaddr_in seraddr;
seraddr.sin_family = AF_INET;
seraddr.sin_port = htons(50000);
seraddr.sin_addr.s_addr = inet_addr("192.168.1.135");
//2.bind
if (bind(fd,(struct sockaddr *)&seraddr,sizeof(seraddr)) < 0)
{
perror("bind fail");
return -1;
}
struct sockaddr_in srcaddr;
socklen_t addrlen = sizeof(srcaddr);
char buf[1024];
//3.接收数据
recvfrom(fd,buf,sizeof(buf),0,(struct sockaddr*)&srcaddr,&addrlen);
printf("--------------------\n");
printf("IP = %s\n",inet_ntoa(srcaddr.sin_addr));
printf("post = %d\n",ntohs(srcaddr.sin_port));
printf("buf = %s\n",buf);
printf("--------------------\n");
pid_t pid = fork();
if (pid < 0)
{
perror("fork fail");
return -1;
}
if (pid > 0)
{
signal(SIGCHLD,father_handler);
c_fd = fd;
while (1)
{
//3.接收数据
recvfrom(fd,buf,sizeof(buf),0,(struct sockaddr*)&srcaddr,&addrlen);
printf("--------------------\n");
printf("IP = %s\n",inet_ntoa(srcaddr.sin_addr));
printf("post = %d\n",ntohs(srcaddr.sin_port));
printf("buf = %s\n",buf);
printf("--------------------\n");
if (strncmp(buf,"quit",4) == 0)
{
kill(pid,SIGUSR1);
wait(NULL);
close(fd);
exit(0);
}
}
}else if (pid == 0)
{
signal(SIGUSR1,child_handler);
while (1)
{
printf(">");
fgets(buf,sizeof(buf),stdin);
sendto(fd,buf,strlen(buf) + 1, 0, (const struct sockaddr*)&srcaddr,sizeof(srcaddr));
if (strncmp(buf,"quit",4) == 0)
{
close(fd);
exit(0);
}
}
}
return 0;
}
TCP编程流程
客户端流程 :
- 创建套接字(socket):与服务器端相同,使用
socket()
函数创建一个套接字。 - 连接服务器(connect):使用
connect()
函数向服务器发起连接请求,指定服务器的IP地址和端口号。 - 进行通信(send/recv):连接建立后,使用
send()
和recv()
函数与服务器进行数据的发送和接收。 - 关闭套接字(close):通信完成后,使用
close()
函数关闭套接字,释放资源。
connect:
对于客户端的 connect() 函数,该函数的功能为客户端主动连接服务器,建立连接是通过三次握手,而这个连接的过程是由内核完成,不是这个函数完成的,这个函数的作用仅仅是通知 Linux 内核,让 Linux 内核自动完成 TCP 三次握手连接
函数原型:
参数:sockfd,目的主机地址,缓冲区大小
返回值:成功返回0;失败返回-1;
服务器端流程:
- 创建套接字(socket):使用
socket()
函数创建一个套接字,指定使用的协议族(如IPv4或IPv6)和socket类型(如流式socket)。 - 绑定套接字(bind):使用
bind()
函数将套接字与服务器的网络信息(如IP地址和端口号)进行绑定。 - 监听套接字(listen):使用
listen()
函数将套接字设置为监听状态,准备接收客户端的连接请求。 - 接受连接(accept):使用
accept()
函数阻塞等待客户端的连接请求,并返回一个新的套接字用于与该客户端进行通信。 - 进行通信(recv/send):使用
recv()
和send()
函数与客户端进行数据的接收和发送。 - 关闭套接字(close):通信完成后,使用
close()
函数关闭套接字,释放资源。
listen
将套接字( sockfd )变成被动的连接监听套接字(被动等待客户端的连接),至于参数 backlog 的作用是设置内核中连接队列的长度(这个长度有什么用,后面做详细的解释),TCP 三次握手也不是由这个函数完成,listen()的作用仅仅告诉内核一些信息。
所以,只要 TCP 服务器调用了 listen(),客户端就可以通过 connect() 和服务器建立连接,而这个连接的过程是由内核完成。
accept
accept()函数功能是,从监听套接字 sockfd
的挂起连接队列中提取第一个连接请求,创建一个新的已连接套接字,并返回一个新的文件描述符,该文件描述符引用这个新套接字。新创建的套接字不处于监听状态。原始套接字 sockfd
不受此调用的影响。