آموزش برنامه نویسی واکنشی در جاوا مدرن با استفاده از Project Reactor

سرفصل ها و درس ها

معرفی Introduction

• مقدمه و اهداف دوره Course Introduction & Objectives

• مقدمه و اهداف دوره Course Introduction & Objectives

• پیش نیازها Prerequisites

معرفی Introduction

• پیش نیازها Prerequisites

اسلایدهای دوره و کد منبع Course Slides & Source Code

• اسلایدهای دوره Course Slides

• اسلایدهای دوره Course Slides

• کد منبع Source Code

اسلایدهای دوره و کد منبع Course Slides & Source Code

• کد منبع Source Code

مقدمه ای بر برنامه نویسی واکنشی Introduction to Reactive Programming

• چرا برنامه نویسی واکنشی؟ Why Reactive Programming?

• چرا برنامه نویسی واکنشی؟ Why Reactive Programming?

• برنامه نویسی واکنشی چیست؟ What is Reactive Programming ?

• برنامه نویسی واکنشی چیست؟ What is Reactive Programming ?

• مقدمه ای بر جریان های واکنشی Introduction to Reactive Streams

مقدمه ای بر برنامه نویسی واکنشی Introduction to Reactive Programming

• مقدمه ای بر جریان های واکنشی Introduction to Reactive Streams

شروع کار با Project Reactor Getting Started with Project Reactor

• مقدمه ای بر Project Reactor Introduction to Project Reactor

• انواع راکتور راکتیو - شار و مونو Reactor Reactive Types - Flux and Mono

شروع کار با Project Reactor Getting Started with Project Reactor

• مقدمه ای بر Project Reactor Introduction to Project Reactor

• انواع راکتور راکتیو - شار و مونو Reactor Reactive Types - Flux and Mono

راه اندازی پروژه برای این دوره Setting up the Project for this course

• راه اندازی پروژه Project SetUp

• راه اندازی پروژه Project SetUp

راه اندازی پروژه برای این دوره Setting up the Project for this course

برنامه نویسی تابعی در جاوا مدرن Functional Programming in Modern Java

• سبک امری در مقابل سبک عملکردی Imperative Style vs Functional Style

برنامه نویسی تابعی در جاوا مدرن Functional Programming in Modern Java

• سبک امری در مقابل سبک عملکردی Imperative Style vs Functional Style

بیایید اولین Flux و Mono خود را ایجاد کنیم Lets create our very first Flux and Mono

• بیایید اولین Flux خود را بنویسیم Let's write our very first Flux

• بیایید اولین Flux خود را بنویسیم Let's write our very first Flux

• بیایید اولین مونو خود را بنویسیم Let's write our very first Mono

• بیایید اولین مونو خود را بنویسیم Let's write our very first Mono

• رویدادهای جریان واکنشی Reactive Stream Events

• رویدادهای جریان واکنشی Reactive Stream Events

• تست Flux با استفاده از JUnit5 Testing Flux using JUnit5

• تست Flux با استفاده از JUnit5 Testing Flux using JUnit5

• تست مونو با استفاده از JUnit5 Testing Mono using JUnit5

• تست مونو با استفاده از JUnit5 Testing Mono using JUnit5

بیایید اولین Flux و Mono خود را ایجاد کنیم Lets create our very first Flux and Mono

تبدیل شار و مونو Transforming Flux and Mono

• با استفاده از عملگر map() تبدیل کنید Transform using map() Operator

• تبدیل داده ها با استفاده از اپراتورها در پروژه راکتور Transforming Data Using Operators in Project Reactor

• تبدیل داده ها با استفاده از اپراتورها در پروژه راکتور Transforming Data Using Operators in Project Reactor

• جریان های واکنشی تغییر ناپذیر هستند Reactive Streams are Immutable

• با استفاده از عملگر filter() فیلتر کنید Filter using filter() Operator

