🚀 Supercharge your reactive microservices with Reactify – a high-performance Java library built on Spring WebFlux and Reactor Core, designed to streamline backend development with essential tools for modern reactive systems.

🔥 Features

• ✔ Seamless Keycloak Integration – Secure your apps effortlessly with built-in Keycloak support.
• ✔ Smart Caching – Boost performance with reactive caching mechanisms.
• ✔ Utility Helpers – Handy utilities to reduce boilerplate and speed up development.
• ✔ Reactive API Client – Effortless HTTP calls with non-blocking, reactive HTTP clients.
• ✔ Optimized for Microservices – Lightweight, fast, and built for scalable architectures.

Add the dependency to your project build.gradle file or maven pom:

⬇️ Download Gradle and Maven

dependencies {
    //Core reactive framework with Spring WebFlux integration 
    implementation("io.github.hoangtien2k3:reactify-core:1.2.9")

    //In-memory reactive caching for high-speed data access
    implementation("io.github.hoangtien2k3:reactify-cache:1.2.4")

    //Reactive REST/SOAP client with fault-tolerant design
    implementation("io.github.hoangtien2k3:reactify-client:1.2.4")

    //Use in minio (aws s3)
    implementation("io.github.hoangtien2k3:reactify-minio:1.2.5")

    //Essential utilities for reactive development
    implementation("io.github.hoangtien2k3:reactify-utils:1.2.5")
}

<dependencies>
   <!-- Core reactive framework with Spring WebFlux integration -->
   <dependency>
      <groupId>io.github.hoangtien2k3</groupId>
      <artifactId>reactify-core</artifactId>
      <version>1.2.9</version>
   </dependency>
   
   <!-- In-memory reactive caching for high-speed data access -->
   <dependency>
      <groupId>io.github.hoangtien2k3</groupId>
      <artifactId>reactify-cache</artifactId>
      <version>1.2.4</version>
   </dependency>
   
   <!-- Reactive REST/SOAP client with fault-tolerant design -->
   <dependency>
      <groupId>io.github.hoangtien2k3</groupId>
      <artifactId>reactify-client</artifactId>
      <version>1.2.4</version>
   </dependency>

   <!-- //Use in minio (aws s3) -->
   <dependency>
     <groupId>io.github.hoangtien2k3</groupId>
     <artifactId>reactify-minio</artifactId>
     <version>1.2.5</version>
   </dependency>
   
   <!-- Essential utilities for reactive development -->
   <dependency>
      <groupId>io.github.hoangtien2k3</groupId>
      <artifactId>reactify-utils</artifactId>
      <version>1.2.5</version>
   </dependency>
</dependencies>

• Document: https://reactify-sand.vercel.app

Config your project file application.yml or application.properties

• Required security configuration Oauth2 with Keycloak:
• Install keycloak and postgresql on docker docker-compose
• Next configure in the application.yml resource file

spring:
  # Config OAuth2 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}

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

Use library with @LocalCache annotation

@LocalCache(
    durationInMinute = 30, //cache duration in minutes
    maxRecord = 10000,     //maximum cache size
    autoCache = true       //true to enable automatic caching, false otherwise
)
@GetMapping("/students")
public Mono<List<Student>> getStudents() {
    var lstStudent = studentService.getAllStudents();
    if (DataUtil.isNullOrEmpty(lstStudent)) {
        return null;
    }
    return lstStudent;
}

Configuration in application.yml or application.properties file

# web client config
client:
  #demo notification config
  notification:
    address: http://localhost:7878
    name: notiServiceClient
    pool:
      max-size: 100
      max-pending-acquire: 100
    timeout:
      read: 60000
      write: 1000

Using Rest/Soap API calls

• See configuration demo in client reactify-test

Just add maven pom or build.gradle and use the utilities available in reactify-utils

@LocalCache(durationInMinute = 30, maxRecord = 10000, autoCache = true)
@GetMapping("/students")
public Mono<List<Student>> getStudents() {
    var lstStudent = studentService.getAllStudents();
    if (DataUtil.isNullOrEmpty(lstStudent)) {
        return null;
    }
    return lstStudent;
}

public Mono<GeoPluginResponse> getBaseCurrency(String baseCurrency) {
    MultiValueMap<String, String> req = new LinkedMultiValueMap<>();
    req.set("base_currency", baseCurrency);
    return baseRestClientQualifier.get(baseCurrencyClient, "/json.gp", null, req, GeoPluginResponse.class)
        .flatMap(optionalResponse -> optionalResponse
            .map(Mono::just)
            .orElseGet(Mono::empty)
        );
}

• Project using reactify-core library can be referenced: https://github.com/hoangtien2k3/keycloak-auth-service

• We welcome contributions! Please check our CONTRIBUTING.md for guidelines.

• If you would like to contribute to the development of this project, please follow our contribution guidelines.

This project is licensed under the Apache License, Version 2.0

Copyright 2024-2025 the original author Hoàng Anh Tiến.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

     https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.