如何解决设计等待发布者的反压-反应式编程
我使用projectreactor
以reactive
的方式用Java开发我的个人项目。让我们在下面的图片上看到:
在我的设计中,有一些发布者线程想要将消息发布到通量或通过通量,并且有一些订阅者处理消息。现在,订户可能太慢了。因此,我需要一些背压机制。而且我知道有一些背压策略,但是没有任何一种策略可以满足我的期望。我希望我的发布者仅阻止(等待),直到消息缓冲区(几乎)为空。
那么,如何以反应方式实现它?
解决方法
并行活动可以有两种:线程和参与者(也称为异步过程)。他们在沟通方式上有所不同。助焊剂是演员的交流对象。它不适合连接线程。线程与BlockingQueue连接良好。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。