• با استفاده از عملگر filter() فیلتر کنید Filter using filter() Operator

• نقشه، فیلتر اپراتورها در مونو Map , Filter Operators in Mono

• تبدیل پیشرفته با استفاده از عملگر flatMap(). Advanced transform using the flatMap() Operator

• عملیات ناهمزمان با استفاده از عملگر flatMap(). Asynchronous Operations using flatMap() Operator

• تبدیل پیشرفته با استفاده از عملگر ()concatMap Advanced transform using the concatMap() Operator

• تبدیل پیشرفته با استفاده از عملگر ()concatMap Advanced transform using the concatMap() Operator

• عملگر flatMap( ) در مونو flatMap( ) operator in Mono

• عملگر flatMapMany( ) در مونو flatMapMany( ) operator in Mono

• عملگر flatMapMany( ) در مونو flatMapMany( ) operator in Mono

• با استفاده از عملگر transform() تبدیل کنید Transform using the transform() Operator

• مدیریت داده های خالی با استفاده از عملگرهای defaultIfEmpty و switchIfEmpty() Handling empty data using defaultIfEmpty and switchIfEmpty() Operators

• مدیریت داده های خالی با استفاده از عملگرهای defaultIfEmpty و switchIfEmpty() Handling empty data using defaultIfEmpty and switchIfEmpty() Operators

• DefaultIfEmpty و SwitchIfEmpty در Mono Operator DefaultIfEmpty and SwitchIfEmpty in Mono Operator

تبدیل شار و مونو Transforming Flux and Mono

• با استفاده از عملگر map() تبدیل کنید Transform using map() Operator

• جریان های واکنشی تغییر ناپذیر هستند Reactive Streams are Immutable

• نقشه، فیلتر اپراتورها در مونو Map , Filter Operators in Mono

• تبدیل پیشرفته با استفاده از عملگر flatMap(). Advanced transform using the flatMap() Operator

• عملیات ناهمزمان با استفاده از عملگر flatMap(). Asynchronous Operations using flatMap() Operator

• عملگر flatMap( ) در مونو flatMap( ) operator in Mono

• با استفاده از عملگر transform() تبدیل کنید Transform using the transform() Operator

• DefaultIfEmpty و SwitchIfEmpty در Mono Operator DefaultIfEmpty and SwitchIfEmpty in Mono Operator

ترکیب فلاکس و مونو Combining Flux and Mono

• مقدمه ای بر ترکیب جریان های واکنشی Introduction to Combining Reactive Streams

• مقدمه ای بر ترکیب جریان های واکنشی Introduction to Combining Reactive Streams

• عملگر concat() و concatWith(). concat() & concatWith() operator

• تکلیف برای نوشتن موارد تست JUnit5 برای concatWith() با استفاده از Flux و Mono Assignment for Writing JUnit5 Test Cases for concatWith() using Flux and Mono

• ترکیب جریان های واکنشی با استفاده از اپراتورهای merge() و mergeWith(). Combining Reactive Streams using merge() and mergeWith() Operators

• ترکیب جریان های واکنشی با استفاده از اپراتورهای merge() و mergeWith(). Combining Reactive Streams using merge() and mergeWith() Operators

• تکلیف برای نوشتن موارد تست JUnit5 برای mergeWith با استفاده از Flux و Mono Assignment for Writing JUnit5 Test Cases for mergeWith using Flux and Mono

• تکلیف برای نوشتن موارد تست JUnit5 برای mergeWith با استفاده از Flux و Mono Assignment for Writing JUnit5 Test Cases for mergeWith using Flux and Mono

• ترکیب جریان های واکنشی با استفاده از عملگر mergeSequential(). Combining Reactive Streams using mergeSequential() operator

• ترکیب جریان های واکنشی با استفاده از عملگر mergeSequential(). Combining Reactive Streams using mergeSequential() operator

