TCP/IP编程之SO_REUSEADDR和SO_REUSEPORT套接字选项

2024-02-29 15:48

本文主要是介绍TCP/IP编程之SO_REUSEADDR和SO_REUSEPORT套接字选项,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

基本概念:

SO_REUSEADDR套接字选项能起到以下4个不同的功用:

(1)SO_REUSEADDR允许启动一个监听服务器并捆绑众所周知端口,即使以前建立的该端口用作它们的本地端口的连接仍存在。

这个条件通常是这样碰到的:

a)启动一个监听服务器;

b)连接请求到的,派生一个子进程来处理这个客户;

c)监听服务器终止,但子进程继续为现有的连接上的客户提供服务;

d)重启监听服务器。

默认情况下,当监听服务器在步骤d调用socket、bind和listen重新启动时,由于它试图捆绑一个现有连接上的端口,从而bind调用会失败。但是如果该服务器在socket和bind两个调用之间设置了SO_REUSEADDR套接字选项,那么bind将成功。所有TCP服务器都应该指定本套接字选项,以允许服务器在这种情形下被重新启动。

(2)SO_REUSEADDR允许在同一端口上启动同一服务器的多个实例,只要每个实例捆绑一个不同的本地IP地址即可。

(3)SO_REUSEADDR允许单个进程捆绑同一个端口到多个套接字上,只要每次捆绑指定不同的本地IP地址即可。

(4)SO_REUSEADDR允许完全重复的捆绑:当一个IP地址和端口已绑定到某个套接字上时。如果传输协议支持,同样的IP地址和端口还可以捆绑到另一个套接字上。一般来说,本特性仅支持UDP套接字。


SO_REUSEPORT套接字选项能起到以下2个不同的功用:

(1)本选项允许完全重复的捆绑,不过只有在想要捆绑同一IP地址和端口的每个套接字都指定了本套接字选项才行。

(2)如果被捆绑的IP地址是一个多播地址,那么SO_REUSEADDR和SO_REUSEPORT被认为是等效的。


这里我们的重点讨论内容是:

SO_REUSEADDR的第(1)个功用(蓝色字体)

SO_REUSEPORT的第(1)个功用(蓝色字体)


应用场景:nginx平滑升级就应用到了相关知识。


例子1:

我们需要知道,

a) 如果不对TCP的套接字选项进行任何限制时,如果启动两个进程,第二个进程就会在调用bind函数的时候出错(Address already in use)。

b) 如果在调用bind之前我们设置了SO_REUSEADDR,但是不在第二个进程启动前close这个套接字,那么第二个进程仍然会在调用bind函数的时候出错(Address already in use)。

c)如果在调用bind之前我们设置了SO_REUSEADDR,并接收了一个客户端连接,并且在第二个进程启动前关闭了bind的套接字,这个时候第一个进程只拥有一个套接字(与客户端的连接),那么第二个进程则可以bind成功,符合预期。

代码:

[cpp]  view plain  copy
  1. #include <sys/types.h>  
  2. #include <sys/socket.h>  
  3. #include <unistd.h>  
  4. #include <stdio.h>  
  5. #include <errno.h>  
  6. #include <arpa/inet.h>  
  7. #include <stdlib.h>  
  8.   
  9. void Perror(const char *s)  
  10. {  
  11.     perror(s);  
  12.     exit(EXIT_FAILURE);  
  13. }  
  14.   
  15. int main()  
  16. {  
  17.     int sockfd = socket(AF_INET, SOCK_STREAM, 0); //TCP  
  18.     int backlog = 100;  
  19.     short port = 9527; //端口  
  20.     struct sockaddr_in servaddr;  
  21.     servaddr.sin_family = AF_INET; //IPv4  
  22.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY); //表示由内核去选择IP地址  
  23.     servaddr.sin_port = htons(port);  
  24.   
  25.     int flag = 1;  
  26.     if (-1 == setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag))) {  
  27.         Perror("setsockopt fail");  
  28.     }  
  29.   
  30.     int res = bind(sockfd, (sockaddr *)&servaddr, sizeof(servaddr));  
  31.     if (0 == res)  
  32.         printf("server bind success, 0.0.0.0:%d\n", port);  
  33.     else {  
  34.         Perror("bind fail");  
  35.     }  
  36.   
  37.     if (-1 == listen(sockfd, backlog)) {  
  38.         Perror("listen fail");  
  39.     }  
  40.   
  41.     //等待连接  
  42.     struct sockaddr_in cliaddr;  
  43.     socklen_t len = sizeof(cliaddr);  
  44.     int connfd = accept(sockfd, (sockaddr *)&cliaddr, &len);  
  45.     if (-1 == connfd) {  
  46.         Perror("accept fail");  
  47.     }  
  48.   
  49.     //解析客户端地址  
  50.     char buff[INET_ADDRSTRLEN + 1] = {0};  
  51.     inet_ntop(AF_INET, &cliaddr.sin_addr, buff, INET_ADDRSTRLEN);  
  52.     uint16_t cli_port = ntohs(cliaddr.sin_port);  
  53.     printf("connection from %s, port %d\n", buff, cli_port);  
  54.   
  55.     //关闭bind的sockfd  
  56.     close(sockfd);  
  57.   
  58.     //  
  59.     sleep(1200);  
  60.   
  61.     return 0;  
  62. }  

