其他示例程序

快速入门 一个展示了Rector 基本组件数种使用方法的应用。

示例代码 一个通过 JUnit 测试演示 Reactor 功能的简单示例应用。

非阻塞的作弊码

如果你深入到这一步的话，这里有一个非阻塞数据流的示例，让你识别 websocket 中的作弊码。告诉我它的奖励… 不要忘记在 reactor-net 的 classpath 中添加你的 Netty 地址。

  1. final Processor<Integer, Integer> keyboardStream = RingBufferProcessor.create();
  3. NetStreams.<String, String>httpServer(spec ->
  4.                 spec
  5.                         .codec(StandardCodecs.STRING_CODEC)
  6.                         .listen(3000)
  7.         )
  8.         .ws("/", channel -> {
  9.                 System.out.println("Connected a websocket client: " + channel.remoteAddress());
  11.                 return Streams
  12.                         .wrap(keyboardStream)
  13.                         .skipWhile(key -> KeyEvent.VK_UP != key)
  14.                         .buffer(10, 1) 
  15.                         .map(keys -> keys.size() == 10 &&
  16.                                 keys.get(0) == KeyEvent.VK_UP &&
  17.                                 keys.get(1) == KeyEvent.VK_UP &&
  18.                                 keys.get(2) == KeyEvent.VK_DOWN &&
  19.                                 keys.get(3) == KeyEvent.VK_DOWN &&
  20.                                 keys.get(4) == KeyEvent.VK_LEFT &&
  21.                                 keys.get(5) == KeyEvent.VK_RIGHT &&
  22.                                 keys.get(6) == KeyEvent.VK_LEFT &&
  23.                                 keys.get(7) == KeyEvent.VK_RIGHT &&
  24.                                 keys.get(8) == KeyEvent.VK_B &&
  25.                                 keys.get(9) == KeyEvent.VK_A
  26.                 )
  27.                 .map(isKonami -> isKonami ? "Konami!" : "Nah")
  28.                 .nest()
  29.                 .flatMap(konamis ->
  30.                         channel.writeWith(konamis)
  31.                 );
  32.         })
  33.         .start()
  34.         .await();
  36. keyboardStream.onNext(KeyEvent.VK_RIGHT);
  37. keyboardStream.onNext(KeyEvent.VK_UP);
  38. keyboardStream.onNext(KeyEvent.VK_UP);
  39. keyboardStream.onNext(KeyEvent.VK_DOWN);
  40. keyboardStream.onNext(KeyEvent.VK_DOWN);
  41. keyboardStream.onNext(KeyEvent.VK_LEFT);
  42. keyboardStream.onNext(KeyEvent.VK_RIGHT);
  43. keyboardStream.onNext(KeyEvent.VK_LEFT);
  44. keyboardStream.onNext(KeyEvent.VK_RIGHT);
  45. keyboardStream.onNext(KeyEvent.VK_B);
  46. keyboardStream.onNext(KeyEvent.VK_A);
  47. keyboardStream.onNext(KeyEvent.VK_C);
  48. keyboardStream.onComplete();
  50. System.out.println(konamis.await());
  • 注意 buffer(size, skip) 的使用，我们希望评估至少10按键之间的全部组合，10 乘 10。就是说我们要创建一个包含所有按键、且每个按键都有10个按键的列表。

1. 除非你希望使用现阶段几乎独立的核心处理器。我们计划在下一步调整调度器和核心处理器，使它们相互协作。2. 有些人可能会挑战这种过度简化的愿景，但还是允许我们在这里更务实些吧 ：）3. 包括 Akka Streams，Ratpack 和 RxJava