HyperLegerFabricSDK开发(五)——event
HyperLeger Fabric SDK开发(五)——event
一、event简介
1、event简介
event包支持访问Fabric网络上的通道事件。事件客户端可以接收区块事件,过滤区块事件,链码事件和交易状态事件。
官方文档:
https://godoc.org/github.com/hyperledger/fabric-sdk-go/pkg/client/event
目前创新互联已为上1000+的企业提供了网站建设、域名、网站空间、网站托管、服务器托管、企业网站设计、果洛州网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。
2、event使用基本流程
event使用基本流程如下:
A、准备通道客户端上下文
B、创建事件客户端
C、注册事件
D、处理事件(或超时)
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)
返回事件客户端实例。客户端接收区块事件,过滤区块事件,链码事件和交易状态事件。
使用示例:
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、注册区块事件
func (c *Client) RegisterBlockEvent(filter ...fab.BlockFilter) (fab.Registration, <-chan *fab.BlockEvent, error)
注册块事件。如果调用者没有注册区块事件的权限,则返回错误。不再需要注册时,必须调用取消注册。
参数:
filter是一个可选的过滤器,可过滤掉不需要的事件。只能指定一个过滤器。
返回:注册对象和用于接收事件的通道。调用Unregister时,通道将关闭。
使用示例:
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、注册链码事件
func (c *Client) RegisterChaincodeEvent(ccID, eventFilter string) (fab.Registration, <-chan *fab.CCEvent, error)
注册链代码事件。不再需要注册时,必须调用Unregister。
参数:
ccID是用于接收事件的链码ID
eventFilter是用于接收事件的链码事件过滤器(正则表达式)
返回:注册对象和用于接收事件的通道。 调用取消注册时,通道将关闭。
使用示例:
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、注册过滤区块事件
func (c *Client) RegisterFilteredBlockEvent() (fab.Registration, <-chan *fab.FilteredBlockEvent, error)
注册过滤区块事件。当不再需要注册时,必须调用Unregister。
返回:注册对象和用于接收事件的通道。调用Unregister时,通道将关闭。
使用示例:
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、注册交易状态事件
func (c *Client) RegisterTxStatusEvent(txID string) (fab.Registration, <-chan *fab.TxStatusEvent, error)
注册交易状态事件。不再需要注册时,必须调用Unregister。
参数:
txID是用于接收事件的交易ID
返回:注册对象和用于接收事件的通道。调用Unregister时,通道将关闭。
使用示例:
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)
删除给定的注册对象并关闭事件通道。
参数:
reg是从其中一个注册函数返回的注册句柄
7、ClientOption选项构建
type ClientOption func(*Client) error
func WithBlockEvents() ClientOption
WithBlockEvents指示要接收的区块事件。 注意,调用者必须具有此选项的足够权限。func WithBlockNum(from uint64) ClientOption
WithBlockNum表示用于接收事件的区块编号。只有deliverclient支持次选项。
func WithSeekType(seek seek.Type) ClientOption
WithSeekType表示所需的搜索类型,最新,最旧或来自给定区块,只有deliverclient支持此项。
三、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)
}
// 区块事件
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
}
网站标题:HyperLegerFabricSDK开发(五)——event
标题URL:http://myzitong.com/article/pecdii.html