Fabric1.2研究笔记-了解Chain Code(一)

fabric SDK提供了很多对channel、peer等的操作接口,这些接口实际上是调用fabric源码中预置的系统chain code,即scc,源码所在目录为 core/scc/。从之前版本代码中可看出,共有五个,但目前1.2版本源码目录中仅有三个,分别是cscc、lscc和qscc。

attachments-2018-03-9MDlTgOS5aa74ab46b850.png

作者:小清新的博客 

来源:CSDN 

原文:https://blog.csdn.net/baidu_37379451/article/details/81099928?utm_source=copy 

版权声明:本文为博主原创文章,转载请附上博文链接!


1、序

       fabric SDK提供了很多对channel、peer等的操作接口,这些接口实际上是调用fabric源码中预置的系统chain code,即scc,源码所在目录为 core/scc/。从之前版本代码中可看出,共有五个,但目前1.2版本源码目录中仅有三个,分别是cscc、lscc和qscc。

    //see systemchaincode_test.go for an example using "sample_syscc"
    var systemChaincodes = []*SystemChaincode{
        {
            Enabled:           true,
            Name:              "cscc",
            Path:              "github.com/hyperledger/fabric/core/scc/cscc",
            InitArgs:          [][]byte{[]byte("")},
            Chaincode:         &cscc.PeerConfiger{},
            InvokableExternal: true, // cscc is invoked to join a channel
        },
        {
            Enabled:           true,
            Name:              "lscc",
            Path:              "github.com/hyperledger/fabric/core/scc/lscc",
            InitArgs:          [][]byte{[]byte("")},
            Chaincode:         lscc.NewLifeCycleSysCC(),
            InvokableExternal: true, // lscc is invoked to deploy new chaincodes
            InvokableCC2CC:    true, // lscc can be invoked by other chaincodes
        },
        {
            Enabled:   true,
            Name:      "escc",
            Path:      "github.com/hyperledger/fabric/core/scc/escc",
            InitArgs:  [][]byte{[]byte("")},
            Chaincode: &escc.EndorserOneValidSignature{},
        },
        {
            Enabled:   true,
            Name:      "vscc",
            Path:      "github.com/hyperledger/fabric/core/scc/vscc",
            InitArgs:  [][]byte{[]byte("")},
            Chaincode: &vscc.ValidatorOneValidSignature{},
        },
        {
            Enabled:           true,
            Name:              "qscc",
            Path:              "github.com/hyperledger/fabric/core/chaincode/qscc",
            InitArgs:          [][]byte{[]byte("")},
            Chaincode:         &qscc.LedgerQuerier{},
            InvokableExternal: true, // qscc can be invoked to retrieve blocks
            InvokableCC2CC:    true, // qscc can be invoked to retrieve blocks also by a cc
        },
    }

SDK提供了动态安装和更新chain code功能,但是源码中设定scc不允许动态安装与修改,其代码如下:

        if lscc.sccprovider.IsSysCC(cds.ChaincodeSpec.ChaincodeId.Name) {
            return errors.Errorf("cannot install: %s is the name of a system chaincode", cds.ChaincodeSpec.ChaincodeId.Name)
        }

下面分别对已有scc进行简单的介绍。
2、qscc

       Query System Chain Code,预置的一些区块查询cc。有对当前区块高度的查询以及一些通过不同参数查询Block详情的方法。block包含签名、transaction输入输出等等信息,它比在couchdb(之前开发fabric项目选用的是couchdb)所展现的数据更全面,下面通过block的查询源码来看block的存储位置以及获取方式。

    // constants for indexable attributes
    const (
        IndexableAttrBlockNum         = IndexableAttr("BlockNum")
        IndexableAttrBlockHash        = IndexableAttr("BlockHash")
        IndexableAttrTxID             = IndexableAttr("TxID")
        IndexableAttrBlockNumTranNum  = IndexableAttr("BlockNumTranNum")
        IndexableAttrBlockTxID        = IndexableAttr("BlockTxID")
        IndexableAttrTxValidationCode = IndexableAttr("TxValidationCode")
    )
    // BlockStoreProvider provides an handle to a BlockStore
    type BlockStoreProvider interface {
        CreateBlockStore(ledgerid string) (BlockStore, error)
        OpenBlockStore(ledgerid string) (BlockStore, error)
        Exists(ledgerid string) (bool, error)
        List() ([]string, error)
        Close()
    }
    // BlockStore - an interface for persisting and retrieving blocks
    // An implementation of this interface is expected to take an argument
    // of type `IndexConfig` which configures the block store on what items should be indexed
    type BlockStore interface {
        AddBlock(block *common.Block) error
        GetBlockchainInfo() (*common.BlockchainInfo, error)
        RetrieveBlocks(startNum uint64) (ledger.ResultsIterator, error)
        RetrieveBlockByHash(blockHash []byte) (*common.Block, error)
        RetrieveBlockByNumber(blockNum uint64) (*common.Block, error) // blockNum of  math.MaxUint64 will return last block
        RetrieveTxByID(txID string) (*common.Envelope, error)
        RetrieveTxByBlockNumTranNum(blockNum uint64, tranNum uint64) (*common.Envelope, error)
        RetrieveBlockByTxID(txID string) (*common.Block, error)
        RetrieveTxValidationCodeByTxID(txID string) (peer.TxValidationCode, error)
        Shutdown()
    }

     上述代码便是查询对应的接口,主要是通过建立索引查询,由此猜测是存储于某个数据库中,但在之前项目开发时并无发现couchdb中存在类似数据,下面选取其中一个接口继续向下研究。

    func (index *blockIndex) getBlockLocByHash(blockHash []byte) (*fileLocPointer, error) {
        if _, ok := index.indexItemsMap[blkstorage.IndexableAttrBlockHash]; !ok {
            return nil, blkstorage.ErrAttrNotIndexed
        }
        b, err := index.db.Get(constructBlockHashKey(blockHash))
        if err != nil {
            return nil, err
        }
        if b == nil {
            return nil, blkstorage.ErrNotFoundInIndex
        }
        blkLoc := &fileLocPointer{}
        blkLoc.unmarshal(b)
        return blkLoc, nil
    }
     
    type blockIndex struct {
        indexItemsMap map[blkstorage.IndexableAttr]bool
        db            *leveldbhelper.DBHandle
    }

       显然,是对某个数据库进行基于索引的查询,但是blockIndex内的db是写死的leveldb,难道说无论配置中选择哪个数据库,它都会自启一个内置的leveldb进行block的存储?从我目前所了解的信息无法得出确切的结论,下一个专题这个问题进行探讨。
---------------------


章发布只为分享区块链技术内容,版权归原作者所有,观点仅代表作者本人,绝不代表区块链兄弟赞同其观点或证实其描述。

attachments-2018-02-kL1zBfXx5a7ffd0b78798.jpg

  • 发表于 2018-10-16 14:06
  • 阅读 ( 2902 )
  • 分类:hyperledger

你可能感兴趣的文章

相关问题

0 条评论

请先 登录 后评论
不写代码的码农
李晓琼

区块链技术开发爱好者

44 篇文章

作家榜 »

  1. 社区运营-小以 621 文章
  2. 社区运营-小链 238 文章
  3. 于中阳Mercina-zy 79 文章
  4. 涂晶 74 文章
  5. 李晓琼 44 文章
  6. 兄弟连区块链培训 42 文章
  7. 吴寿鹤 36 文章
  8. 刘旷 28 文章