change continued send tx

startTest.go

@@ -42,7 +42,6 @@ func startTest() {
 				case arr := <-tranArrChan:
 					if err := transaction.BroadcastTxArr(arr, cfg); err != nil {
 						log.Errorf("Bath Send Tran error: %s", err)
-						return
 					}
 				}
 			}
@@ -61,7 +60,8 @@ func updateNonce(nonceMap sync.Map, cfg *tool.Config) sync.Map {
 		if !ok {
 			return false
 		}
-		newNonceMap.Store(key, load.(int)+cfg.SignCount)
+		nonce := load.(int)
+		newNonceMap.Store(key, nonce+cfg.SignCount)
 		load, ok = newNonceMap.Load(key)
 		if !ok {
 			return false

transaction/signedTx.go

@@ -14,6 +14,7 @@ import (
 	"google.golang.org/grpc"
 	"math/big"
 	"net"
+	"strconv"
 	"strings"
 	"sync"
 	"sync/atomic"
@@ -108,13 +109,14 @@ func InitAccNonce(sendTxAccountArr [][]string, cfg *tool.Config) (error, sync.Ma
 					nonceReq := &ring.NonceRequest{
 						Address: (*metatypes.Address)(fromAddr.Bytes()),
 					}
-					ctx, cancel := context.WithTimeout(context.Background(), time.Second*1)
+					ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
 					defer cancel()
 					response, err := serviceClient.Nonce(ctx, nonceReq)
 					if err != nil {
 						log.Error("get account nonce error:", err)
 					}
-					accountsNonceMap.Store(privateKey, response.Nonce)
+					intNum, _ := strconv.Atoi(strconv.FormatUint(response.Nonce, 10))
+					accountsNonceMap.Store(privateKey, intNum)
 					atomic.AddInt32(&handleNonceCount, 1)
 				}
 			}
@@ -144,7 +146,7 @@ func SignedTxArr(syncMap sync.Map, sendTxAccountArr [][]string, cfg *tool.Config
 			log.Error("Load nonce map error...........")
 			continue
 		}
-		nonce := new(big.Int).SetUint64(value.(uint64))
+		nonce := new(big.Int).SetInt64(int64(value.(int)))
 		log.Infof("from addr:%s,nonce:%d", fromAddr, nonce)
 		for signCount := 0; signCount < cfg.SignCount; signCount++ {
 			tranCfg := TranConfig{