区块链就是何交易打交道，我们今天就介绍下，交易处理过程中的一个重要组成部分：txpool。这篇文章主要从功能角度介绍，通过这篇文章会了解：; q0 H+ o- f4 p, v: D2 F$ w
txpool的在交易中的位置和作用。0 V, ^0 j2 F7 j; }  H
txpool的功能，核心组成部分queued和pending。
; R8 F4 I& M( u7 f; d, c8 j/ M  v, btxpool如何实现它的功能。
  U3 K$ D  W: S& A9 ~% s7 Jtxpool源码的重要关注点。
: u5 Y( d( S; X; c, n9 H& p
$ f  X* y/ m; g( v2 M以太坊内部有个重要的内部功能是txpool，从字面意思就能看出来，交易池就是存放交易的池子。它在以太坊中的位置如下图，只要有新交易，无论是本节点创建的，还是其他peer节点广播来的，都会先加入到交易池里，在打包区块的时候，就从这个池子里提取，区块产生之后，共识区块，交易上链。
" Y/ z4 ~: o' itxpool有4个功能：, }" ?5 _. b5 R+ r) w
作为存放交易的缓冲区，大量交易到来时，先存起来
2 m% ^% \& ^; _$ Y! L* z为打包区块服务，合适交易会被打包到区块
" F) y! [5 H' D* b* [0 g清理交易
% A- ]2 f& ]  a, A' B当交易的数量多于缓冲区大小时，过滤/惩罚发送大量交易的账户（攻击者）: T" _* `  {$ D) T- P1 c, k( _
我们来一张稍微详细点的模块交互图，看txpool怎么实现上面4个功能的。
% K: ~) B' p8 S- M# s5 {& j3 d/ z! }; e1 Y1 @/ n
缓存功能的设计
% ~/ A1 s9 U/ }& _- }5 W/ B) Ntxpool中的交易分为queued和pending 2种，其中queued存放未来的、当前无法执行的交易。以太坊使用nonce值决定某个账户的交易顺序，多条交易值nonce值必须连续，如果和过去的交易不连续，则无法执行，我们不妨使用nonce值，标记交易的号码，nonce为10的交易，称为第10号交易。举个例子，当前账户的nonce是10，txpool中有该账户的第100号交易，但txpool中没有第11~99号交易，这些交易的缺失，造成第100号交易无法执行，所以第100号交易就是未来的交易、不可执行的交易，存放在queue中。3 l  C% D8 [" ^: R3 E
pending存放可执行的交易。比如我们把上面的1199号交易补全了，那么11100号交易都可以进入到pending，因为这些交易都是连续的，都可以打包进区块。
- b$ v2 ?7 H1 H& n当节点收到交易（本地节点发起的或peer广播来的）时，会先存放到queued，txpool在某些情况下，把queued中可执行的交易，转移到pending中。7 }% V& w: I0 @% \4 q; N2 U) E1 o
为区块打包服务+ U* ]7 i- ^3 H% R% u) u% @5 |1 L. K
这是txpool最核心的功能，worker在打包区块的时候，会获取所有的pending交易，但这些交易还存在txpool中，worker只是读取出来，至于txpool何时删除交易，稍后从txpool清理交易的角度单独在看。- y" H3 t3 K$ z
清理交易
  {$ i( O) I6 Ptxpool清理交易有以下几种条件，符合任意以下1条的，都是无效交易，会被从pending或者queued中移除：
9 \4 l, C3 \0 u# e  r6 p8 ^. ~交易的nonce值已经低于账户在当前高度上的nonce值，代表交易已过期，交易已经上链就属于这种情况
8 v1 B% D9 k  S! }交易的GasLimit大于区块的GasLimit，区块容不下交易) m# T, q- s( m; I" Y
账户的余额已不足以支持该交易要消耗的费用! j* I2 T5 f: `/ M9 a; m
交易的数量超过了queued和pending的缓冲区大小，需要进行清理
3 ]% E5 A! K; g" C! p, d7 h( i; J- n5 S
交易清理主要有3个场景：, V  g" |! h; y! d
! a' U# d& @! X
txpool订阅了ChainHeadEvent事件，该事件代表主链上有新区块产生，txpool会根据最新的区块，检查每个账号的交易，有些无效的会被删除，有些由于区块回滚会从pending移动到queued，然后把queued中可执行的交易移动到pending，为下一轮区块打包组号准备。. x  `2 f" l$ N8 }, S9 x4 m$ m

