이 기사에서는 플레이어가 획득한 NFT를 즉시 전송하기 위해 Metacube에서 사용되는 트랜잭션 배처를 소개합니다. Batcher의 확장 가능한 행위자 기반 아키텍처를 설명하고 Go에서 자세한 구현을 제공합니다.
모든 코드 조각은 관련 GitHub 저장소에서 사용할 수 있습니다.
배쳐는 두 명의 주연 배우로 구성됩니다.
이 액터 분리를 통해 확장 가능하고 효율적인 배처가 가능합니다. 발신자가 거래를 보내는 동안 빌더는 거래를 준비하므로 지속적이고 효율적인 거래 흐름이 가능합니다.
다음 구현은 Go에만 적용되지만 기능은 동일하게 유지되므로 개념을 다른 언어에도 쉽게 적용할 수 있습니다.
게다가 이 구현은 동일한 계약에서 NFT를 보내는 데만 적용된다는 점에 유의하세요. 그러나 보다 일반적인 접근 방식은 기사 뒷부분에서 언급됩니다.
마지막으로 코드는 Nethermind에서 개발한 starknet.go 라이브러리를 기반으로 합니다.
Batcher 자체부터 시작해 보겠습니다.
type Batcher struct {
accnt *account.Account
contractAddress *felt.Felt
maxSize int
inChan <-chan []string
failChan chan<- []string
}
계정(acccnt)은 NFT를 보유하는 계정이며, NFT를 전송하는 거래에 서명하는 데 사용됩니다. 이러한 NFT는 동일한 계약의 일부이므로 contractAddress 필드가 있습니다. maxSize 필드는 배치의 최대 크기이고 inChan은 트랜잭션이 Batcher로 전송되는 채널입니다. fallChan은 전송에 실패한 트랜잭션을 다시 보내는 데 사용됩니다.
이 구현에서 나중에 호출되는 거래 데이터([]string)는 수신자 주소와 NFT ID라는 두 요소의 배열입니다.
Batcher는 Builder와 Sender 액터를 동시에 실행합니다.
type TxnDataPair struct {
Txn rpc.BroadcastInvokev1Txn
Data [][]string
}
func (b *Batcher) Run() {
txnDataPairChan := make(chan TxnDataPair)
go b.runBuildActor(txnDataPairChan)
go b.runSendActor(txnDataPairChan)
}
정의된 채널 txnDataPairChan은 거래 데이터 쌍을 Builder에서 Sender로 보냅니다. 각 거래 데이터 쌍은 일괄 거래로 구성되며, 각 거래에 대한 데이터가 여기에 포함됩니다. 각 트랜잭션의 데이터는 배치 트랜잭션과 함께 전송되므로 실패한 트랜잭션은 Batcher를 인스턴스화하는 엔터티로 다시 전송될 수 있습니다.
Build 액터를 분석해 보겠습니다. 가독성을 높이기 위해 코드가 단순화되었습니다(전체 코드).
type Batcher struct {
accnt *account.Account
contractAddress *felt.Felt
maxSize int
inChan <-chan []string
failChan chan<- []string
}
runBuildActor 함수는 Builder 행위자의 이벤트 루프입니다. 트랜잭션이 Batcher로 전송될 때까지 기다리고 배치가 가득 차거나 시간 초과에 도달하면 배치 트랜잭션을 작성합니다. 그런 다음 일괄 트랜잭션이 Sender 액터에게 전송됩니다.
이제 Sender 액터를 분석해 보겠습니다. 가독성을 높이기 위해 코드가 단순화되었습니다(전체 코드).
type TxnDataPair struct {
Txn rpc.BroadcastInvokev1Txn
Data [][]string
}
func (b *Batcher) Run() {
txnDataPairChan := make(chan TxnDataPair)
go b.runBuildActor(txnDataPairChan)
go b.runSendActor(txnDataPairChan)
}
runSendActor 함수는 송신자 행위자의 이벤트 루프입니다. Builder가 일괄 트랜잭션을 보낼 때까지 기다렸다가 서명하고 Starknet 네트워크로 보내고 상태를 모니터링합니다.
수수료 추정에 대한 참고 사항: 일괄 거래를 보내기 전에 일괄 거래의 수수료 비용을 추정할 수 있습니다. 거래 서명 후 다음 코드를 추가할 수 있습니다:
// This function builds a function call from the transaction data.
func (b *Batcher) buildFunctionCall(data []string) (*rpc.FunctionCall, error) {
// Parse the recipient address
toAddressInFelt, err := utils.HexToFelt(data[0])
if err != nil {
...
}
// Parse the NFT ID
nftID, err := strconv.Atoi(data[1])
if err != nil {
...
}
// The entry point is a standard ERC721 function
// https://docs.openzeppelin.com/contracts-cairo/0.20.0/erc721
return &rpc.FunctionCall{
ContractAddress: b.contractAddress,
EntryPointSelector: utils.GetSelectorFromNameFelt(
"safe_transfer_from",
),
Calldata: []*felt.Felt{
b.accnt.AccountAddress, // from
toAddressInFelt, // to
new(felt.Felt).SetUint64(uint64(nftID)), // NFT ID
new(felt.Felt).SetUint64(0), // data -> None
new(felt.Felt).SetUint64(0), // extra data -> None
},
}, nil
}
// This function builds the batch transaction from the function calls.
func (b *Batcher) buildBatchTransaction(functionCalls []rpc.FunctionCall) (rpc.BroadcastInvokev1Txn, error) {
// Format the calldata (i.e., the function calls)
calldata, err := b.accnt.FmtCalldata(functionCalls)
if err != nil {
...
}
return rpc.BroadcastInvokev1Txn{
InvokeTxnV1: rpc.InvokeTxnV1{
MaxFee: new(felt.Felt).SetUint64(MAX_FEE),
Version: rpc.TransactionV1,
Nonce: new(felt.Felt).SetUint64(0), // Will be set by the send actor
Type: rpc.TransactionType_Invoke,
SenderAddress: b.accnt.AccountAddress,
Calldata: calldata,
},
}, nil
}
// Actual Build actor event loop
func (b *Batcher) runBuildActor(txnDataPairChan chan<- TxnDataPair) {
size := 0
functionCalls := make([]rpc.FunctionCall, 0, b.maxSize)
currentData := make([][]string, 0, b.maxSize)
for {
// Boolean to trigger the batch building
trigger := false
select {
// Receive new transaction data
case data, ok := <-b.inChan:
if !ok {
...
}
functionCall, err := b.buildFunctionCall(data)
if err != nil {
...
}
functionCalls = append(functionCalls, *functionCall)
size++
currentData = append(currentData, data)
if size >= b.maxSize {
// The batch is full, trigger the building
trigger = true
}
// We don't want a smaller batch to wait indefinitely to be full, so we set a timeout to trigger the building even if the batch is not full
case <-time.After(WAITING_TIME):
if size > 0 {
trigger = true
}
}
if trigger {
builtTxn, err := b.buildBatchTransaction(functionCalls)
if err != nil {
...
} else {
// Send the batch transaction to the Sender
txnDataPairChan <- TxnDataPair{
Txn: builtTxn,
Data: currentData,
}
}
// Reset variables
size = 0
functionCalls = make([]rpc.FunctionCall, 0, b.maxSize)
currentData = make([][]string, 0, b.maxSize)
}
}
}
이는 거래를 보내기 전에 수수료가 너무 높지 않은지 확인하는 데 유용할 수 있습니다. 예상 수수료가 예상보다 높은 경우 예상 수수료가 예상보다 높으면 거래의 최대 수수료 필드를 다시 조정해야 할 수도 있습니다. 하지만 거래 내용이 변경되면 다시 서명해야 합니다!
그러나 거래 처리량이 상당히 높을 경우 수수료를 추정할 때 몇 가지 문제가 발생할 수 있습니다. 이는 해당 거래가 방금 승인되었을 때 계정의 nonce를 업데이트하는 데 약간의 지연이 있기 때문입니다. 따라서 다음 트랜잭션의 수수료를 추정할 때 Nonce가 여전히 이전 트랜잭션인 것으로 생각하여 실패할 수 있습니다. 따라서 여전히 수수료를 추정하고 싶다면 이러한 문제를 피하기 위해 각 거래 사이에 약간의 시간을 투자해야 할 수도 있습니다.
제시된 배처는 동일한 계약에서 NFT를 보내는 데만 사용됩니다. 그러나 아키텍처는 모든 유형의 거래를 전송하도록 쉽게 조정할 수 있습니다.
먼저 Batcher로 전송되는 거래 데이터는 보다 일반적이어야 하며 따라서 더 많은 정보를 포함해야 합니다. 여기에는 계약 주소, 진입점 선택기 및 통화 데이터가 포함되어야 합니다. 그런 다음 buildFunctionCall 함수를 조정하여 이 정보를 구문 분석해야 합니다.
발신자 계정을 일반화하여 한 단계 더 나아갈 수도 있습니다. 트랜잭션은 발신자 계정별로 일괄 처리되어야 하므로 더 많은 리팩토링이 필요합니다. 그러나 이는 가능하며 보다 다양한 배처를 허용합니다.
그러나 성급한 최적화는 모든 악의 근원이라는 점을 기억하세요. 따라서 NFT나 ETH 또는 STRK와 같은 특정 토큰을 보내야 하는 경우 제시된 Batcher만으로 충분합니다.
저장소 코드를 CLI 도구로 사용하여 여러 NFT를 일괄 전송할 수 있습니다. 이 도구는 사용하기 쉬우므로 이 문서를 읽은 후 필요에 맞게 조정할 수 있습니다. 자세한 내용은 README를 참고해주세요.
이 기사가 Metacube가 플레이어에게 NFT를 보내는 방법을 더 잘 이해하는 데 도움이 되었기를 바랍니다. Batcher는 핵심 인프라 구성 요소이며 이를 커뮤니티와 공유하게 되어 기쁘게 생각합니다. 질문이나 의견이 있으면 언제든지 댓글을 달거나 저에게 연락해 주세요. 읽어주셔서 감사합니다!
위 내용은 Starknet 트랜잭션 배처의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
