golang版本比特币节点及比特币钱包使用

sfiveaa · · 3846 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

install btcd

go get -u github.com/Masterminds/glide
git clone https://github.com/btcsuite/btcd $GOPATH/src/github.com/btcsuite/btcd
cd $GOPATH/src/github.com/bitsuit/btcd
glide install
go install . ./cmd/...

btcd的项目都是通过glide进行管理的,因此在安装btcd的时候还需要安装glide

run btcd(simnet)

btcd -u shenxin -P shenxin --simnet --miningaddr=SUsbWJE1VMREXFUv8KcBmke7cPsSXaFvnE

如果需要自动挖矿要加上 --generate 参数,--miningaddr= 设置挖矿时接收比特币的地址。如果没有设置自动挖矿,可以在后面的客户端中使用 generate() 方法来手动挖矿(由于 simnet 上挖矿速度太快,不方便测试,因此此处使用手动挖矿)。

需要注意的是,当运行simnet时需要运行至少两个节点才能挖矿,不然不能进行挖矿(或者说挖不到矿)。

install btcwallet

git clone https://github.com/btcsuite/btcwallet $GOPATH/src/github.com/btcsuite/btcwallet
cd $GOPATH/src/github.com/btcsuite/btcwallet
glide install
go install . ./cmd/...

如果直接使用的 btcwallet 写客户端需要进行下面的操作:将 $GOPATH/src/github.com/btcsuite/btcwallet/vendor 文件夹下的所有文件复制到 $GOPATH/src/下面($GOPATH/src/文件夹下已有的文件可以不用复制)。复制之后删除vendor文件夹,以保证在后面使用btcwallet客户端的时候不会出现引用包路径不同导致的错误。

create btcwallet(testnet)

btcwallet -u shenxin -p shenxin --simnet --create

根据终端里面的提示输入对应的操作符,并设置钱包密码为:"shenxin"。命令中的 -u 和 -p 是钱包连接btcd grpc服务需要的账号密码,或者使用 "--btcdusername="、"--btcdpassword=" 来设置连接btcd需要的账号及密码,但是这样将不会开启btcwallet的rpc服务。

run btcwallet(testnet) server

btcwallet -u shenxin -p shenxin --walletpass=shenxin --simnet

btcd和btcwallet都是运行的simnet,因此btcwallet启动之后会自动连接到btcd。

create btcwallet clien

package main

import (
    "fmt"
    "io/ioutil"
    "log"
    "path/filepath"

    "github.com/btcsuite/btcd/chaincfg"
    "github.com/btcsuite/btcd/rpcclient"
    "github.com/btcsuite/btcutil"
)

// default account address: SUsbWJE1VMREXFUv8KcBmke7cPsSXaFvnE
// main account address: SiAXFyKMF6afKEhoTYAPSYGWxbCRUddqTh
// ss account address: Sad47SLU1hsgiQb2Ew6jf39PfqhJzEjERZ SjPHLr6MUn7fjjBuZK6a3pj9NFgYGvpu25

func main() {
    client := initClient()
    fmt.Println(client.ListAccounts())
    fmt.Println(transferFrom("main", "SUsbWJE1VMREXFUv8KcBmke7cPsSXaFvnE", 5))
    fmt.Println(transfer("Sad47SLU1hsgiQb2Ew6jf39PfqhJzEjERZ", 0.5))
    generate()
    fmt.Println(getBalanceByAccount("default"))
    fmt.Println(getBalanceByAccount("main"))
    fmt.Println(getBalanceByAccount("ss"))
}

func initClient() *rpcclient.Client {
    ntfnHandlers := rpcclient.NotificationHandlers{
        OnAccountBalance: func(account string, balance btcutil.Amount, confirmed bool) {
            log.Printf("New balance for account %s: %v", account,
                balance)
        },
    }
    certHomeDir := btcutil.AppDataDir("btcwallet", false)
    certs, err := ioutil.ReadFile(filepath.Join(certHomeDir, "rpc.cert"))
    if err != nil {
        log.Fatal(err)
    }
    connCfg := &rpcclient.ConnConfig{
        Host:         "localhost:18554",
        Endpoint:     "ws",
        User:         "shenxin",
        Pass:         "shenxin",
        Certificates: certs,
    }
    client, err := rpcclient.New(connCfg, &ntfnHandlers)
    if err != nil {
        log.Fatal(err)
    }
    return client
}

func transferFrom(account, addr string, amount float64) bool {
    client := initClient()
    err := client.WalletPassphrase("shenxin", 5)
    if err != nil {
        log.Fatal(err)
    }
    address, _ := btcutil.DecodeAddress(addr, &chaincfg.SimNetParams)
    btcAmount, _ := btcutil.NewAmount(amount)
    hash, err := client.SendFrom(account, address, btcAmount)
    if err != nil {
        log.Fatal(err)
        return false
    } else {
        log.Println("txid:", hash)
        return true
    }
}

func transfer(addr string, amount float64) bool {
    client := initClient()
    err := client.WalletPassphrase("shenxin", 5)
    if err != nil {
        log.Fatal(err)
    }
    address, _ := btcutil.DecodeAddress(addr, &chaincfg.SimNetParams)
    btcAmount, _ := btcutil.NewAmount(amount)
    hash, err := client.SendToAddress(address, btcAmount)
    if err != nil {
        log.Fatal(err)
        return false
    } else {
        log.Println("txid:", hash)
        return true
    }
}

func generate() bool {
    client := initClient()
    _, err := client.Generate(12)
    if err != nil {
        return false
    } else {
        return true
    }
}

func getBalanceByAccount(account string) btcutil.Amount {
    client := initClient()
    err := client.WalletPassphrase("shenxin", 5)
    if err != nil {
        log.Fatal(err)
    }
    amount, err := client.GetBalance(account)
    if err != nil {
        return 0
    } else {
        return amount
    }
}

节点中有一个默认账户 "default",另外调用client.CreateNewAccount()创建两个账户 "ss" "main"。使用 client.GetNewAddress("accountname") 分别在各个账户中创建地址。

在初始化 address 的时候需要设置 chaincfg.params 参数,参数要和运行的节点类型相对应,不然就会出现错误(例如btcd运行的是simnet,因此初始化address的时候使用的是&chaincfg.SimNetParams)。

client.SendToAddress(address, amount) 方法默认是从 "default" 账户发送比特币。

待解决:

  • 每次调用钱包方法的时候,钱包软件日志都会提示报错(不影响客户端运行):RPCS: Websocket receive failed from client [::1]:59799: websocket: close 1006 unexpected EOF

有疑问加站长微信联系(非本文作者)

本文来自:简书

感谢作者:sfiveaa

查看原文:golang版本比特币节点及比特币钱包使用

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

3846 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传