• ترکیب جریان های واکنشی با استفاده از عملگر zip و zipWith(). Combining Reactive Streams using zip and zipWith() Operator

• تکلیف نوشتن موارد تست JUnit5 برای zip با استفاده از Flux و Mono Assignment for Writing JUnit5 Test Cases for zipWith using Flux and Mono

ترکیب فلاکس و مونو Combining Flux and Mono

• عملگر concat() و concatWith(). concat() & concatWith() operator

• تکلیف برای نوشتن موارد تست JUnit5 برای concatWith() با استفاده از Flux و Mono Assignment for Writing JUnit5 Test Cases for concatWith() using Flux and Mono

• ترکیب جریان های واکنشی با استفاده از عملگر zip و zipWith(). Combining Reactive Streams using zip and zipWith() Operator

• تکلیف نوشتن موارد تست JUnit5 برای zip با استفاده از Flux و Mono Assignment for Writing JUnit5 Test Cases for zipWith using Flux and Mono

ساخت Movie ReactiveService با استفاده از Project Reactor Build Movie ReactiveService using Project Reactor

• مروری بر این MovieService Overview of this MovieService

• همه MovieInfo را بازیابی کنید Retrieve all of the MovieInfo

• همه MovieInfo را بازیابی کنید Retrieve all of the MovieInfo

• بازیابی MovieInfo توسط movieId Retrieve MovieInfo by movieId

• پیاده سازی getMovieById با استفاده از عملگر FlatMap در مونو Implement getMovieById using FlatMap operator in Mono

• پیاده سازی getMovieById با استفاده از عملگر FlatMap در مونو Implement getMovieById using FlatMap operator in Mono

ساخت Movie ReactiveService با استفاده از Project Reactor Build Movie ReactiveService using Project Reactor

• مروری بر این MovieService Overview of this MovieService

• بازیابی MovieInfo توسط movieId Retrieve MovieInfo by movieId

doOn* CallBacks - نگاه کردن به یک دنباله doOn* CallBacks - Peeking into a Sequence

• doOn* CallBacks doOn* CallBacks

doOn* CallBacks - نگاه کردن به یک دنباله doOn* CallBacks - Peeking into a Sequence

• doOn* CallBacks doOn* CallBacks

مدیریت استثنا/خطا در Flux و Mono Exception/Error Handling in Flux and Mono

• استثناها در جریان های واکنشی Exceptions in Reactive Streams

• مقدمه ای بر اپراتورهای رسیدگی به استثنا Introduction to Exception Handling Operators

• onErrorReturn(): اپراتور کنترل استثنا onErrorReturn() : Exception Handling Operator

• onErrorReturn(): اپراتور کنترل استثنا onErrorReturn() : Exception Handling Operator

• onErrorResume(): اپراتور Exception Handling onErrorResume() : Exception Handling Operator

• onErrorContinue(): اپراتور Exception Handling onErrorContinue() : Exception Handling Operator

• onErrorMap (): اپراتور کنترل استثنا onErrorMap() : Exception Handling Operator

• onErrorMap (): اپراتور کنترل استثنا onErrorMap() : Exception Handling Operator

• doOnError(): گرفتن استثناها و پرتاب خطا doOnError() : Catching Exceptions and Throw the error

• مدیریت خطای اپراتورها در مونو Error Handling Operators in Mono

• مدیریت خطای اپراتورها در مونو Error Handling Operators in Mono

• onErrorMap() را در مونو کاوش کنید Explore onErrorMap() in Mono

• onErrorMap() را در مونو کاوش کنید Explore onErrorMap() in Mono

• اپراتور onErrorContinue() را در مونو کاوش کنید Explore onErrorContinue() Operator in Mono

مدیریت استثنا/خطا در Flux و Mono Exception/Error Handling in Flux and Mono

• استثناها در جریان های واکنشی Exceptions in Reactive Streams

