首页 / 区块链 / 区块链教程Fabric1.0源代码分析Peer peer node start命令实现

区块链教程Fabric1.0源代码分析Peer peer node start命令实现

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了区块链教程Fabric1.0源代码分析Peer peer node start命令实现，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含17292字，纯文字阅读大概需要25分钟。

内容图文

　　区块链教程Fabric1.0源代码分析Peer peer node start命令实现，2018年下半年，区块链行业正逐渐褪去发展之初的浮躁、回归理性，表面上看相关人才需求与身价似乎正在回落。但事实上，正是初期泡沫的渐退，让人们更多的关注点放在了区块链真正的技术之上。

Fabric 1.0源代码笔记之 Peer #peer node start命令实现

区块链教程Fabric1.0源代码分析Peer peer node start命令实现 - 文章图片

1、peer node加载子命令start和status

peer node加载子命令start和status，代码如下：

func Cmd() *cobra.Command {
????nodeCmd.AddCommand(startCmd()) //加载子命令start
????nodeCmd.AddCommand(statusCmd()) //加载子命令status
????return nodeCmd
}

var nodeCmd = &cobra.Command{
????Use:   nodeFuncName,
????Short: fmt.Sprint(shortDes),
????Long:  fmt.Sprint(longDes),
}
//代码在peer/node/node.go

startCmd()代码如下：
其中serve(args)为peer node start的实现代码，比较复杂，本文将重点讲解。
另statusCmd()代码与startCmd()相近，暂略。

func startCmd() *cobra.Command {
????flags := nodeStartCmd.Flags()
????flags.BoolVarP(&chaincodeDevMode, "peer-chaincodedev", "", false, "Whether peer in chaincode development mode")
????flags.BoolVarP(&peerDefaultChain, "peer-defaultchain", "", false, "Whether to start peer with chain testchainid")
????flags.StringVarP(&orderingEndpoint, "orderer", "o", "orderer:7050", "Ordering service endpoint") //orderer
????return nodeStartCmd
}

var nodeStartCmd = &cobra.Command{
????Use:   "start",
????Short: "Starts the node.",
????Long:  `Starts a node that interacts with the network.`,
????RunE: func(cmd *cobra.Command, args []string) error {
????????return serve(args) //serve(args)为peer node start的实现代码
????},
}
//代码在peer/node/start.go

注：如下内容均为serve(args)的代码，即peer node start命令执行流程。

2、初始化Ledger（账本）

初始化账本，即如下一条代码：

ledgermgmt.Initialize()
//代码在peer/node/start.go

ledgermgmt.Initialize()代码展开如下：

func initialize() {
????openedLedgers = make(map[string]ledger.PeerLedger) //openedLedgers为全局变量，存储目前使用的账本列表
????provider, err := kvledger.NewProvider() //创建账本Provider实例
????ledgerProvider = provider
}
//代码在core/ledger/ledgermgmt/ledger_mgmt.go

kvledger.NewProvider()代码如下：

func NewProvider() (ledger.PeerLedgerProvider, error) {
????idStore := openIDStore(ledgerconfig.GetLedgerProviderPath()) //打开idStore

????//创建并初始化blkstorage
????attrsToIndex := []blkstorage.IndexableAttr{
????????blkstorage.IndexableAttrBlockHash,
????????blkstorage.IndexableAttrBlockNum,
????????blkstorage.IndexableAttrTxID,
????????blkstorage.IndexableAttrBlockNumTranNum,
????????blkstorage.IndexableAttrBlockTxID,
????????blkstorage.IndexableAttrTxValidationCode,
????}
????indexConfig := &blkstorage.IndexConfig{AttrsToIndex: attrsToIndex}
????blockStoreProvider := fsblkstorage.NewProvider(
????????fsblkstorage.NewConf(ledgerconfig.GetBlockStorePath(), ledgerconfig.GetMaxBlockfileSize()),
????????indexConfig)

????//创建并初始化statedb
????var vdbProvider statedb.VersionedDBProvider
????if !ledgerconfig.IsCouchDBEnabled() {
????????vdbProvider = stateleveldb.NewVersionedDBProvider()
????} else {
????????vdbProvider, err = statecouchdb.NewVersionedDBProvider()
????}

????//创建并初始化historydb
????var historydbProvider historydb.HistoryDBProvider
????historydbProvider = historyleveldb.NewHistoryDBProvider()
????//构造Provider
????provider := &Provider{idStore, blockStoreProvider, vdbProvider, historydbProvider}
????provider.recoverUnderConstructionLedger()
????return provider, nil
}
//代码在core/ledger/kvledger/kv_ledger_provider.go

