Performance Optimization: Database Pooling, Redis Caching, and Monitoring

API-Gateway/src/main/resources/application.yml

@@ -43,6 +43,19 @@ spring:
           uri: lb://fund-transfer-service
           predicates:
             - Path=/fund-transfers/**
+      httpclient:
+        connect-timeout: 5000
+        response-timeout: 10s
+
+management:
+  endpoints:
+    web:
+      exposure:
+        include: health,metrics,prometheus
+  metrics:
+    export:
+      prometheus:
+        enabled: true
 
   security:
     oauth2:

Account-Service/pom.xml

@@ -22,6 +22,14 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-cache</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>

Account-Service/src/main/java/org/training/account/service/configuration/CacheConfig.java

@@ -0,0 +1,9 @@
+package org.training.account.service.configuration;
+
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableCaching
+public class CacheConfig {
+}

Account-Service/src/main/java/org/training/account/service/repository/AccountRepository.java

@@ -1,5 +1,6 @@
 package org.training.account.service.repository;
 
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.training.account.service.model.AccountType;
 import org.training.account.service.model.entity.Account;
@@ -23,6 +24,7 @@ public interface AccountRepository extends JpaRepository<Account, Long> {
      * @param accountNumber The account number to search for.
      * @return An optional containing the found account, or an empty optional if no account was found.
      */
+    @Cacheable(value = "accounts", key = "#accountNumber")
     Optional<Account> findAccountByAccountNumber(String accountNumber);
 
     /**
@@ -31,5 +33,6 @@ public interface AccountRepository extends JpaRepository<Account, Long> {
      * @param userId the ID of the user
      * @return an optional account object
      */
+    @Cacheable(value = "accounts", key = "'user:' + #userId")
     Optional<Account> findAccountByUserId(Long userId);
 }

Account-Service/src/main/resources/application.yml

@@ -10,6 +10,12 @@ spring:
     url: jdbc:mysql://localhost:3306/account_service
     username: root
     password: root
+    hikari:
+      maximum-pool-size: 20
+      minimum-idle: 5
+      idle-timeout: 300000
+      connection-timeout: 20000
+      max-lifetime: 1200000
 
   jpa:
     hibernate:
@@ -18,6 +24,40 @@ spring:
     properties:
       hibernate:
         format_sql: true
+        jdbc:
+          batch_size: 20
+        order_inserts: true
+        order_updates: true
+        batch_versioned_data: true
+
+  cache:
+    type: redis
+    redis:
+      time-to-live: 600000
+
+  redis:
+    host: ${REDIS_HOST:localhost}
+    port: ${REDIS_PORT:6379}
+    timeout: 2000ms
+
+feign:
+  client:
+    config:
+      default:
+        connectTimeout: 5000
+        readTimeout: 10000
+  circuitbreaker:
+    enabled: true
+
+management:
+  endpoints:
+    web:
+      exposure:
+        include: health,metrics,prometheus
+  metrics:
+    export:
+      prometheus:
+        enabled: true
 
 server:
   port: 8081

Fund-Transfer/pom.xml

@@ -22,6 +22,14 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-cache</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>

Fund-Transfer/src/main/java/org/training/fundtransfer/configuration/CacheConfig.java

@@ -0,0 +1,9 @@
+package org.training.fundtransfer.configuration;
+
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableCaching
+public class CacheConfig {
+}

Fund-Transfer/src/main/java/org/training/fundtransfer/repository/FundTransferRepository.java

@@ -1,5 +1,6 @@
 package org.training.fundtransfer.repository;
 
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.training.fundtransfer.model.entity.FundTransfer;
 
@@ -14,6 +15,7 @@ public interface FundTransferRepository extends JpaRepository<FundTransfer, Long
      * @param referenceId the transaction reference ID
      * @return an optional fund transfer object
      */
+    @Cacheable(value = "fundTransfers", key = "'ref:' + #referenceId")
     Optional<FundTransfer> findFundTransferByTransactionReference(String referenceId);
 
     /**
@@ -22,5 +24,6 @@ public interface FundTransferRepository extends JpaRepository<FundTransfer, Long
      * @param accountId The ID of the from account.
      * @return A list of FundTransfer objects.
      */
+    @Cacheable(value = "fundTransfers", key = "'account:' + #accountId")
     List<FundTransfer> findFundTransferByFromAccount(String accountId);
 }

Fund-Transfer/src/main/java/org/training/fundtransfer/service/implementation/FundTransferServiceImpl.java

@@ -5,6 +5,7 @@
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.training.fundtransfer.exception.AccountUpdateException;
 import org.training.fundtransfer.exception.GlobalErrorCode;
 import org.training.fundtransfer.exception.InsufficientBalance;
