Reactive API总览
要构建一个流,主要使用三个抽象,并将它们组合成异步处理逻辑。
每个流都需要处理由Publisher实例发布给它的事件;发布者有一个subscribe()的方法。
如果某个订阅者希望接收发布者发布的事件,则需要使用subscribe()订阅发布者。
消息的接收方需要实现订阅者接口。一般情况下,接受者是每个Flow处理的结束,因为它的实例不会进一步发送消息。
可以将Subscriber看作Sink。有四个方法需要重写onSubscribe(), onNext(), onError()和onComplete()。
如果希望转换传入的消息并将其进一步传递给下一个订阅服务,则需要实现Processor接口。
它既充当订阅服务(因为它接收消息),又充当发布服务(因为它处理这些消息并将它们发送以进行进一步处理)。
发布和消费消息
假设想要创建一个简单的流,其中有一个发布者发布消息,一个简单的订阅者在消息到达时使用消息。
先创建一个EndSubscriber类。需要实现订阅服务接口。接下来,重写所需的方法。
onSubscribe()方法在处理开始之前被调用。
大型站长资讯类网站! https://www.0833zz.com