兄弟连区块链教程命令实现
兄弟连区块链教程Fabric1.0源代码分析Peer peer node start命令实现，2018年下半年，区块链行业正逐渐褪去发展之初的浮躁、回归理性，表面上看相关人才需求与身价似乎正在回落。但事实上，正是初期泡沫的渐退，让人们更多的关注点放在了区块链真正的技术之上。
# Fabric 1.0源代码笔记 之 Peer #peer node start命令实现
## 1、peer node加载子命令start和status
peer node加载子命令start和status，代码如下：
```go
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()相近，暂略。
```go
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（账本）
初始化账本，即如下一条代码：
```go
ledgermgmt.Initialize()
//代码在peer/node/start.go
```
ledgermgmt.Initialize()代码展开如下：
```go
func initialize() {
openedLedgers = make(map[string]ledger.PeerLedger) //openedLedgers为全局变量，存储目前使用的账本列表
provider, err := kvledger.NewProvider() //创建账本Provider实例
ledgerProvider = provider
}
//代码在core/ledger/ledgermgmt/ledger_mgmt.go
```
kvledger.NewProvider()代码如下：
```go
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（事件中心服务器）
```go
//初始化全局变量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)代码如下：
```go
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")), //zui大进行缓冲的消息数
viper.GetDuration("peer.events.timeout")) //缓冲已满的情况下，往缓冲中发送消息的超时
pb.RegisterEventsServer(grpcServer.Server(), ehServer) //EventHubServer注册至grpcServer
return grpcServer, nil
//代码在peer/node/start.go
```
pb.RegisterEventsServer(grpcServer.Server(), ehServer)代码如下：
```go
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，并注册系统链码
代码如下：
```go
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。
```go
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。
```go
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。
网上报名
新闻资讯
更多>>-
兄弟连“因材施教搭建桥梁”计划正式启动
2018-06-14
-
兄弟连PHP培训：高薪就业才是硬道理
2018-06-14
-
兄弟连北京安卓培训：万元高薪班级爆满
2018-06-14
-
25W高薪挑战安卓 零基础培训首选兄弟连
2018-06-14
-
兄弟连PHP教程发布 海量资源应有尽有
2018-06-14
