Kevin のわかりやすい Spring Reactive Web Applications: Reactor 第 2 部

セクション 1: Creating a new sequence

セクション1では、Reactor Sequenceを新しく作成するOperatorについて学習します。

• justOrEmpty ： justOrEmpty Operatorを使用して、Reactor Sequenceに1つの値または空の（Empty）Sequenceを生成する方法を学びます。

• fromIterable: Java のCollection に含まれるデータから Sequence を生成する方法を学習します。

• fromStream : fromStream Operator を使用して Java Stream から Sequence を生成する方法を学習します。

• range : range Operator を使って定められた範囲内の整数 Sequence を生成する方法を学習します。

• defer ： defer Operatorを介してSubscriberが購読するまでデータの emit を遅らせる方法を理解します。

• using ： using Operatorを使用してリソースを取得および解放するプロセスを含むSequenceを生成する方法を学びます。

• generate、create ： generate 、 create Operatorを使用してプログラムでデータを生成する方法を学びます。

セクション 2: Filtering a sequence

セクション2では、Reactor SequenceでデータをフィルタリングするOperatorを学習します。

• filter ： filter Operatorを使用してReactor Sequenceでデータをフィルタリングする方法を学びます。

• skip : skip Operator を使用してシーケンスからデータをスキップする方法を学習します。

• skip 拡張 Operator : skipLast , skipUntil , skipUntilOther ,
  skipWhileを使用してさまざまな方法でデータをスキップする方法を学びます。

• take : take Operator を使用して、Sequence で emit されたデータの中から必要なデータのみを取得する方法を学習します。

• take 拡張 Operator : takeLast , takeUntil , takeUntilOther ,
  takeWhileを使用して、さまざまな方法で emitted データの中から必要なデータのみをインポートする方法について学習します。

• next : emitされたデータのうち、最初のデータだけを取得する方法を見てください。

  
  

セクション 3: Transforming an existing sequence

セクション3では、Reactor Sequenceからデータを変換するOperatorについて学習します。

• map : map Operator を使用して Sequence のデータを変換する方法を学習します。

• flatMap : flatMap Operator を使用して emit されるデータを変換する方法と平坦化の意味について理解する時間があります。

• flatMap 拡張 Operator : FlatMapIterable , FlatMapMany , FlatMapSequentialを使用したさまざまな方法の平坦化方法を学習します。

• concat ： concat Operatorを使用して複数のSequenceを接続する方法を学びます。

• merge ： merge Operatorを使用して複数のSeque nceをマージする方法を理解します。

• zip ： zip Operatorを使用して複数のSequenceのソースデータを結合する方法を学びます。

• and, when : and , when Operator で条件に応じて Reactor Sequence の終了を確認できる方法について学習します。

• then ：タスクを順次実行するためのthen Operatorを学習します。

• collectList, collectMap : どのデータを List または Map に入れて、一度に Downstream に emit するかを学習します。

セクション 4: Peeking into a sequence

セクション4では、Reactor Sequenceの内部を覗くことができるOperatorについて学びます。

• doOnXXXX ： doOnSubscribe 、 doOnRequest 、 doOnNext 、 doOnCompleteなどを使用してSequenceの内部を覗きながら、Sequenceのライフサイクルを理解します。

セクション 5: Working with time

セクション 5 では、Reactor Sequence が提供する Operator のうち、時間に関連する Operator を学習します。

• delayElements : 一定時間間隔でデータを emit させるdelayElementsについて学習します。

• delaySubscription vs delaySequence : delaySubscription と delaySequence の動作方法とそれぞれの違いを理解します。

• timeout : 指定された時間内にデータが emit されない場合にエラーを発生させるtimeout Operator について学習します。

セクション 6: Handling errors

セクション6では、Reactor Sequenceで発生するエラーを処理するために使用されるOperatorを学習します。