编译:

g++ server.cpp -o s1

g++ server.cpp -o s2

运行结果:



例子2,

SO_REUSEPORT可能在比较旧的内核版本上不支持,我的测试环境的内核版本是3.10,相对SO_REUSEADDR来说,SO_REUSEPORT没有那么多的限制条件,允许两个毫无血缘关系的进程使用相同的IP地址同时监听同一个端口,并且不会出现惊群效应。

代码:

[cpp]  view plain  copy
  1. #include <sys/types.h>  
  2. #include <sys/socket.h>  
  3. #include <unistd.h>  
  4. #include <stdio.h>  
  5. #include <errno.h>  
  6. #include <arpa/inet.h>  
  7. #include <stdlib.h>  
  8.   
  9. void Perror(const char *s)  
  10. {  
  11.     perror(s);  
  12.     exit(EXIT_FAILURE);  
  13. }  
  14.   
  15. int main()  
  16. {  
  17.     int sockfd = socket(AF_INET, SOCK_STREAM, 0); //TCP  
  18.     int backlog = 100;  
  19.     short port = 9527; //端口  
  20.     struct sockaddr_in servaddr;  
  21.     servaddr.sin_family = AF_INET; //IPv4  
  22.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY); //表示由内核去选择IP地址  
  23.     servaddr.sin_port = htons(port);  
  24.   
  25.     int flag = 1;  
  26.     if (-1 == setsockopt(sockfd, SOL_SOCKET, SO_REUSEPORT, &flag, sizeof(flag))) {  
  27.         Perror("setsockopt fail");  
  28.     }  
  29.   
  30.     int res = bind(sockfd, (sockaddr *)&servaddr, sizeof(servaddr));  
  31.     if (0 == res)  
  32.         printf("server bind success, 0.0.0.0:%d\n", port);  
  33.     else {  
  34.         Perror("bind fail");  
  35.     }  
  36.   
  37.     if (-1 == listen(sockfd, backlog)) {  
  38.         Perror("listen fail");  
  39.     }  
  40.   
  41.     //等待连接  
  42.     while (1) {  
  43.         struct sockaddr_in cliaddr;  
  44.         socklen_t len = sizeof(cliaddr);  
  45.         int connfd = accept(sockfd, (sockaddr *)&cliaddr, &len);  
  46.         if (-1 == connfd) {  
  47.             Perror("accept fail");  
  48.         }  
  49.   
  50.         //解析客户端地址  
  51.         char buff[INET_ADDRSTRLEN + 1] = {0};  
  52.         inet_ntop(AF_INET, &cliaddr.sin_addr, buff, INET_ADDRSTRLEN);  
  53.         uint16_t cli_port = ntohs(cliaddr.sin_port);  
  54.         printf("connection from %s, port %d\n", buff, cli_port);  
  55.     }  
  56.   
  57.     return 0;  
  58. }  

编译:

g++ server.cpp -o s1

g++ server.cpp -o s2

运行结果:

