CometBFT (原Tendermint Core) 使用指南

CometBFT是一个高性能的拜占庭容错(BFT)状态机复制引擎，它是Tendermint Core项目的延续。下面我将介绍如何在Go项目中使用CometBFT进行分布式应用开发。

基本概念

CometBFT包含两个主要组件：

1. 共识引擎 - 负责节点间的共识达成
2. 应用接口(ABCI) - 与应用通信的接口

安装

go get github.com/cometbft/cometbft

基本使用示例

1. 创建简单ABCI应用

package main

import (
	"fmt"
	"log"

	abcitypes "github.com/cometbft/cometbft/abci/types"
	"github.com/cometbft/cometbft/node"
	"github.com/cometbft/cometbft/p2p"
	"github.com/cometbft/cometbft/proxy"
)

type Application struct {
	abcitypes.BaseApplication
	state []byte
}

func (app *Application) DeliverTx(req abcitypes.RequestDeliverTx) abcitypes.ResponseDeliverTx {
	app.state = req.Tx
	return abcitypes.ResponseDeliverTx{Code: 0}
}

func (app *Application) Query(req abcitypes.RequestQuery) abcitypes.ResponseQuery {
	return abcitypes.ResponseQuery{Value: app.state}
}

func main() {
	// 创建应用实例
	app := &Application{}

	// 创建节点配置
	config := node.DefaultConfig()
	config.P2P.ListenAddress = "tcp://0.0.0.0:26656"
	config.RPC.ListenAddress = "tcp://0.0.0.0:26657"

	// 创建节点
	nodeKey, err := p2p.LoadOrGenNodeKey("config/node_key.json")
	if err != nil {
		log.Fatal(err)
	}

	n, err := node.NewNode(
		config,
		nodeKey,
		proxy.NewLocalClientCreator(app),
		node.DefaultGenesisDocProviderFunc(config),
		node.DefaultDBProvider,
		node.DefaultMetricsProvider(config.Instrumentation),
		logger,
	)
	if err != nil {
		log.Fatal(err)
	}

	// 启动节点
	if err := n.Start(); err != nil {
		log.Fatal(err)
	}

	fmt.Println("CometBFT node started")
	
	// 等待中断信号
	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt, syscall.SIGTERM)
	<-c
	
	// 停止节点
	if err := n.Stop(); err != nil {
		log.Fatal(err)
	}
}

2. 与运行中的CometBFT节点交互

package main

import (
	"context"
	"fmt"
	"log"

	"github.com/cometbft/cometbft/rpc/client/http"
)

func main() {
	// 创建RPC客户端
	client, err := http.New("tcp://localhost:26657", "/websocket")
	if err != nil {
		log.Fatal(err)
	}

	// 获取节点状态
	status, err := client.Status(context.Background())
	if err != nil {
		log.Fatal(err)
	}

	fmt.Printf("Node ID: %s\n", status.NodeInfo.ID)
	fmt.Printf("Latest block height: %d\n", status.SyncInfo.LatestBlockHeight)

	// 广播交易
	tx := []byte("test transaction")
	res, err := client.BroadcastTxSync(context.Background(), tx)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Printf("Transaction hash: %X\n", res.Hash)
}

高级功能

1. 自定义验证逻辑

func (app *Application) CheckTx(req abcitypes.RequestCheckTx) abcitypes.ResponseCheckTx {
	// 实现交易验证逻辑
	if len(req.Tx) > 100 {
		return abcitypes.ResponseCheckTx{
			Code: 1,
			Log:  "Transaction too large",
		}
	}
	return abcitypes.ResponseCheckTx{Code: 0}
}

2. 处理区块事件

func (app *Application) BeginBlock(req abcitypes.RequestBeginBlock) abcitypes.ResponseBeginBlock {
	// 在区块开始时的处理逻辑
	return abcitypes.ResponseBeginBlock{}
}

func (app *Application) EndBlock(req abcitypes.RequestEndBlock) abcitypes.ResponseEndBlock {
	// 在区块结束时的处理逻辑
	return abcitypes.ResponseEndBlock{}
}

func (app *Application) Commit() abcitypes.ResponseCommit {
	// 提交状态到持久化存储
	return abcitypes.ResponseCommit{Data: app.state}
}

部署建议

1. 配置：根据网络需求调整config.toml中的参数，特别是：

   • timeout_*系列参数
   • mempool配置
   • p2p网络配置

2. 持久化：确保定期备份data目录

3. 监控：利用Prometheus监控指标（默认在26660端口）

4. 安全：

   • 保护节点密钥
   • 配置防火墙规则
   • 考虑使用TLS加密RPC通信

常见问题解决

1. 节点无法连接：

   • 检查config.toml中的seeds和persistent_peers
   • 确保防火墙允许P2P端口(默认26656)通信

2. 同步问题：

   • 检查节点日志中的错误信息
   • 尝试从可信节点重置状态

3. 性能问题：

   • 调整mempool.size
   • 优化ABCI应用处理逻辑

CometBFT提供了强大的分布式共识能力，通过ABCI接口可以与任何状态机集成。以上示例展示了基本用法，实际项目中还需要考虑更多细节如状态持久化、快照、升级等。