如何使用web3.py向Ganache区块链批量发送交易？

以下是几种实用的批量交易发送方案，适配web3.py和Ganache环境：

• 批量构造签名后逐个发送
  先为每笔交易生成签名后的原始数据，再依次调用发送接口。核心要点是手动维护递增的nonce，避免交易冲突。

  from web3 import Web3
  import time
  
  w3 = Web3(Web3.HTTPProvider('http://127.0.0.1:7545'))
  sender_addr = '0x你的发送者地址'
  private_key = '0x你的私钥'
  recipients = ['0x接收地址1', '0x接收地址2', '0x接收地址3']
  amount = w3.to_wei(0.1, 'ether')
  
  signed_txs = []
  # 预先生成所有已签名交易
  for idx, recipient in enumerate(recipients):
      nonce = w3.eth.get_transaction_count(sender_addr) + idx
      tx_params = {
          'to': recipient,
          'value': amount,
          'gas': 21000,
          'gasPrice': w3.eth.gas_price,
          'nonce': nonce,
          'chainId': w3.eth.chain_id
      }
      signed_tx = w3.eth.account.sign_transaction(tx_params, private_key)
      signed_txs.append(signed_tx.rawTransaction)
  
  # 逐个发送交易
  tx_hashes = []
  for raw_tx in signed_txs:
      tx_hash = w3.eth.send_raw_transaction(raw_tx)
      tx_hashes.append(tx_hash.hex())
      time.sleep(0.1)  # 给Ganache留处理时间，避免拥堵
  

• 并发发送已签名交易
  利用线程池并发发送，提升批量处理速度。注意控制并发数，避免超出Ganache的处理能力。

  from concurrent.futures import ThreadPoolExecutor
  
  def send_single_tx(raw_tx):
      return w3.eth.send_raw_transaction(raw_tx).hex()
  
  # 用线程池并发发送
  with ThreadPoolExecutor(max_workers=5) as executor:
      tx_hashes = list(executor.map(send_single_tx, signed_txs))
  

• 通过合约批量函数实现（适合约操作）
  如果是同类型的合约交互（比如批量转账），可以部署一个支持批量操作的合约，通过单笔交易完成多笔业务操作，节省gas和链上资源。
  示例Solidity合约：

  contract BatchTransfer {
      function batchTransfer(address[] calldata recipients, uint256 singleAmount) external payable {
          require(recipients.length * singleAmount <= msg.value, "资金不足");
          for(uint i = 0; i < recipients.length; i++){
              payable(recipients[i]).transfer(singleAmount);
          }
      }
  }
  

  web3.py调用代码：

  # 初始化合约实例（需提前部署合约并获取ABI和地址）
  contract_addr = '0x你的合约地址'
  contract_abi = [...]  # 合约ABI
  batch_contract = w3.eth.contract(address=contract_addr, abi=contract_abi)
  
  nonce = w3.eth.get_transaction_count(sender_addr)
  total_amount = len(recipients) * amount
  tx_params = batch_contract.functions.batchTransfer(recipients, amount).build_transaction({
      'from': sender_addr,
      'value': total_amount,
      'gas': 1000000,
      'gasPrice': w3.eth.gas_price,
      'nonce': nonce,
      'chainId': w3.eth.chain_id
  })
  signed_tx = w3.eth.account.sign_transaction(tx_params, private_key)
  tx_hash = w3.eth.send_raw_transaction(signed_tx.rawTransaction)
  

内容的提问来源于stack exchange，提问作者Hugo Hazard