Fabric 1.0源代码分析(31) Peer

# Fabric 1.0源代码笔记之 Peer

## 1、Peer概述

在Fabric中，Peer（节点）是指在网络中负责接收交易请求、维护一致账本的各个fabric-peer实例。节点之间彼此通过gRPC通信。

按角色划分，Peer包括两种类型：

* Endorser（背书者）：负责对来自客户端的交易提案进行检查和背书。

* Committer（提交者）：负责检查交易请求，执行交易并维护区块链和账本结构。

Peer核心代码在peer目录下，其他相关代码分布在core/peer和protos/peer目录下。目录结构如下：

* peer目录：

* main.go，peer命令入口。

* node目录，peer node命令及子命令peer node start和peer node status实现。

* node.go，peer node命令入口。

* start.go，peer node start子命令实现。

* status.go，peer node status子命令实现。

* channel目录，peer channel命令及子命令实现。

* chaincode目录，peer chaincode命令及子命令实现。

* clilogging目录，peer clilogging命令及子命令实现。

* version目录，peer version命令实现。

* common目录，peer相关通用代码。

* common.go，部分公共函数。

* ordererclient.go，BroadcastClient接口及实现。

* gossip目录，gossip最终一致性算法相关代码。

* core/peer目录：

* config.go，Peer配置相关工具函数。

* peer.go，Peer服务相关工具函数。

* core/endorser目录：背书服务端。

如下为分节说明Peer代码：

