Java9异步编程-反应式流运用
发布时间：2021-12-06 10:38:14 所属栏目：语言 来源：互联网
导读：Reactive API总览 要构建一个流，主要使用三个抽象，并将它们组合成异步处理逻辑。 每个流都需要处理由Publisher实例发布给它的事件;发布者有一个subscribe()的方法。 如果某个订阅者希望接收发布者发布的事件，则需要使用subscribe()订阅发布者。 消息的接收
|
Reactive API总览 要构建一个流，主要使用三个抽象，并将它们组合成异步处理逻辑。 每个流都需要处理由Publisher实例发布给它的事件;发布者有一个subscribe()的方法。 如果某个订阅者希望接收发布者发布的事件，则需要使用subscribe()订阅发布者。 消息的接收方需要实现订阅者接口。一般情况下，接受者是每个Flow处理的结束，因为它的实例不会进一步发送消息。 可以将Subscriber看作Sink。有四个方法需要重写onSubscribe()， onNext()， onError()和onComplete()。 如果希望转换传入的消息并将其进一步传递给下一个订阅服务，则需要实现Processor接口。 它既充当订阅服务(因为它接收消息)，又充当发布服务(因为它处理这些消息并将它们发送以进行进一步处理)。 发布和消费消息 假设想要创建一个简单的流，其中有一个发布者发布消息，一个简单的订阅者在消息到达时使用消息。 先创建一个EndSubscriber类。需要实现订阅服务接口。接下来，重写所需的方法。 onSubscribe()方法在处理开始之前被调用。 （编辑：ASP站长） 【免责声明】本站内容转载自互联网，其相关言论仅代表作者个人观点绝非权威，不代表本站立场。如您发现内容存在版权问题，请提交相关链接至邮箱：bqsm@foxmail.com，我们将及时予以处理。 |
相关内容
未处理完善
-
无相关信息
最新更新