在响应式编程领域，尤其是利用 Project Reactor 时，开发者可能会遇到在响应链中切换执行上下文的需求。为了解决这个问题，引入了两个操作符：subscribeOn 和 publishOn。默认情况下，Reactor 负责在调用订阅的线程执行整个管道。若希望切换执行线程，可采用 subscribeOn 和 publishOn 方法。简单例子展示，管道执行...
Java响应式编程 第六篇 subcribeOn vs publishOn
在响应式编程领域，尤其是利用 Project Reactor 时，开发者可能会遇到在响应链中切换执行上下文的需求。为了解决这个问题，引入了两个操作符：subscribeOn 和 publishOn。
默认情况下，Reactor 负责在调用订阅的线程执行整个管道。若希望切换执行线程，可采用 subscribeOn 和 publishOn 方法。简单例子展示，管道执行上下文始终为 "main"。
为了改变此行为，引入 subscribeOn() 方法，让订阅过程在特定线程池中进行。此处我们使用"Schedulers.boundElastic()"，为响应链条中任一点配置线程。例子中，开始于 "main" 线程的订阅被 "boundedElastic-1" 线程替换。
此外，publishOn() 方法允许从特定线程触发回调。此方法在响应链中某个位置放置，其效果是控制回调执行的线程。在两个 map 操作中应用此方法，观察结果，可以看到与主线程的执行隔离。在 publishOn 操作前的步骤持续在 "main" 线程中执行，随后的操作则在 "boundedElastic-1" 线程中执行。
由此发现，subscribeOn() 和 publishOn() 的关键区别在于，subscribeOn() 提供的调度器会应用于整个响应链，而 publishOn() 则控制特定操作的执行线程。合理选择这些方法可以帮助优化并发处理与线程管理。2024-10-24