* [Fabric 1.0源代码笔记之 Peer #peer根命令入口及加载子命令](peer_main.md)

* [Fabric 1.0源代码笔记之 Peer #peer node start命令实现](peer_node_start.md)

* [Fabric 1.0源代码笔记之 Peer #peer channel命令及子命令实现](peer_channel.md)

* [Fabric 1.0源代码笔记之 Peer #peer chaincode命令及子命令实现](peer_chaincode.md)

* [Fabric 1.0源代码笔记之 Peer #EndorserClient（Endorser客户端）](EndorserClient.md)

* [Fabric 1.0源代码笔记之 Peer #EndorserServer（Endorser服务端）](EndorserServer.md)

* [Fabric 1.0源代码笔记之 Peer #BroadcastClient（Broadcast客户端）](BroadcastClient.md)

* [Fabric 1.0源代码笔记之 Peer #committer（提交者）](committer.md)

## 2、Peer配置相关工具函数

```go

//为全局变量localAddress和peerEndpoint赋值

func CacheConfiguration() (err error)

func cacheConfiguration() //调用CacheConfiguration()

//获取localAddress

func GetLocalAddress() (string, error)

//获取peerEndpoint

func GetPeerEndpoint() (*pb.PeerEndpoint, error)

//获取Peer安全配置

func GetSecureConfig() (comm.SecureServerConfig, error)

//代码在core/peer/config.go

```

PeerEndpoint结构体定义如下：

```go

type PeerID struct {

Name string

}

type PeerEndpoint struct {

Id *PeerID

Address string

}

//代码在protos/peer/peer.pb.go

```

SecureServerConfig结构体定义如下：

```go

type SecureServerConfig struct {

ServerCertificate []byte //签名公钥，取自peer.tls.cert.file

ServerKey []byte //签名私钥，取自peer.tls.key.file

ServerRootCAs [][]byte //根CA证书，取自peer.tls.rootcert.file

ClientRootCAs [][]byte

UseTLS bool //是否启用TLS，取自peer.tls.enabled

RequireClientCert bool

}

//代码在core/comm/server.go

```

## 3、Peer服务相关工具函数

```go

func (cs *chainSupport) Ledger() ledger.PeerLedger

func (cs *chainSupport) GetMSPIDs(cid string) []string

func MockInitialize()

func MockSetMSPIDGetter(mspIDGetter func(string) []string)

func Initialize(init func(string)) //Peer初始化，并部署系统链码

func InitChain(cid string)

func getCurrConfigBlockFromLedger(ledger ledger.PeerLedger) (*common.Block, error)

func createChain(cid string, ledger ledger.PeerLedger, cb *common.Block) error

func CreateChainFromBlock(cb *common.Block) error

func MockCreateChain(cid string) error

func GetLedger(cid string) ledger.PeerLedger

func GetPolicyManager(cid string) policies.Manager

func GetCurrConfigBlock(cid string) *common.Block

func updateTrustedRoots(cm configtxapi.Manager)

func buildTrustedRootsForChain(cm configtxapi.Manager)

func GetMSPIDs(cid string) []string

func SetCurrConfigBlock(block *common.Block, cid string) error

func NewPeerClientConnection() (*grpc.ClientConn, error)

func GetLocalIP() string

func NewPeerClientConnectionWithAddress(peerAddress string) (*grpc.ClientConn, error)

func GetChannelsInfo() []*pb.ChannelInfo

//构造type channelPolicyManagerGetter struct{}

func NewChannelPolicyManagerGetter() policies.ChannelPolicyManagerGetter

func (c *channelPolicyManagerGetter) Manager(channelID string) (policies.Manager, bool)

func CreatePeerServer(listenAddress string,secureConfig comm.SecureServerConfig) (comm.GRPCServer, error)

func GetPeerServer() comm.GRPCServer

//代码在core/peer/peer.go

```

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

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

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

尹成学院微信：备注：CSDN

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

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

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

尹成学院微信：备注：CSDN

Fabric 1.0源代码分析(31) Peer相关推荐

Fabric 1.0源代码分析(32)Peer #peer根命令入口及加载子命令
# Fabric 1.0源代码笔记之 Peer #peer根命令入口及加载子命令 ## 1.加载环境变量配置和配置文件 Fabric支持通过环境变量对部分配置进行更新,如:CORE_LOGGING_ ...
Fabric 1.0源代码分析(37) Peer #DeliverClient（Deliver客户端）
# Fabric 1.0源代码笔记之 Peer #DeliverClient(Deliver客户端) ## 1.DeliverClient概述 DeliverClient代码分布如下: * peer ...
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源代码分析(34) Peer #peer chaincode命令及子命令实现
# Fabric 1.0源代码笔记之 Peer #peer chaincode命令及子命令实现 ## 1.peer chaincode install子命令实现(安装链码) ### 1.0.peer ...
Fabric 1.0源代码分析(38) Peer #BroadcastClient（Broadcast客户端）
# Fabric 1.0源代码笔记之 Peer #BroadcastClient(Broadcast客户端) ## 1.BroadcastClient概述 BroadcastClient代码分布如下 ...
Fabric 1.0源代码分析(33) Peer #peer channel命令及子命令实现
# Fabric 1.0源代码笔记之 Peer #peer channel命令及子命令实现 ## 1.peer channel create子命令实现(创建通道) ### 1.1.初始化Ordere ...
Fabric 1.0源代码分析(15)gossip（流言算法）
# Fabric 1.0源代码笔记之 gossip(流言算法) ## 1.gossip概述 gossip,翻译为流言蜚语,即为一种可最终达到一致的算法.最终一致的另外的含义就是,不保证同时达到一致. ...
Fabric 1.0源代码分析(22)Ledger #blkstorage（block文件存储）
# Fabric 1.0源代码笔记之 Ledger #blkstorage(block文件存储) ## blkstorage概述 blkstorage,默认目录/var/hyperledger/pr ...
Fabric 1.0源代码分析(25) Orderer
# Fabric 1.0源代码笔记之 Orderer ## 1.Orderer概述 Orderer,为排序节点,对所有发往网络中的交易进行排序,将排序后的交易安排配置中的约定整理为块,之后提交给Co ...

Fabric 1.0源代码分析(31) Peer

Fabric 1.0源代码分析(31) Peer相关推荐

最新文章

热门文章