Ledger更详细内容，参考：Fabric 1.0源代码笔记之 Ledger（账本）

3、配置及创建PeerServer、创建EventHubServer（事件中心服务器）

//初始化全局变量localAddress和peerEndpoint
err := peer.CacheConfiguration() 
peerEndpoint, err := peer.GetPeerEndpoint() //获取peerEndpoint
listenAddr := viper.GetString("peer.listenAddress") //PeerServer监听地址
secureConfig, err := peer.GetSecureConfig() //获取PeerServer安全配置，是否启用TLS、公钥、私钥、根证书
//以监听地址和安全配置，创建Peer GRPC Server
peerServer, err := peer.CreatePeerServer(listenAddr, secureConfig)
//创建EventHubServer（事件中心服务器）
ehubGrpcServer, err := createEventHubServer(secureConfig)
//代码在peer/node/start.go

func createEventHubServer(secureConfig comm.SecureServerConfig) (comm.GRPCServer, error)代码如下：

var lis net.Listener
var err error
lis, err = net.Listen("tcp", viper.GetString("peer.events.address")) //创建Listen
grpcServer, err := comm.NewGRPCServerFromListener(lis, secureConfig) //从Listen创建GRPCServer
ehServer := producer.NewEventsServer(
????uint(viper.GetInt("peer.events.buffersize")), //最大进行缓冲的消息数
????viper.GetDuration("peer.events.timeout")) //缓冲已满的情况下，往缓冲中发送消息的超时
pb.RegisterEventsServer(grpcServer.Server(), ehServer) //EventHubServer注册至grpcServer
return grpcServer, nil
//代码在peer/node/start.go

pb.RegisterEventsServer(grpcServer.Server(), ehServer)代码如下：

func RegisterEventsServer(s *grpc.Server, srv EventsServer) {
????s.RegisterService(&_Events_serviceDesc, srv) 
}
//代码在protos/peer/events.pb.go

events（事件服务）更详细内容，参考：Fabric 1.0源代码笔记之 events（事件服务）

4、创建并启动Chaincode Server，并注册系统链码

代码如下：

ccprovider.EnableCCInfoCache() //ccInfoCacheEnabled = true
//创建Chaincode Server
//如果peer.chaincodeListenAddress，没有定义或者定义和peerListenAddress相同，均直接使用peerServer
//否则另行创建NewGRPCServer用于Chaincode Server
ccSrv, ccEpFunc := createChaincodeServer(peerServer, listenAddr)
//Chaincode service注册到grpcServer，并注册系统链码
registerChaincodeSupport(ccSrv.Server(), ccEpFunc)
go ccSrv.Start() //启动grpcServer
//代码在peer/node/start.go

ccSrv, ccEpFunc := createChaincodeServer(peerServer, listenAddr)代码如下：创建Chaincode Server。

func createChaincodeServer(peerServer comm.GRPCServer, peerListenAddress string) (comm.GRPCServer, ccEndpointFunc) {
????//peer.chaincodeListenAddress，链码容器连接时的监听地址
????cclistenAddress := viper.GetString("peer.chaincodeListenAddress")

????var srv comm.GRPCServer
????var ccEpFunc ccEndpointFunc
????
????//如果peer.chaincodeListenAddress，没有定义或者定义和peerListenAddress相同，均直接使用peerServer
????//否则另行创建NewGRPCServer用于Chaincode Server
????if cclistenAddress == "" {
????????ccEpFunc = peer.GetPeerEndpoint
????????srv = peerServer
????} else if cclistenAddress == peerListenAddress {
????????ccEpFunc = peer.GetPeerEndpoint
????????srv = peerServer
????} else {
????????config, err := peer.GetSecureConfig()
????????srv, err = comm.NewGRPCServer(cclistenAddress, config)
????????ccEpFunc = getChaincodeAddressEndpoint
????}

????return srv, ccEpFunc
}
//代码在peer/node/start.go

registerChaincodeSupport(ccSrv.Server(), ccEpFunc)代码如下：Chaincode service注册到grpcServer。

