change continued send tx

startTest.go

@@ -4,10 +4,13 @@ import (
 	"ChainGrpcTest/log"
 	"ChainGrpcTest/tool"
 	"ChainGrpcTest/transaction"
+	"github.com/ethereum/go-ethereum/core/types"
+	"sync"
 )
 
 var (
 	SendTxAccountArr [][]string
+	tranArrChan      chan []*types.Transaction
 )
 
 func init() {
@@ -18,9 +21,11 @@ func init() {
 		return
 	}
 	cfg.StorageAccFileName += ".xlsx"
+	tranArrChan = make(chan []*types.Transaction, 1000000000)
 }
 
 func startTest() {
+	if broadcastTxArr {
 		SendTxAccountArr = tool.ReadExcelOfStartEnd(startCount, endCount, cfg.StorageAccFileName)
 		log.Infof("Program start initAccCount：%d tranCount", cfg.Count)
 		cfg.GoRoutineCount = goRoutineCount
@@ -31,12 +36,36 @@ func startTest() {
 			log.Errorf("Bath Send Tran error: %s", err)
 			return
 		}
-	arr := transaction.SignedTxArr(syncMap, SendTxAccountArr, cfg)
-	if broadcastTxArr {
+		go func() {
+			for {
+				select {
+				case arr := <-tranArrChan:
 					if err := transaction.BroadcastTxArr(arr, cfg); err != nil {
 						log.Errorf("Bath Send Tran error: %s", err)
 						return
 					}
 				}
-
+			}
+		}()
+		for {
+			arr := transaction.SignedTxArr(syncMap, SendTxAccountArr, cfg)
+			tranArrChan <- arr
+			updateNonce(syncMap, cfg)
+		}
+	}
+}
+func updateNonce(nonceMap sync.Map, cfg *tool.Config) {
+	nonceMap.Range(func(key, value any) bool {
+		load, ok := nonceMap.Load(key)
+		if !ok {
+			return false
+		}
+		nonceMap.Store(key, load.(int)+cfg.SignCount)
+		load, ok = nonceMap.Load(key)
+		if !ok {
+			return false
+		}
+		log.Info("updated addr nonce:", load)
+		return true
+	})
 }