HyperLeger Fabric SDK開發(fā)（五）——event

一、event簡介

1、event簡介

event包支持訪問Fabric網(wǎng)絡(luò)上的通道事件。事件客戶端可以接收區(qū)塊事件，過濾區(qū)塊事件，鏈碼事件和交易狀態(tài)事件。
官方文檔：
https://godoc.org/github.com/hyperledger/fabric-sdk-go/pkg/client/event

成都創(chuàng)新互聯(lián)公司為企業(yè)級(jí)客戶提高一站式互聯(lián)網(wǎng)+設(shè)計(jì)服務(wù)，主要包括成都網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、成都App制作、小程序設(shè)計(jì)、宣傳片制作、LOGO設(shè)計(jì)等，幫助客戶快速提升營銷能力和企業(yè)形象，創(chuàng)新互聯(lián)各部門都有經(jīng)驗(yàn)豐富的經(jīng)驗(yàn)，可以確保每一個(gè)作品的質(zhì)量和創(chuàng)作周期，同時(shí)每年都有很多新員工加入，為我們帶來大量新的創(chuàng)意。 

2、event使用基本流程

event使用基本流程如下：
A、準(zhǔn)備通道客戶端上下文
B、創(chuàng)建事件客戶端
C、注冊(cè)事件
D、處理事件（或超時(shí)）
E、注銷事件
使用示例：

ec, err := New(mockChannelProvider("mychannel"))
if err != nil {
    fmt.Println("failed to create client")
}

registration, notifier, err := ec.RegisterChaincodeEvent("examplecc", "event123")
if err != nil {
    fmt.Println("failed to register chaincode event")
}
defer ec.Unregister(registration)

select {
case ccEvent := <-notifier:
    fmt.Printf("received chaincode event %v\n", ccEvent)
case <-time.After(time.Second * 5):
    fmt.Println("timeout while waiting for chaincode event")
}

// Timeout is expected since there is no event producer
// output:
// timeout while waiting for chaincode event

二、event常用接口

1、事件客戶端獲取

type Client struct {
   eventService      fab.EventService
   permitBlockEvents bool
   fromBlock         uint64
   seekType          seek.Type
}
func New(channelProvider context.ChannelProvider, opts ...ClientOption) (*Client, error)

返回事件客戶端實(shí)例?？蛻舳私邮諈^(qū)塊事件，過濾區(qū)塊事件，鏈碼事件和交易狀態(tài)事件。
使用示例：

ctx := mockChannelProvider("mychannel")

ec, err := New(ctx, WithBlockEvents())
if err != nil {
    fmt.Println(err)
}

if ec != nil {
    fmt.Println("event client created")
} else {
    fmt.Println("event client is nil")
}
// output:
// event client created

2、注冊(cè)區(qū)塊事件

func (c *Client) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error)
注冊(cè)塊事件。如果調(diào)用者沒有注冊(cè)區(qū)塊事件的權(quán)限，則返回錯(cuò)誤。不再需要注冊(cè)時(shí)，必須調(diào)用取消注冊(cè)。
參數(shù)：
filter是一個(gè)可選的過濾器，可過濾掉不需要的事件。只能指定一個(gè)過濾器。
返回：注冊(cè)對(duì)象和用于接收事件的通道。調(diào)用Unregister時(shí)，通道將關(guān)閉。
使用示例：

ec, err := New(mockChannelProvider("mychannel"), WithBlockEvents())
if err != nil {
    fmt.Println("failed to create client")
}

registration, _, err := ec.RegisterBlockEvent()
if err != nil {
    fmt.Println("failed to register block event")
}
defer ec.Unregister(registration)

fmt.Println("block event registered successfully")
// output:
// block event registered successfully

3、注冊(cè)鏈碼事件

func (c *Client) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error)
注冊(cè)鏈代碼事件。不再需要注冊(cè)時(shí)，必須調(diào)用Unregister。
參數(shù):
ccID是用于接收事件的鏈碼ID
eventFilter是用于接收事件的鏈碼事件過濾器（正則表達(dá)式）
返回：注冊(cè)對(duì)象和用于接收事件的通道。 調(diào)用取消注冊(cè)時(shí)，通道將關(guān)閉。
使用示例：

ec, err := New(mockChannelProvider("mychannel"))
if err != nil {
    fmt.Println("failed to create client")
}

