fabric-sdk-go获取通道列表 resMgmtClient.QueryChannels

fabric的test-network

fabric源码包提供1个测试案例目录test-network,见下图。

在这里插入图片描述

在该目录中,执行./network.sh createChannel -c mychannel,将启动1个网络,创建名为mychannel的通道。

在这里插入图片描述

在这个网络中,存在peer0.org1.example.com、peer0.org2.example.com、orderer.example.com共3个节点。

在这里插入图片描述

配置/etc/hosts

配置/etc/hosts的目的,是让另1个终端SDK程序能够访问到3个节点:peer0.org1.example.com、peer0.org2.example.com、orderer.example.com。

使用docker exec -it peer0.org1.example.com /bin/ash进入其中1个节点。

在这里插入图片描述

在peer0.org1的节点中执行ping peer0.org1.example.com,获得该节点的IP地址。类似地,获得其他2个节点的IP地址。

在这里插入图片描述

另开1个终端,修改/etc/hosts文件如下。并确认,这个终端,与上述3个节点的网络是相通的。

在这里插入图片描述

在这里插入图片描述

用Go编写SDK案例,访问上面的网络

新建1个目录queryChannel,这个案例用来查询网络中已经创建的通道名称。在这个目录中,新建2个文件e2e.yaml和queryChannel.go。

在这里插入图片描述配置文件e2e.yaml内容如下。

version: 1.0.0

client:

organization: Org1

logging:

level: info

cryptoconfig:

path: /root/go/src/github.com/hyperledger/fabric/scripts/fabric-samples/test-network/organizations

credentialStore:

path: "/tmp/state-store"

cryptoStore:

path: /tmp/msp

tlsCerts:

client:

key:

path: /root/go/src/github.com/hyperledger/fabric/scripts/fabric-samples/test-network/organizations/peerOrganizations/org1.example.com/users/User1@org1.example.com/tls/client.key

cert:

path: /root/go/src/github.com/hyperledger/fabric/scripts/fabric-samples/test-network/organizations/peerOrganizations/org1.example.com/users/User1@org1.example.com/tls/client.crt

organizations:

Org1:

mspid: Org1MSP

cryptoPath: peerOrganizations/org1.example.com/users/{username}@org1.example.com/msp

peers:

- peer0.org1.example.com

peers:

peer0.org1.example.com:

url: peer0.org1.example.com:7051

tlsCACerts:

path: /root/go/src/github.com/hyperledger/fabric/scripts/fabric-samples/test-network/organizations/peerOrganizations/org1.example.com/tlsca/tlsca.org1.example.com-cert.pem

SDK程序queryChannel.go的内容如下。

package main

import (

"log"

"strings"

"github.com/hyperledger/fabric-sdk-go/pkg/client/resmgmt"

"github.com/hyperledger/fabric-sdk-go/pkg/common/errors/retry"

"github.com/hyperledger/fabric-sdk-go/pkg/common/providers/core"

"github.com/hyperledger/fabric-sdk-go/pkg/common/providers/fab"

"github.com/hyperledger/fabric-sdk-go/pkg/core/config"

"github.com/hyperledger/fabric-sdk-go/pkg/core/config/lookup"

"github.com/hyperledger/fabric-sdk-go/pkg/fabsdk"

"github.com/pkg/errors"

)

const (

orgName = "Org1"

orgAdmin = "Admin"

)

func main() {

configPath := "./e2e.yaml"

configProvider := config.FromFile(configPath)

sdk, err := fabsdk.New(configProvider)

if err != nil {

log.Fatalf("Failed to create new SDK: %s", err)

}

defer sdk.Close()

queryChannel(sdk)

}

func queryChannel(sdk *fabsdk.FabricSDK) {

configBackend, err := sdk.Config()

if err != nil {

log.Fatalf("Failed to get config backend from SDK: %s", err)

}

targets, err := orgTargetPeers([]string{orgName}, configBackend)

if err != nil {

log.Fatalf("creating peers failed: %s", err)

}

clientContext := sdk.Context(fabsdk.WithUser("User1"), fabsdk.WithOrg("Org1"))

resMgmtClient, err := resmgmt.New(clientContext)

if err != nil {

log.Fatalf("failed to query channel management client:%s", err)

}

channelQueryResponse, err := resMgmtClient.QueryChannels(

resmgmt.WithTargetEndpoints(targets[0]), resmgmt.WithRetry(retry.DefaultResMgmtOpts))

if err != nil {

log.Fatalf("QueryChannels return error: %s", err)

}

for _, channel := range channelQueryResponse.Channels {

log.Printf("*** Channel :%s\n", channel.ChannelId)

}

}

func orgTargetPeers(orgs []string, configBackend ...core.ConfigBackend) ([]string, error) {

networkConfig := fab.NetworkConfig{}

err := lookup.New(configBackend...).UnmarshalKey("organizations", &networkConfig.Organizations)

if err != nil {

return nil, errors.WithMessage(err, "failed to get organizations from config ")

}

var peers []string

for _, org := range orgs {

orgConfig, ok := networkConfig.Organizations[strings.ToLower(org)]

if !ok {

continue

}

peers = append(peers, orgConfig.Peers...)

}

return peers, nil

}

执行go mod init .初始化该案例,会下载一些依赖包。

在这里插入图片描述

执行go run . ,运行这个SDK案例程序,在指定网络中查询并输出已经安装的通道名称。

在这里插入图片描述

看聊效

————————————————

版权声明:本文为CSDN博主「看聊效」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。

原文链接:https://blog.csdn.net/qq_18807043/article/details/108684285