go-sdk-demo-0214
宿文栋
package main
import (
//"os"
//"path"
//"testing"
//"time"
//"github.com/hyperledger/fabric-sdk-go/api/apiconfig"
//ca "github.com/hyperledger/fabric-sdk-go/api/apifabca"
//fab "github.com/hyperledger/fabric-sdk-go/api/apifabclient"
//"github.com/hyperledger/fabric-sdk-go/api/apitxn"
//pb "github.com/hyperledger/fabric-sdk-go/third_party/github.com/hyperledger/fabric/protos/peer"
fabricapi "github.com/hyperledger/fabric-sdk-go/def/fabapi"
//"github.com/hyperledger/fabric-sdk-go/pkg/config"
"github.com/hyperledger/fabric-sdk-go/pkg/errors"
//"github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/events"
"github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/orderer"
//admin "github.com/hyperledger/fabric-sdk-go/pkg/fabric-txn/admin"
//"github.com/hyperledger/fabric-sdk-go/third_party/github.com/hyperledger/fabric/common/cauthdsl"
"fmt"
identityImpl "github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/identity"
//hfc "github.com/hyperledger/fabric-sdk-go/pkg/fabric-client"
//"github.com/cloudflare/cfssl/api/client
//config "github.com/hyperledger/fabric-sdk-go/api/apiconfig"
//fab "github.com/hyperledger/fabric-sdk-go/api/apifabclient"
"io/ioutil"
//"github.com/cloudflare/cfssl/api/client"
"encoding/hex"
afc "github.com/hyperledger/fabric-sdk-go/api/apifabclient"
"github.com/hyperledger/fabric-sdk-go/api/apitxn"
fab "github.com/hyperledger/fabric-sdk-go/api/apifabclient"
peerapi "github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/peer"
"github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/events"
//ca "github.com/hyperledger/fabric-sdk-go/api/apifabca"
fabricCAClient "github.com/hyperledger/fabric-sdk-go/pkg/fabric-ca-client"
"github.com/hyperledger/fabric-sdk-go/pkg/config"
/*bccspFactory "github.com/hyperledger/fabric-sdk-go/third_party/github.com/hyperledger/fabric/bccsp/factory"
kvs "github.com/hyperledger/fabric-sdk-go/pkg/fabric-client/keyvaluestore"
fabricclient "github.com/hyperledger/fabric-sdk-go/pkg/fabric-client"*/
"github.com/hyperledger/fabric-sdk-go/pkg/logging"
"github.com/hyperledger/fabric-sdk-go/pkg/logging/deflogger"
)
/*type fbconfig struct {
tlsEnabled bool
errorCase bool
}*/
func main() {
//初始化日志系统
if !logging.IsLoggerInitialized() {
logging.InitLogger(deflogger.GetLoggingProvider())
}
//fabric_ca()
fabric_local()
//bookcode()
}
/**
通过fabtic-ca-server 获取账号信息，并利用获取的账号访问Peer服务器节点
*/
func fabric_ca(){
//读取SDK配置文件
sdkOptions := fabricapi.Options{ConfigFile: "./fabricsdk/config_test.yaml",}
//创建SDK代理
sdk, _ := fabricapi.NewSDK(sdkOptions)
countext,_ := sdk.NewContext("Org1MSP")
user := identityImpl.NewUser("Admin","Org1MSP");
//读取fabric-ca的配置文件
configImpl , _ := config.InitConfig("./fabricsdk/config_test.yaml")
caClient , _ := fabricCAClient.NewFabricCAClient(configImpl, "Org1")
key, cert , _ := caClient.Enroll("user88", "peer2wd")
user.SetEnrollmentCertificate(cert)
user.SetPrivateKey(key)
session, _ := sdk.NewSession(countext,user)
//创建fabric客户端代理
client, _ := sdk.NewSystemClient(session)
//创建通道代理，通道名为:roberttestchannel12
channel, _ := client.NewChannel("roberttestchannel12" )
//创建Orderer节点代理
orderer, _ := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", client.Config())
channel.AddOrderer(orderer)
//创建Peer节点代理
newpeer, _ := fabricapi.NewPeer("grpc://192.168.23.212:7051", "", "", client.Config())
channel.AddPeer(newpeer)
//获取当前通道的信息
blockchaininfo, _ := channel.QueryInfo()
fmt.Println(" the peer block height %d", blockchaininfo.Height)
targets := peerapi.PeersToTxnProcessors(channel.Peers())
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
ChaincodeID: "cc_endfinlshed",
Fcn: "query",
Args: [][]byte{[]byte("a")},
}
queryResponses, err := channel.QueryByChaincode(request)
if err != nil {
check(err,"QueryByChaincode failed %s")
}
for _ , parmbytes := range queryResponses{
fmt.Println(" chaincode query info is : %s " , string(parmbytes))
}
}
/**
通过cryptogen模块生成的账号访问Peer服务器节点
*/
func fabric_local() {
//读取配置文件
sdkOptions := fabricapi.Options{ConfigFile: "./fabricsdk/config_test.yaml",}
//创建SDK代理
sdk, _ := fabricapi.NewSDK(sdkOptions)
session, _ := sdk.NewPreEnrolledUserSession("org1", "Admin")
//创建fabric客户端代理
client, _ := sdk.NewSystemClient(session)
//创建通道代理，通道名为:roberttestchannel12
channel, _ := client.NewChannel("roberttestchannel12")
//创建Orderer节点代理
orderer, _ := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", client.Config())
channel.AddOrderer(orderer)
//创建Peer节点代理
peer ,_ := fabricapi.NewPeer("grpc://192.168.23.212:7051","","",client.Config())
channel.AddPeer(peer)
//获取当前通道的信息
blockchainInfo, _ := channel.QueryInfo()
fmt.Println(" the peer block height %d",blockchainInfo.Height)
peer188 ,err := fabricapi.NewPeer("grpc://172.16.10.188:7051","","",client.Config())
channel.AddPeer(peer188)
targets := peerapi.PeersToTxnProcessors(channel.Peers())
transientData := make(map[string][]byte)
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
Fcn: "invoke",
Args: [][]byte{[]byte("a"),[]byte("b"),[]byte("1")},
TransientMap: transientData,
ChaincodeID: "cc_endfinlshed",
}
transactionProposalResponses, txnID, err := channel.SendTransactionProposal(request)
fmt.Println(" tx id : %s",txnID)
if err != nil {
check(err," send transtion error ")
}
for _, v := range transactionProposalResponses {
if v.Err != nil {
check(v.Err, "endorser %s failed")
}
}
tx, err := channel.CreateTransaction(transactionProposalResponses)
transactionResponse, err := channel.SendTransaction(tx)
fmt.Println(" srarch result %s " , transactionResponse )
}
func bookcode(){
//读取配置文件
sdkOptions := fabricapi.Options{
ConfigFile: "./fabricsdk/config_test.yaml",
}
//创建SDK代理
sdk, _ := fabricapi.NewSDK(sdkOptions)
session, _ := sdk.NewPreEnrolledUserSession("org1", "Admin")
//创建Golang的 fabric客户端代理
client, _ := sdk.NewSystemClient(session)
//创建通道代理，通道名为:roberttestchannel12
channel, _ := client.NewChannel("roberttestchannel12")
//创建Orderer节点代理
orderer, _ := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", client.Config())
channel.AddOrderer(orderer)
//创建Peer节点代理
peer ,_ := fabricapi.NewPeer("grpc://192.168.23.212:7051","","",client.Config())
channel.AddPeer(peer)
//获取当前通道的信息
blockchainInfo, _ := channel.QueryInfo()
fmt.Println(" the peer block height %d",blockchainInfo.Height)
}
func fabric_ca_old(){
configImpl, err := config.InitConfig("./fabricsdk/config_test.yaml")
if err != nil {
check( err ,"find error" )
}
caClient, err := fabricCAClient.NewFabricCAClient(configImpl, "Org1")
key, cert, err := caClient.Enroll("user88", "peer2wd")
================ ============================
sdkOptions := fabricapi.Options{
ConfigFile: "./fabricsdk/config_test.yaml",
}
sdk, err := fabricapi.NewSDK(sdkOptions)
if err != nil {
fmt.Println( errors.WithMessage(err, "SDK init failed"))
}
//session, err := sdk.NewPreEnrolledUserSession("Org1MSP" ,"Admin")
countext,err := sdk.NewContext("Org1MSP")
user := identityImpl.NewUser("Admin","Org1MSP");
user.SetEnrollmentCertificate(cert)
user.SetPrivateKey(key)
session, _ := sdk.NewSession(countext,user)
sc, _ := sdk.NewSystemClient(session)
channel, _ := sc.NewChannel("roberttestchannel12" )
orderer, _ := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", sc.Config())
newpeer, _ := fabricapi.NewPeer("grpc://192.168.23.212:7051", "", "", sc.Config())
channel.AddOrderer(orderer)
channel.AddPeer(newpeer)
blockchaininfo, _ := channel.QueryInfo()
fmt.Println(" the peer block height %d", blockchaininfo.Height)
}
func fabric_local1(){
sdkOptions := fabricapi.Options{
ConfigFile: "./fabricsdk/config_test.yaml",
}
sdk, err := fabricapi.NewSDK(sdkOptions)
session, err := sdk.NewPreEnrolledUserSession("org1", "Admin")
client, err := sdk.NewSystemClient(session)
channel, err := client.NewChannel("roberttestchannel12")
orderer, err := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", client.Config())
channel.AddOrderer(orderer)
peer ,err := fabricapi.NewPeer("grpc://192.168.23.212:7051","","",client.Config())
channel.AddPeer(peer)
peer188 ,err := fabricapi.NewPeer("grpc://172.16.10.188:7051","","",client.Config())
channel.AddPeer(peer188)
//获取当前通道的详细信息
/*bciAfterTx, err4 := channel.QueryInfo()
check(err4,"_6")
fmt.Println(" the peer block height %d",bciAfterTx.Height)*/
//查询Peer节点加入的所有通道
/*channels,err := client.QueryChannels(peer)
for _ , responsechannel := range channels.Channels{
fmt.Println(" the channel info is : %s " , responsechannel.ChannelId )
}*/
//根据区块编号获取区块信息
/*block, err := channel.QueryBlock(23)
fmt.Println(" The block info : %s " , hex.EncodeToString(block.Header.PreviousHash))*/
//根据区块链HASH获取区块详细信息
/*let blockinfobyhash = yield channel.queryBlockByHash(new Buffer("ec298dc1cd1f0e0a3f6d6e25b5796e7b5e4d668aeb6ec3a90b4aa6bb1a7f0c17","hex"),peer)
console.info( JSON.stringify(blockinfobyhash ) )*/
//blockinfo , err := channel.QueryBlockByHash(block.Header.PreviousHash)
/*blockhash , err := hex.DecodeString("7376086e18a8ddbc40d318557c39987fd538c64340aa0df191e1062b935e147e")
blockinfo , err := channel.QueryBlockByHash( blockhash )
fmt.Println(" The block info : %s " , blockinfo.String())*/
//查询已经install的chaincode
/*installchaincodes , err := client.QueryInstalledChaincodes(peer)
for _ , responseinstall := range installchaincodes.Chaincodes{
fmt.Println(" chaincode info is : %s %s " , responseinstall.Version , responseinstall.Path )
}*/
// 查询已经实例化的Chaincode
/*channel.SetPrimaryPeer(peer)
instantChaincodes, err := channel.QueryInstantiatedChaincodes();
for _ , responseinstant := range instantChaincodes.Chaincodes{
fmt.Println(" chaincode info is : %s %s " , responseinstant.Version , responseinstant.Path )
}*/
//根据交易编号获取交易详细信息
/* let resulttxinfo = yield channel.queryTransaction("56f51f9a54fb4755fd68c6c24931234a59340f7c98308374e9991d276d7d4a96", peer);
console.info( JSON.stringify( resulttxinfo ) )
*/
/*tran , err := channel.QueryTransaction("56f51f9a54fb4755fd68c6c24931234a59340f7c98308374e9991d276d7d4a96")
fmt.Println(" transcaion info is : %s " , tran.String())
*/
//发起交易(查询交易)
/*targets := peerapi.PeersToTxnProcessors(channel.Peers())
client.SetUserContext(session.Identity())
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
ChaincodeID: "cc_endfinlshed",
Fcn: "query",
Args: [][]byte{[]byte("a")},
}
queryResponses, err := channel.QueryByChaincode(request)
if err != nil {
check(err,"QueryByChaincode failed %s")
}
for _ , parmbytes := range queryResponses{
fmt.Println(" chaincode query info is : %s " , string(parmbytes))
}*/
// 发起交易，写入交易
targets := peerapi.PeersToTxnProcessors(channel.Peers())
transientData := make(map[string][]byte)
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
Fcn: "invoke",
Args: [][]byte{[]byte("a"),[]byte("b"),[]byte("1")},
TransientMap: transientData,
ChaincodeID: "cc_endfinlshed",
}
transactionProposalResponses, txnID, err := channel.SendTransactionProposal(request)
fmt.Println(" tx id : %s",txnID)
if err != nil {
check(err," send transtion error ")
}
for _, v := range transactionProposalResponses {
if v.Err != nil {
check(v.Err, "endorser %s failed")
}
}
tx, err := channel.CreateTransaction(transactionProposalResponses)
transactionResponse, err := channel.SendTransaction(tx)
fmt.Println(" srarch result %s " , transactionResponse )
//eventHub, err := events.NewEventHub(client)
}
func fabric_local_old(){
sdkOptions := fabricapi.Options{
ConfigFile: "./fabricsdk/config_test.yaml",
}
sdk, err := fabricapi.NewSDK(sdkOptions)
if err != nil {
check(err, "SDK init failed")
}
session, err := sdk.NewPreEnrolledUserSession("org1", "Admin")
if err != nil {
check(err, "failed getting admin user session for org")
}
sc, err := sdk.NewSystemClient(session)
if err != nil {
check( err ,"NewSystemClient failed")
}
client := sc
channel, err := client.NewChannel("roberttestchannel12")
if err != nil {
check( err , "NewChannel failed")
}
orderer, err := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", client.Config())
if err != nil {
check(err, "NewOrderer failed")
}
channel.AddOrderer(orderer)
peer ,err := fabricapi.NewPeer("grpc://192.168.23.212:7051","","",client.Config())
if err != nil {
check(err, "NewOrderer failed")
}
channel.AddPeer(peer)
peer188 ,err := fabricapi.NewPeer("grpc://172.16.10.188:7051","","",client.Config())
if err != nil {
check(err, "NewPeer failed")
}
channel.AddPeer(peer188)
//获取当前通道的详细信息
/*bciAfterTx, err4 := channel.QueryInfo()
check(err4,"_6")
fmt.Println(" the peer block height %d",bciAfterTx.Height)*/
//查询Peer节点加入的所有通道
/*channels,err := client.QueryChannels(peer)
for _ , responsechannel := range channels.Channels{
fmt.Println(" the channel info is : %s " , responsechannel.ChannelId )
}*/
//根据区块编号获取区块信息
/*block, err := channel.QueryBlock(23)
fmt.Println(" The block info : %s " , hex.EncodeToString(block.Header.PreviousHash))*/
//根据区块链HASH获取区块详细信息
/*let blockinfobyhash = yield channel.queryBlockByHash(new Buffer("ec298dc1cd1f0e0a3f6d6e25b5796e7b5e4d668aeb6ec3a90b4aa6bb1a7f0c17","hex"),peer)
console.info( JSON.stringify(blockinfobyhash ) )*/
//blockinfo , err := channel.QueryBlockByHash(block.Header.PreviousHash)
/*blockhash , err := hex.DecodeString("7376086e18a8ddbc40d318557c39987fd538c64340aa0df191e1062b935e147e")
blockinfo , err := channel.QueryBlockByHash( blockhash )
fmt.Println(" The block info : %s " , blockinfo.String())*/
//查询已经install的chaincode
/*installchaincodes , err := client.QueryInstalledChaincodes(peer)
for _ , responseinstall := range installchaincodes.Chaincodes{
fmt.Println(" chaincode info is : %s %s " , responseinstall.Version , responseinstall.Path )
}*/
// 查询已经实例化的Chaincode
/*channel.SetPrimaryPeer(peer)
instantChaincodes, err := channel.QueryInstantiatedChaincodes();
for _ , responseinstant := range instantChaincodes.Chaincodes{
fmt.Println(" chaincode info is : %s %s " , responseinstant.Version , responseinstant.Path )
}*/
//根据交易编号获取交易详细信息
/* let resulttxinfo = yield channel.queryTransaction("56f51f9a54fb4755fd68c6c24931234a59340f7c98308374e9991d276d7d4a96", peer);
console.info( JSON.stringify( resulttxinfo ) )
*/
/*tran , err := channel.QueryTransaction("56f51f9a54fb4755fd68c6c24931234a59340f7c98308374e9991d276d7d4a96")
fmt.Println(" transcaion info is : %s " , tran.String())
*/
//发起交易(查询交易)
/*targets := peerapi.PeersToTxnProcessors(channel.Peers())
client.SetUserContext(session.Identity())
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
ChaincodeID: "cc_endfinlshed",
Fcn: "query",
Args: [][]byte{[]byte("a")},
}
queryResponses, err := channel.QueryByChaincode(request)
if err != nil {
check(err,"QueryByChaincode failed %s")
}
for _ , parmbytes := range queryResponses{
fmt.Println(" chaincode query info is : %s " , string(parmbytes))
}*/
// 发起交易，写入交易
targets := peerapi.PeersToTxnProcessors(channel.Peers())
transientData := make(map[string][]byte)
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
Fcn: "invoke",
Args: [][]byte{[]byte("a"),[]byte("b"),[]byte("1")},
TransientMap: transientData,
ChaincodeID: "cc_endfinlshed",
}
transactionProposalResponses, txnID, err := channel.SendTransactionProposal(request)
fmt.Println(" tx id : %s",txnID)
if err != nil {
check(err," send transtion error ")
}
for _, v := range transactionProposalResponses {
if v.Err != nil {
check(v.Err, "endorser %s failed")
}
}
tx, err := channel.CreateTransaction(transactionProposalResponses)
transactionResponse, err := channel.SendTransaction(tx)
fmt.Println(" srarch result %s " , transactionResponse )
//eventHub, err := events.NewEventHub(client)
}
// getEventHub initilizes the event hub
func getEventHub( client fab.FabricClient) (fab.EventHub, error) {
eventHub, err := events.NewEventHub(client)
if err != nil {
return nil, errors.WithMessage(err, "NewEventHub failed")
}
foundEventHub := false
peerConfig, err := client.Config().PeersConfig("org1")
if err != nil {
return nil, errors.WithMessage(err, "PeersConfig failed")
}
for _, p := range peerConfig {
if p.URL != "" {
serverHostOverride := ""
if str, ok := p.GRPCOptions["ssl-target-name-override"].(string); ok {
serverHostOverride = str
}
eventHub.SetPeerAddr(p.EventURL, p.TLSCACerts.Path, serverHostOverride)
foundEventHub = true
break
}
}
if !foundEventHub {
return nil, errors.New("event hub configuration not found")
}
return eventHub, nil
}
/**
创建交提案
*/
func CreateAndSendTransactionProposal(channel afc.Channel,
chainCodeID string,
fcn string,
args [][]byte,
targets []apitxn.ProposalProcessor,
transientData map[string][]byte) ([]*apitxn.TransactionProposalResponse, apitxn.TransactionID, error) {
request := apitxn.ChaincodeInvokeRequest{
Targets: targets,
Fcn: fcn,
Args: args,
TransientMap: transientData,
ChaincodeID: chainCodeID,
}
transactionProposalResponses, txnID, err := channel.SendTransactionProposal(request)
if err != nil {
return nil, txnID, err
}
for _, v := range transactionProposalResponses {
if v.Err != nil {
return nil, txnID, errors.Wrapf(v.Err, "endorser %s failed", v.Endorser)
}
}
return transactionProposalResponses, txnID, nil
}
func temp(){
//fmt.Print("ddd")
sdkOptions := fabricapi.Options{
ConfigFile: "./fabricsdk/config_test.yaml",
}
sdk, err := fabricapi.NewSDK(sdkOptions)
if err != nil {
fmt.Println( errors.WithMessage(err, "SDK init failed"))
}
//session, err := sdk.NewPreEnrolledUserSession("Org1MSP" ,"Admin")
countext,err := sdk.NewContext("Org1MSP")
user := identityImpl.NewUser("Admin","Org1MSP");
cer, err := ioutil.ReadFile("/project/opt_fabric/fabricconfig/crypto-config/peerOrganizations/org1.robertfabrictest.com/users/Admin@org1.robertfabrictest.com/msp/signcerts/Admin@org1.robertfabrictest.com-cert.pem")
check(err,"1")
privatekey , err1 := ioutil.ReadFile("/project/opt_fabric/fabricconfig/crypto-config/peerOrganizations/org1.robertfabrictest.com/users/Admin@org1.robertfabrictest.com/msp/keystore/b031338f76290f089d330b064d4534202a49ae8d65ca5d266c377bc46812a884_sk")
check(err1,"2")
pfstring := hex.EncodeToString(privatekey)
fmt.Println("dddd + " + pfstring )
pk,err2 := sdk.CryptoSuiteProvider().GetKey(privatekey)
check(err2,"2.1")
user.SetEnrollmentCertificate(cer)
user.SetPrivateKey(pk)
session, err := sdk.NewSession(countext,user)
if err != nil {
fmt.Println( errors.WithMessage(err, "failed getting admin user session for org"))
}
sc, err := sdk.NewSystemClient(session)
if err != nil {
fmt.Println( errors.WithMessage(err, "NewSystemClient failed") )
}
channel, err_1 := sc.NewChannel("roberttestchannel" )
check(err_1,"_1")
orderer, err_2 := orderer.NewOrderer("grpc://192.168.23.212:7050", "", "", sc.Config())
check(err_2,"_2")
newpeer, err_3 := fabricapi.NewPeer("grpc://192.168.23.212:7051", "", "", sc.Config())
check(err_3,"_3")
err_4 :=channel.AddOrderer(orderer)
check(err_4,"_4")
channel.AddPeer(newpeer)
channel.SetPrimaryPeer(newpeer)
primaryPeer := channel.PrimaryPeer()
_, err_5 := sc.QueryChannels(primaryPeer)
check(err_5,"_5")
/*for _, responseChannel := range response.Channels {
if responseChannel.ChannelId == channel.Name() {
}
}*/
bciAfterTx, err4 := channel.QueryInfo()
check(err4,"_6")
fmt.Println(" the peer block height %d",bciAfterTx.Height)
}
func check(e error , num string) {
if e != nil {
fmt.Println( errors.WithMessage(e, " find a error "+num))
}
}
类似资料：