Memperkenalkan Pustaka Java untuk Backend Microservice Webflux (Reactor-core)

Pautan github: https://github.com/hoangtien2k3/reactify-core

1. Gambaran Keseluruhan Perpustakaan

Pustaka ini dibina pada komponen teras Spring WebFlux dan Reactor-Core – dua alat berkuasa yang menyokong pengaturcaraan reaktif. Dengan perpustakaan ini, anda boleh membina aplikasi perkhidmatan mikro tak segerak dengan mudah, mengendalikan aliran data bukan linear dengan cekap.

Ciri serlahkan termasuk:

• Sokongan pengaturcaraan reaktif penuh: pemprosesan data tak segerak berasaskan aliran.
• Pengoptimuman prestasi tinggi: Minimumkan bilangan utas yang diperlukan dan maksimumkan sumber CPU.
• Skala mudah: Sesuai untuk sistem perkhidmatan mikro yang memerlukan pengendalian jumlah besar permintaan daripada pengguna.

2. Kelebihan perpustakaan

1. Prestasi tinggi dan responsif yang baik:
   Menggunakan mekanisme tanpa sekatan, pustaka ini boleh mengendalikan beribu-ribu permintaan serentak tanpa membuat terlalu banyak urutan, yang mengurangkan beban sumber dan meningkatkan kelajuan tindak balas.

2. Pemprosesan strim mudah:
   Reactor-Core menyediakan API yang berkuasa untuk pemprosesan strim, sesuai untuk aplikasi yang perlu memproses data berterusan seperti sistem pemberitahuan masa nyata, pemprosesan acara dan sistem pemprosesan data besar.

3. Penyatuan mudah dengan ekosistem Spring:
   Perpustakaan ini direka bentuk untuk berfungsi dengan baik dengan komponen dalam ekosistem Spring seperti Spring Security, Spring Data R2DBC, membantu membina aplikasi lengkap dengan sedikit usaha.

Persediaan reactify-core

1. Gunakan anotasi @ComponentScan untuk mengimbas semua perpustakaan

@ComponentScan(basePackages = {
        "com.reactify.*",           // add default: com.reactify.*
        "com.example.myproject"     // varies depending on your project
})
@SpringBootApplication
public class ExampleApplication {
    public static void main(String[] args) {
        SpringApplication.run(Example.class, args);
    }
}

2. Konfigurasikan fail projek anda application.yml atau application.properties

# spring config
spring:
  main:
    web-application-type: reactive
    allow-bean-definition-overriding: true
  messages:
    basename: i18n/messages

  #connect db R2DBC PostgreSQL
  r2dbc:
    url: r2dbc:postgresql://localhost:5434/auth
    username: admin
    password: admin
    pool:
      max-size: 10
      initial-size: 5

  # Config connect Keycloak
  security:
    oauth2:
      client:
        provider:
          oidc:
            token-uri: ${keycloak.serverUrl}/realms/${keycloak.realm}/protocol/openid-connect/token
        registration:
          oidc:
            client-id: ${keycloak.clientId}
            client-secret: ${keycloak.clientSecret}
            authorization-grant-type: ${keycloak.grantType} #password || #client_credentials
      resourceserver:
        jwt:
          jwk-set-uri: ${keycloak.serverUrl}/realms/${keycloak.realm}/protocol/openid-connect/certs
      keycloak:
        client-id: ${keycloak.clientId}

# Web client config
client:
  #keycloak
  keycloak:
    address: http://localhost:8080/realms/ezbuy-server/protocol/openid-connect
    name: keycloak
    auth:
      client-id: ezbuy-client
      client-secret: mI92QDfvi20tZgFtjpRAPWu8TR6eMHmw
  #notification
  notification:
    internal-oauth: true
    address: http://localhost:7777/v1/transmission
    name: notiServiceClient
    pool:
      max-size: 100
      max-pending-acquire: 100
    timeout:
      read: 60000
      write: 1000

# Unauthenticated endpoints config
application:
  http-logging:
    request:
      enable: true
      header: true
      param: true
      body: true
    response:
      enable: true
      body: true
  whiteList:
    - uri: /v1/auth/generate-otp
      methods:
        - POST
    - uri: /**
      methods:
        - OPTIONS
    - uri: /v1/auth/get-all
      methods:
        - GET
  data:
    sync-data:
      limit: 500

#keycloak client config
keycloak:
  clientId: ezbuy-client
  clientSecret: mI92QDfvi20tZgFtjpRAPWu8TR6eMHmw
  realm: ezbuy-server
  serverUrl: http://localhost:8080
  grantType: password
  host: localhost

# minio server config
minio:
  bucket: ezbuy-bucket
  enabled: true
  baseUrl: http://localhost:9000
  publicUrl: http://localhost:9000/ezbuy-bucket
  accessKey: 4DoaZ0KdzpXdDlVK104t
  secretKey: nuRiQUIJNVygMOHhmtR4LT1etAa7F8PQOsRGP5oj
  private:
    bucket: ezbuy-private

3. Selepas melengkapkan konfigurasi, mula menjalankan projek.

  # Using Maven
  mvn spring-boot:run

  # Using Gradle
  gradle bootRun

4. Rujuk projek berikut, digunakan

pustaka teras reactify untuk projek microservice webflux: keycloak-auth-service

Semua orang boleh memberi maklum balas dan mencari kesilapan atau menambah baik perpustakaan ini untuk membantu membangunkan komuniti dengan lebih kukuh, terima kasih banyak
Selamat hari raya

Atas ialah kandungan terperinci Memperkenalkan Pustaka Java untuk Backend Microservice Webflux (Reactor-core). Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!