@@ -52,6 +53,7 @@ public class FundTransferServiceImpl implements FundTransferService {
      * @throws InsufficientBalance If the required amount to transfer is not available.
      */
     @Override
+    @Transactional
     public FundTransferResponse fundTransfer(FundTransferRequest fundTransferRequest) {
 
         Account fromAccount;

Fund-Transfer/src/main/resources/application.yml

@@ -11,13 +11,51 @@ spring:
     url: jdbc:mysql://localhost:3306/fund_transfer_service
     username: root
     password: root
+    hikari:
+      maximum-pool-size: 20
+      minimum-idle: 5
+      idle-timeout: 300000
+      connection-timeout: 20000
+      max-lifetime: 1200000
 
   jpa:
     hibernate:
       ddl-auto: update
-
     show-sql: true
-
     properties:
       hibernate:
-        format_sql: true
+        format_sql: true
+        jdbc:
+          batch_size: 20
+        order_inserts: true
+        order_updates: true
+        batch_versioned_data: true
+
+  cache:
+    type: redis
+    redis:
+      time-to-live: 600000
+
+  redis:
+    host: ${REDIS_HOST:localhost}
+    port: ${REDIS_PORT:6379}
+    timeout: 2000ms
+
+feign:
+  client:
+    config:
+      default:
+        connectTimeout: 5000
+        readTimeout: 10000
+  circuitbreaker:
+    enabled: true
+
+management:
+  endpoints:
+    web:
+      exposure:
+        include: health,metrics,prometheus
+  metrics:
+    export:
+      prometheus:
+        enabled: true

Sequence-Generator/src/main/resources/application.yml

@@ -6,6 +6,12 @@ spring:
     url: jdbc:mysql://localhost:3306/sequence_generator
     username: root
     password: root
+    hikari:
+      maximum-pool-size: 20
+      minimum-idle: 5
+      idle-timeout: 300000
+      connection-timeout: 20000
+      max-lifetime: 1200000
 
   jpa:
     hibernate:
@@ -14,5 +20,20 @@ spring:
     properties:
       hibernate:
         format_sql: true
+        jdbc:
+          batch_size: 20
+        order_inserts: true
+        order_updates: true
+        batch_versioned_data: true
+
+management:
+  endpoints:
+    web:
+      exposure:
+        include: health,metrics,prometheus
+  metrics:
+    export:
+      prometheus:
+        enabled: true
 server:
   port: 8083

Service-Registry/src/main/resources/application.yml

@@ -11,3 +11,13 @@ eureka:
 spring:
   application:
     name: SERVICE-REGISTRY
+
+management:
+  endpoints:
+    web:
+      exposure:
+        include: health,metrics,prometheus
+  metrics:
+    export:
+      prometheus:
+        enabled: true

Transaction-Service/pom.xml

@@ -22,6 +22,14 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-redis</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-cache</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-data-jpa</artifactId>

Transaction-Service/src/main/java/org/training/transactions/configuration/CacheConfig.java

@@ -0,0 +1,9 @@
+package org.training.transactions.configuration;
+
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableCaching
+public class CacheConfig {
+}

Transaction-Service/src/main/java/org/training/transactions/repository/TransactionRepository.java

@@ -1,5 +1,6 @@
 package org.training.transactions.repository;
 
+import org.springframework.cache.annotation.Cacheable;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.training.transactions.model.entity.Transaction;
 
@@ -13,6 +14,7 @@ public interface TransactionRepository extends JpaRepository<Transaction, Long>
      * @param accountId the ID of the account
      * @return a list of transactions
      */
+    @Cacheable(value = "transactions", key = "'account:' + #accountId")
     List<Transaction> findTransactionByAccountId(String accountId);
 
     /**
@@ -21,5 +23,6 @@ public interface TransactionRepository extends JpaRepository<Transaction, Long>
      * @param referenceId The reference ID to match against.
      * @return The list of transactions that match the reference ID.
      */
+    @Cacheable(value = "transactions", key = "'ref:' + #referenceId")
     List<Transaction> findTransactionByReferenceId(String referenceId);
 }

Transaction-Service/src/main/resources/application.yml

@@ -9,6 +9,12 @@ spring:
     url: jdbc:mysql://localhost:3306/transaction_service
     username: root
     password: root
+    hikari:
+      maximum-pool-size: 20
+      minimum-idle: 5
+      idle-timeout: 300000
+      connection-timeout: 20000
+      max-lifetime: 1200000
 
   jpa:
     hibernate:
@@ -17,6 +23,40 @@ spring:
     properties:
       hibernate:
         format_sql: true
+        jdbc:
+          batch_size: 20
+        order_inserts: true
+        order_updates: true
+        batch_versioned_data: true
+
+  cache:
+    type: redis
+    redis:
+      time-to-live: 600000
+
+  redis:
+    host: ${REDIS_HOST:localhost}
+    port: ${REDIS_PORT:6379}
+    timeout: 2000ms
+
+feign:
+  client:
+    config:
+      default:
+        connectTimeout: 5000
+        readTimeout: 10000
+  circuitbreaker:
+    enabled: true
+
+management:
+  endpoints:
+    web:
+      exposure:
+        include: health,metrics,prometheus
+  metrics:
+    export:
+      prometheus:
+        enabled: true
 
 server:
-  port: 8084
+  port: 8084