jms - JMS 与响应式流有何不同？

Question

我正在学习 API 中的 Reactive Streams，我对它与 JMS 之间的相似性感到震惊。在 JMS 中，我们也有异步处理、发布者和订阅者。我在进行这种等效时缺少什么观点？

Answer 1

Reactive Streams 是面向背压的，JMS 是面向消息的。尽管您可以使用 JMS 进行背压。

阻塞 API(非响应式)
java.util.concurrent.Future::get <-> javax.jms.MessageConsumer.receive
非阻塞 API
org.reactivestreams.Publisher::subscribe <-> javax.jms.MessageConsumer::setMessageListenerorg.reactivestreams.Subscriber::onNext <-> javax.jms.MessageListener::onMessage
背压 API <-> 消息 API
org.reactivestreams.Subscription::request <-> javax.jms.MessageProducer::send
初始化/终结/错误处理
org.reactivestreams.Subscriber::onSubscribe <-> javax.jms.MessageListener::onMessageorg.reactivestreams.Subscriber::onError <-> javax.jms.MessageListener::onMessageorg.reactivestreams.Subscriber::onComplete <-> javax.jms.MessageListener::onMessageorg.reactivestreams.Subscription::cancel <-> javax.jms.MessageProducer::send