change not sign for tran send

startTest.go

@@ -49,7 +49,8 @@ func startTest() {
 		}()
 		for {
 			log.Info("----------------------------------start")
-			arr := transaction.SignedTxArr(syncMap, SendTxAccountArr, cfg)
+			//arr := transaction.SignedTxArr(syncMap, SendTxAccountArr, cfg)
+			arr := transaction.NoSignTxArr(syncMap, SendTxAccountArr, cfg)
 			log.Info("----------------------------------end")
 			tranArrChan <- arr
 			syncMap = updateNonce(syncMap, cfg)

transaction/bathTest.go

@@ -93,14 +93,14 @@ func broadcastTx(cfg *tool.Config, client ring.RingServiceClient) error {
 }
 
 func constructionEthLegacyTx(tran *types.Transaction) v1.EthLegacyTx {
-	v, r, s := tran.RawSignatureValues()
+	//v, r, s := tran.RawSignatureValues()
 	toAddr := metatypes.BytesToAddress(tran.To().Bytes())
-	nv := metatypes.NewBigInt(0)
-	nv.Set(v)
-	nr := metatypes.NewBigInt(0)
-	nr.Set(r)
-	ns := metatypes.NewBigInt(0)
-	ns.Set(s)
+	//nv := metatypes.NewBigInt(0)
+	//nv.Set(v)
+	//nr := metatypes.NewBigInt(0)
+	//nr.Set(r)
+	//ns := metatypes.NewBigInt(0)
+	//ns.Set(s)
 	rawTx := v1.EthLegacyTx{
 		Nonce:    tran.Nonce(),
 		GasPrice: metatypes.NewBigInt(tran.GasPrice().Int64()),
@@ -108,9 +108,9 @@ func constructionEthLegacyTx(tran *types.Transaction) v1.EthLegacyTx {
 		To:       &toAddr,
 		Value:    metatypes.NewBigInt(tran.Value().Int64()),
 		Data:     tran.Data(),
-		V:        nv,
-		R:        nr,
-		S:        ns,
+		V:        metatypes.NewBigInt(236),
+		R:        metatypes.NewBigInt(103540811401203670175009355687785215115755383244051477218884606498783205629384),
+		S:        metatypes.NewBigInt(36344895504144551167108335919542572829921945163306838661809661076218798969327),
 	}
 	return rawTx
 }

transaction/signedTx.go

@@ -74,11 +74,13 @@ func newTransactor(cfg TranConfig) (*Transactor, error) {
 func dialerFunc(ctx context.Context, addr string) (net.Conn, error) {
 	return Connect(addr)
 }
+
 func Connect(protoAddr string) (net.Conn, error) {
 	proto, address := ProtocolAndAddress(protoAddr)
 	conn, err := net.Dial(proto, address)
 	return conn, err
 }
+
 func ProtocolAndAddress(listenAddr string) (string, string) {
 	protocol, address := "tcp", listenAddr
 	parts := strings.SplitN(address, "://", 2)
@@ -211,3 +213,32 @@ func Add(signedTx *types.Transaction) {
 	defer signTranArr.mux.Unlock()
 	signTranArr.TranArr = append(signTranArr.TranArr, signedTx)
 }
+
+func NoSignTxArr(syncMap sync.Map, sendTxAccountArr [][]string, cfg *tool.Config) []*types.Transaction {
+	for _, rows := range sendTxAccountArr {
+		fromAddr := rows[0]
+		privateKey := rows[1]
+		value, ok := syncMap.Load(privateKey)
+		if !ok {
+			log.Error("Load nonce map error...........")
+			continue
+		}
+		nonce := new(big.Int).SetInt64(int64(value.(int)))
+		log.Infof("from addr:%s,nonce:%d", fromAddr, nonce)
+		receiveAddr := common.HexToAddress(cfg.ReceiveAddr)
+		for signCount := 0; signCount < cfg.SignCount; signCount++ {
+			var txData = types.LegacyTx{
+				Nonce:    nonce.Uint64(),
+				To:       &receiveAddr,
+				Value:    big.NewInt(cfg.Amount),
+				Gas:      300000,
+				GasPrice: big.NewInt(1000000001),
+				Data:     nil,
+			}
+			newtx := types.NewTx(&txData)
+			signTranArr.TranArr = append(signTranArr.TranArr, newtx)
+			nonce = big.NewInt(1).Add(nonce, big.NewInt(1))
+		}
+	}
+	return signTranArr.TranArr
+}