Spring Boot 4 Microservices & REST APIs · درس

الضغط العكسي والعوامل

حوّل التدفقات التفاعلية وتحكّم بها

الضغط العكسي والعوامل درس مجاني في Spring Boot 4 Microservices & REST APIs على CoddyKit. هذا هو الدرس 4 من أصل 4. يمكنك قراءة الدرس كاملاً أدناه مجاناً — ثم تمرن عليه مباشرة في المتصفح باستخدام محرر أكواد مدمج ومدرس ذكاء اصطناعي متاح 24/7. هذا الدرس جزء من مسار التعلم في Spring Boot 4 Microservices & REST APIs، وتقدمك يتزامن عبر الويب وتطبيق CoddyKit. تتضمن دورة Spring Boot 4 Microservices & REST APIs 4 دروس في المجموع.

بعض أجزاء هذا الدرس لم تُترجم بعد وتظهر باللغة الإنجليزية.

Operators Build Pipelines

Reactive operators chain together to form a processing pipeline. Each operator returns a new publisher describing the next step.

Common ones: map, flatMap, filter, take, buffer.

map vs flatMap

map transforms each item synchronously (1-to-1). flatMap transforms each item into another publisher and flattens the results — use it for async work.

Using map

map for pure, synchronous transformations.

Flux<Integer> lengths = Flux.just("a", "bb", "ccc")
    .map(String::length);
lengths.subscribe(System.out::println); // 1, 2, 3

Using flatMap

flatMap when each item triggers an async call returning a Mono or Flux.

Flux<User> users = Flux.just("1", "2", "3")
    .flatMap(id -> userService.findById(id));
users.subscribe(System.out::println);

flatMap Ordering

flatMap interleaves results as inner publishers complete, so order is not guaranteed. Use concatMap to preserve order.

Flux<User> ordered = Flux.just("1", "2", "3")
    .concatMap(id -> userService.findById(id));

What is Backpressure

Backpressure is the mechanism by which a slow consumer tells a fast producer to slow down.

Subscribers request a number of items; the producer only emits up to that demand. This prevents memory overflow.

Limiting with take

take requests only the first N items, then cancels the upstream.

Flux<Long> first3 = Flux.interval(Duration.ofMillis(100))
    .take(3);
first3.subscribe(System.out::println); // 0, 1, 2

Buffering Items

buffer groups items into lists, useful for batching.

Flux<List<Integer>> batches = Flux.range(1, 10)
    .buffer(3);
batches.subscribe(System.out::println);
// [1,2,3], [4,5,6], [7,8,9], [10]

onBackpressureBuffer

When a producer is faster than the consumer, strategies control overflow: buffer, drop, or latest.

Flux.interval(Duration.ofMillis(1))
    .onBackpressureBuffer(100)
    .subscribe(System.out::println);

Throttling with limitRate

limitRate caps how many items are requested upstream at a time, applying controlled backpressure.

Flux.range(1, 1000)
    .limitRate(10)
    .subscribe(System.out::println);

Combining Operators

Real pipelines chain several operators to filter, transform, and limit a stream.

Flux.range(1, 100)
    .filter(n -> n % 2 == 0)
    .map(n -> n * n)
    .take(5)
    .subscribe(System.out::println);

Quick Check

Test your understanding of operators and backpressure.

Recap

You learned about operators and backpressure:

map = sync transform; flatMap = async, unordered; concatMap = async, ordered
Backpressure lets slow consumers control fast producers
take, buffer, limitRate shape the stream

الأسئلة الشائعة

هل درس «الضغط العكسي والعوامل» مجاني؟

نعم — نص درس «الضغط العكسي والعوامل» كامل متاح مجاناً هنا على الويب. لتمرينه بشكل تفاعلي (محرر أكواد مدمج ومدرس ذكاء اصطناعي متاح 24/7) وفتح باقي دورة Spring Boot 4 Microservices & REST APIs، انتقل إلى CoddyKit PRO. تتضمن دورة Spring Boot 4 Microservices & REST APIs 4 دروس في المجموع.

ماذا ستتعلم في «الضغط العكسي والعوامل»؟

حوّل التدفقات التفاعلية وتحكّم بها تتمرن على Spring Boot 4 Microservices & REST APIs مع أكواد عملية تشغلها مباشرة في المتصفح، ومدرس ذكاء اصطناعي متاح 24/7 يجيب على أسئلتك أثناء عملك.

هل أحتاج إلى خبرة سابقة لأبدأ Spring Boot 4 Microservices & REST APIs؟

لا تُشترط خبرة سابقة. Spring Boot 4 Microservices & REST APIs على CoddyKit منظم للمبتدئين حتى المتقدمين، لذا يمكنك البدء من هنا أو من البداية والتقدم بسرعتك الخاصة. هذا هو الدرس 4 من أصل 4.

كم من الوقت يستغرق درس «الضغط العكسي والعوامل»؟

معظم دروس CoddyKit تستغرق حوالي 5–10 دقائق. كل منها موجز وتفاعلي، لذا تحرز تقدماً مستمراً وتستأنف من حيث توقفت عبر الويب والتطبيق.

هل يمكنني كتابة وتشغيل أكواد في درس Spring Boot 4 Microservices & REST APIs هذا؟

نعم. كل درس في Spring Boot 4 Microservices & REST APIs يتضمن محرر أكواد مدمج، لذا تكتب وتشغل أكواداً حقيقية مباشرة في متصفحك وتحصل على تعليقات فورية من الذكاء الاصطناعي — بدون إعداد محلي.

جميع الدروس في هذه الدورة

← العودة إلى Spring Boot 4 Microservices & REST APIs