HttpClient for nodes, registration to Discovery

This commit is contained in:
2024-11-23 23:58:27 +02:00
parent d15f8c2629
commit 03b1ea3b6d
6 changed files with 92 additions and 6 deletions

View File

@@ -4,14 +4,33 @@ import jakarta.persistence.EntityManager;
import org.apache.logging.log4j.Logger; import org.apache.logging.log4j.Logger;
import org.apache.logging.log4j.LogManager; import org.apache.logging.log4j.LogManager;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
public class Main { public class Main {
public static Logger logger = LogManager.getLogger(Main.class); public static Logger logger = LogManager.getLogger(Main.class);
public static void main(String[] args) { public static void main(String[] args) throws URISyntaxException, IOException, InterruptedException {
HttpClient client = HttpClient.newHttpClient();
logger.info("Node up."); logger.info("Node up.");
EntityManager em = Data.getEntityManager(); EntityManager em = Data.getEntityManager();
logger.info("Connected to database: << symphony >>"); logger.info("Connected to database: << symphony >>");
em.close(); em.close();
HttpRequest request = HttpRequest.newBuilder()
.uri(new URI("http://symphony-discovery:8083/check"))
.build();
HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
if (response.statusCode() == 200) {
logger.info("Node successfully registered to Discovery");
}
} }
} }

View File

@@ -32,6 +32,12 @@
<artifactId>javalin</artifactId> <artifactId>javalin</artifactId>
<version>6.3.0</version> <version>6.3.0</version>
</dependency> </dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-simple</artifactId>
<version>2.0.16</version>
</dependency>
</dependencies> </dependencies>
<build> <build>

View File

@@ -7,7 +7,6 @@ public class Main {
Javalin app = Javalin.create().start(8083); Javalin app = Javalin.create().start(8083);
JavalinConfig.setup(app); JavalinConfig.setup(app);
System.out.print("Discovery service up and running"); System.out.print("Discovery service up and running");
} }
} }

View File

@@ -9,6 +9,9 @@
</Appenders> </Appenders>
<Loggers> <Loggers>
<Logger name="io.javalin" level="off" additivity="false"/>
<Logger name="org.eclipse" level="off" additivity="false"/>
<Root level="info"> <Root level="info">
<AppenderRef ref="Console"/> <AppenderRef ref="Console"/>
</Root> </Root>

View File

@@ -0,0 +1,20 @@
org.slf4j.simpleLogger.defaultLogLevel=off
org.slf4j.simpleLogger.log.io.javalin=off
org.slf4j.simpleLogger.log.org.eclipse.jetty=off
org.slf4j.simpleLogger.log.org.eclipse.jetty.server=off
org.slf4j.simpleLogger.log.org.eclipse.jetty.util=off
# org.slf4j.simpleLogger.log.org.springframework=off
# org.slf4j.simpleLogger.log.org.hibernate=off
org.slf4j.simpleLogger.showDateTime=true
org.slf4j.simpleLogger.dateTimeFormat=yyyy-MM-dd HH:mm:ss:SSS Z
org.slf4j.simpleLogger.showThreadName=true
org.slf4j.simpleLogger.showLogName=true
org.slf4j.simpleLogger.showShortLogName=false

View File

@@ -36,12 +36,12 @@ services:
- postgres_db - postgres_db
symphony-dbnode1: symphony-dbnode1:
container_name: dbnode1 container_name: node1
build: build:
context: ./SymphonyDatabaseNode context: ./SymphonyDatabaseNode
dockerfile: Dockerfile dockerfile: Dockerfile
ports: ports:
- "8084:8084" - "8100:8100"
networks: networks:
- symphony-network - symphony-network
depends_on: depends_on:
@@ -49,12 +49,51 @@ services:
- symphony-discovery - symphony-discovery
symphony-dbnode2: symphony-dbnode2:
container_name: dbnode2 container_name: node2
build: build:
context: ./SymphonyDatabaseNode context: ./SymphonyDatabaseNode
dockerfile: Dockerfile dockerfile: Dockerfile
ports: ports:
- "8085:8085" - "8101:8101"
networks:
- symphony-network
depends_on:
- postgres_db
- symphony-discovery
symphony-dbnode3:
container_name: node3
build:
context: ./SymphonyDatabaseNode
dockerfile: Dockerfile
ports:
- "8102:8102"
networks:
- symphony-network
depends_on:
- postgres_db
- symphony-discovery
symphony-dbnode4:
container_name: node4
build:
context: ./SymphonyDatabaseNode
dockerfile: Dockerfile
ports:
- "8103:8103"
networks:
- symphony-network
depends_on:
- postgres_db
- symphony-discovery
symphony-dbnode5:
container_name: node5
build:
context: ./SymphonyDatabaseNode
dockerfile: Dockerfile
ports:
- "8104:8104"
networks: networks:
- symphony-network - symphony-network
depends_on: depends_on: