Einführung der Java-Bibliothek für den Backend-Microservice Webflux (Reactor-Core)

Github-Link: https://github.com/hoangtien2k3/reactify-core

1. Bibliotheksübersicht

Diese Bibliothek basiert auf den Kernkomponenten von Spring WebFlux und Reactor-Core – zwei leistungsstarken Tools, die reaktive Programmierung unterstützen. Mit dieser Bibliothek können Sie ganz einfach asynchrone Microservice-Anwendungen erstellen und nichtlineare Datenströme effizient verarbeiten.

Zu den Highlight-Funktionen gehören:

• Vollständige reaktive Programmierunterstützung: Stream-basierte asynchrone Datenverarbeitung.
• Hochleistungsoptimierung: Minimieren Sie die Anzahl der benötigten Threads und maximieren Sie die CPU-Ressourcen.
• Einfache Skalierbarkeit: Geeignet für Microservice-Systeme, die die Bearbeitung großer Mengen an Anfragen von Benutzern erfordern.

2. Vorteile der Bibliothek

1. Hohe Leistung und gute Reaktionsfähigkeit:
   Mithilfe eines nicht blockierenden Mechanismus kann diese Bibliothek Tausende gleichzeitiger Anforderungen verarbeiten, ohne zu viele Threads zu erstellen, was die Ressourcenbelastung reduziert und die Antwortgeschwindigkeit verbessert.

2. Einfache Stream-Verarbeitung:
   Reactor-Core bietet eine leistungsstarke API für die Stream-Verarbeitung, die für Anwendungen geeignet ist, die kontinuierliche Daten verarbeiten müssen, z. B. Echtzeit-Benachrichtigungssysteme, Ereignisverarbeitung und Big-Data-Verarbeitungssysteme.

3. Einfache Integration in das Spring-Ökosystem:
   Die Bibliothek ist so konzipiert, dass sie gut mit Komponenten im Spring-Ökosystem wie Spring Security und Spring Data R2DBC zusammenarbeitet und dabei hilft, vollständige Anwendungen mit weniger Aufwand zu erstellen.

Richten Sie Reify-Core ein

1. Verwenden Sie die Annotation @ComponentScan, um alle Bibliotheken zu scannen

@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. Konfigurieren Sie Ihre Projektdatei application.yml oder 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. Starten Sie nach Abschluss der Konfiguration die Ausführung des Projekts.

  # Using Maven
  mvn spring-boot:run

  # Using Gradle
  gradle bootRun

4. Beziehen Sie sich auf das folgende Projekt, verwendet

reactify-core-Bibliothek für das Webflux-Microservice-Projekt: keycloak-auth-service

Jeder kann Feedback geben und Fehler finden oder diese Bibliothek verbessern, um zur Stärkung der Community beizutragen. Vielen Dank
Ich wünsche Ihnen einen schönen Tag

Das obige ist der detaillierte Inhalt vonEinführung der Java-Bibliothek für den Backend-Microservice Webflux (Reactor-Core). Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!