• مقدمه ای بر اپراتورهای رسیدگی به استثنا Introduction to Exception Handling Operators

• onErrorResume(): اپراتور Exception Handling onErrorResume() : Exception Handling Operator

• onErrorContinue(): اپراتور Exception Handling onErrorContinue() : Exception Handling Operator

• doOnError(): گرفتن استثناها و پرتاب خطا doOnError() : Catching Exceptions and Throw the error

• اپراتور onErrorContinue() را در مونو کاوش کنید Explore onErrorContinue() Operator in Mono

اجرای Exception Handling در Movies Reactive Service Implement Exception Handling in Movies Reactive Service

• مدیریت استثنا در MoviesReactiveService با استفاده از onErrorMap Exception Handling in MoviesReactiveService using onErrorMap

• مدیریت استثنا در MoviesReactiveService با استفاده از onErrorMap Exception Handling in MoviesReactiveService using onErrorMap

• تست استثنا در MoviesReactiveService با استفاده از Mockito Test Exception in MoviesReactiveService using Mockito

• تست استثنا در MoviesReactiveService با استفاده از Mockito Test Exception in MoviesReactiveService using Mockito

اجرای Exception Handling در Movies Reactive Service Implement Exception Handling in Movies Reactive Service

دوباره امتحان کنید، با استفاده از retry()، retryWhen()، تکرار() تکرار کنید Retry, Repeat using retry(), retryWhen(), repeat()

• امتحان مجدد استثناها با استفاده از retry() و retry(n) Retry Exceptions using retry() and retry(n)

• امتحان مجدد استثناها با استفاده از retry() و retry(n) Retry Exceptions using retry() and retry(n)

• امتحان مجدد استثناهای خاص با استفاده از retryWhen() Retry Specific Exceptions using retryWhen()

• امتحان مجدد استثناهای خاص با استفاده از retryWhen() Retry Specific Exceptions using retryWhen()

• یک دنباله را با استفاده از repeat() و repeat(n) تکرار کنید Repeat a Sequence using repeat() and repeat(n)

• یک دنباله را با استفاده از repeat() و repeat(n) تکرار کنید Repeat a Sequence using repeat() and repeat(n)

دوباره امتحان کنید، با استفاده از retry()، retryWhen()، تکرار() تکرار کنید Retry, Repeat using retry(), retryWhen(), repeat()

مدل اجرای راکتورها - زمان‌بندی‌ها، رشته‌ها و Threadpool Reactors Execution Model - Schedulers, Threads and Threadpool

• مدل اجرای راکتور Reactor Execution Model

• تغییر رشته ها با استفاده از publicOn() Switching Threads using publishOn()

• تغییر رشته ها با استفاده از subscribeOn() Switching Threads using subscribeOn()

• تغییر رشته ها با استفاده از subscribeOn() Switching Threads using subscribeOn()

مدل اجرای راکتورها - زمان‌بندی‌ها، رشته‌ها و Threadpool Reactors Execution Model - Schedulers, Threads and Threadpool

• مدل اجرای راکتور Reactor Execution Model

• تغییر رشته ها با استفاده از publicOn() Switching Threads using publishOn()

برقراری تماس های مسدود شده در MovieReactiveService Making Blocking Calls in MovieReactiveService

• برقراری تماس های مسدود شده در MovieReactiveService Making Blocking calls in MovieReactiveService

• برقراری تماس های مسدود شده در MovieReactiveService Making Blocking calls in MovieReactiveService

برقراری تماس های مسدود شده در MovieReactiveService Making Blocking Calls in MovieReactiveService

فشار پشت BackPressure

• مقدمه ای بر BackPressure Introduction to BackPressure

• مقدمه ای بر BackPressure Introduction to BackPressure

• بیایید BackPressure را پیاده سازی کنیم Let's implement BackPressure

• بیایید BackPressure را پیاده سازی کنیم Let's implement BackPressure