registration, _, err := ec.RegisterChaincodeEvent("examplecc", "event123")
if err != nil {
    fmt.Println("failed to register chaincode event")
}
defer ec.Unregister(registration)

fmt.Println("chaincode event registered successfully")
// output:
// chaincode event registered successfully

使用示例：

// If you require payload for chaincode events you have to use WithBlockEvents() option
ec, err := New(mockChannelProvider("mychannel"), WithBlockEvents())
if err != nil {
    fmt.Println("failed to create client")
}

registration, _, err := ec.RegisterChaincodeEvent("examplecc", "event123")
if err != nil {
    fmt.Println("failed to register chaincode event")
}
defer ec.Unregister(registration)

fmt.Println("chaincode event registered successfully")
// output:
// chaincode event registered successfully

4、注冊(cè)過濾區(qū)塊事件

func (c *Client) RegisterFilteredBlockEvent() (fab.Registration, <-chan *fab.FilteredBlockEvent, error)
注冊(cè)過濾區(qū)塊事件。當(dāng)不再需要注冊(cè)時(shí)，必須調(diào)用Unregister。
返回：注冊(cè)對(duì)象和用于接收事件的通道。調(diào)用Unregister時(shí)，通道將關(guān)閉。
使用示例：

ec, err := New(mockChannelProvider("mychannel"))
if err != nil {
    fmt.Println("failed to create client")
}

registration, _, err := ec.RegisterFilteredBlockEvent()
if err != nil {
    fmt.Println("failed to register filtered block event")
}
defer ec.Unregister(registration)

fmt.Println("filtered block event registered successfully")
// output:
// filtered block event registered successfully

5、注冊(cè)交易狀態(tài)事件

func (c *Client) RegisterTxStatusEvent(txID string) (fab.Registration, <-chan *fab.TxStatusEvent, error)
注冊(cè)交易狀態(tài)事件。不再需要注冊(cè)時(shí)，必須調(diào)用Unregister。
參數(shù):
txID是用于接收事件的交易ID
返回：注冊(cè)對(duì)象和用于接收事件的通道。調(diào)用Unregister時(shí)，通道將關(guān)閉。
使用示例：

ec, err := New(mockChannelProvider("mychannel"))
if err != nil {
    fmt.Println("failed to create client")
}

registration, _, err := ec.RegisterTxStatusEvent("tx123")
if err != nil {
    fmt.Println("failed to register tx status event")
}
defer ec.Unregister(registration)

fmt.Println("tx status event registered successfully")
// output:
// tx status event registered successfully

6、注銷

func (c *Client) Unregister(reg fab.Registration)
刪除給定的注冊(cè)對(duì)象并關(guān)閉事件通道。
參數(shù):
reg是從其中一個(gè)注冊(cè)函數(shù)返回的注冊(cè)句柄

7、ClientOption選項(xiàng)構(gòu)建

type ClientOption func(*Client) error
func WithBlockEvents() ClientOption

WithBlockEvents指示要接收的區(qū)塊事件。 注意，調(diào)用者必須具有此選項(xiàng)的足夠權(quán)限。
func WithBlockNum(from uint64) ClientOption
WithBlockNum表示用于接收事件的區(qū)塊編號(hào)。只有deliverclient支持次選項(xiàng)。
func WithSeekType(seek seek.Type) ClientOption
WithSeekType表示所需的搜索類型，最新，最舊或來自給定區(qū)塊，只有deliverclient支持此項(xiàng)。

三、event示例

var (
   sdk           *fabsdk.FabricSDK
   channelName   = "assetchannel"
   org           = "org1"
   user          = "Admin"
)
ctx := sdk.ChannelContext(channelName, fabsdk.WithOrg(org), fabsdk.WithUser(user))

cli, err := event.New(ctx)
if err != nil {
panic(err)
}

// 區(qū)塊事件
reg, blkevent, err := cli.RegisterBlockEvent()
if err != nil {
panic(err)
}
defer cli.Unregister(reg)

timeoutctx, cancel := context.WithTimeout(context.Background(), time.Minute)
defer cancel()

for {
    select {
    case evt := <-blkevent:
    fmt.Printf("received a block", evt)
    case <-timeoutctx.Done():
    fmt.Println("event timeout, exit!")
    return
}

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。

名稱欄目：HyperLegerFabricSDK開發(fā)（五）——event-創(chuàng)新互聯(lián)
標(biāo)題鏈接：http://weahome.cn/article/igopi.html