func registerChaincodeSupport(grpcServer *grpc.Server, ccEpFunc ccEndpointFunc) {
????userRunsCC := chaincode.IsDevMode() //是否开发模式
????ccStartupTimeout := viper.GetDuration("chaincode.startuptimeout") //启动链码容器的超时
????if ccStartupTimeout < time.Duration(5)*time.Second { //至少5秒
????????ccStartupTimeout = time.Duration(5) * time.Second
????} else {
????}
????//构造ChaincodeSupport
????ccSrv := chaincode.NewChaincodeSupport(ccEpFunc, userRunsCC, ccStartupTimeout)
????scc.RegisterSysCCs() //注册系统链码
????pb.RegisterChaincodeSupportServer(grpcServer, ccSrv) //service注册到grpcServer
}
//代码在peer/node/start.go

ccSrv := chaincode.NewChaincodeSupport(ccEpFunc, userRunsCC, ccStartupTimeout)代码如下：构造ChaincodeSupport。

var theChaincodeSupport *ChaincodeSupport

func NewChaincodeSupport(getCCEndpoint func() (*pb.PeerEndpoint, error), userrunsCC bool, ccstartuptimeout time.Duration) *ChaincodeSupport {
????//即/var/hyperledger/production/chaincodes
????ccprovider.SetChaincodesPath(config.GetPath("peer.fileSystemPath") + string(filepath.Separator) + "chaincodes")

????pnid := viper.GetString("peer.networkId") //网络ID
????pid := viper.GetString("peer.id") //节点ID

????//构造ChaincodeSupport
????theChaincodeSupport = &ChaincodeSupport{runningChaincodes: &runningChaincodes{chaincodeMap: make(map[string]*chaincodeRTEnv), launchStarted: make(map[string]bool)}, peerNetworkID: 
pnid, peerID: pid}

????ccEndpoint, err := getCCEndpoint() //此处传入ccEpFunc
????if err != nil {
????????theChaincodeSupport.peerAddress = viper.GetString("chaincode.peerAddress")
????} else {
????????theChaincodeSupport.peerAddress = ccEndpoint.Address
????}
????if theChaincodeSupport.peerAddress == "" {
????????theChaincodeSupport.peerAddress = peerAddressDefault
????}

????theChaincodeSupport.userRunsCC = userrunsCC //是否开发模式
????theChaincodeSupport.ccStartupTimeout = ccstartuptimeout //启动链码容器的超时

????theChaincodeSupport.peerTLS = viper.GetBool("peer.tls.enabled") //是否启用TLS
????if theChaincodeSupport.peerTLS {
????????theChaincodeSupport.peerTLSCertFile = config.GetPath("peer.tls.cert.file")
????????theChaincodeSupport.peerTLSKeyFile = config.GetPath("peer.tls.key.file")
????????theChaincodeSupport.peerTLSSvrHostOrd = viper.GetString("peer.tls.serverhostoverride")
????}

????kadef := 0
????// Peer和链码之间的心跳超时，小于或等于0意味着关闭
????if ka := viper.GetString("chaincode.keepalive"); ka == "" {
????????theChaincodeSupport.keepalive = time.Duration(kadef) * time.Second //0
????} else {
????????t, terr := strconv.Atoi(ka)
????????if terr != nil {
????????????t = kadef //0
????????} else if t <= 0 {
????????????t = kadef //0
????????}
????????theChaincodeSupport.keepalive = time.Duration(t) * time.Second //非0
????}

????execto := time.Duration(30) * time.Second
????//invoke和initialize命令执行超时
????if eto := viper.GetDuration("chaincode.executetimeout"); eto <= time.Duration(1)*time.Second {
????????//小于1秒时，默认30秒
????} else {
????????execto = eto
????}
????theChaincodeSupport.executetimeout = execto

????viper.SetEnvPrefix("CORE")
????viper.AutomaticEnv()
????replacer := strings.NewReplacer(".", "_")
????viper.SetEnvKeyReplacer(replacer)

????theChaincodeSupport.chaincodeLogLevel = getLogLevelFromViper("level")
????theChaincodeSupport.shimLogLevel = getLogLevelFromViper("shim")
????theChaincodeSupport.logFormat = viper.GetString("chaincode.logging.format")

????return theChaincodeSupport
}

//代码在core/chaincode/chaincode_support.go

scc.RegisterSysCCs()代码如下：注册系统链码。

