Spring Boot ile Reaktif Programlama, geliştiricilere bloklamayan, olay güdümlü ve yüksek ölçeklenebilir uygulamalar oluşturma imkanı sunar. Spring WebFlux ve Project Reactor kullanarak eşzamanlı istekleri düşük kaynak kullanımıyla yönetebilir, mikro hizmetler ve gerçek zamanlı uygulamalar geliştirebilirsiniz.
Bu bölümde Neden Reaktif Programlama Kullanmalıyız? konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
Şunlara sahip olduğunuzdan emin olun:
Spring WebFlux bağımlılığını pom.xml veya build.gradle dosyanıza ekleyin.
Maven:
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency>
Gradle:
implementation 'org.springframework.boot:spring-boot-starter-webflux'
Mono ve Flux kullanarak bloklamayan bir REST endpoint'i tanımlayın.
Spring Boot uygulamasını çalıştırın:
./mvnw spring-boot:run
Veya Gradle kullanarak:
gradle bootRun
Bu bölümde API'yi Test Etme konusunu netleştirip uygulamada kullanacağınız temel noktaları özetliyoruz.
Bu kontrol adımı, endpoint davranışının beklenen çıktı ile uyumunu doğrulamak için kullanılır.
curl -X GET http://localhost:8080/reaktif/mono
Beklenen çıktı:
Reaktif Mono'dan Merhaba!
Bu kontrol adımı, endpoint davranışının beklenen çıktı ile uyumunu doğrulamak için kullanılır.
curl -X GET http://localhost:8080/reaktif/flux
Beklenen çıktı (her kelime için 1 saniyelik gecikme ile):
Merhaba Reaktif Dünya
Artık Spring Boot Reaktif Programlama için üretim odaklı bir Spring Boot temeliniz var. Sonraki adımda ayarları kendi domainine uyarlayıp test ve gözlemlenebilirlik katmanını ekleyerek gerçek trafik altında doğrulayın.
package com.example.reaktif; import org.springframework.web.bind.annotation.*; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import java.time.Duration; import java.util.List; @RestController @RequestMapping("/reaktif") public class ReaktifController { @GetMapping("/mono") public Mono<String> getMono() { return Mono.just("Reaktif Mono'dan Merhaba!"); } @GetMapping("/flux") public Flux<String> getFlux() { return Flux.fromIterable(List.of("Merhaba", "Reaktif", "Dünya")) .delayElements(Duration.ofSeconds(1)); } }
package com.example.reaktif import org.springframework.web.bind.annotation.* import reactor.core.publisher.Flux import reactor.core.publisher.Mono import java.time.Duration @RestController @RequestMapping("/reaktif") class ReaktifController { @GetMapping("/mono") fun getMono(): Mono<String> { return Mono.just("Reaktif Mono'dan Merhaba!") } @GetMapping("/flux") fun getFlux(): Flux<String> { return Flux.just("Merhaba", "Reaktif", "Dünya") .delayElements(Duration.ofSeconds(1)) } }
