你的浏览器版本过低,可能导致网站不能正常访问!
为了你能正常使用网站功能,请使用这些浏览器。

单台 Linux 能承载多少连接和TCP

[复制链接]
gaosmile 发布时间:2021-1-11 15:18
本文给大家实操一下,看看我们在实际操作中,怎么去修改配置,又怎么让客户端和服务器一起把连接数提上去。

. A: ~+ Q% M" V7 c3 }+ e
相信看了本文之后,大家对单台 Linux 能承载多少连接和TCP会有更深的了解。

1 x4 s" m; k: l- x# k* h1 m. @
, ?2 G% K% y' j8 T6 Q' g% [; {
微信图片_20210111150814.png
echo "5000 65000" > /proc/sys/net/ipv4/ip_local_port_range
5 l5 d2 v" d1 G. \7 o3 ?
微信图片_20210111150818.png
  • 连接1:192.168.1.101 5000 192.168.1.100 8090
  • 连接2:192.168.1.101 5001 192.168.1.100 8090
  • 连接N:192.168.1.101 ...  192.168.1.100 8090
  • 连接6W:192.168.1.101 65000 192.168.1.100 8090
    * a$ g" D! S: w. h  B6 N! P6 g

    9 N! I0 G* h( j9 N6 E# c. B
微信图片_20210111150821.png
微信图片_20210111150824.png
//修改整个系统能打开的文件描述符为20W
0 f1 N" w. ?" c# z& d8 J: eecho 200000 > /proc/sys/fs/file-max8 \& g- _- E" Y0 H

  Q+ h# E1 C: a  z! H) R% W. Q# K: J+ u6 _
//修改所有用户每个进程可打开文件描述符为20W) A* z* R3 \! {/ p6 }) c5 B( C+ r
#vi /etc/sysctl.conf
/ Y9 ?: q- U" w1 [& r0 ~fs.nr_open=210000$ Q6 i# N) }; ]+ R' M* X! @4 E
#sysctl -p
' T* t1 k, }# F& P& O% |+ I3 u#vi /etc/security/limits.conf
! M/ X+ i) X+ Z- r% I3 X*  soft  nofile  200000
  {& v9 L# e# M$ _4 m# h* t*  hard  nofile  200000
( \$ g# D7 q. G3 a

注意: limits中的hard limit不能超过nr_open, 所以要先改nr_open。而且最好是在sysctl.conf中改。避免重启的时候 hard limit生效了,nr_open不生效导致启动问题。

微信图片_20210111150827.png
  f. [! _* P% j/ M/ ?
* C' h2 E$ Y6 V, @2 O" \6 Z
微信图片_20210111150831.png
“socket中有一个主要的数据结构sock_common,在它里面有两个联合体。”
$ x. f8 v) s, A  Z+ ?
// file: include/net/sock.h
& C0 [4 z& S) p8 A' c6 X1 M6 N3 Mstruct sock_common {1 x1 b" s6 |( z) ^7 R/ ~8 ]; B. u) z
union {; m. ]' U* {; K4 V
  __addrpair skc_addrpair; //TCP连接IP对儿
; c0 G. O9 ]; m" K/ {9 x2 Y  struct {4 ?1 p- @9 E, J9 d$ n
   __be32 skc_daddr;
: {. c4 U5 h( d/ S: v$ o   __be32 skc_rcv_saddr;
  `2 m* O6 S* d  \: m  };
" H& ]& {9 A/ B$ O8 O, {! m }; * r& E/ q6 Q- d$ a
union {
, U6 g' |2 |/ @, i7 o  __portpair skc_portpair; //TCP连接端口对儿# Q- [0 u3 n8 c5 ^# {
  struct {8 `8 e. A: d$ r) }/ T; ~6 y
   __be16 skc_dport;8 F5 B, l4 S2 |; _  w
   __u16 skc_num;
6 w; o( j2 L' W1 ]3 m* `  };+ t0 L- O& r+ q/ H/ V8 N3 k
};0 e+ p4 `$ X! `: O3 p* j3 F
......
6 b! L! z2 c" L}  }  t" C$ N) D$ }
“其中skc_addrpair记录的是TCP连接里的IP对儿,skc_portpair记录的是端口对儿。”
微信图片_20210111150834.png

6 N% M7 C# E, X& Q; @+ ?
微信图片_20210111150837.png
“在网络包到达网卡之后,依次经历DMA、硬中断、软中断等处理,最后被送到socket的接收队列中了。”  F1 J: b; [/ a( U" B; \5 G
微信图片_20210111150840.png
“对于TCP协议来说,协议处理的入口函数是tcp_v4_rcv。我们看一下它的代码”% o+ X# `0 F# P2 s7 N0 }
// file: net/ipv4/tcp_ipv4.c0 i, J( x6 }0 y" S. l1 g0 F, W
int tcp_v4_rcv(struct sk_buff *skb). p: D* r. [5 Q$ T# J4 ]9 ~9 E
{
5 t4 g3 `4 R' q+ }2 B; R/ _ ......' Q& \2 F+ `3 a% `
th = tcp_hdr(skb); //获取tcp header
+ a5 `% ^& P4 ~2 g$ G- T0 J. o9 ~ iph = ip_hdr(skb); //获取ip header7 s  |5 _- {. ?. K

6 I2 k$ o" J8 F7 f( e+ f4 `1 {+ Y) ~ sk = __inet_lookup_skb(&tcp_hashinfo, skb, th->source, th->dest);
1 V5 R. M9 Q/ Z ......* L/ v7 ]2 c% \8 _2 U6 k
}
- ]  X) U: Y1 U6 Q" x
微信图片_20210111150844.png
// file: include/net/inet_hashtables.h4 y& X: t4 i) }2 p" V
static inline struct sock *__inet_lookup(struct net *net,
9 J! K( Z' Y, w6 D" B      struct inet_hashinfo *hashinfo,# U  T% S+ T% D* k' E) {
      const __be32 saddr, const __be16 sport,5 f' z) J( }* m8 s
      const __be32 daddr, const __be16 dport,
$ m% I# G+ }( H8 o9 Z/ I7 E# W" M      const int dif)
9 c. w8 s( G* W7 \5 x, J" d% g{
0 v+ x# z, M# C  O8 T7 k u16 hnum = ntohs(dport);1 X/ `: [# i" g+ v; `2 b7 ?" H
struct sock *sk = __inet_lookup_established(net, hashinfo,
- j1 ^, y6 i- ~+ f/ T: j0 b    saddr, sport, daddr, hnum, dif);
& w; }7 @+ U. `7 A! c
" e2 d% H3 {4 O2 A) { return sk ? : __inet_lookup_listener(net, hashinfo, saddr, sport,
; S/ m8 S+ Y* Z; i) O0 H  e          daddr, hnum, dif);
5 i& \+ A' J  V! [( M  j6 N2 K}5 G) q0 {8 M4 ]
“先判断有没有连接状态的socket,这会走到__inet_lookup_established函数中”
struct sock *__inet_lookup_established(struct net *net,# W" |) T- G9 t2 k9 T
      struct inet_hashinfo *hashinfo,& b9 O( I& j$ o- H$ a
      const __be32 saddr, const __be16 sport,7 N: t: P6 B+ x
      const __be32 daddr, const u16 hnum,
: B; r( o$ s! V" d( L      const int dif)
$ a1 J: e/ U6 j' t; @{
9 X: N/ {& V) R/ z1 o+ {9 _: T9 F //将源端口、目的端口拼成一个32位int整数
/ c* Z: d7 s' j; b& f const __portpair ports = INET_COMBINED_PORTS(sport, hnum); ) Z. L1 E* m1 d) s
......6 e) u* O' j1 D" ~0 A
9 T7 o' T; r) E& z8 q
//内核用hash的方法加速socket的查找7 I6 I& ^6 M# p% a0 \
unsigned int hash = inet_ehashfn(net, daddr, hnum, saddr, sport); ! q; ~7 r: Q: X  \" Q3 n$ r, ]
unsigned int slot = hash & hashinfo->ehash_mask;
) }2 K$ ]) U6 U5 d! o struct inet_ehash_bucket *head = &hashinfo->ehash[slot];' {2 @/ I7 x: U" |
/ _. x0 \+ c/ r: @
begin:4 [- K4 u; Z2 n7 i% A$ F
//遍历链表,逐个对比直到找到. Y* V, Q. Y6 Z4 m6 m4 \+ z
sk_nulls_for_each_rcu(sk, node, &head->chain) {2 G1 O- D( O3 k) ?: n) O
  if (sk->sk_hash != hash)+ u1 r, n2 N: u, B: k
   continue;
2 `, }! W' i6 W. l, ^# V. X  if (likely(INET_MATCH(sk, net, acookie,
0 b3 [/ ]. O3 s9 O2 v% ?9 J& |          saddr, daddr, ports, dif))) {3 o9 x" \3 j" V3 X9 }
   if (unlikely(!atomic_inc_not_zero(&sk->sk_refcnt)))
) J3 f/ O$ X+ T4 V    goto begintw;
8 {$ B  o+ P  R' V6 r& B   if (unlikely(!INET_MATCH(sk, net, acookie,
2 c1 e. a5 j1 M. T       saddr, daddr, ports, dif))) {
( x! g7 D2 y# W0 l    sock_put(sk);* {3 `' T* p- j0 }$ o4 F" E% E
    goto begin;
# J" X5 D6 }, A% O7 z, P! S   }  x- m+ M  i( L; J$ p4 e
   goto out;
' {2 w8 N8 S+ f: `  }
$ d  M9 _% a  b& ` }% |' M! k$ j, ]2 o5 V
}
$ R4 W% A- O" M8 g
微信图片_20210111150847.png
// include/net/inet_hashtables.h/ S4 ^% d3 a# Z0 y: L( Y# m0 q
#define INET_MATCH(__sk, __net, __cookie, __saddr, __daddr, __ports, __dif) \, f0 R: Y% n6 ]- A
((inet_sk(__sk)->inet_portpair == (__ports)) &&  \: S0 o: H1 w& _- E2 ?. ~; D& F
  (inet_sk(__sk)->inet_daddr == (__saddr)) &&  \9 S1 V4 A* U+ l' r! V# Y" I; ^
  (inet_sk(__sk)->inet_rcv_saddr == (__daddr)) &&  \8 e9 P- \  m! {: Y# j
  (!(__sk)->sk_bound_dev_if ||    \
) k" v8 y! n) `    ((__sk)->sk_bound_dev_if == (__dif)))  &&  \! l5 o8 |* j1 D7 k
  net_eq(sock_net(__sk), (__net)))  a- F6 M. b* Q/ H! |; d( t3 h
“在INET_MATCH中将网络包tcp header中的__saddr、__daddr、__ports和Linux中的socket中inet_portpair、inet_daddr、inet_rcv_saddr进行对比。如果匹配socket就找到了。当然除了ip和端口,INET_MATCH还比较了其它一些东东,所以TCP还有五元组、七元组之类的说法。”
! A0 e9 Y5 }' w# A6 ~8 o
微信图片_20210111150851.png
# cat /etc/redhat-release
' J) F; w6 r+ ZRed Hat Enterprise Linux Server release 6.2 (Santiago)
! ?4 |6 i' w- c7 W9 n2 v) u7 p
+ |9 k, q4 j; d1 W$ d, w# ss -ant | grep ESTAB |wc -l# q  t( y( O% }6 k9 ]
1000013: {* [; ?- J5 m
; H  L0 g+ |5 p
# cat /proc/meminfo
( q' L' Q/ R4 R! NMemTotal:        3925408 kB
7 y/ O9 C! `: w+ R/ {MemFree:           97748 kB
1 |1 B" x6 k9 cBuffers:           35412 kB
8 a; B6 p2 Y' V9 L5 I' @0 i! xCached:           119600 kB
) K  b1 i8 Y( p, e7 y4 @......
4 H" |9 g& c5 ?7 P+ E+ oSlab:            3241528 kB
: J2 N5 K0 u4 m
微信图片_20210111150855.png

6 M5 a2 u, v! o- _# c& R& G
微信图片_20210111150859.png

" S1 z6 O" h$ Z: ]& c5 K& k
  Q; r, Q; i3 z# y* \  E4 t
总结

( U) f5 D; Y+ n! S/ I
客户端每建立一个连接就要消耗一个端口,所以很多同学当看到客户端机器上连接数一旦超过3W、5W就紧张的不行,总觉得机器要出问题了。
这篇文章的第一版也是很早就写出来了,不过飞哥又打磨了好长时间才算满意。在文中我们展示了一下 TCP socket的部分内核代码。通过源码来看:
TCP连接就是在客户机、服务器上的一对儿的socket。它们都在各自内核对象上记录了双方的ip对儿、端口对儿(也就是我们常说的四元组),通过这个在通信时找到对方。
TCP连接发送方在发送网络包的时候,会把这份信息复制到IP Header上。网络包带着这份信物穿过互联网,到达目的服务器。目的服务器内核会按照 IP 包 header 中携带的信物(四元组)去匹配找到正确的socket(连接)。
在这个过程里我们可以看到,客户端的端口只是这个四元组里的一元而已。哪怕两条连接用的是同一个端口号,只要客户端ip不一样,或者是服务器不一样都不影响内核正确寻找到对应的连接,而不会串线!
所以在客户端增加TCP最大并发能力有两个方法。第一个办法,为客户端配置多个ip。第二个办法,连接多个不同的server。

不过这两个办法最好不要混用。因为使用多 IP 时,客户端需要bind。一旦bind之后,内核建立连接的时候就不会选择用过的端口了。bind函数会改变内核选择端口的策略~~

最后我们亲手实验证明了客户端也可以突破百万的并发量级。相信读过此文的你,以后再也不用再惧怕65535这个数字了。

$ f& f- s3 e% N$ R8 ~
赞 收藏 评论0 发布时间:2021-1-11 15:18

举报

0个回答
关于
我们是谁
投资者关系
意法半导体可持续发展举措
创新与技术
意法半导体官网
联系我们
联系ST分支机构
寻找销售人员和分销渠道
社区
媒体中心
活动与培训
隐私策略
隐私策略
Cookies管理
行使您的权利
官方最新发布
人形机器人运动控制、感知与智能配电
半导体创新技术与应用方向
EE架构与软件定义汽车
12V/48V 汽车智能配电(SPD)
区域控制单元(ZCU)与分区架构
关注我们
st-img 微信公众号
st-img 手机版