func RegisterSysCCs() {
????//cscc、lscc、escc、vscc、qscc
????for _, sysCC := range systemChaincodes {
????????RegisterSysCC(sysCC)
????}
}
代码在core/scc/importsysccs.go

5、注册Admin server和Endorser server

代码如下：

//s.RegisterService(&_Admin_serviceDesc, srv)
//var _Admin_serviceDesc = grpc.ServiceDesc{...}
//core.NewAdminServer()构造ServerAdmin结构体，ServerAdmin结构体实现type AdminServer interface接口
pb.RegisterAdminServer(peerServer.Server(), core.NewAdminServer())
//构造结构体Endorser，Endorser结构体实现type EndorserServer interface接口
serverEndorser := endorser.NewEndorserServer()
//s.RegisterService(&_Endorser_serviceDesc, srv)
//var _Endorser_serviceDesc = grpc.ServiceDesc{...}
pb.RegisterEndorserServer(peerServer.Server(), serverEndorser)
//代码在peer/node/start.go

附type AdminServer interface接口定义：

type AdminServer interface {
????GetStatus(context.Context, *google_protobuf.Empty) (*ServerStatus, error)
????StartServer(context.Context, *google_protobuf.Empty) (*ServerStatus, error)
????GetModuleLogLevel(context.Context, *LogLevelRequest) (*LogLevelResponse, error)
????SetModuleLogLevel(context.Context, *LogLevelRequest) (*LogLevelResponse, error)
????RevertLogLevels(context.Context, *google_protobuf.Empty) (*google_protobuf.Empty, error)
}
//代码在protos/peer/admin.pb.go

附type EndorserServer interface接口定义：

type EndorserServer interface {
????ProcessProposal(context.Context, *SignedProposal) (*ProposalResponse, error)
}
//代码在protos/peer/peer.pb.go

6、初始化Gossip服务

bootstrap := viper.GetStringSlice("peer.gossip.bootstrap") //启动节点后gossip连接的初始节点
serializedIdentity, err := mgmt.GetLocalSigningIdentityOrPanic().Serialize() //获取签名身份
messageCryptoService := peergossip.NewMCS( //构造mspMessageCryptoService（消息加密服务）
????peer.NewChannelPolicyManagerGetter(), //构造type channelPolicyManagerGetter struct{}
????localmsp.NewSigner(), //构造type mspSigner struct {}
????mgmt.NewDeserializersManager()) //构造type mspDeserializersManager struct{}
secAdv := peergossip.NewSecurityAdvisor(mgmt.NewDeserializersManager()) //构造mspSecurityAdvisor（安全顾问）

secureDialOpts := func() []grpc.DialOption {
????var dialOpts []grpc.DialOption
????dialOpts = append(dialOpts, grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(comm.MaxRecvMsgSize()), //MaxRecvMsgSize
????????grpc.MaxCallSendMsgSize(comm.MaxSendMsgSize()))) //MaxSendMsgSize
????dialOpts = append(dialOpts, comm.ClientKeepaliveOptions()...) //ClientKeepaliveOptions
????????
????if comm.TLSEnabled() {
????????tlsCert := peerServer.ServerCertificate()
????????dialOpts = append(dialOpts, grpc.WithTransportCredentials(comm.GetCASupport().GetPeerCredentials(tlsCert)))
????} else {
????????dialOpts = append(dialOpts, grpc.WithInsecure())
????}
????return dialOpts
}

err = service.InitGossipService(serializedIdentity, peerEndpoint.Address, peerServer.Server(),
????messageCryptoService, secAdv, secureDialOpts, bootstrap...) //构造gossipServiceImpl
defer service.GetGossipService().Stop()
//代码在peer/node/start.go

Gossip更详细内容参考：Fabric 1.0源代码笔记之 gossip（流言算法）

7、初始化、部署并执行系统链码（scc）

代码如下：

initSysCCs() //初始化系统链码，调用scc.DeploySysCCs("")
peer.Initialize(func(cid string) { //初始化所有链
????scc.DeploySysCCs(cid) //按chain id部署并运行系统链码
})
//代码在peer/node/start.go

func Initialize(init func(string))代码如下：

