Reactive katmanı

Flow API ile reaktif akış yazarsın.

reaktif yayın katmanı

Reaktif katman, veriyi iterek (push) yayan bir model kurar. Subscriber arabirimi onNext(String item) metoduyla öğeleri tüketir. SimplePublisher abone listesi tutar; publish her aboneye onNext çağrısı yapar.

Bu, reaktif akışların (Reactive Streams) özüdür: yayıcı, abonelerine öğe iter. Harici bir kütüphane olmadan düz Java ile kurulur.

fonksiyonel arabirim ve lambda

Subscriber tek soyut metotlu bir arabirimdir; yani fonksiyonel arabirim. Bu yüzden anonim sınıf yerine lambda ile yazılabilir: s -> System.out.println("got: " + s). Derleyici, hedef türden s'in String olduğunu çıkarır.

Bu, kodu kısaltır ve okunurluğu artırır. subscribe metodu bir Subscriber bekler; lambda otomatik olarak ona dönüştürülür.

Uygulama Subscriber ve SimplePublisher sınıflarını yaz

Üstteki yapıya interface Subscriber ekle; void onNext(String item); metodu olsun. class SimplePublisher tanımla; aboneleri bir listede tutsun, void subscribe(Subscriber s) metodu abone eklesin, void publish(String item) metodu her aboneye s.onNext(item) çağırsın. main içinde SimplePublisher p = new SimplePublisher(); oluştur, p.subscribe(s -> System.out.println("got: " + s)); ile abone ol ve p.publish("hello"); çağır.

Örnek çözümü göster

@interface Service {}

@Service
class HelloService {
    String greet() { return "hello"; }
}

interface Subscriber {
    void onNext(String item);
}

class SimplePublisher {
    java.util.List<Subscriber> subs = new java.util.ArrayList<>();
    void subscribe(Subscriber s) { subs.add(s); }
    void publish(String item) {
        for (Subscriber s : subs) s.onNext(item);
    }
}

public class Main {
    public static void main(String[] args) {
        SimplePublisher p = new SimplePublisher();
        p.subscribe(s -> System.out.println("got: " + s));
        p.publish("hello");
    }
}

Kendini test et

abone metodunu tamamla

void ____(String item);

Cevabı göster

void onNext(String item);

Reaktif akışta Subscriber ne yapar?
- Dosya açar
- Sınıfı derler
- Çöp toplar
- Öğeleri tüketir
Cevabı göster

Öğeleri tüketir — Subscriber, onNext metoduyla yayınlanan öğeleri tüketir.
reaktif öğeleri eşleştir

Publisher

Yayın yapan
Subscriber

Abone olan
onNext

Öğe olayı
subscribe

Abonelik ekleme

Sıradaki ders: Performans katmanı

Deneyiminizi Geliştiriyoruz

Çerez Tercihleri

Kesinlikle Gerekli Çerezler

Analitik Çerezler