这篇关于TCP/IP编程之SO_REUSEADDR和SO_REUSEPORT套接字选项的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/759301

相关文章

Nginx实现动态封禁IP的步骤指南

《Nginx实现动态封禁IP的步骤指南》在日常的生产环境中,网站可能会遭遇恶意请求、DDoS攻击或其他有害的访问行为,为了应对这些情况,动态封禁IP是一项十分重要的安全策略,本篇博客将介绍如何通过NG... 目录1、简述2、实现方式3、使用 fail2ban 动态封禁3.1 安装 fail2ban3.2 配

Ubuntu固定虚拟机ip地址的方法教程

《Ubuntu固定虚拟机ip地址的方法教程》本文详细介绍了如何在Ubuntu虚拟机中固定IP地址,包括检查和编辑`/etc/apt/sources.list`文件、更新网络配置文件以及使用Networ... 1、由于虚拟机网络是桥接,所以ip地址会不停地变化,接下来我们就讲述ip如何固定 2、如果apt安

查询SQL Server数据库服务器IP地址的多种有效方法

《查询SQLServer数据库服务器IP地址的多种有效方法》作为数据库管理员或开发人员,了解如何查询SQLServer数据库服务器的IP地址是一项重要技能,本文将介绍几种简单而有效的方法,帮助你轻松... 目录使用T-SQL查询方法1:使用系统函数方法2:使用系统视图使用SQL Server Configu

使用Java实现获取客户端IP地址

《使用Java实现获取客户端IP地址》这篇文章主要为大家详细介绍了如何使用Java实现获取客户端IP地址,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 首先是获取 IP,直接上代码import org.springframework.web.context.request.Requ

C#多线程编程中导致死锁的常见陷阱和避免方法

《C#多线程编程中导致死锁的常见陷阱和避免方法》在C#多线程编程中,死锁(Deadlock)是一种常见的、令人头疼的错误,死锁通常发生在多个线程试图获取多个资源的锁时,导致相互等待对方释放资源,最终形... 目录引言1. 什么是死锁?死锁的典型条件:2. 导致死锁的常见原因2.1 锁的顺序问题错误示例:不同

C++实现获取本机MAC地址与IP地址

《C++实现获取本机MAC地址与IP地址》这篇文章主要为大家详细介绍了C++实现获取本机MAC地址与IP地址的两种方式,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 实际工作中,项目上常常需要获取本机的IP地址和MAC地址,在此使用两种方案获取1.MFC中获取IP和MAC地址获取

C/C++通过IP获取局域网网卡MAC地址

《C/C++通过IP获取局域网网卡MAC地址》这篇文章主要为大家详细介绍了C++如何通过Win32API函数SendARP从IP地址获取局域网内网卡的MAC地址,感兴趣的小伙伴可以跟随小编一起学习一下... C/C++通过IP获取局域网网卡MAC地址通过win32 SendARP获取MAC地址代码#i

PyCharm接入DeepSeek实现AI编程的操作流程

《PyCharm接入DeepSeek实现AI编程的操作流程》DeepSeek是一家专注于人工智能技术研发的公司,致力于开发高性能、低成本的AI模型,接下来,我们把DeepSeek接入到PyCharm中... 目录引言效果演示创建API key在PyCharm中下载Continue插件配置Continue引言

shell脚本快速检查192.168.1网段ip是否在用的方法

《shell脚本快速检查192.168.1网段ip是否在用的方法》该Shell脚本通过并发ping命令检查192.168.1网段中哪些IP地址正在使用,脚本定义了网络段、超时时间和并行扫描数量,并使用... 目录脚本:检查 192.168.1 网段 IP 是否在用脚本说明使用方法示例输出优化建议总结检查 1

Redis连接失败:客户端IP不在白名单中的问题分析与解决方案

《Redis连接失败:客户端IP不在白名单中的问题分析与解决方案》在现代分布式系统中,Redis作为一种高性能的内存数据库,被广泛应用于缓存、消息队列、会话存储等场景,然而,在实际使用过程中,我们可能... 目录一、问题背景二、错误分析1. 错误信息解读2. 根本原因三、解决方案1. 将客户端IP添加到Re