Fabric 1.0源代码分析(20) Ledger #idStore（ledgerID数据库）

2024-04-15 07:57:19

# Fabric 1.0源代码笔记之 Ledger #idStore（ledgerID数据库）

## 1、idStore概述

* Fabric支持创建多个Ledger，不同Ledger以ledgerID区分。

* 多个ledgerID及其创世区块存储在idStore数据库中，idStore数据库基于leveldb实现。

* idStore默认使用路径：/var/hyperledger/production/ledgersData/ledgerProvider/。

* idStore库中特殊key "underConstructionLedgerKey"，用于标志最新在建的ledgerID，ledgerID创建成功后或失败时该标志将清除，另外此标志也用于异常时按ledgerID恢复数据。

* idStore相关代码集中在core/ledger/kvledger/kv_ledger_provider.go。

## 2、idStore结构体定义

leveldbhelper更详细内容，参考：[Fabric 1.0源代码笔记之 LevelDB（KV数据库）](../leveldb/README.md)

```go

type idStore struct {

db *leveldbhelper.DB

}

//代码在core/ledger/kvledger/kv_ledger_provider.go

```

## 3、idStore方法定义

```go

func openIDStore(path string) *idStore //按path创建并打开leveldb数据库

func (s *idStore) setUnderConstructionFlag(ledgerID string) error //设置ledgerID在建标志，将key为"underConstructionLedgerKey"，value为ledgerID写入库

func (s *idStore) unsetUnderConstructionFlag() error //取消ledgerID在建标志（确认构建失败时），删除key"underConstructionLedgerKey"

func (s *idStore) getUnderConstructionFlag() (string, error) //获取ledgerID在建标志（按ledgerID恢复时），按key"underConstructionLedgerKey"，取ledgerID

func (s *idStore) createLedgerID(ledgerID string, gb *common.Block) error //创建LedgerID，即以ledgerID为key，将创世区块写入库

func (s *idStore) ledgerIDExists(ledgerID string) (bool, error) //查找ledgerID是否存在，即查库中key为ledgerID是否存在

func (s *idStore) getAllLedgerIds() ([]string, error) //获取ledgerID列表

func (s *idStore) close() //关闭idStore leveldb数据库

func (s *idStore) encodeLedgerKey(ledgerID string) []byte //为ledgerID添加前缀即"l"

func (s *idStore) decodeLedgerID(key []byte) string //解除ledgerID前缀

//代码在core/ledger/kvledger/kv_ledger_provider.go

```

func (s *idStore) createLedgerID(ledgerID string, gb *common.Block) error代码如下：

将ledgerID和Block入库，并清除ledgerID在建标志。

```go

func (s *idStore) createLedgerID(ledgerID string, gb *common.Block) error {

key := s.encodeLedgerKey(ledgerID) //为ledgerID添加前缀即"l"

var val []byte

var err error

if val, err = proto.Marshal(gb); err != nil { //Block序列化

return err

}

if val, err = s.db.Get(key); err != nil {

return err

}

if val != nil {

return ErrLedgerIDExists //ledgerID已存在

}

batch := &leveldb.Batch{}

batch.Put(key, val) //ledgerID和Block入库

batch.Delete(underConstructionLedgerKey) //清除ledgerID在建标志

return s.db.WriteBatch(batch, true) //提交执行

}

//代码在core/ledger/kvledger/kv_ledger_provider.go

```

网址：http://www.qukuailianxueyuan.io/

欲领取造币技术与全套虚拟机资料

区块链技术交流QQ群：756146052 备注：CSDN

尹成学院微信：备注：CSDN

网址：http://www.qukuailianxueyuan.io/

欲领取造币技术与全套虚拟机资料

区块链技术交流QQ群：756146052 备注：CSDN

尹成学院微信：备注：CSDN

Fabric 1.0源代码分析(20) Ledger #idStore（ledgerID数据库）相关推荐

Fabric 1.0源代码分析(22)Ledger #blkstorage（block文件存储）
# Fabric 1.0源代码笔记之 Ledger #blkstorage(block文件存储) ## blkstorage概述 blkstorage,默认目录/var/hyperledger/pr ...
Fabric 1.0源代码分析(23)LevelDB（KV数据库）
# Fabric 1.0源代码笔记之 LevelDB(KV数据库) ## 1.LevelDB概述 LevelDB是Google开源的持久化KV单机数据库,具有很高的随机写,顺序读/写性能,但是随机读 ...
Fabric 1.0源代码分析(26)Orderer #ledger（Orderer Ledger）
# Fabric 1.0源代码笔记之 Orderer #ledger(Orderer Ledger) ## 1.Orderer Ledger概述 Orderer Ledger代码分布在orderer ...
Fabric 1.0源代码分析(32) Peer #peer node start命令实现
# Fabric 1.0源代码笔记之 Peer #peer node start命令实现 ## 1.peer node加载子命令start和status peer node加载子命令start和st ...
Fabric 1.0源代码分析(15)gossip（流言算法）
# Fabric 1.0源代码笔记之 gossip(流言算法) ## 1.gossip概述 gossip,翻译为流言蜚语,即为一种可最终达到一致的算法.最终一致的另外的含义就是,不保证同时达到一致. ...
Fabric 1.0源代码分析(25) Orderer
# Fabric 1.0源代码笔记之 Orderer ## 1.Orderer概述 Orderer,为排序节点,对所有发往网络中的交易进行排序,将排序后的交易安排配置中的约定整理为块,之后提交给Co ...
Fabric 1.0源代码分析(43) Tx（Transaction 交易）
# Fabric 1.0源代码笔记之 Tx(Transaction 交易) ## 1.Tx概述 Tx,即Transaction,交易或事务. Tx代码分布目录结构如下: * protos/commo ...
Fabric 1.0源代码分析(31) Peer
# Fabric 1.0源代码笔记之 Peer ## 1.Peer概述在Fabric中,Peer(节点)是指在网络中负责接收交易请求.维护一致账本的各个fabric-peer实例.节点之间彼此通过 ...
Fabric 1.0源代码分析(2) blockfile（区块文件存储）
# Fabric 1.0源代码笔记之 blockfile(区块文件存储) ## 1.blockfile概述 blockfile,即Fabric区块链区块文件存储,默认目录/var/hyperledg ...

最新文章

热门文章