• یک تست JUnit برای BackPressure بنویسید Write a JUnit test for backPressure

• یک تست JUnit برای BackPressure بنویسید Write a JUnit test for backPressure

• مدیریت فشار برگشتی با استفاده از ()onBackpressureDrop Handling Backpressure using onBackpressureDrop()

• مدیریت فشار برگشتی با استفاده از ()onBackpressureDrop Handling Backpressure using onBackpressureDrop()

• مدیریت فشار برگشتی با استفاده از ()onBackpressureBuffer Handling Backpressure using onBackpressureBuffer()

• مدیریت فشار برگشتی با استفاده از ()onBackpressureBuffer Handling Backpressure using onBackpressureBuffer()

• مدیریت Backpressure با استفاده از onBackpressureError() Handling Backpressure using onBackpressureError()

• مدیریت Backpressure با استفاده از onBackpressureError() Handling Backpressure using onBackpressureError()

فشار پشت BackPressure

کاوش موازی سازی داده ها در Project Reactor Explore Data Parallelism in Project Reactor

• موازی سازی با استفاده از عملگر ()parallel و ()runOn Parallelism using parallel() and runOn() operator

• موازی سازی با استفاده از عملگر ()parallel و ()runOn Parallelism using parallel() and runOn() operator

• موازی سازی با استفاده از عملگر flatmap(). Parallelism using flatmap() operator

• موازی سازی با استفاده از عملگر flatMapSequential(). Parallelism using flatMapSequential() operator

• موازی سازی با استفاده از عملگر flatMapSequential(). Parallelism using flatMapSequential() operator

کاوش موازی سازی داده ها در Project Reactor Explore Data Parallelism in Project Reactor

• موازی سازی با استفاده از عملگر flatmap(). Parallelism using flatmap() operator

جریان های سرد و گرم Cold & Hot Streams

• جریان های سرد و گرم Cold & Hot Streams

• جریان های سرد Cold Streams

• جریان های داغ - ConnectableFlux Hot Streams - ConnectableFlux

• Hot Streams - ConnectableFlux با استفاده از AutoConnect و RefCount Hot Streams - ConnectableFlux using autoConnect and RefCount

• Hot Streams - ConnectableFlux با استفاده از AutoConnect و RefCount Hot Streams - ConnectableFlux using autoConnect and RefCount

جریان های سرد و گرم Cold & Hot Streams

• جریان های سرد و گرم Cold & Hot Streams

• جریان های سرد Cold Streams

• جریان های داغ - ConnectableFlux Hot Streams - ConnectableFlux

تست با استفاده از VirtualTimeScheduler Testing using VirtualTimeScheduler

• StepVerifier با استفاده از VirtualTimeScheduler StepVerifier using VirtualTimeScheduler

• StepVerifier با استفاده از VirtualTimeScheduler StepVerifier using VirtualTimeScheduler

تست با استفاده از VirtualTimeScheduler Testing using VirtualTimeScheduler

RestClient NonBlocking را با استفاده از WebClient بسازید Build NonBlocking RestClient using WebClient

• نمای کلی API فیلم واکنشی Overview of the Reactive Movie API

• MovieInfoService RestClient غیر مسدود کننده را بسازید Build the non-blocking MovieInfoService RestClient

• MovieInfoService RestClient غیر مسدود کننده را بسازید Build the non-blocking MovieInfoService RestClient

• Unit Test NonBlocking Client با استفاده از StepVerifier و JUnit Unit Test NonBlocking Client using StepVerifier and JUnit

• Unit Test NonBlocking Client با استفاده از StepVerifier و JUnit Unit Test NonBlocking Client using StepVerifier and JUnit

• ساخت MovieInfoService RestClient غیر مسدود کننده - getMovieInfoById Build the non-blocking MovieInfoService RestClient - getMovieInfoById