* C3 t8 }- N* t6 B- [0 @: dqueued交易移动到pending被称为“提升”（promote），这个过程中，同样会检查交易，当交易不符合以上条件时，就会被直接从queued中删除。
/ B3 @0 j  v  m. K
! B2 o0 d9 u4 {7 y删除停留在queued中超过3小时的交易，3小时这个超时时间是可以通过geth的启动参数调整的。txpool记录了某个账户交易进入pending的时间，如果这个时间超过了3小时，代表该账号的交易迟迟不能被主链打包，既然无法被主链接受，就删除掉在queued中本来就无法执行的交易。
7 F+ x5 ?. g- ?# F( h* Y* T, v( M4 {* j- U4 `: G" ?  [+ j
6 Q% e. E/ N, R1 C# @" m8 u5 c
惩罚恶意账号7 t! a/ j, z" l+ ]4 D2 O* i
这也是txpool很重要的一个属性，可以防止恶意账户以发起大量垃圾交易。防止恶意用户造成：
7 [, H+ q: a4 X! r占用txpool空间
4 @9 S, L6 b$ T浪费节点大量内存和CPU5 f3 U- ]0 @% a$ e1 |& J
降低打包性能/ c' s; ?" [) n* ~
% `- l9 {, U6 J, E6 y) p
**只有当交易的总数量超过缓冲区大小时，txpool才会认为有恶意账户发起大量交易。**pending和queued缓冲区大小不同，但处理策略类似：
% h" B# W2 @( z# [pending的缓冲区容量是4096，当pending的交易数量多于此时，就会运行检查，每个账号的交易数量是否多于16，把这些账号搜集出来，进行循环依次清理，什么意思呢？就是每轮只删除（移动到queued）这些账号的每个账号1条交易，然后看数量是否降下来了，不满足再进行下一轮，直到满足。( ]. r& @2 _3 C6 F" M# H. h/ `
queued的缓冲区容量是1024，超过之后清理策略和pending差不多，但这里可是真删除了。
5 Q+ ]2 q8 i- F" M; S& X: P) F
3 Z9 k) p! S( U. y: z该部分功能未抽象成单独的函数，而是在promoteExecutables()中，就是在每次把queued交易转移到pending后执行的。3 Y, ]% O7 e8 i2 ~# P  R1 [% @: V
本地交易的特权，txpool虽然对交易有诸多限制，但如果交易是本节点的账号发起的，以上数量限制等都对他无效。所以，如果你用本节点账号不停的发送交易，并不会被认为是攻击者，你用txpool.status命令，可以查看到交易的数量，肯定可以大于4096，我曾达到过60000+。
! _/ C; i7 b0 a( S重点关注的源码
) C3 S/ p9 X9 Z6 Ntxpool的主要设计上面就讲完了，如果你想把txpool的代码阅读一番，我建议你重点关注一下这些函数和变量，按图索骥能就完全掌握txpool的实现。
- `' S8 E- M, W  ]. g" r4 ]) R% O! @$ jTxPoolConfig：txpool的配置参数
# j; _) [% j/ o0 s" V9 O% `& _chainHeadCh：txpool订阅了新区块事件+ f& {4 K# ^4 N+ s1 k" L: b
pending：pending的交易，每个账号都有一个交易列表/ b' B# y8 V6 {% o% K* p: _# m% T
queue：queued的交易，每个账号都有一个交易列表0 C+ T9 y. e7 B9 D& ~
loop：txpool的事件处理函数
+ w- X. O* p' A1 U9 iaddTx：添加1条交易的源头，你能找到类似的函数
/ b+ v# N6 [/ H1 S# {8 |0 npromoteExecutables：queued交易移动到pending4 A4 d: P) }+ l3 R
reset：根据当前区块的最新高度，重置txpool中的交易