13.7应用开发案例四：发送事件

Fabric应用程序除了通过主动查询来获取当前已确认的状态&＃xff0c;还可以通过订阅并监听事件&＃xff08;event&＃xff09;来获取交易执行信息&＃xff0c;用于进行交易确认或者审计。

本节的例子将展示如何在链码中发送事件。详细代码可见examples/chaincode/go/eventsender/eventsender.go。

发送事件需要使用stub.SetEvent方法。方法格式为SetEvent&＃xff08;namestring&＃xff0c;payload[]byte&＃xff09;error。其中&＃xff0c;name表示事件名称&＃xff0c;payload为事件内容。

通过该方法&＃xff0c;可以设定当这个交易在Committer处被认证通过&＃xff0c;写入到区块时所发送的事件。

示例链码的invoke分支方法被调用时&＃xff0c;会将记录在账本中的递增序列和Invoke传入的参数串联起来作为事件内容&＃xff0c;以evtsender为事件名称&＃xff0c;调用stub.SetEvent方法。

关键代码如下所示&＃xff1a;

func (t *EventSender) invoke(stub shim.ChaincodeStubInterface, args []string)pb.Response {b, err :&＃61; stub.GetState("noevents")if err !&＃61; nil {return shim.Error("Failed to get state")}noevts, _ :&＃61; strconv.Atoi(string(b))tosend :&＃61; "Event " &＃43; string(b)for _, s :&＃61; range args {tosend &＃61; tosend &＃43; "," &＃43; s}err &＃61; stub.PutState("noevents", []byte(strconv.Itoa(noevts&＃43;1)))if err !&＃61; nil {return shim.Error(err.Error())}err &＃61; stub.SetEvent("evtsender", []byte(tosend))if err !&＃61; nil {return shim.Error(err.Error())}return shim.Success(nil)
}

应用开发者可以使用SDK中封装的方法监听链码发出的事件&＃xff0c;并据此作出处理逻辑。也可以简单用Fabric提供的block-listener工具监听并查看事件。

block-listener工具代码位于examples/events/block-listener&＃xff0c;其中展示了如何利用事件客户端来从网络中获取事件信息。创建事件客户端的核心代码如下所示&＃xff1a;

func createEventClient(eventAddress string, _ string) *adapter {var obcEHClient *consumer.EventsClientdone :&＃61; make(chan *pb.Event_Block)adapter :&＃61; &adapter{notfy: done}obcEHClient, _ &＃61; consumer.NewEventsClient(eventAddress, 5, adapter)if err :&＃61; obcEHClient.Start(); err !&＃61; nil {fmt.Printf("could not start chat. err: %s\n", err)obcEHClient.Stop()return nil}return adapter
}

来源&＃xff1a;我是码农&＃xff0c;转载请保留出处和链接&＃xff01;

本文链接&＃xff1a;http://www.54manong.com/?id&＃61;891