兄弟连区块链教程Fabric1.0源代码分析ledgerID数据
2018-11-01 16:40
1041 查看
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数据库)
type idStore struct { db *leveldbhelper.DB } //代码在core/ledger/kvledger/kv_ledger_provider.go
3、idStore方法定义
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在建标志。
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
相关文章推荐
- 兄弟连区块链教程Fabric1.0源代码分析blockfile区块文件存储1
- 区块链教程Fabric1.0源代码分析Ledger blkstorage block文件存储
- 区块链教程Fabric1.0源代码分析Orderer Ledge
- 区块链教程Fabric1.0源代码分析Peer peer chaincode命令及子命令实现
- 区块链教程Fabric1.0源代码分析scc(系统链码)
- 区块链教程Fabric1.0源代码分析Tx RWSet(读写集)
- 区块链教程Fabric1.0源代码分析Ledger historydb历史数据库
- 区块链教程Fabric1.0源代码分析blockfile区块文件存储2
- 区块链教程Fabric1.0源代码分析configtx#genesis
- 区块链教程Fabric1.0源代码分析flogging(Fabric日志系统)
- 区块链教程Fabric1.0源代码分析Orderer multichain多链支持包
- 区块链教程Fabric1.0源代码分析configupdate处理通道配置更新
- 区块链教程Fabric1.0源代码分析consenter#filter
- 区块链教程Fabric1.0源代码分析Ledger(账本)二
- 区块链教程Fabric1.0源代码分析Orderer BroadcastServer
- 区块链教程Fabric1.0源代码分析链码 链码语言平台
- 区块链教程Fabric1.0源代码分析配置交易体系介
- 区块链教程Fabric1.0源代码分析流言算法Gossip服务端二