• ساخت MovieInfoService RestClient غیر مسدود کننده - getMovieInfoById Build the non-blocking MovieInfoService RestClient - getMovieInfoById

• یک مورد آزمایشی برای تابع retrieveMovieInfoById_RestClient بنویسید Write a test case for retrieveMovieInfoById_RestClient function

• RestClient Review غیر مسدود کننده را بسازید Build the non-blocking Review RestClient

• یک مورد آزمایشی برای تابع retrieveReviewsFlux_RestClient بنویسید Write a test case for retrieveReviewsFlux_RestClient function

• یک مورد آزمایشی برای تابع retrieveReviewsFlux_RestClient بنویسید Write a test case for retrieveReviewsFlux_RestClient function

• GetAllMovies غیر مسدود کننده MovieReactiveService Client بسازید Build getAllMovies non-blocking MovieReactiveService Client

• GetAllMovies غیر مسدود کننده MovieReactiveService Client بسازید Build getAllMovies non-blocking MovieReactiveService Client

• GetMovieById غیر مسدود کننده MovieReactiveService Client بسازید Build getMovieById non-blocking MovieReactiveService Client

RestClient NonBlocking را با استفاده از WebClient بسازید Build NonBlocking RestClient using WebClient

• نمای کلی API فیلم واکنشی Overview of the Reactive Movie API

• یک مورد آزمایشی برای تابع retrieveMovieInfoById_RestClient بنویسید Write a test case for retrieveMovieInfoById_RestClient function

• RestClient Review غیر مسدود کننده را بسازید Build the non-blocking Review RestClient

• GetMovieById غیر مسدود کننده MovieReactiveService Client بسازید Build getMovieById non-blocking MovieReactiveService Client

ایجاد یک Flux/Mono به صورت برنامه ای Programmatically Creating a Flux/Mono

• گزینه های مختلف Creating Flux/Mono Different options of Creating Flux/Mono

• ایجاد Flux با استفاده از gener() Create Flux using generate()

• با استفاده از create() یک Flux ایجاد کنید Create a Flux using create()

• با استفاده از create() یک Flux ایجاد کنید Create a Flux using create()

• ایجاد یک مونو با استفاده از create() Create a Mono using create()

• ایجاد یک مونو با استفاده از create() Create a Mono using create()

• با استفاده از handle() یک Flux ایجاد کنید Create a Flux using handle()

• با استفاده از handle() یک Flux ایجاد کنید Create a Flux using handle()

ایجاد یک Flux/Mono به صورت برنامه ای Programmatically Creating a Flux/Mono

• گزینه های مختلف Creating Flux/Mono Different options of Creating Flux/Mono

• ایجاد Flux با استفاده از gener() Create Flux using generate()

اشکال زدایی در Project Reactor Debugging in Project Reactor

• مقدمه ای بر اشکال زدایی در Project Reactor Introduction to Debugging in Project Reactor

• مقدمه ای بر اشکال زدایی در Project Reactor Introduction to Debugging in Project Reactor

• اشکال زدایی استثناها با استفاده از Hooks.onOperatorDebug() Debug Exceptions using Hooks.onOperatorDebug()

• اشکال زدایی استثناها با استفاده از Hooks.onOperatorDebug() Debug Exceptions using Hooks.onOperatorDebug()

• اشکال زدایی استثناها با استفاده از عملگرهای "نقطه بازرسی". Debug Exceptions using "checkpoint" operators

• اشکال زدایی جهانی آماده تولید با استفاده از "ReactorDebugAgent" Production-ready Global Debugging using "ReactorDebugAgent"

• اشکال زدایی جهانی آماده تولید با استفاده از "ReactorDebugAgent" Production-ready Global Debugging using "ReactorDebugAgent"

اشکال زدایی در Project Reactor Debugging in Project Reactor

• اشکال زدایی استثناها با استفاده از عملگرهای "نقطه بازرسی". Debug Exceptions using "checkpoint" operators