之前曾写过一篇介绍 Spring 提出的 Reactive Streams 实现方案 —— Project Reactor 的文章：《Reactor 入门与实践》，其中介绍了 Spring Reactor API 的用法。相信很多人都能发现，Spring Reactor 的 API 看上去和 Java 8 Stream 很像：

Project Reactor:

Flux.fromIterable(Character.captainAmerica3())
        .filter(Character::isPlay)
        .map(Character::getName)
        .subscribe(System.out::println);

Java 8 Stream:

Character.captainAmerica3().stream()
        .filter(Character::isPlay)
        .map(Character::getName)
        .forEach(System.out::println);

上面两段代码分别由 Spring Reactor 和 Java 8 Stream 实现，功能是打印《美队3》参演的角色名称。代码的形式和大部分方法名称都是相同的。

那 Spring Reactor 或者说 Reactive Streams 和 Java 8 Stream 的差别是什么呢？

简单来说，这两者最大的差别是前者是 Push-based，后者是 Pull-based。

Push 与 Pull

Reactive Streams 与 Java 8 Stream 最大的不同在于，前者是 Push 模式，后者是 Pull 模式。可能大部分人对推与拉的概念不是很了解。先做一个形象的介绍，常见的操作集合类的方式就是 Pull 模式：

List<User> users = userRpcClient.findAllUsers();
for (String user : users) {
    // do something
}

为什么说这样的代码是 Pull 模式呢？因为这样的代码，客户端主动向服务端请求数据，然后在操作数据。好比客户端主动从服务端拉取数据，故称为拉模式。

那 Push 模式是什么样呢？

userRpcPublisher.subscribe(new UserSubscriber() {
    public void onNext(User user) {
        // do something
    }
});

简单来说就是 Callback 风格的代码通常都是 Push 模式的。

Pull 模式的代码的问题在于，如果 userRpcClient.findAllUsers() 表示的操作是一个很耗时的操作，那 Pull-based 的代码的并发能力将很成问题。这就是 Push 模式出现的原因。

当然，上面两个例子只是为了给大家一个直观的介绍。并不是说传统形式的代码就一定是 Pull 模式，Callback 风格的代码就一定是 Pull 模式。

换言之，代码形式并不是 Pull 与 Push 的本质。从更深的层面说，Pull 模式对应的是同步的、命令式的程序，Push 模式对应的是异步的、非阻塞的、反应式的程序。

因此，虽然在代码形式上说 Java 8 Stream 和 Reactive Streams 的代码有些像，但从本质上来说，同步、阻塞的 Java 8 Stream 与异步、非阻塞的 Reactive Streams 有着很大的差别。

因此 Reactive Streams 不仅在形的层面，以接口定义的形式对反应式编程做出了规范，更在实的层面定义了 TCK，用来保证相关实现确实满足了异步、非阻塞等等的要求。