func Initialize(init func(string)) {
????chainInitializer = init

????var cb *common.Block
????var ledger ledger.PeerLedger
????ledgermgmt.Initialize()
????ledgerIds, err := ledgermgmt.GetLedgerIDs()
????for _, cid := range ledgerIds {
????????ledger, err = ledgermgmt.OpenLedger(cid)
????????cb, err = getCurrConfigBlockFromLedger(ledger) //获取最新的配置块
????????err = createChain(cid, ledger, cb)
????????InitChain(cid) //即调用chainInitializer(cid)，即scc.DeploySysCCs(cid)
????}
}
//代码在core/peer/peer.go

createChain(cid, ledger, cb)代码如下：

func createChain(cid string, ledger ledger.PeerLedger, cb *common.Block) error {
????envelopeConfig, err := utils.ExtractEnvelope(cb, 0) //获取配置交易
????configtxInitializer := configtx.NewInitializer() //构造initializer
????gossipEventer := service.GetGossipService().NewConfigEventer() //获取gossipServiceInstance，并构造configEventer

????gossipCallbackWrapper := func(cm configtxapi.Manager) {
????????ac, ok := configtxInitializer.ApplicationConfig()
????????gossipEventer.ProcessConfigUpdate(&chainSupport{
????????????Manager:     cm,
????????????Application: ac,
????????})
????????//验证可疑节点身份，并关闭无效链接
????????service.GetGossipService().SuspectPeers(func(identity api.PeerIdentityType) bool {
????????????return true
????????})
????}

????trustedRootsCallbackWrapper := func(cm configtxapi.Manager) {
????????updateTrustedRoots(cm)
????}

????configtxManager, err := configtx.NewManagerImpl(
????????envelopeConfig,
????????configtxInitializer,
????????[]func(cm configtxapi.Manager){gossipCallbackWrapper, trustedRootsCallbackWrapper},
????)
????mspmgmt.XXXSetMSPManager(cid, configtxManager.MSPManager())

????ac, ok := configtxInitializer.ApplicationConfig()
????cs := &chainSupport{
????????Manager:     configtxManager,
????????Application: ac, // TODO, refactor as this is accessible through Manager
????????ledger:      ledger,
????}

????c := committer.NewLedgerCommitterReactive(ledger, txvalidator.NewTxValidator(cs), func(block *common.Block) error {
????????chainID, err := utils.GetChainIDFromBlock(block)
????????if err != nil {
????????????return err
????????}
????????return SetCurrConfigBlock(block, chainID)
????})

????ordererAddresses := configtxManager.ChannelConfig().OrdererAddresses()
????service.GetGossipService().InitializeChannel(cs.ChainID(), c, ordererAddresses)

????chains.Lock()
????defer chains.Unlock()
????chains.list[cid] = &chain{
????????cs:        cs,
????????cb:        cb,
????????committer: c,
????}
????return nil
}
//代码在core/peer/peer.go

scc更详细内容参考：Fabric 1.0源代码笔记之 scc（系统链码）

8、启动peerServer和ehubGrpcServer，并监控系统信号，以及启动Go自带的profiling支持进行调试

代码如下：

serve := make(chan error)
sigs := make(chan os.Signal, 1)
signal.Notify(sigs, syscall.SIGINT, syscall.SIGTERM)

go func() {
????sig := <-sigs //接收系统信号
????serve <- nil
}

go func() {
????var grpcErr error
????grpcErr = peerServer.Start() //启动peerServer
????serve <- grpcErr
}

err := writePid(config.GetPath("peer.fileSystemPath")+"/peer.pid", os.Getpid()) //写入pid

go ehubGrpcServer.Start() //启动ehubGrpcServer

if viper.GetBool("peer.profile.enabled") {
????go func() { //启动Go自带的profiling支持进行调试
????????profileListenAddress := viper.GetString("peer.profile.listenAddress")
????????profileErr := http.ListenAndServe(profileListenAddress, nil)
????}
}

return <-serve //等待serve
//代码在peer/node/start.go

9、按配置文件重新更新模块日志级别

overrideLogModules := []string{"msp", "gossip", "ledger", "cauthdsl", "policies", "grpc"}
for _, module := range overrideLogModules {
????err = common.SetLogLevelFromViper(module)
}
flogging.SetPeerStartupModulesMap()
//代码在peer/node/start.go

内容总结

以上是互联网集市为您收集整理的区块链教程Fabric1.0源代码分析Peer peer node start命令实现全部内容，希望文章能够帮你解决区块链教程Fabric1.0源代码分析Peer peer node start命令实现所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/847179.html

