Skip to content

M
Micro_Services
Commit 8499fd76 authored by Ali Saeed's avatar Ali Saeed
Browse files
Options

create intial two zones

parent e0c61f36
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 1576 additions and 179 deletions
.idea/compiler.xml
View file @ 8499fd76
...@@ -9,8 +9,11 @@ ...@@ -9,8 +9,11 @@
<module name="users-service" /> <module name="users-service" />
<module name="replica-invoicing-service" /> <module name="replica-invoicing-service" />
<module name="invoicing-service" /> <module name="invoicing-service" />
<module name="users-service-zone-2" />
<module name="invoicing-service-zone-2" />
<module name="service-discovery" /> <module name="service-discovery" />
<module name="cloud-gateway" /> <module name="cloud-gateway" />
<module name="replica-invoicing-service-zone-2" />
</profile> </profile>
</annotationProcessing> </annotationProcessing>
</component> </component>
...@@ -18,9 +21,12 @@ ...@@ -18,9 +21,12 @@
<option name="ADDITIONAL_OPTIONS_OVERRIDE"> <option name="ADDITIONAL_OPTIONS_OVERRIDE">
<module name="cloud-gateway" options="-parameters" /> <module name="cloud-gateway" options="-parameters" />
<module name="invoicing-service" options="-parameters" /> <module name="invoicing-service" options="-parameters" />
<module name="invoicing-service-zone-2" options="-parameters" />
<module name="replica-invoicing-service" options="-parameters" /> <module name="replica-invoicing-service" options="-parameters" />
<module name="replica-invoicing-service-zone-2" options="-parameters" />
<module name="service-discovery" options="-parameters" /> <module name="service-discovery" options="-parameters" />
<module name="users-service" options="-parameters" /> <module name="users-service" options="-parameters" />
<module name="users-service-zone-2" options="-parameters" />
</option> </option>
</component> </component>
</project> </project>
\ No newline at end of file
.idea/encodings.xml
View file @ 8499fd76
...@@ -3,14 +3,20 @@ ...@@ -3,14 +3,20 @@
<component name="Encoding"> <component name="Encoding">
<file url="file://$PROJECT_DIR$/cloud-gateway/src/main/java" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/cloud-gateway/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/cloud-gateway/src/main/resources" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/cloud-gateway/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/invoicing-service-zone-2/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/invoicing-service-zone-2/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/invoicing-service/src/main/java" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/invoicing-service/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/invoicing-service/src/main/resources" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/invoicing-service/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/replica-invoicing-service-zone-2/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/replica-invoicing-service-zone-2/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/replica-invoicing-service/src/main/java" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/replica-invoicing-service/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/replica-invoicing-service/src/main/resources" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/replica-invoicing-service/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/service-discovery/src/main/java" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/service-discovery/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/service-discovery/src/main/resources" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/service-discovery/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/users-service-zone-2/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/users-service-zone-2/src/main/resources" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/users-service/src/main/java" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/users-service/src/main/java" charset="UTF-8" />
<file url="file://$PROJECT_DIR$/users-service/src/main/resources" charset="UTF-8" /> <file url="file://$PROJECT_DIR$/users-service/src/main/resources" charset="UTF-8" />
</component> </component>
......
cloud-gateway/src/main/resources/application.yml
View file @ 8499fd76
...@@ -6,24 +6,39 @@ spring: ...@@ -6,24 +6,39 @@ spring:
cloud: cloud:
gateway: gateway:
routes: routes:
- id: invoicing-service - id: invoicing-service-damascus-zone
uri: lb://invoicing-service uri: lb://invoicing-service
predicates: predicates:
- Path=/invoices/** - Path=/damascus/invoices/**
- id: replica-invoicing-service filters:
- RewritePath=/damascus/invoices/(?<segment>.+), /invoices/${segment}
- id: replica-invoicing-service-damascus-zone
uri: lb://invoicing-service uri: lb://invoicing-service
predicates: predicates:
- Path=/invoices/** - Path=/damascus/invoices/**
- id: users-service filters:
- RewritePath=/damascus/invoices/(?<segment>.+), /invoices/${segment}
- id: users-service-damascus-zone
uri: lb://users-service uri: lb://users-service
predicates: predicates:
- Path=/users/** - Path=/damascus/users/**
eureka: filters:
client: - RewritePath=/damascus/users/(?<segment>.+), /users/${segment}
register-with-eureka: true - id: invoicing-service-latakia-zone
fetch-registry: true uri: lb://invoicing-service
service-url: predicates:
default-zone: http://localhost:8761/eureka/ - Path=/latakia/invoices/**
# instance: filters:
# hostname: localhost - RewritePath=/latakia/invoices/(?<segment>.+), /invoices/${segment}
# preferIpAddress: true - id: replica-invoicing-service-latakia-zone
\ No newline at end of file uri: lb://invoicing-service
predicates:
- Path=/latakia/invoices/**
filters:
- RewritePath=/latakia/invoices/(?<segment>.+), /invoices/${segment}
- id: users-service-latakia-zone
uri: lb://users-service
predicates:
- Path=/latakia/users/**
filters:
- RewritePath=/latakia/users/(?<segment>.+), /users/${segment}
\ No newline at end of file
cloud-gateway/target/classes/application.yml
View file @ 8499fd76
...@@ -6,24 +6,39 @@ spring: ...@@ -6,24 +6,39 @@ spring:
cloud: cloud:
gateway: gateway:
routes: routes:
- id: invoicing-service - id: invoicing-service-damascus-zone
uri: lb://invoicing-service uri: lb://invoicing-service
predicates: predicates:
- Path=/invoices/** - Path=/damascus/invoices/**
- id: replica-invoicing-service filters:
- RewritePath=/damascus/invoices/(?<segment>.+), /invoices/${segment}
- id: replica-invoicing-service-damascus-zone
uri: lb://invoicing-service uri: lb://invoicing-service
predicates: predicates:
- Path=/invoices/** - Path=/damascus/invoices/**
- id: users-service filters:
- RewritePath=/damascus/invoices/(?<segment>.+), /invoices/${segment}
- id: users-service-damascus-zone
uri: lb://users-service uri: lb://users-service
predicates: predicates:
- Path=/users/** - Path=/damascus/users/**
eureka: filters:
client: - RewritePath=/damascus/users/(?<segment>.+), /users/${segment}
register-with-eureka: true - id: invoicing-service-latakia-zone
fetch-registry: true uri: lb://invoicing-service
service-url: predicates:
default-zone: http://localhost:8761/eureka/ - Path=/latakia/invoices/**
# instance: filters:
# hostname: localhost - RewritePath=/latakia/invoices/(?<segment>.+), /invoices/${segment}
# preferIpAddress: true - id: replica-invoicing-service-latakia-zone
\ No newline at end of file uri: lb://invoicing-service
predicates:
- Path=/latakia/invoices/**
filters:
- RewritePath=/latakia/invoices/(?<segment>.+), /invoices/${segment}
- id: users-service-latakia-zone
uri: lb://users-service
predicates:
- Path=/latakia/users/**
filters:
- RewritePath=/latakia/users/(?<segment>.+), /users/${segment}
\ No newline at end of file
invoicing-service-zone-2/pom.xml 0 → 100644
View file @ 8499fd76
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.1</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>invoicing-service-zone-2</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<spring-cloud.version>2022.0.0</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.9</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>netflix-candidates</id>
<name>Netflix Candidates</name>
<url>https://artifactory-oss.prod.netflix.net/artifactory/maven-oss-candidates</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
</project>
\ No newline at end of file
invoicing-service-zone-2/src/main/java/org/example/InvoicingServiceZone2Application.java 0 → 100644
View file @ 8499fd76
package org.example;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@SpringBootApplication
@EnableDiscoveryClient
public class InvoicingServiceZone2Application {
public static void main(String[] args) {
SpringApplication.run(InvoicingServiceZone2Application.class, args);
}
@Bean
@LoadBalanced
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
invoicing-service-zone-2/src/main/java/org/example/models/Invoice.java 0 → 100644
View file @ 8499fd76
package org.example.models;
public class Invoice {
private String invoiceID;
private String userID;
private String description;
private boolean status;
private double value;
public Invoice(String invoiceID, String userID, String description, boolean status, double value) {
this.invoiceID = invoiceID;
this.userID = userID;
this.description = description;
this.status = status;
this.value = value;
}
public Invoice() {
this.invoiceID = "";
this.userID = "";
this.description = "description";
this.status = false;
this.value = 0.0;
}
public String getInvoiceID() {
return invoiceID;
}
public void setInvoiceID(String invoiceID) {
this.invoiceID = invoiceID;
}
public String getUserID() {
return userID;
}
public void setUserID(String userID) {
this.userID = userID;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public boolean isStatus() {
return status;
}
public void setStatus(boolean status) {
this.status = status;
}
public double getValue() {
return value;
}
public void setValue(double value) {
this.value = value;
}
@Override
public String toString() {
return "Invoice{" +
"invoiceID='" + invoiceID + '\'' +
", userID='" + userID + '\'' +
", description='" + description + '\'' +
", status=" + status +
", value=" + value +
'}';
}
}
invoicing-service-zone-2/src/main/java/org/example/models/User.java 0 → 100644
View file @ 8499fd76
package org.example.models;
public class User {
private String userId;
private String name;
private double balance;
public User(String userId, String name, double balance) {
this.userId = userId;
this.name = name;
this.balance = balance;
}
public User() {
this.userId = "";
this.name = "ali";
this.balance = 0.0;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public double getBalance() {
return balance;
}
public void setBalance(double balance) {
this.balance = balance;
}
@Override
public String toString() {
return "User{" +
"userId='" + userId + '\'' +
", name='" + name + '\'' +
", balance=" + balance +
'}';
}
}
invoicing-service-zone-2/src/main/java/org/example/resources/ExternalAPI.java 0 → 100644
View file @ 8499fd76
package org.example.resources;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import org.example.models.Invoice;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import java.io.IOException;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;
public class ExternalAPI {
public static Invoice getInvoiceDetails(String invoiceId) throws IOException {
String prompt = "{\n" +
" \"prompt\": \"generate just one random json object contains these attributes: value, status, description, userID, invoiceID. where status is false and value is double and invoiceId is " + invoiceId + ", please just return this object without any words else\"\n" +
"}";
String response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("{");
int endIndex = response.toString().indexOf("}");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Gson gson = new Gson();
Invoice invoice = gson.fromJson(jsonString, Invoice.class);
System.out.println(invoice.toString());
return invoice;
}
static public List<Invoice> getUnPaidInvoicesForSpecificUser(String userId){
String prompt = "{\n" +
" \"prompt\": \"generate list of random json objects each object contains these attributes: value, status, description, userID, invoiceID. where status is false and value is double and invoiceId is unique and userId is " + userId+ ", please just return this list of objects without any words else\"\n" +
"}";
ArrayList<Invoice> invoices = new ArrayList<Invoice>();
String response = null;
response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("[");
int endIndex = response.toString().indexOf("]");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Type listType = new TypeToken<List<Invoice>>() {}.getType();
Gson gson = new Gson();
invoices = gson.fromJson(jsonString, listType);
return invoices;
}
static public List<Invoice> getUnPaidInvoices(){
String prompt = "{\n" +
" \"prompt\": \"generate list of random json objects each object contains these attributes: value, status, description, userID, invoiceID. where status is false and value is double and invoiceId is unique and userId is between 1 to 4, please just return this list of objects without any words else\"\n" +
"}";
ArrayList<Invoice> invoices = new ArrayList<Invoice>();
String response = null;
response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("[");
int endIndex = response.toString().indexOf("]");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Type listType = new TypeToken<List<Invoice>>() {}.getType();
Gson gson = new Gson();
invoices = gson.fromJson(jsonString, listType);
return invoices;
}
static public List<Invoice> getPaidInvoices(){
String prompt = "{\n" +
" \"prompt\": \"generate list of random json objects each object contains these attributes: value, status, description, userID, invoiceID. where status is true and value is double and invoiceId is unique and userId is between 1 to 4, please just return this list of objects without any words else\"\n" +
"}";
ArrayList<Invoice> invoices = new ArrayList<Invoice>();
String response = null;
response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("[");
int endIndex = response.toString().indexOf("]");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Type listType = new TypeToken<List<Invoice>>() {}.getType();
Gson gson = new Gson();
invoices = gson.fromJson(jsonString, listType);
return invoices;
}
public static String sendRequestToAPI(String prompt) {
RestTemplate restTemplate = new RestTemplate();
String url = "https://fumes-api.onrender.com/llama3";
org.springframework.http.HttpHeaders headers = new org.springframework.http.HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<String> requestEntity = new HttpEntity<>(prompt, headers);
ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class);
String response = responseEntity.getBody();
System.out.println(response);
return response;
}
}
invoicing-service-zone-2/src/main/java/org/example/resources/InvoiceResource.java 0 → 100644
View file @ 8499fd76
package org.example.resources;
import org.example.models.Invoice;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
@RestController
@RequestMapping("/invoices")
public class InvoiceResource {
private static final Logger log = LoggerFactory.getLogger(InvoiceResource.class);
@Autowired
RestTemplate restTemplate;
@GetMapping("/getInvoiceDetails/{invoiceId}")
public Invoice getInvoiceDetails(@PathVariable("invoiceId") String invoiceId){
Invoice invoice = null;
try {
invoice = ExternalAPI.getInvoiceDetails(invoiceId);
System.out.println("Got invoice details it's Id is "+ invoiceId);
System.out.println("Got invoice details it's Id is "+ invoiceId);
System.out.println(invoice.toString());
} catch (IOException e){
throw new RuntimeException(e);
}
return invoice;
}
@GetMapping("/getUnPaidInvoicesForSpecificUser/{userId}")
public List<Invoice> getUnPaidInvoicesForSpecificUser(@PathVariable("userId") String userId){
List<Invoice> inv = new ArrayList<>();
inv = ExternalAPI.getUnPaidInvoicesForSpecificUser(userId);
log.info("Got unpaid invoices for user has "+userId+ " userId");
System.out.println("Got unpaid invoices for user has "+userId+ " userId");
return inv;
}
@PostMapping("/updateInvoiceStatus/{invoiceId}")
public boolean updateInvoiceStatus(@PathVariable("invoiceId") String invoiceId){
/* here some logic like get invoice from database and set the status to true */
log.info("mark the invoice which has "+invoiceId+" invoiceId status as true (paid)");
System.out.println("mark the invoice which has "+invoiceId+" invoiceId status as true (paid)");
return true;
}
@GetMapping("/getUnPaidInvoices")
public List<Invoice> getUnPaidInvoices(){
List<Invoice> invoices = new ArrayList<Invoice>();
invoices = ExternalAPI.getUnPaidInvoices();
log.info("Got all unpaid invoices");
System.out.println("Got all unpaid invoices");
return invoices;
}
@GetMapping("/getPaidInvoices")
public List<Invoice> getPaidInvoices(){
List<Invoice> invoices = new ArrayList<Invoice>();
invoices = ExternalAPI.getPaidInvoices();
log.info("Got all paid invoices");
System.out.println("Got all paid invoices");
return invoices;
}
}
invoicing-service-zone-2/src/main/resources/application.properties 0 → 100644
View file @ 8499fd76
spring.application.name=invoicing-service
server.port=8085
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=latakia
invoicing-service-zone-2/src/main/resources/logback.xml 0 → 100644
View file @ 8499fd76
<configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/latakia/invoicing-service.log</file>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Console appender -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.example" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</logger>
<root level="error">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</root>
</configuration>
\ No newline at end of file
invoicing-service-zone-2/target/classes/application.properties 0 → 100644
View file @ 8499fd76
spring.application.name=invoicing-service
server.port=8085
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=latakia
invoicing-service-zone-2/target/classes/logback.xml 0 → 100644
View file @ 8499fd76
<configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/latakia/invoicing-service.log</file>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Console appender -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.example" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</logger>
<root level="error">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</root>
</configuration>
\ No newline at end of file
invoicing-service/src/main/resources/application.properties
View file @ 8499fd76
spring.application.name=invoicing-service spring.application.name=invoicing-service
server.port=8081 server.port=8081
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/} eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=damascus
\ No newline at end of file
invoicing-service/src/main/resources/logback.xml
View file @ 8499fd76
<configuration> <configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender"> <appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/invoicing-service.log</file> <file>logs/damascus/invoicing-service.log</file>
<encoder> <encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder> </encoder>
......
invoicing-service/target/classes/application.properties
View file @ 8499fd76
spring.application.name=invoicing-service spring.application.name=invoicing-service
server.port=8081 server.port=8081
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/} eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=damascus
\ No newline at end of file
invoicing-service/target/classes/logback.xml
View file @ 8499fd76
<configuration> <configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender"> <appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/invoicing-service.log</file> <file>logs/damascus/invoicing-service.log</file>
<encoder> <encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder> </encoder>
......
logs/invoicing-service.log → logs/damascus/invoicing-service.log
View file @ 8499fd76
2024-04-27 02:01:52.860 [main] INFO o.e.InvoicingServiceApplication - Starting InvoicingServiceApplication using Java 17 with PID 524 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services) 2024-04-27 16:20:05.651 [main] INFO o.e.InvoicingServiceApplication - Starting InvoicingServiceApplication using Java 17 with PID 13212 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 02:01:52.866 [main] DEBUG o.e.InvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3 2024-04-27 16:20:05.657 [main] DEBUG o.e.InvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 02:01:52.869 [main] INFO o.e.InvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default" 2024-04-27 16:20:05.660 [main] INFO o.e.InvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 02:02:00.667 [main] INFO o.e.InvoicingServiceApplication - Started InvoicingServiceApplication in 9.26 seconds (process running for 10.595) 2024-04-27 16:20:17.548 [main] INFO o.e.InvoicingServiceApplication - Started InvoicingServiceApplication in 14.802 seconds (process running for 16.341)
2024-04-27 02:03:19.873 [http-nio-8081-exec-3] INFO o.example.resources.InvoiceResource - Got all unpaid invoices 2024-04-27 17:21:38.589 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/localhost:invoicing-service:8081 - de-registration failedCannot execute request on any known server
2024-04-27 02:03:36.018 [http-nio-8081-exec-5] INFO o.example.resources.InvoiceResource - Got all paid invoices
2024-04-27 02:03:58.980 [http-nio-8081-exec-4] INFO o.example.resources.InvoiceResource - Got unpaid invoices for user has 1 userId
2024-04-27 02:05:06.758 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/DESKTOP-LO543MC:invoicing-service:8081 - de-registration failedCannot execute request on any known server
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server
at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112) at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
...@@ -39,47 +36,7 @@ com.netflix.discovery.shared.transport.TransportException: Cannot execute reques ...@@ -39,47 +36,7 @@ com.netflix.discovery.shared.transport.TransportException: Cannot execute reques
at java.base/java.lang.Iterable.forEach(Iterable.java:75) at java.base/java.lang.Iterable.forEach(Iterable.java:75)
at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108) at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108)
at java.base/java.lang.Thread.run(Thread.java:833) at java.base/java.lang.Thread.run(Thread.java:833)
2024-04-27 14:45:09.232 [main] INFO o.e.InvoicingServiceApplication - Starting InvoicingServiceApplication using Java 17 with PID 6092 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services) 2024-04-27 22:34:32.461 [main] INFO o.e.InvoicingServiceApplication - Starting InvoicingServiceApplication using Java 17 with PID 8736 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 14:45:09.303 [main] DEBUG o.e.InvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3 2024-04-27 22:34:32.470 [main] DEBUG o.e.InvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 14:45:09.306 [main] INFO o.e.InvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default" 2024-04-27 22:34:32.480 [main] INFO o.e.InvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 14:45:21.736 [main] INFO o.e.InvoicingServiceApplication - Started InvoicingServiceApplication in 15.264 seconds (process running for 18.594) 2024-04-27 22:34:42.618 [main] INFO o.e.InvoicingServiceApplication - Started InvoicingServiceApplication in 12.377 seconds (process running for 14.273)
2024-04-27 14:52:32.458 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/localhost:invoicing-service:8081 - de-registration failedCannot execute request on any known server
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server
at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$2.execute(EurekaHttpClientDecorator.java:74)
at com.netflix.discovery.shared.transport.decorator.SessionedEurekaHttpClient.execute(SessionedEurekaHttpClient.java:77)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
at com.netflix.discovery.DiscoveryClient.unregister(DiscoveryClient.java:916)
at com.netflix.discovery.DiscoveryClient.shutdown(DiscoveryClient.java:892)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:424)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeDestroyMethods(InitDestroyAnnotationBeanPostProcessor.java:382)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeDestruction(InitDestroyAnnotationBeanPostProcessor.java:212)
at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:191)
at org.springframework.beans.factory.support.DisposableBeanAdapter.run(DisposableBeanAdapter.java:184)
at org.springframework.cloud.context.scope.GenericScope$BeanLifecycleWrapper.destroy(GenericScope.java:389)
at org.springframework.cloud.context.scope.GenericScope.destroy(GenericScope.java:136)
at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:200)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroyBean(DefaultSingletonBeanRegistry.java:587)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingleton(DefaultSingletonBeanRegistry.java:559)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingleton(DefaultListableBeanFactory.java:1177)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingletons(DefaultSingletonBeanRegistry.java:520)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingletons(DefaultListableBeanFactory.java:1170)
at org.springframework.context.support.AbstractApplicationContext.destroyBeans(AbstractApplicationContext.java:1082)
at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:1051)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.doClose(ServletWebServerApplicationContext.java:173)
at org.springframework.context.support.AbstractApplicationContext.close(AbstractApplicationContext.java:1001)
at org.springframework.boot.SpringApplicationShutdownHook.closeAndWait(SpringApplicationShutdownHook.java:139)
at java.base/java.lang.Iterable.forEach(Iterable.java:75)
at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108)
at java.base/java.lang.Thread.run(Thread.java:833)
2024-04-27 14:57:33.199 [main] INFO o.e.InvoicingServiceApplication - Starting InvoicingServiceApplication using Java 17 with PID 4824 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 14:57:33.214 [main] DEBUG o.e.InvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 14:57:33.218 [main] INFO o.e.InvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 14:57:49.919 [main] INFO o.e.InvoicingServiceApplication - Started InvoicingServiceApplication in 19.381 seconds (process running for 21.022)
2024-04-27 15:03:12.894 [http-nio-8081-exec-1] INFO o.example.resources.InvoiceResource - Got unpaid invoices for user has 1 userId
2024-04-27 15:05:34.074 [http-nio-8081-exec-3] INFO o.example.resources.InvoiceResource - Got unpaid invoices for user has 1 userId
logs/replica-invoicing-service.log → logs/damascus/replica-invoicing-service.log
View file @ 8499fd76
2024-04-27 14:45:32.428 [main] INFO o.e.ReplicaInvoicingServiceApplication - Starting ReplicaInvoicingServiceApplication using Java 17 with PID 14580 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services) 2024-04-27 16:21:21.440 [main] INFO o.e.ReplicaInvoicingServiceApplication - Starting ReplicaInvoicingServiceApplication using Java 17 with PID 14868 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 14:45:32.440 [main] DEBUG o.e.ReplicaInvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3 2024-04-27 16:21:21.448 [main] DEBUG o.e.ReplicaInvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 14:45:32.442 [main] INFO o.e.ReplicaInvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default" 2024-04-27 16:21:21.451 [main] INFO o.e.ReplicaInvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 14:45:45.216 [main] INFO o.e.ReplicaInvoicingServiceApplication - Started ReplicaInvoicingServiceApplication in 15.461 seconds (process running for 18.944) 2024-04-27 16:21:34.489 [main] INFO o.e.ReplicaInvoicingServiceApplication - Started ReplicaInvoicingServiceApplication in 16.131 seconds (process running for 17.752)
2024-04-27 14:52:32.634 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/localhost:invoicing-service:8082 - de-registration failedCannot execute request on any known server 2024-04-27 16:48:46.995 [http-nio-8082-exec-1] INFO o.example.resources.InvoiceResource - mark the invoice which has 2 invoiceId status as true (paid)
2024-04-27 17:21:38.647 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/localhost:invoicing-service:8082 - de-registration failedCannot execute request on any known server
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server
at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112) at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71) at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
...@@ -36,14 +37,7 @@ com.netflix.discovery.shared.transport.TransportException: Cannot execute reques ...@@ -36,14 +37,7 @@ com.netflix.discovery.shared.transport.TransportException: Cannot execute reques
at java.base/java.lang.Iterable.forEach(Iterable.java:75) at java.base/java.lang.Iterable.forEach(Iterable.java:75)
at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108) at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108)
at java.base/java.lang.Thread.run(Thread.java:833) at java.base/java.lang.Thread.run(Thread.java:833)
2024-04-27 14:58:15.377 [main] INFO o.e.ReplicaInvoicingServiceApplication - Starting ReplicaInvoicingServiceApplication using Java 17 with PID 2868 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services) 2024-04-27 22:35:08.458 [main] INFO o.e.ReplicaInvoicingServiceApplication - Starting ReplicaInvoicingServiceApplication using Java 17 with PID 3408 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 14:58:15.387 [main] DEBUG o.e.ReplicaInvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3 2024-04-27 22:35:08.465 [main] DEBUG o.e.ReplicaInvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 14:58:15.392 [main] INFO o.e.ReplicaInvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default" 2024-04-27 22:35:08.468 [main] INFO o.e.ReplicaInvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 14:58:28.455 [main] INFO o.e.ReplicaInvoicingServiceApplication - Started ReplicaInvoicingServiceApplication in 16.165 seconds (process running for 18.125) 2024-04-27 22:35:19.906 [main] INFO o.e.ReplicaInvoicingServiceApplication - Started ReplicaInvoicingServiceApplication in 13.232 seconds (process running for 14.892)
2024-04-27 15:01:17.962 [http-nio-8082-exec-1] INFO o.example.resources.InvoiceResource - Got unpaid invoices for user has 1 userId
2024-04-27 15:01:59.774 [http-nio-8082-exec-2] INFO o.example.resources.InvoiceResource - Got unpaid invoices for user has 1 userId
2024-04-27 15:04:07.667 [main] INFO o.e.ReplicaInvoicingServiceApplication - Starting ReplicaInvoicingServiceApplication using Java 17 with PID 6272 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 15:04:07.676 [main] DEBUG o.e.ReplicaInvoicingServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 15:04:07.678 [main] INFO o.e.ReplicaInvoicingServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 15:04:18.877 [main] INFO o.e.ReplicaInvoicingServiceApplication - Started ReplicaInvoicingServiceApplication in 13.725 seconds (process running for 15.098)
2024-04-27 15:07:07.363 [http-nio-8082-exec-1] INFO o.example.resources.InvoiceResource - mark the invoice which has 2 invoiceId status as true (paid)
logs/damascus/users-service.log 0 → 100644
View file @ 8499fd76
2024-04-27 16:22:03.993 [main] INFO org.example.UsersServiceApplication - Starting UsersServiceApplication using Java 17 with PID 14992 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\users-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 16:22:04.000 [main] DEBUG org.example.UsersServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 16:22:04.002 [main] INFO org.example.UsersServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 16:22:15.818 [main] INFO org.example.UsersServiceApplication - Started UsersServiceApplication in 14.479 seconds (process running for 16.05)
2024-04-27 16:50:16.225 [http-nio-8080-exec-3] INFO org.example.resources.UserResource - Got all users have paid invoices
2024-04-27 22:36:01.616 [main] INFO org.example.UsersServiceApplication - Starting UsersServiceApplication using Java 17 with PID 15268 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\users-service\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 22:36:01.624 [main] DEBUG org.example.UsersServiceApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 22:36:01.626 [main] INFO org.example.UsersServiceApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 22:36:10.720 [main] INFO org.example.UsersServiceApplication - Started UsersServiceApplication in 10.793 seconds (process running for 12.915)
logs/latakia/invoicing-service.log 0 → 100644
View file @ 8499fd76
2024-04-27 16:21:01.293 [main] INFO o.e.InvoicingServiceZone2Application - Starting InvoicingServiceZone2Application using Java 17 with PID 1180 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service-zone-2\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 16:21:01.299 [main] DEBUG o.e.InvoicingServiceZone2Application - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 16:21:01.303 [main] INFO o.e.InvoicingServiceZone2Application - No active profile set, falling back to 1 default profile: "default"
2024-04-27 16:21:13.972 [main] INFO o.e.InvoicingServiceZone2Application - Started InvoicingServiceZone2Application in 16.041 seconds (process running for 18.792)
2024-04-27 16:50:16.156 [http-nio-8085-exec-1] INFO o.example.resources.InvoiceResource - Got all paid invoices
2024-04-27 17:21:35.280 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/localhost:invoicing-service:8085 - de-registration failedCannot execute request on any known server
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server
at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$2.execute(EurekaHttpClientDecorator.java:74)
at com.netflix.discovery.shared.transport.decorator.SessionedEurekaHttpClient.execute(SessionedEurekaHttpClient.java:77)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
at com.netflix.discovery.DiscoveryClient.unregister(DiscoveryClient.java:916)
at com.netflix.discovery.DiscoveryClient.shutdown(DiscoveryClient.java:892)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:424)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeDestroyMethods(InitDestroyAnnotationBeanPostProcessor.java:382)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeDestruction(InitDestroyAnnotationBeanPostProcessor.java:212)
at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:191)
at org.springframework.beans.factory.support.DisposableBeanAdapter.run(DisposableBeanAdapter.java:184)
at org.springframework.cloud.context.scope.GenericScope$BeanLifecycleWrapper.destroy(GenericScope.java:389)
at org.springframework.cloud.context.scope.GenericScope.destroy(GenericScope.java:136)
at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:200)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroyBean(DefaultSingletonBeanRegistry.java:587)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingleton(DefaultSingletonBeanRegistry.java:559)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingleton(DefaultListableBeanFactory.java:1177)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingletons(DefaultSingletonBeanRegistry.java:520)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingletons(DefaultListableBeanFactory.java:1170)
at org.springframework.context.support.AbstractApplicationContext.destroyBeans(AbstractApplicationContext.java:1082)
at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:1051)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.doClose(ServletWebServerApplicationContext.java:173)
at org.springframework.context.support.AbstractApplicationContext.close(AbstractApplicationContext.java:1001)
at org.springframework.boot.SpringApplicationShutdownHook.closeAndWait(SpringApplicationShutdownHook.java:139)
at java.base/java.lang.Iterable.forEach(Iterable.java:75)
at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108)
at java.base/java.lang.Thread.run(Thread.java:833)
2024-04-27 22:34:50.481 [main] INFO o.e.InvoicingServiceZone2Application - Starting InvoicingServiceZone2Application using Java 17 with PID 13092 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\invoicing-service-zone-2\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 22:34:50.491 [main] DEBUG o.e.InvoicingServiceZone2Application - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 22:34:50.494 [main] INFO o.e.InvoicingServiceZone2Application - No active profile set, falling back to 1 default profile: "default"
2024-04-27 22:35:01.092 [main] INFO o.e.InvoicingServiceZone2Application - Started InvoicingServiceZone2Application in 12.219 seconds (process running for 14.397)
logs/latakia/replica-invoicing-service.log 0 → 100644
View file @ 8499fd76
2024-04-27 16:21:45.568 [main] INFO o.e.ReplicaInvoicingServiceZone2Application - Starting ReplicaInvoicingServiceZone2Application using Java 17 with PID 12996 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service-zone-2\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 16:21:45.574 [main] DEBUG o.e.ReplicaInvoicingServiceZone2Application - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 16:21:45.581 [main] INFO o.e.ReplicaInvoicingServiceZone2Application - No active profile set, falling back to 1 default profile: "default"
2024-04-27 16:21:58.135 [main] INFO o.e.ReplicaInvoicingServiceZone2Application - Started ReplicaInvoicingServiceZone2Application in 15.225 seconds (process running for 17.391)
2024-04-27 16:51:08.155 [http-nio-8084-exec-3] INFO o.example.resources.InvoiceResource - Got all paid invoices
2024-04-27 17:21:39.073 [SpringApplicationShutdownHook] ERROR c.netflix.discovery.DiscoveryClient - DiscoveryClient_INVOICING-SERVICE/localhost:invoicing-service:8084 - de-registration failedCannot execute request on any known server
com.netflix.discovery.shared.transport.TransportException: Cannot execute request on any known server
at com.netflix.discovery.shared.transport.decorator.RetryableEurekaHttpClient.execute(RetryableEurekaHttpClient.java:112)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator$2.execute(EurekaHttpClientDecorator.java:74)
at com.netflix.discovery.shared.transport.decorator.SessionedEurekaHttpClient.execute(SessionedEurekaHttpClient.java:77)
at com.netflix.discovery.shared.transport.decorator.EurekaHttpClientDecorator.cancel(EurekaHttpClientDecorator.java:71)
at com.netflix.discovery.DiscoveryClient.unregister(DiscoveryClient.java:916)
at com.netflix.discovery.DiscoveryClient.shutdown(DiscoveryClient.java:892)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.base/java.lang.reflect.Method.invoke(Method.java:568)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleElement.invoke(InitDestroyAnnotationBeanPostProcessor.java:424)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor$LifecycleMetadata.invokeDestroyMethods(InitDestroyAnnotationBeanPostProcessor.java:382)
at org.springframework.beans.factory.annotation.InitDestroyAnnotationBeanPostProcessor.postProcessBeforeDestruction(InitDestroyAnnotationBeanPostProcessor.java:212)
at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:191)
at org.springframework.beans.factory.support.DisposableBeanAdapter.run(DisposableBeanAdapter.java:184)
at org.springframework.cloud.context.scope.GenericScope$BeanLifecycleWrapper.destroy(GenericScope.java:389)
at org.springframework.cloud.context.scope.GenericScope.destroy(GenericScope.java:136)
at org.springframework.beans.factory.support.DisposableBeanAdapter.destroy(DisposableBeanAdapter.java:200)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroyBean(DefaultSingletonBeanRegistry.java:587)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingleton(DefaultSingletonBeanRegistry.java:559)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingleton(DefaultListableBeanFactory.java:1177)
at org.springframework.beans.factory.support.DefaultSingletonBeanRegistry.destroySingletons(DefaultSingletonBeanRegistry.java:520)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.destroySingletons(DefaultListableBeanFactory.java:1170)
at org.springframework.context.support.AbstractApplicationContext.destroyBeans(AbstractApplicationContext.java:1082)
at org.springframework.context.support.AbstractApplicationContext.doClose(AbstractApplicationContext.java:1051)
at org.springframework.boot.web.servlet.context.ServletWebServerApplicationContext.doClose(ServletWebServerApplicationContext.java:173)
at org.springframework.context.support.AbstractApplicationContext.close(AbstractApplicationContext.java:1001)
at org.springframework.boot.SpringApplicationShutdownHook.closeAndWait(SpringApplicationShutdownHook.java:139)
at java.base/java.lang.Iterable.forEach(Iterable.java:75)
at org.springframework.boot.SpringApplicationShutdownHook.run(SpringApplicationShutdownHook.java:108)
at java.base/java.lang.Thread.run(Thread.java:833)
2024-04-27 22:35:27.590 [main] INFO o.e.ReplicaInvoicingServiceZone2Application - Starting ReplicaInvoicingServiceZone2Application using Java 17 with PID 8948 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\replica-invoicing-service-zone-2\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 22:35:27.599 [main] DEBUG o.e.ReplicaInvoicingServiceZone2Application - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 22:35:27.601 [main] INFO o.e.ReplicaInvoicingServiceZone2Application - No active profile set, falling back to 1 default profile: "default"
2024-04-27 22:35:37.400 [main] INFO o.e.ReplicaInvoicingServiceZone2Application - Started ReplicaInvoicingServiceZone2Application in 11.469 seconds (process running for 13.428)
logs/latakia/users-service.log 0 → 100644
View file @ 8499fd76
2024-04-27 16:22:23.017 [main] INFO o.e.UsersServiceZone2Application - Starting UsersServiceZone2Application using Java 17 with PID 17228 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\users-service-zone-2\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 16:22:23.024 [main] DEBUG o.e.UsersServiceZone2Application - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 16:22:23.027 [main] INFO o.e.UsersServiceZone2Application - No active profile set, falling back to 1 default profile: "default"
2024-04-27 16:22:33.545 [main] INFO o.e.UsersServiceZone2Application - Started UsersServiceZone2Application in 13.08 seconds (process running for 15.201)
2024-04-27 16:48:47.054 [http-nio-8083-exec-5] INFO org.example.resources.UserResource - paid invoice with 2 invoiceId for user has 1 userId
2024-04-27 16:51:08.205 [http-nio-8083-exec-8] INFO org.example.resources.UserResource - Got all users have paid invoices
2024-04-27 22:35:45.019 [main] INFO o.e.UsersServiceZone2Application - Starting UsersServiceZone2Application using Java 17 with PID 10676 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\users-service-zone-2\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 22:35:45.027 [main] DEBUG o.e.UsersServiceZone2Application - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 22:35:45.030 [main] INFO o.e.UsersServiceZone2Application - No active profile set, falling back to 1 default profile: "default"
2024-04-27 22:35:54.367 [main] INFO o.e.UsersServiceZone2Application - Started UsersServiceZone2Application in 10.982 seconds (process running for 12.942)
logs/users-service.log deleted 100644 → 0
View file @ e0c61f36
This diff is collapsed.
pom.xml
View file @ 8499fd76
...@@ -15,6 +15,9 @@ ...@@ -15,6 +15,9 @@
<module>service-discovery</module> <module>service-discovery</module>
<module>cloud-gateway</module> <module>cloud-gateway</module>
<module>replica-invoicing-service</module> <module>replica-invoicing-service</module>
<module>users-service-zone-2</module>
<module>invoicing-service-zone-2</module>
<module>replica-invoicing-service-zone-2</module>
</modules> </modules>
<properties> <properties>
......
replica-invoicing-service-zone-2/pom.xml 0 → 100644
View file @ 8499fd76
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.1</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>replica-invoicing-service-zone-2</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<spring-cloud.version>2022.0.0</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.9</version>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>netflix-candidates</id>
<name>Netflix Candidates</name>
<url>https://artifactory-oss.prod.netflix.net/artifactory/maven-oss-candidates</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
</project>
\ No newline at end of file
replica-invoicing-service-zone-2/src/main/java/org/example/ReplicaInvoicingServiceZone2Application.java 0 → 100644
View file @ 8499fd76
package org.example;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
@SpringBootApplication
@EnableDiscoveryClient
public class ReplicaInvoicingServiceZone2Application {
public static void main(String[] args) {
SpringApplication.run(ReplicaInvoicingServiceZone2Application.class, args);
}
@Bean
@LoadBalanced
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
replica-invoicing-service-zone-2/src/main/java/org/example/models/Invoice.java 0 → 100644
View file @ 8499fd76
package org.example.models;
public class Invoice {
private String invoiceID;
private String userID;
private String description;
private boolean status;
private double value;
public Invoice(String invoiceID, String userID, String description, boolean status, double value) {
this.invoiceID = invoiceID;
this.userID = userID;
this.description = description;
this.status = status;
this.value = value;
}
public Invoice() {
this.invoiceID = "";
this.userID = "";
this.description = "description";
this.status = false;
this.value = 0.0;
}
public String getInvoiceID() {
return invoiceID;
}
public void setInvoiceID(String invoiceID) {
this.invoiceID = invoiceID;
}
public String getUserID() {
return userID;
}
public void setUserID(String userID) {
this.userID = userID;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public boolean isStatus() {
return status;
}
public void setStatus(boolean status) {
this.status = status;
}
public double getValue() {
return value;
}
public void setValue(double value) {
this.value = value;
}
@Override
public String toString() {
return "Invoice{" +
"invoiceID='" + invoiceID + '\'' +
", userID='" + userID + '\'' +
", description='" + description + '\'' +
", status=" + status +
", value=" + value +
'}';
}
}
replica-invoicing-service-zone-2/src/main/java/org/example/models/User.java 0 → 100644
View file @ 8499fd76
package org.example.models;
public class User {
private String userId;
private String name;
private double balance;
public User(String userId, String name, double balance) {
this.userId = userId;
this.name = name;
this.balance = balance;
}
public User() {
this.userId = "";
this.name = "ali";
this.balance = 0.0;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public double getBalance() {
return balance;
}
public void setBalance(double balance) {
this.balance = balance;
}
@Override
public String toString() {
return "User{" +
"userId='" + userId + '\'' +
", name='" + name + '\'' +
", balance=" + balance +
'}';
}
}
replica-invoicing-service-zone-2/src/main/java/org/example/resources/ExternalAPI.java 0 → 100644
View file @ 8499fd76
package org.example.resources;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import org.example.models.Invoice;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import java.io.IOException;
import java.lang.reflect.Type;
import java.util.ArrayList;
import java.util.List;
public class ExternalAPI {
public static Invoice getInvoiceDetails(String invoiceId) throws IOException {
String prompt = "{\n" +
" \"prompt\": \"generate just one random json object contains these attributes: value, status, description, userID, invoiceID. where status is false and value is double and invoiceId is " + invoiceId + ", please just return this object without any words else\"\n" +
"}";
String response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("{");
int endIndex = response.toString().indexOf("}");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Gson gson = new Gson();
Invoice invoice = gson.fromJson(jsonString, Invoice.class);
System.out.println(invoice.toString());
return invoice;
}
static public List<Invoice> getUnPaidInvoicesForSpecificUser(String userId){
String prompt = "{\n" +
" \"prompt\": \"generate list of random json objects each object contains these attributes: value, status, description, userID, invoiceID. where status is false and value is double and invoiceId is unique and userId is " + userId+ ", please just return this list of objects without any words else\"\n" +
"}";
ArrayList<Invoice> invoices = new ArrayList<Invoice>();
String response = null;
response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("[");
int endIndex = response.toString().indexOf("]");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Type listType = new TypeToken<List<Invoice>>() {}.getType();
Gson gson = new Gson();
invoices = gson.fromJson(jsonString, listType);
return invoices;
}
static public List<Invoice> getUnPaidInvoices(){
String prompt = "{\n" +
" \"prompt\": \"generate list of random json objects each object contains these attributes: value, status, description, userID, invoiceID. where status is false and value is double and invoiceId is unique and userId is between 1 to 4, please just return this list of objects without any words else\"\n" +
"}";
ArrayList<Invoice> invoices = new ArrayList<Invoice>();
String response = null;
response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("[");
int endIndex = response.toString().indexOf("]");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Type listType = new TypeToken<List<Invoice>>() {}.getType();
Gson gson = new Gson();
invoices = gson.fromJson(jsonString, listType);
return invoices;
}
static public List<Invoice> getPaidInvoices(){
String prompt = "{\n" +
" \"prompt\": \"generate list of random json objects each object contains these attributes: value, status, description, userID, invoiceID. where status is true and value is double and invoiceId is unique and userId is between 1 to 4, please just return this list of objects without any words else\"\n" +
"}";
ArrayList<Invoice> invoices = new ArrayList<Invoice>();
String response = null;
response = sendRequestToAPI(prompt);
String jsonString = "";
int firstIndex = response.toString().indexOf("[");
int endIndex = response.toString().indexOf("]");
jsonString = response.toString().substring(firstIndex, endIndex + 1);
Type listType = new TypeToken<List<Invoice>>() {}.getType();
Gson gson = new Gson();
invoices = gson.fromJson(jsonString, listType);
return invoices;
}
public static String sendRequestToAPI(String prompt) {
RestTemplate restTemplate = new RestTemplate();
String url = "https://fumes-api.onrender.com/llama3";
org.springframework.http.HttpHeaders headers = new org.springframework.http.HttpHeaders();
headers.setContentType(MediaType.APPLICATION_JSON);
HttpEntity<String> requestEntity = new HttpEntity<>(prompt, headers);
ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.POST, requestEntity, String.class);
String response = responseEntity.getBody();
System.out.println(response);
return response;
}
}
replica-invoicing-service-zone-2/src/main/java/org/example/resources/InvoiceResource.java 0 → 100644
View file @ 8499fd76
package org.example.resources;
import org.example.models.Invoice;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
@RestController
@RequestMapping("/invoices")
public class InvoiceResource {
private static final Logger log = LoggerFactory.getLogger(InvoiceResource.class);
@Autowired
RestTemplate restTemplate;
@GetMapping("/getInvoiceDetails/{invoiceId}")
public Invoice getInvoiceDetails(@PathVariable("invoiceId") String invoiceId){
Invoice invoice = null;
try {
invoice = ExternalAPI.getInvoiceDetails(invoiceId);
System.out.println("Got invoice details it's Id is "+ invoiceId);
System.out.println("Got invoice details it's Id is "+ invoiceId);
System.out.println(invoice.toString());
} catch (IOException e){
throw new RuntimeException(e);
}
return invoice;
}
@GetMapping("/getUnPaidInvoicesForSpecificUser/{userId}")
public List<Invoice> getUnPaidInvoicesForSpecificUser(@PathVariable("userId") String userId){
List<Invoice> inv = new ArrayList<>();
inv = ExternalAPI.getUnPaidInvoicesForSpecificUser(userId);
log.info("Got unpaid invoices for user has "+userId+ " userId");
System.out.println("Got unpaid invoices for user has "+userId+ " userId");
return inv;
}
@PostMapping("/updateInvoiceStatus/{invoiceId}")
public boolean updateInvoiceStatus(@PathVariable("invoiceId") String invoiceId){
/* here some logic like get invoice from database and set the status to true */
log.info("mark the invoice which has "+invoiceId+" invoiceId status as true (paid)");
System.out.println("mark the invoice which has "+invoiceId+" invoiceId status as true (paid)");
return true;
}
@GetMapping("/getUnPaidInvoices")
public List<Invoice> getUnPaidInvoices(){
List<Invoice> invoices = new ArrayList<Invoice>();
invoices = ExternalAPI.getUnPaidInvoices();
log.info("Got all unpaid invoices");
System.out.println("Got all unpaid invoices");
return invoices;
}
@GetMapping("/getPaidInvoices")
public List<Invoice> getPaidInvoices(){
List<Invoice> invoices = new ArrayList<Invoice>();
invoices = ExternalAPI.getPaidInvoices();
log.info("Got all paid invoices");
System.out.println("Got all paid invoices");
return invoices;
}
}
replica-invoicing-service-zone-2/src/main/resources/application.properties 0 → 100644
View file @ 8499fd76
spring.application.name=invoicing-service
server.port=8084
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=latakia
replica-invoicing-service-zone-2/src/main/resources/logback.xml 0 → 100644
View file @ 8499fd76
<configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/latakia/replica-invoicing-service.log</file>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Console appender -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.example" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</logger>
<root level="error">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</root>
</configuration>
\ No newline at end of file
replica-invoicing-service-zone-2/target/classes/application.properties 0 → 100644
View file @ 8499fd76
spring.application.name=invoicing-service
server.port=8084
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=latakia
replica-invoicing-service-zone-2/target/classes/logback.xml 0 → 100644
View file @ 8499fd76
<configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/latakia/replica-invoicing-service.log</file>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Console appender -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.example" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</logger>
<root level="error">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</root>
</configuration>
\ No newline at end of file
replica-invoicing-service/src/main/resources/application.properties
View file @ 8499fd76
spring.application.name=invoicing-service spring.application.name=invoicing-service
server.port=8082 server.port=8082
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/} eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=damascus
\ No newline at end of file
replica-invoicing-service/src/main/resources/logback.xml
View file @ 8499fd76
<configuration> <configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender"> <appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/replica-invoicing-service.log</file> <file>logs/damascus/replica-invoicing-service.log</file>
<encoder> <encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder> </encoder>
......
replica-invoicing-service/target/classes/application.properties
View file @ 8499fd76
spring.application.name=invoicing-service spring.application.name=invoicing-service
server.port=8082 server.port=8082
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/} eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=damascus
\ No newline at end of file
replica-invoicing-service/target/classes/logback.xml
View file @ 8499fd76
<configuration> <configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender"> <appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/replica-invoicing-service.log</file> <file>logs/damascus/replica-invoicing-service.log</file>
<encoder> <encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder> </encoder>
......
service-discovery/logs/application.log
View file @ 8499fd76
...@@ -12011,3 +12011,11 @@ java.lang.IllegalStateException: Client instance has been closed. ...@@ -12011,3 +12011,11 @@ java.lang.IllegalStateException: Client instance has been closed.
2024-04-27 14:55:35.290 [main] DEBUG o.e.ServiceDiscoveryApplication - Running with Spring Boot v3.0.1, Spring v6.0.3 2024-04-27 14:55:35.290 [main] DEBUG o.e.ServiceDiscoveryApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 14:55:35.292 [main] INFO o.e.ServiceDiscoveryApplication - No active profile set, falling back to 1 default profile: "default" 2024-04-27 14:55:35.292 [main] INFO o.e.ServiceDiscoveryApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 14:55:48.675 [main] INFO o.e.ServiceDiscoveryApplication - Started ServiceDiscoveryApplication in 15.859 seconds (process running for 17.358) 2024-04-27 14:55:48.675 [main] INFO o.e.ServiceDiscoveryApplication - Started ServiceDiscoveryApplication in 15.859 seconds (process running for 17.358)
2024-04-27 16:19:20.746 [main] INFO o.e.ServiceDiscoveryApplication - Starting ServiceDiscoveryApplication using Java 17 with PID 10204 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\service-discovery\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 16:19:20.751 [main] DEBUG o.e.ServiceDiscoveryApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 16:19:20.754 [main] INFO o.e.ServiceDiscoveryApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 16:19:36.395 [main] INFO o.e.ServiceDiscoveryApplication - Started ServiceDiscoveryApplication in 18.075 seconds (process running for 19.587)
2024-04-27 22:32:36.577 [main] INFO o.e.ServiceDiscoveryApplication - Starting ServiceDiscoveryApplication using Java 17 with PID 6664 (D:\Second Semester\Advanced DS\Practical\New folder\micro-services\service-discovery\target\classes started by dell in D:\Second Semester\Advanced DS\Practical\New folder\micro-services)
2024-04-27 22:32:36.584 [main] DEBUG o.e.ServiceDiscoveryApplication - Running with Spring Boot v3.0.1, Spring v6.0.3
2024-04-27 22:32:36.587 [main] INFO o.e.ServiceDiscoveryApplication - No active profile set, falling back to 1 default profile: "default"
2024-04-27 22:32:50.785 [main] INFO o.e.ServiceDiscoveryApplication - Started ServiceDiscoveryApplication in 15.74 seconds (process running for 17.625)
users-service-zone-2/pom.xml 0 → 100644
View file @ 8499fd76
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.1</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>users-service-zone-2</artifactId>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<spring-cloud.version>2022.0.0</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.7.0</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.8.9</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
<repositories>
<repository>
<id>netflix-candidates</id>
<name>Netflix Candidates</name>
<url>https://artifactory-oss.prod.netflix.net/artifactory/maven-oss-candidates</url>
<snapshots>
<enabled>false</enabled>
</snapshots>
</repository>
</repositories>
</project>
\ No newline at end of file
users-service-zone-2/src/main/java/org/example/UsersServiceZone2Application.java 0 → 100644
View file @ 8499fd76
package org.example;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
@SpringBootApplication
@EnableDiscoveryClient
public class UsersServiceZone2Application {
public static void main(String[] args) {
SpringApplication.run(UsersServiceZone2Application.class, args);
}
@Bean
@LoadBalanced
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
users-service-zone-2/src/main/java/org/example/models/Invoice.java 0 → 100644
View file @ 8499fd76
package org.example.models;
public class Invoice {
private String invoiceID;
private String userID;
private String description;
private boolean status;
private double value;
public Invoice(String invoiceID, String userID, String description, boolean status, double value) {
this.invoiceID = invoiceID;
this.userID = userID;
this.description = description;
this.status = status;
this.value = value;
}
public Invoice() {
this.invoiceID = "";
this.userID = "";
this.description = "description";
this.status = false;
this.value = 0.0;
}
public String getInvoiceID() {
return invoiceID;
}
public void setInvoiceID(String invoiceID) {
this.invoiceID = invoiceID;
}
public String getUserID() {
return userID;
}
public void setUserID(String userID) {
this.userID = userID;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
public boolean isStatus() {
return status;
}
public void setStatus(boolean status) {
this.status = status;
}
public double getValue() {
return value;
}
public void setValue(double value) {
this.value = value;
}
@Override
public String toString() {
return "Invoice{" +
"invoiceID='" + invoiceID + '\'' +
", userID='" + userID + '\'' +
", description='" + description + '\'' +
", status=" + status +
", value=" + value +
'}';
}
}
users-service-zone-2/src/main/java/org/example/models/User.java 0 → 100644
View file @ 8499fd76
package org.example.models;
public class User {
private String userId;
private String name;
private double balance;
public User(String userId, String name, double balance) {
this.userId = userId;
this.name = name;
this.balance = balance;
}
public User() {
this.userId = "";
this.name = "ali";
this.balance = 0.0;
}
public String getUserId() {
return userId;
}
public void setUserId(String userId) {
this.userId = userId;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public double getBalance() {
return balance;
}
public void setBalance(double balance) {
this.balance = balance;
}
@Override
public String toString() {
return "User{" +
"userId='" + userId + '\'' +
", name='" + name + '\'' +
", balance=" + balance +
'}';
}
}
users-service-zone-2/src/main/java/org/example/repositories/UserRepository.java 0 → 100644
View file @ 8499fd76
package org.example.repositories;
import com.google.gson.Gson;
import org.example.models.User;
import redis.clients.jedis.Jedis;
public class UserRepository {
private Jedis jedis;
private Gson gson;
public UserRepository() {
jedis = new Jedis("localhost", 6379);
gson = new Gson();
}
public boolean exist(String userId){
if (jedis.exists(userId)) {
return true;
}
return false;
}
public void addUser(User user) {
String userJson = convertToJson(user);
jedis.set(user.getUserId(), userJson);
}
public User getUser(String userId) {
String userJson = jedis.get(userId);
return convertFromJson(userJson,userId);
}
public void updateUser(User user) {
if (jedis.exists(user.getUserId())) {
String userJson = convertToJson(user);
jedis.set(user.getUserId(), userJson);
}
}
public void deleteUser(String userId) {
jedis.del(userId);
}
private String convertToJson(User user) {
UserJsonData userJsonData = new UserJsonData();
userJsonData.setName(user.getName());
userJsonData.setBalance(user.getBalance());
return gson.toJson(userJsonData);
}
private User convertFromJson(String userJson,String userId) {
UserJsonData userJsonData = gson.fromJson(userJson, UserJsonData.class);
User user = new User();
user.setUserId(userId);
user.setName(userJsonData.getName());
user.setBalance(userJsonData.getBalance());
return user;
}
private static class UserJsonData {
private String name;
private double balance;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public double getBalance() {
return balance;
}
public void setBalance(double balance) {
this.balance = balance;
}
}
}
users-service-zone-2/src/main/java/org/example/resources/UserResource.java 0 → 100644
View file @ 8499fd76
package org.example.resources;
import org.example.models.Invoice;
import org.example.models.User;
import org.example.repositories.UserRepository;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.util.*;
@RestController
@RequestMapping("/users")
public class UserResource {
private static final Logger log = LoggerFactory.getLogger(UserResource.class);
UserRepository userRepository = new UserRepository();
@Autowired
RestTemplate restTemplate;
@GetMapping("/getUnPaidInvoices/{userId}")
public List<Invoice> getUnPaidInvoices(@PathVariable("userId") String userId){
if(userRepository.exist(userId)) {
List<Invoice> invoices = Arrays.asList(restTemplate.getForObject("http://invoicing-service/invoices/getUnPaidInvoicesForSpecificUser/" + userId, Invoice[].class));
log.info("Got unpaid invoices for user has "+userId+ " userId");
System.out.println("Got all unpaid invoices for user has "+userId+ " userId");
return invoices;
}
return null;
}
@PostMapping("/payInvoice/{userId}/{invoiceId}")
public boolean payInvoice(@PathVariable("userId") String userId,@PathVariable("invoiceId") String invoiceId){
User user = new User();
if(userRepository.exist(userId)){
user = userRepository.getUser(userId);
Invoice invoice = restTemplate.getForObject("http://invoicing-service/invoices/getInvoiceDetails/" + invoiceId, Invoice.class);
if(user.getBalance() >= invoice.getValue()){
user.setBalance(user.getBalance() - invoice.getValue());
String url = "http://invoicing-service/invoices/updateInvoiceStatus/" + invoiceId;
ResponseEntity<Boolean> response = restTemplate.exchange(url, HttpMethod.POST, null, Boolean.class);
boolean status = response.getBody();
userRepository.updateUser(user);
log.info("paid invoice with "+invoiceId+ " invoiceId for user has "+userId+" userId");
System.out.println("paid invoice with "+invoiceId+ " invoiceId for user has "+userId+" userId");
return status;
}
else{
System.out.println("you do not have enough balance!!!");
return false;
}
}
else {
System.out.println("user does not exist!!");
return false;
}
}
@GetMapping("/getAllUsersHaveUnPaidInvoices")
public HashMap<User,Invoice> getAllUsersHaveUnPaidInvoices(){
List<Invoice> invoices = Arrays.asList(restTemplate.getForObject("http://invoicing-service/invoices/getUnPaidInvoices", Invoice[].class));
HashMap<User,Invoice> userInvoiceHashMap = new HashMap<>();
for (Invoice invoice: invoices)
{
System.out.println(invoice.toString());
User user = new User();
user = userRepository.getUser(invoice.getUserID());
userInvoiceHashMap.put(user,invoice);
}
log.info("Got all users have unPaid invoices");
System.out.println("Got all users have unPaid invoices");
return userInvoiceHashMap;
}
@GetMapping("/getAllUsersHavePaidInvoices")
public HashMap<User,Invoice> getAllUsersHavePaidInvoices(){
HashMap<User,Invoice> userInvoiceHashMap = new HashMap<>();
List<Invoice> invoices = Arrays.asList(restTemplate.getForObject("http://invoicing-service/invoices/getPaidInvoices", Invoice[].class));
for (Invoice invoice: invoices)
{
System.out.println(invoice.toString());
User user = new User();
user = userRepository.getUser(invoice.getUserID());
userInvoiceHashMap.put(user,invoice);
}
log.info("Got all users have paid invoices");
System.out.println("Got all users have paid invoices");
return userInvoiceHashMap;
}
}
users-service-zone-2/src/main/resources/application.properties 0 → 100644
View file @ 8499fd76
spring.application.name=users-service
server.port=8083
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=latakia
\ No newline at end of file
users-service-zone-2/src/main/resources/logback.xml 0 → 100644
View file @ 8499fd76
<configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/latakia/users-service.log</file>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Console appender -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.example" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</logger>
<root level="error">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</root>
</configuration>
\ No newline at end of file
users-service-zone-2/target/classes/application.properties 0 → 100644
View file @ 8499fd76
spring.application.name=users-service
server.port=8083
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=latakia
\ No newline at end of file
users-service-zone-2/target/classes/logback.xml 0 → 100644
View file @ 8499fd76
<configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/latakia/users-service.log</file>
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- Console appender -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<logger name="org.example" level="DEBUG" additivity="false">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</logger>
<root level="error">
<appender-ref ref="FILE"/>
<appender-ref ref="CONSOLE"/> <!-- Add the console appender reference -->
</root>
</configuration>
\ No newline at end of file
users-service/src/main/resources/application.properties
View file @ 8499fd76
spring.application.name=users-service spring.application.name=users-service
server.port=8080 server.port=8080
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/} eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=damascus
\ No newline at end of file
users-service/src/main/resources/logback.xml
View file @ 8499fd76
<configuration> <configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender"> <appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/users-service.log</file> <file>logs/damascus/users-service.log</file>
<encoder> <encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder> </encoder>
......
users-service/target/classes/application.properties
View file @ 8499fd76
spring.application.name=users-service spring.application.name=users-service
server.port=8080 server.port=8080
eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/} eureka.client.serviceUrl.defaultZone= ${EUREKA_URL:http://localhost:8761/eureka/}
eureka.instance.metadataMap.zone=damascus
\ No newline at end of file
users-service/target/classes/logback.xml
View file @ 8499fd76
<configuration> <configuration>
<appender name="FILE" class="ch.qos.logback.core.FileAppender"> <appender name="FILE" class="ch.qos.logback.core.FileAppender">
<file>logs/users-service.log</file> <file>logs/damascus/users-service.log</file>
<encoder> <encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder> </encoder>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment

HIAST - GitLab