核心概念

    多机构之间的合作,一般每个机构都会部署自己的WeEvent服务。例如:

    机构A通过属于A的WeEvent服务发布事件,机构B通过自己的WeEvent服务订阅事件。如果生产者和发布者属于同一机构,可以使用同一套服务。

    事件Event可以简单理解成业务层面的一个消息。一般是终端用户或设备触发。

    事件内容是一个字节数组byte[],对WeEvent是透明的。业务可以存放任何数据,例如字符型的JsonXML ,或者二进制的Protocol Buffer等。

    业务上一般把数据结构相同,属于同类型的事件归属于同一主题Topic

    每个主题Topic逻辑上都有彼此独立的队列。主题之间是完全隔离的,存储、通知都不会互相影响。

    生产者往某个主题发布事件,WeEvent会将事件永久存储在区块链FISCO-BCOS上,不可篡改,支持事后审核。

    消费者Consumer订阅某个主题后,当有生产者往该主题发布事件,消费者会及时收到事件通知。

    订阅成功时WeEvent会返回一个的订阅IDSubscriptionID,代表完成一次订阅,订阅ID具有唯一性。

    除了实时订阅最新的事件,WeEvent也支持从某个历史事件EventID之后开始订阅。

    消费者通过订阅IDSubscriptionID 取消一个订阅后,不会再收到该主题的事件通知。