来源：【匿名】

【上一篇】通过7个python函数理解区块链【下一篇】利用swoole+redis实现股票和区块链服务

更多 ►

【区块链教程Fabric1.0源代码分析Peer peer node start命令实现】教程文章相关的互联网学习教程文章

区块链教程Fabric1.0源代码分析blockfile区块文件存储一【代码】

Fabric 1.0源代码笔记之 blockfile（区块文件存储） 1、blockfile概述blockfile，即Fabric区块链区块文件存储，默认目录/var/hyperledger/production/ledgersData/chains，含index和chains两个子目录。其中index为索引目录，采用leveldb实现。而chains为各ledger的区块链文件，子目录以ledgerid为名，使用文件系统实现。区块文件以blockfile_为前缀，最大大小默认64M。blockfile，相关代码集中在common/ledger/blkstorage/fsblkst...

区块链教程Fabric1.0源代码分析MSP成员关系服务提供者二【代码】

3、MSP接口实现 MSP接口实现，即bccspmsp结构体及方法，bccspmsp定义如下：type bccspmsp struct { ????rootCerts []Identity //信任的CA证书列表 ????intermediateCerts []Identity //信任的中间证书列表 ????tlsRootCerts [][]byte //信任的CA TLS 证书列表 ????tlsIntermediateCerts [][]byte //信任的中间TLS 证书列表 ????certificationTreeInternalNodesMap map[string]bool //待定 ????signer SigningIdentity //签名身份 ?...

区块链教程Fabric1.0源代码分析PeerBroadcastClient（Broadcas【代码】

区块链教程Fabric1.0源代码分析PeerBroadcastClient（Broadcast客户端），2018年下半年，区块链行业正逐渐褪去发展之初的浮躁、回归理性，表面上看相关人才需求与身价似乎正在回落。但事实上，正是初期泡沫的渐退，让人们更多的关注点放在了区块链真正的技术之上。 Fabric1.0源代码笔记之Peer DeliverClient（Deliver客户端）1、DeliverClient概述DeliverClient代码分布如下：peer/channel/deliverclient.go，deliverClientIntf接口...

区块链教程Fabric1.0源代码分析policy（背书策略【代码】

区块链教程Fabric1.0源代码分析policy（背书策略），2018年下半年，区块链行业正逐渐褪去发展之初的浮躁、回归理性，表面上看相关人才需求与身价似乎正在回落。但事实上，正是初期泡沫的渐退，让人们更多的关注点放在了区块链真正的技术之上。 Fabric 1.0源代码笔记之 policy（背书策略）1、policy概述policy代码分布在core/policy、core/policyprovider、common/policies目录下。目录结构如下：core/policy/policy.go，PolicyChe...

区块链教程Fabric1.0源代码分析Chaincode（链码）体系总结【代码】

Fabric 1.0源代码笔记之 Chaincode（链码） 1、Chaincode概述Chaincode，即链码或智能合约，代码分布在protos/peer目录、core/chaincode和core/common/ccprovider目录，目录结构如下：protos/peer目录：????* chaincode.pb.go，ChaincodeDeploymentSpec、ChaincodeInvocationSpec结构体定义。core/chaincode目录：???? platforms目录，链码的编写语言平台实现，如golang或java。???????? platforms.go，Platform接口定义，及部分工...

兄弟连区块链教程Fabric1.0源代码分析ledgerID数据【代码】

1、idStore概述 Fabric支持创建多个Ledger，不同Ledger以ledgerID区分。多个ledgerID及其创世区块存储在idStore数据库中，idStore数据库基于leveldb实现。idStore默认使用路径：/var/hyperledger/production/ledgersData/ledgerProvider/。idStore库中特殊key "underConstructionLedgerKey"，用于标志最新在建的ledgerID，ledgerID创建成功后或失败时该标志将清除，另外此标志也用于异常时按ledgerID恢复数据。idStore相关代码集中...

企业级区块链对比：Quorum vs. Corda vs. Hyperledger Fabric【图】

企业分布账本技术（Distributed Ledger Technology）需要解决5个方面的挑战：数据隐私性、技术正当性、可伸缩性、最终一致性和互操作性。本文将对企业以太坊（Quorum）、Hyperledger Fabric和Corda就这些环节进行比较。如果希望快速掌握区块链应用的开发，推荐汇智网的区块链应用开发系列教程，内容涵盖比特币、以太坊、eos、超级账本fabric和tendermint等多种区块链，以及 java、go、c#、nodejs、python、php、dart等多种开发语...

Hyperledger Fabric 2.2.1 区块链问题汇总（后续有问题再更新）【代码】【图】

搭建Hyperledger Fabric时遇到了很多问题，很多坑，这里汇总一下，有些可能没保存图片，还有些问题没及时记录起来： 1、生成orderer区块文件时，如下图所示：必须要指定channelID修改命令如下即可： configtxgen -profile TestTwoOrgsOrdererGenesis -channelID qkltestchannel -outputBlock ./order.genesis.block 2、创建orderer区块文件时，如下图所示：原因：OrdererDefaults引用不到，百度了一下，参考文章：https://blog.csd...

区块链教程Fabric1.0源代码分析Ledger statedb（状态数据库）【代码】

Fabric 1.0源代码笔记之 Ledger #statedb（状态数据库） 1、statedb概述 statedb，或VersionedDB，即状态数据库，存储了交易（transaction）日志中所有键的最新值，也称世界状态（world state）。可选择基于leveldb或cauchdb实现。 statedb，代码分布在core/ledger/kvledger/txmgmt/statedb目录下，目录结构如下：statedb.go，定义了核心接口VersionedDBProvider、VersionedDB、ResultsIterator和QueryResult，以及UpdateBatch和n...

区块链学习——HyperLedger-Fabric v1.0 启动过程分析【代码】【图】

本章我们从fabric v1.0的e2e_cli示例开始分析整个启动过程以及在过程中的一些配置文件首先呢，还是确保你的基本环境已经搭建完成，v1.0源码和镜像也都下载完毕fabric启动过程中的相关脚本文件解析network_setup.sh脚本文件在源码目录下的network_setup.sh文件是官方提供的快速部署测试的一个自动化脚本，接下来我们看一下在启动这个文件时都做了什么: 在上图中我们只是截取了启动函数，在这个函数中可以清楚的看出在启动中调用了g...

Hyperledger Fabric 超级账本区块链技术概述优点

超级账本概述区块链的第一个也是最被广泛认可的应用是比特币，另一种加密货币以太坊采取了不同的方法，它集成了许多与比特币相同的特征，添加了智能合约来创建分布式应用程序的平台。比特币和以太坊属于区块链，我们将其归类为无公开许可的区块链技术。基本上，这些都是对任何人开放的公共网络，参与者可以匿名互动。随着比特币、以太坊和其他一些衍生技术的普及，将区块链的底层技术、分布式账本和分布式应用平台应用到更具创新...

区块链学习之Hyperledger Fabric开发环境搭建(Go+Docker+Fabric)【代码】【图】

Fabric采用Go语言实现，因此推荐使用Golang 1.12+版本进行编译生成fabric-peer、fabric-orderer和fabric-ca等组件的二进制文件，对于区块链的业务开发最好也推荐使用Go语言，因为Fabric虽然支持Java等语言，但是因为支持过程中经常有些莫名的Bug，因此推荐使用Go语言。Fabric目前采用Docker容器作为链码执行环境，因此即使在本地运行，链码服务器也需要安装Docker环境，Docker推荐使用1.18或更新的版本。因此建议采用Go+Docker+Fab...

Hyperledger Fabric【区块链学习一】【图】

Hyperledger Fabric 学习什么是区块链什么是区块链在我们没有接触的时候，只知道它是一个去中心化的存储方式。当我们发生交易，或者动作的时候我们会将记录通知给所有参与者共同维护，达到去中心化的进行存储。并且我们会将记录使用加密技术保证记录一旦添加到了账本中就无法修改（无法修改的账本就可以追溯信息根源）这个也就是区块链有时候被称为证明系统。区块链使用场景多方参与跨机构数据共享需求能够除本增收提高工作效率...

第七章九析带你轻松完爆 hyperledger fabric - 区块链防篡改机制

本系列文章:第一章：九析带你完爆 hyperledger fabric -?快速上手 basic-network 样例第二章：九析带你完爆?hyperledger?fabric - 快速搭建 GO 环境第三章：九析带你完爆 hyperledger?fabric - 快速上手 first-network 样例第四章：九析带你完爆 hyperledger?fabric - 系统逻辑架构篇第五章：九析带你完爆 hyperledger?fabirc - 网络节点介绍第六章: 九析带你轻松完爆 hyperledger fabric - 区块和区块链介绍第七章: 九析带你轻松...

第六章九析带你轻松完爆 hyperledger fabric - 区块和区块链介绍【图】

本系列文章:第一章：九析带你完爆 hyperledger fabric -?快速上手 basic-network 样例第二章：九析带你完爆?hyperledger?fabric - 快速搭建 GO 环境第三章：九析带你完爆 hyperledger?fabric - 快速上手 first-network 样例第四章：九析带你完爆 hyperledger?fabric - 系统逻辑架构篇第五章：九析带你完爆 hyperledger?fabirc - 网络节点介绍第六章: 九析带你完爆 hyperledger fabric - 区块和区块链介绍目录1 前言2 区块3 区块链...

首页 / 区块链 / 区块链教程Fabric1.0源代码分析Peer peer node start命令实现

区块链教程Fabric1.0源代码分析Peer peer node start命令实现

内容导读

内容图文

Fabric 1.0源代码笔记之 Peer #peer node start命令实现

1、peer node加载子命令start和status

2、初始化Ledger（账本）

3、配置及创建PeerServer、创建EventHubServer（事件中心服务器）

4、创建并启动Chaincode Server，并注册系统链码

5、注册Admin server和Endorser server

6、初始化Gossip服务

7、初始化、部署并执行系统链码（scc）

8、启动peerServer和ehubGrpcServer，并监控系统信号，以及启动Go自带的profiling支持进行调试

9、按配置文件重新更新模块日志级别

内容总结

内容备注

内容手机端

【区块链教程Fabric1.0源代码分析Peer peer node start命令实现】教程文章相关的互联网学习教程文章

区块链教程Fabric1.0源代码分析blockfile区块文件存储一【代码】

区块链教程Fabric1.0源代码分析MSP成员关系服务提供者二【代码】

区块链教程Fabric1.0源代码分析PeerBroadcastClient（Broadcas【代码】

区块链教程Fabric1.0源代码分析policy（背书策略【代码】

区块链教程Fabric1.0源代码分析Chaincode（链码）体系总结【代码】

兄弟连区块链教程Fabric1.0源代码分析ledgerID数据【代码】

企业级区块链对比：Quorum vs. Corda vs. Hyperledger Fabric【图】

Hyperledger Fabric 2.2.1 区块链问题汇总（后续有问题再更新）【代码】【图】

区块链教程Fabric1.0源代码分析Ledger statedb（状态数据库）【代码】

区块链学习——HyperLedger-Fabric v1.0 启动过程分析【代码】【图】

Hyperledger Fabric 超级账本区块链技术概述优点

区块链学习之Hyperledger Fabric开发环境搭建(Go+Docker+Fabric)【代码】【图】

Hyperledger Fabric【区块链学习一】【图】

第七章九析带你轻松完爆 hyperledger fabric - 区块链防篡改机制

第六章九析带你轻松完爆 hyperledger fabric - 区块和区块链介绍【图】

NODE - 相关标签

区块链 - 相关标签

源代码 - 相关标签

区块链 - 最新教程

区块链 - 最热教程

首页 / 区块链 / 区块链教程Fabric1.0源代码分析Peer peer node start命令实现

区块链教程Fabric1.0源代码分析Peer peer node start命令实现

内容导读

内容图文

Fabric 1.0源代码笔记 之 Peer #peer node start命令实现

1、peer node加载子命令start和status

2、初始化Ledger（账本）

3、配置及创建PeerServer、创建EventHubServer（事件中心服务器）

4、创建并启动Chaincode Server，并注册系统链码

5、注册Admin server和Endorser server

6、初始化Gossip服务

7、初始化、部署并执行系统链码（scc）

8、启动peerServer和ehubGrpcServer，并监控系统信号，以及启动Go自带的profiling支持进行调试

9、按配置文件重新更新模块日志级别

内容总结

内容备注

内容手机端

【区块链教程Fabric1.0源代码分析Peer peer node start命令实现】教程文章相关的互联网学习教程文章

NODE - 相关标签

区块链 - 相关标签

源代码 - 相关标签

区块链 - 最新教程

区块链 - 最热教程

Fabric 1.0源代码笔记之 Peer #peer node start命令实现