• error ： error Operatorを使用してReactor Sequenceでエラーを明示的にスローする方法を学びます。

• onErrorReturn, onErrorResume : onErrorReturnとonErrorResume Operator を利用してエラーが発生したときに代替値を emit したり、または代替 Sequence 開始する方法について学習します。

• onErrorContinue : onErrorContinue Operator を使用してエラーが発生しても Sequence が引き続き動作するようにする方法について学習します。

• onErrorMap ： onErrorMap Operatorを使用してSequenceで発生したエラーを新しい例外タイプに変換する方法を学びます。

• retry : retry Operator を使用してエラーが発生した場合に Sequence が再び動作するように再試行する方法について学習します。

  
  

セクション 7: Splitting a Flux

セクション7では、Reactor Sequenceで emitされるデータを分割するOperatorを学習します。

• window : window Operator を利用して emit されるデータを一定数の window に分けて emit する方法について学習します。

• buffer, bufferTimeout : bufferおよびbufferTimeout Operator を利用して emit されるデータをバッファに入れて emit する方法について学習します。

• groupBy : groupBy Operator を利用して emit されるデータを特定の基準に合わせてグループ化する方法について学習します。

  
  

セクション 8: Multicasting a Flux to several Subscribers

セクション8では、1つのFluxで複数のSubscriberにデータをマルチキャストするOperatorを学習します。

• publish : publish Operator を使って Sequence 上のデータをマルチキャストする方法について学習します。

• autoConnect ： autoConnect Operatorを使用して購読が発生したときにUpstreamソースに自動的に接続する方法を学びます。

• refCount ： refCount Operatorを使用して購読が発生したときにUpstreamソースに自動的に接続し、購読がキャンセルされたときにUpstreamソースから自動的に接続が解除される方法について学習します。

• replay : replay Operator を使用して新しいサブスクリプションが発生したときに Sequence 上のデータを再 emit する方法について学習します。

  
  

KevinのわかりやすいSpring Reactive Web Applicationsのフルレクチャーの構成

• パート1は、リアクティブプログラミングの概念とSpring Reactive Web Applicationの重要な役割を果たすProject Reactorについて説明します。

• パート2は、パート1で扱っていなかったProject ReactorのOperatorについてのみ扱います。 OperatorはReactorのいくつかの部品の中で最も重要な役割を果たしています。また、リアクティブプログラミングにある程度慣れている方が、Operatorの部分だけを別々に学習できるように、個別の講義で構成されています。

• パート3は、Spring WebFluxがどのように動作するかを理解した後に、アクティブなWebアプリケーションを作成するためのサンプルプロジェクト中心に構成されます。 （2024年度中にオープン予定です。）

学習資料

• 授業ごとに講義で使用されるPPT講義資料をダウンロードして確認できます。 PPT講義資料は、授業中に授業別にダウンロードできますが、授業別に分かれており、見にくい方は下記のGithub Repositoryでセクション別に統合されている講義資料を活用してください。

  • セクション別講義資料集

• クラスで説明したサンプルコードはすべてgithubにあり、以下のアドレスからダウンロードできます。

  • ソースサンプルソースコード

• すべてのクラスは5分から20分の間のビデオで構成されています。

• 第1部講義制作段階に記録された映像が一定部分含まれており、一部の授業映像ではパッケージ構造が元のサンプルソースコードと異なって見える場合がありますので参考にお願いします。

選手の知識と注意事項

• Javaプレーヤーの知識は必須です。

• Reactorの学習経験がある方は、第1部講義を必ず受講する必要はありません。

• Reactorの学習経験がない人や、リアクティブプログラミングの概念に初めて触れる方は、第1部講義を学習することをお勧めします。

• サンプルコードをブログなどで使用する場合は、出所を残してください。

• 講義で使用されたマーベルダイアグラム画像（Reactor公式サイト画像を除く）は著作権がありますので、ブログなど他サイトではご使用いただけません。