Compare commits

..

2 Commits

Author SHA1 Message Date
0590f7b532 feature: add README.md 2024-09-17 22:26:19 +04:00
0eec58a347 feature: completed lab 2 2024-09-17 22:07:57 +04:00
127 changed files with 298 additions and 3419 deletions

6
.idea/.gitignore generated vendored
View File

@@ -1,6 +0,0 @@
# Default ignored files
/shelf/
/workspace.xml
/DAS_2024_1.iml
/modules.xml
/vcs.xml

View File

@@ -1,61 +0,0 @@
# Отчет. Лабораторная работа 1
В рамках лабораторной работы с помощью технологии контейнеризации docker были развернуты сервисы:
- Redmine - система баг-трекинга
- Postgres - СУБД
- RabbitMQ - брокер сообщений
## Описание
В docker-compose.yml файле описаны настройки для запуска трех выбранных сервисов в контейнерах. Для большинства строк файла оставлены
комментарии, объясняющие содержимое файла.
Стоит отметить, для сервиса Redmine было принято решение в качестве сервера баз данных не использовать базу данных по умолчанию - SQLite,
а поднять внешний сервер баз данных Postgres, который был запущен в рамках этого же файла docker-compose.yml.
Для того, чтобы при старте postgres уже была создана база данных для Redmine, а также пользователь, под учетной записью
которого будет работать Redmine, был написан скрипт init-database.sh с использованием bash и sql:
```
# Создаем пользователя redmine и БД redminedb
psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USER" --dbname "$POSTGRES_DB" <<-EOSQL
CREATE USER redmine WITH PASSWORD 'redmine-password';
CREATE DATABASE redminedb;
GRANT ALL PRIVILEGES ON DATABASE redminedb TO redmine;
EOSQL
# Даем права на схему public
psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USERNAME" -d redminedb <<-EOSQL
ALTER SCHEMA public OWNER TO redmine;
GRANT ALL ON SCHEMA public TO redmine;
EOSQL
```
Этот скрипт монтируется в директорию контейнера postgres ``docker-entrypoint-initdb.d``, которая является специальной точкой входа
для инициализации БД и содержит соответствующие скрипты.
## Как запустить
Для того, чтобы запустить сервисы, необходимо выполнить следующие действия:
1. Установить и запустить Docker Engine или Docker Desktop (включает в себя Docker Engine и предоставляет UI)
2. Через консоль перейти в папку, в которой расположен файл docker-compose.yml
3. Выполнить команду:
```
docker compose up -d
```
В случае успешного запуска всех контейнеров в консоли будет выведено следующее сообщение:
```
[+] Running 3/3
✔ Container rabbitmq Started 0.8s
✔ Container redmine Started 1.2s
✔ Container postgres Started 0.5s
```
Также будет создана папка postgres_data, которая монтируется в контейнере postgres
Мы также можем увидеть статус всех запущенных контейнеров, если выполним команду:
```
docker ps
```
Или обратившись к логам каждого из контейнеров:
``
docker logs <container_name>
``
## Видео-отчет
Работоспособность лабораторной работы можно оценить в следующем [видео](https://disk.yandex.ru/d/15QhUl3KQYSavA).

View File

@@ -1,34 +0,0 @@
services:
postgres:
image: postgres:latest # название и версия образа docker
container_name: postgres # название контейнера
environment: # блок переменных окружения, которые будут использованы для запуска и настройки
POSTGRES_USERNAME: postgres # имя пользователя супер-пользователя СУБД
POSTGRES_PASSWORD: postgres-admin # имя пользователя супер-пользователя СУБД
PGDATA: "/var/lib/postgresql/data/pgdata" # путь к директории, где Postgres будет хранить свои данные.
ports:
- "5432:5432" # пробрасываем стандартный порт для доступа к postgres
volumes:
- ./postgres_data:/var/lib/postgresql/data/ # монтируем локальную директорию в директорию внутри контейнера с данными базы данных
- ./init-database.sh:/docker-entrypoint-initdb.d/init-database.sh # Монтирует скрипт инициализации базы данных в специальную директорию внутри контейнера.
redmine:
image: redmine
container_name: redmine
ports:
- "8080:3000"
environment:
REDMINE_DB_POSTGRES: postgres # хост, на котором расположена база данных Postgres
REDMINE_DB_USERNAME: redmine # имя пользователя для подключения к базе данных Redmine
REDMINE_DB_DATABASE: redminedb # база данных, к которой будет подключаться Redmine
REDMINE_DB_PASSWORD: redmine-password # пароль, который будет использоваться для подключения
depends_on: # обозначаем зависимость запуска сервиса redmine от запуска сервиса postgres
- postgres
rabbitmq:
container_name: rabbitmq
image: rabbitmq:3-management
environment:
RABBITMQ_DEFAULT_USER: rabbit # переопределяем значения имя для пользователя, который создается по умолчанию
RABBITMQ_DEFAULT_PASS: rabbit-password # переопределяем значения пароля для пользователя, который создается по умолчанию
ports:
- "15672:15672" # порт для доступа к веб-интерфейсу
- "5672:5672" # порт для доступа через протокол AMQP к брокеру сообщений

View File

@@ -1,15 +0,0 @@
#!/bin/bash
set -e
# Создаем пользователя redmine и БД redminedb
psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USER" --dbname "$POSTGRES_DB" <<-EOSQL
CREATE USER redmine WITH PASSWORD 'redmine-password';
CREATE DATABASE redminedb;
GRANT ALL PRIVILEGES ON DATABASE redminedb TO redmine;
EOSQL
# Даем права на схему public
psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USERNAME" -d redminedb <<-EOSQL
ALTER SCHEMA public OWNER TO redmine;
GRANT ALL ON SCHEMA public TO redmine;
EOSQL

View File

@@ -1,38 +0,0 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

View File

@@ -1,43 +0,0 @@
# Отчет. Лабораторная работа 2
В рамках лабораторной работы №2 были написаны два сервиса, работающих с текстовыми файлами.
Для первого сервиса был выбран вариант задания №5:
```
Ищет в каталоге /var/data файл с самым коротким названием и перекладывает его в /var/result/data.txt.
```
А для второго - №2:
```
Ищет наименьшее число из файла /var/data/data.txt и сохраняет его третью степень в /var/result/result.txt.
```
## Описание
Сначала сервис first перемещает данные из файла с самым коротким названием, находящегося в указанной примонтированной директории, в выходную папку.
Доступ к выходной папке имеет второй сервис, который выводит наименьшее число из помещенного первым сервисом файла
в третьей степени в выходной файл.
Выходной файл расположен в примонтированной директории и доступен на машине, где запускаются сервисы.
В Dockerfile используется многоэтапная сборка с использованием нескольких базовых образов на каждом этапе.
Описание значения каждой строки есть в Dockerfile в сервисе first.
В файле docker-compose.yml приведено описание новых строк, связанных с подключением примонтированных томов.
Стоит отметить, что для "общения" сервисов используется общий том common, который монтируется в контейнер по пути /var/result. Это позволяет сохранять результаты
работы первого сервиса для использования вторым сервисом.
## Как запустить
Для того, чтобы запустить сервисы, необходимо выполнить следующие действия:
1. Установить и запустить Docker Engine или Docker Desktop
2. Через консоль перейти в папку, в которой расположен файл docker-compose.yml
3. Выполнить команду:
```
docker compose up --build
```
В случае успешного запуска всех контейнеров в консоли будет выведено следующее сообщение:
```
✔ Network borschevskaya_anna_lab_2_default Created 0.1s
✔ Container borschevskaya_anna_lab_2-first-1 Created 0.1s
✔ Container borschevskaya_anna_lab_2-second-1 Created 0.1s
Attaching to borschevskaya_anna_lab_2-first-1, borschevskaya_anna_lab_2-second-1
```
Далее, в консоль каждого сервиса будут выведены сообщения о том, как прошла обработка файлов.
В случае отсутствия заданных значений переменных окружения INPUT_PATH и OUTPUT_PATH и
в иных исключительных ситуация будет выведена информация об этом.
## Видео-отчет
Работоспособность лабораторной работы можно оценить в следующем [видео](https://disk.yandex.ru/i/LFxdyRUFQDwXEQ).

View File

@@ -1,22 +0,0 @@
services:
first:
build: ./first # директория, в которой нужно искать Dockerfile для сборки первого сервиса
environment:
INPUT_PATH: /var/data/ # директория с входными данными для обработки файлов
OUTPUT_PATH: /var/result/ # директория с выходными данными обработки
volumes:
- ./volumes/input:/var/data # монтируется локальная папка с входными данными в папку внутри контейнера
- common:/var/result # монтируется общий для двух сервисов том, в который first сложит результаты обработки по варианту
second:
build: ./second # директория, в которой нужно искать Dockerfile для сборки второго сервиса
depends_on: # сервис second зависит от сервиса first и будет запущен после него
- first
environment:
INPUT_PATH: /var/result/
OUTPUT_PATH: /var/data/
volumes:
- ./volumes/output:/var/data
- common:/var/result # монтируется общий для двух сервисов том, из которого second получит результаты обработки first сервиса и выполнит свою логику
volumes:
common:

View File

@@ -1,25 +0,0 @@
# Используем образ Maven для сборки
FROM maven:3.8-eclipse-temurin-21-alpine AS build
# Устанавливаем рабочую директорию
WORKDIR /app
# Копируем только pom.xml и загружаем зависимости
# Так зависимости закэшируются в Docker при изменении кода закэшированные слои с зависимостями будут подгружаться быстрее
COPY pom.xml .
RUN mvn dependency:go-offline
# Копируем остальные исходные файлы
COPY src ./src
# Собираем весь проект
RUN mvn clean package -DskipTests
# Используем официальный образ JDK для запуска собранного jar-файла
FROM eclipse-temurin:21-jdk-alpine
# Копируем jar-файл из предыдущего этапа
COPY --from=build /app/target/*.jar /app.jar
# Указываем команду для запуска приложения
CMD ["java", "-jar", "app.jar"]

View File

@@ -1,37 +0,0 @@
<?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">
<modelVersion>4.0.0</modelVersion>
<groupId>ru.first</groupId>
<artifactId>first</artifactId>
<version>1.0.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>21</maven.compiler.source>
<maven.compiler.target>21</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<build>
<plugins>
<plugin>
<!-- Build an executable JAR -->
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<archive>
<manifest>
<addClasspath>true</addClasspath>
<classpathPrefix>lib/</classpathPrefix>
<mainClass>ru.first.Main</mainClass>
</manifest>
</archive>
</configuration>
</plugin>
</plugins>
</build>
</project>

View File

@@ -1,50 +0,0 @@
package ru.first;
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.util.Arrays;
import java.util.Comparator;
import static java.nio.file.StandardCopyOption.REPLACE_EXISTING;
import static java.util.Objects.isNull;
public class Main {
public static final String INPUT_PATH = System.getenv("INPUT_PATH");
public static final String OUTPUT_PATH = System.getenv("OUTPUT_PATH");
public static final String RESULT_FILE_NAME = "data.txt";
public static void main(String[] args) throws IOException {
if (isNull(INPUT_PATH) || INPUT_PATH.isEmpty() || isNull(OUTPUT_PATH) || OUTPUT_PATH.isEmpty()) {
System.out.printf("Отсутствуют переменные окружения INPUT_PATH = '%s' или OUTPUT_PATH = '%s'%n",
INPUT_PATH, OUTPUT_PATH);
return;
}
var inputPathDir = Path.of(INPUT_PATH);
if (!Files.exists(inputPathDir)) {
Files.createDirectory(inputPathDir);
}
var inputDirectory = new File(INPUT_PATH);
var allDirFiles = inputDirectory.listFiles();
if (isNull(allDirFiles) || allDirFiles.length == 0) {
System.out.println("Директория пуста");
return;
}
var dirFiles = Arrays.stream(allDirFiles).filter(File::isFile).toList();
if (dirFiles.isEmpty()) {
System.out.println("В указанной директории нет подходящих для обработки файлов");
return;
}
var shortestName = dirFiles.stream().min(Comparator.comparing(file -> file.getName().length())).get();
var outputPathDir = Path.of(OUTPUT_PATH);
if (!Files.exists(outputPathDir)) {
Files.createDirectory(outputPathDir);
}
var resultFilePath = Path.of(OUTPUT_PATH + File.separator + RESULT_FILE_NAME);
Files.move(Path.of(INPUT_PATH + File.separator + shortestName.getName()), resultFilePath, REPLACE_EXISTING);
}
}

View File

@@ -1,16 +0,0 @@
FROM maven:3.8-eclipse-temurin-21-alpine AS build
WORKDIR /app
COPY pom.xml .
RUN mvn dependency:go-offline
COPY src ./src
RUN mvn clean package -DskipTests
FROM eclipse-temurin:21-jdk-alpine
COPY --from=build /app/target/*.jar /app.jar
CMD ["java", "-jar", "app.jar"]

View File

@@ -1,36 +0,0 @@
<?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">
<modelVersion>4.0.0</modelVersion>
<groupId>ru.second</groupId>
<artifactId>second</artifactId>
<version>1.0.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>21</maven.compiler.source>
<maven.compiler.target>21</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>3.1.0</version>
<configuration>
<archive>
<manifest>
<addClasspath>true</addClasspath>
<classpathPrefix>lib/</classpathPrefix>
<mainClass>ru.second.Main</mainClass>
</manifest>
</archive>
</configuration>
</plugin>
</plugins>
</build>
</project>

View File

@@ -1,51 +0,0 @@
package ru.second;
import java.io.File;
import java.io.FileWriter;
import java.nio.file.Files;
import static java.util.Objects.isNull;
public class Main {
public static final String INPUT_PATH = System.getenv("INPUT_PATH");
public static final String INPUT_FILE_NAME = "data.txt";
public static final String OUTPUT_PATH = System.getenv("OUTPUT_PATH");
public static final String RESULT_FILE_NAME = "result.txt";
public static void main(String[] args) {
if (isNull(INPUT_PATH) || INPUT_PATH.isEmpty() || isNull(OUTPUT_PATH) || OUTPUT_PATH.isEmpty()) {
System.out.printf("Отсутствуют переменные окружения INPUT_PATH = '%s' или OUTPUT_PATH = '%s'%n",
INPUT_PATH, OUTPUT_PATH);
return;
}
var inputFile = new File(INPUT_PATH + File.separator + INPUT_FILE_NAME);
if (!inputFile.exists()) {
System.out.println("Входной файл не существует");
return;
}
try (var stream = Files.lines(inputFile.toPath());
var writer = new FileWriter(OUTPUT_PATH + File.separator + RESULT_FILE_NAME);
) {
var min = stream.map(Main::parseInt).reduce(Integer::min);
if (min.isEmpty()) {
System.out.println("Не найдено минимальное значение среди строк файла");
return;
}
var minValue = Math.pow(min.get(), 3);
System.out.printf("Get min value = '%d'%n", min.get());
writer.append(Double.toString(minValue));
System.out.printf("To file %s was written value %f%n", RESULT_FILE_NAME, minValue);
} catch (Exception ex) {
System.out.println(ex.getMessage());
}
}
private static Integer parseInt(String line) {
line = line.replace("\\n", "");
return Integer.parseInt(line);
}
}

View File

@@ -1,58 +0,0 @@
# Отчет. Лабораторная работа 3
## Описание
В рамках лабораторной работы № 3 были реализованы два сервиса (Java + Spring), осуществляющие CRUD-операции над сущностями.
Модель данных следующая:
Сущность "Компания" (сервис company)
- идентификатор компании
- название
- адрес
Сущность "Вакансия" (сервис vacancy)
- идентификатор вакансии
- название
- описание
- нижняя граница зарплаты
- верхняя граница зарплаты
- идентификатор компании
Компания с вакансией связана как "один ко многим".
Каждый из сервисов имеет API с пятью эндпоинтами. При этом в сервисе vacancy при запросе вакансии по id происходит
дополнительный запрос в сервис company для получения информации по компании, связанной с вакансией.
Происходит это взаимодействие с помощью библиотеки OpenFeign, которая "под капотом" использует HttpClient.
В качестве хранилища данных использовалась СУБД Postgres. У каждого сервиса своя база данных в поднятой СУБД.
Для создания схемы БД была использована библиотека Flyway, которая применила написанные миграции при старте приложения.
Запросы к сервисам проксирует шлюз на основе Nginx. Для этого перед запуском nginx был описан конфигурационный файл nginx.conf,
в котором описан прослушиваемый порт и название сервера (в блоке server), маршруты до микросервисов и параметры проксирования (в блоке location).
Таким образом, с помощью Docker Compose были подняты сервисы:
- company
- vacancy
- postgres
- nginx
## Как запустить
Для того, чтобы запустить сервисы, необходимо выполнить следующие действия:
1. Установить и запустить Docker Engine или Docker Desktop
2. Через консоль перейти в папку, в которой расположен файл docker-compose.yml
3. Выполнить команду:
```
docker compose up --build
```
В случае успешного запуска всех контейнеров в консоли будет выведено следующее сообщение:
```
[+] Running 5/5
✔ Network borschevskaya_anna_lab_3_default Created 0.0s
✔ Container postgres Started 0.6s
✔ Container vacancy Started 1.1s
✔ Container company Started 0.9s
✔ Container borschevskaya_anna_lab_3-nginx-1 Started
```
Далее можно осуществлять запросы к сервисам по адресу http://localhost/{location}, где часть пути location меняется в зависимости от сервиса и запроса.
## Видео-отчет
Работоспособность лабораторной работы можно оценить в следующем [видео](https://disk.yandex.ru/i/KPNBfnlcgl1auw).
Демонстрация взаимодействия с системой производится с применением сервиса Postman.

View File

@@ -1,38 +0,0 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

View File

@@ -1,21 +0,0 @@
# Используем образ Maven для сборки
FROM maven:3.8-eclipse-temurin-21-alpine AS build
# Устанавливаем рабочую директорию
WORKDIR /app
# Копируем остальные исходные файлы
COPY pom.xml .
COPY src src
# Собираем весь проект
RUN mvn clean package -DskipTests
# Используем официальный образ JDK для запуска собранного jar-файла
FROM eclipse-temurin:21-jdk-alpine
# Копируем jar-файл из предыдущего этапа
COPY --from=build /app/target/*.jar /app.jar
# Указываем команду для запуска приложения
CMD ["java", "-jar", "app.jar"]

View File

@@ -1,66 +0,0 @@
<?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">
<modelVersion>4.0.0</modelVersion>
<groupId>ru.somecompany</groupId>
<artifactId>company-service</artifactId>
<version>1.0-SNAPSHOT</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.2.3</version>
<relativePath/>
</parent>
<properties>
<maven.compiler.source>21</maven.compiler.source>
<maven.compiler.target>21</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.flywaydb</groupId>
<artifactId>flyway-core</artifactId>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.30</version>
</dependency>
<dependency>
<groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.springdoc</groupId>
<artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
<version>2.3.0</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>

View File

@@ -1,12 +0,0 @@
package ru.somecompany;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class CompanyApplication {
public static void main(String[] args) {
SpringApplication.run(CompanyApplication.class, args);
}
}

View File

@@ -1,44 +0,0 @@
package ru.somecompany.controller;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.validation.constraints.NotNull;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestBody;
import ru.somecompany.domain.CompanyEntity;
import ru.somecompany.domain.CreateCompanyRequest;
import java.util.List;
import java.util.UUID;
@Validated
@Tag(name = "company", description = "API для управления компаниями")
public interface CompanyController {
@Operation(summary = "Получение всех компаний")
@GetMapping(value = "/api/v1/company")
List<CompanyEntity> getCompanies();
@Operation(summary = "Создание компании")
@PostMapping(value = "/api/v1/company")
CompanyEntity createCompany(@RequestBody @NotNull CreateCompanyRequest companyRequest);
@Operation(summary = "Получение информации о компании по id")
@GetMapping(value = "/api/v1/company/{companyId}")
CompanyEntity getCompany(@PathVariable UUID companyId);
@Operation(summary = "Редактирование компании")
@PutMapping(value = "/api/v1/company/{companyId}")
CompanyEntity updateCompany(@PathVariable UUID companyId,
@RequestBody @NotNull CreateCompanyRequest companyRequest);
@Operation(summary = "Удалении компании по id")
@DeleteMapping(value = "/api/v1/company/{companyId}")
void deleteCompany(@PathVariable UUID companyId);
}

View File

@@ -1,42 +0,0 @@
package ru.somecompany.controller;
import lombok.RequiredArgsConstructor;
import org.springframework.web.bind.annotation.RestController;
import ru.somecompany.domain.CompanyEntity;
import ru.somecompany.domain.CreateCompanyRequest;
import ru.somecompany.service.CompanyService;
import java.util.List;
import java.util.UUID;
@RestController
@RequiredArgsConstructor
public class CompanyControllerImpl implements CompanyController {
private final CompanyService companyService;
@Override
public List<CompanyEntity> getCompanies() {
return companyService.getCompanies();
}
@Override
public CompanyEntity createCompany(CreateCompanyRequest companyRequest) {
return companyService.createCompany(companyRequest);
}
@Override
public CompanyEntity getCompany(UUID companyId) {
return companyService.getCompany(companyId);
}
@Override
public CompanyEntity updateCompany(UUID companyId, CreateCompanyRequest companyRequest) {
return companyService.updateCompany(companyId, companyRequest);
}
@Override
public void deleteCompany(UUID companyId) {
companyService.deleteCompany(companyId);
}
}

View File

@@ -1,32 +0,0 @@
package ru.somecompany.domain;
import jakarta.persistence.Column;
import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.UUID;
@Data
@Entity
@Builder
@Table(name = "company")
@AllArgsConstructor
@NoArgsConstructor
public class CompanyEntity {
@Id
@GeneratedValue
private UUID id;
@Column(name = "name", unique = true, nullable = false)
private String name;
@Column(name = "address", unique = true, nullable = false)
private String address;
}

View File

@@ -1,13 +0,0 @@
package ru.somecompany.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
@Data
@AllArgsConstructor
public class CreateCompanyRequest {
private String name;
private String address;
}

View File

@@ -1,41 +0,0 @@
package ru.somecompany.exception;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import java.time.LocalDateTime;
import static org.springframework.http.HttpStatus.NOT_FOUND;
@Slf4j
public abstract class AbstractWebExceptionHandler {
public static ResponseEntity<ResponseError> buildResponse(ErrorCode errorCode, HttpStatus status, String msg,
boolean details, Throwable ex) {
return buildResponse(errorCode.name(), status, msg, details, ex, LocalDateTime.now());
}
public static ResponseEntity<ResponseError> buildResponse(String errorCode, HttpStatus status, String msg,
boolean details, Throwable ex, LocalDateTime timestamp) {
if (details) {
log.error(msg, ex); // with stack-trace
} else {
var message = StringUtils.equals(msg, ex.getMessage()) ? msg : msg + ": " + ex.getMessage();
if (status == NOT_FOUND) {
log.warn(message);
} else {
log.error(message);
}
}
return ResponseEntity.status(status.value())
.body(ResponseError.builder()
.code(errorCode)
.message(msg)
.timestamp(timestamp)
.status(status.value())
.build());
}
}

View File

@@ -1,5 +0,0 @@
package ru.somecompany.exception;
public enum BasicError implements ErrorCode {
NOT_FOUND
}

View File

@@ -1,26 +0,0 @@
package ru.somecompany.exception;
import lombok.Getter;
import org.springframework.http.HttpStatus;
@Getter
public class CompanyAppRuntimeException extends RuntimeException {
private final ErrorCode errorCode;
private final HttpStatus status;
private final boolean details;
public CompanyAppRuntimeException(ErrorCode errorCode, HttpStatus status, String message) {
this(errorCode, status, message, null);
}
public CompanyAppRuntimeException(ErrorCode errorCode, HttpStatus status, String message, Throwable error) {
this(errorCode, status, message, true, error);
}
public CompanyAppRuntimeException(ErrorCode errorCode, HttpStatus status, String message, boolean details, Throwable error) {
super(message, error);
this.errorCode = errorCode;
this.status = status;
this.details = details;
}
}

View File

@@ -1,9 +0,0 @@
package ru.somecompany.exception;
import java.io.Serializable;
public interface ErrorCode extends Serializable {
String name();
}

View File

@@ -1,28 +0,0 @@
package ru.somecompany.exception;
import org.springframework.http.HttpStatus;
import static ru.somecompany.exception.BasicError.NOT_FOUND;
public class ResourceNotFoundException extends CompanyAppRuntimeException {
public ResourceNotFoundException(ErrorCode errorCode, String message) {
this(errorCode, message, null);
}
public ResourceNotFoundException(ErrorCode errorCode, String message, Throwable error) {
super(errorCode, HttpStatus.NOT_FOUND, message, error);
}
public static ResourceNotFoundException notFound(String message, Object... args) {
return new ResourceNotFoundException(NOT_FOUND, String.format(message, args), null);
}
public static ResourceNotFoundException notFound() {
return new ResourceNotFoundException(NOT_FOUND, "Запрашиваемые данные не найдены", null);
}
public static ResourceNotFoundException notFound(Throwable error) {
return new ResourceNotFoundException(NOT_FOUND, error.getMessage(), error);
}
}

View File

@@ -1,24 +0,0 @@
package ru.somecompany.exception;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ResponseError {
@JsonProperty(required = true)
private LocalDateTime timestamp;
@JsonProperty(required = true)
private Integer status;
@JsonProperty(required = true)
private String message;
@JsonProperty(required = true)
private String code;
}

View File

@@ -1,22 +0,0 @@
package ru.somecompany.exception;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
@Slf4j
@Getter
@RestControllerAdvice
@RequiredArgsConstructor
public class WebExceptionHandler extends AbstractWebExceptionHandler {
private final ObjectMapper objectMapper;
@ExceptionHandler(CompanyAppRuntimeException.class)
public ResponseEntity<ResponseError> handleException(CompanyAppRuntimeException ex) {
return buildResponse(ex.getErrorCode(), ex.getStatus(), ex.getMessage(), ex.isDetails(), ex);
}
}

View File

@@ -1,9 +0,0 @@
package ru.somecompany.repository;
import org.springframework.data.jpa.repository.JpaRepository;
import ru.somecompany.domain.CompanyEntity;
import java.util.UUID;
public interface CompanyRepository extends JpaRepository<CompanyEntity, UUID> {
}

View File

@@ -1,20 +0,0 @@
package ru.somecompany.service;
import ru.somecompany.domain.CompanyEntity;
import ru.somecompany.domain.CreateCompanyRequest;
import java.util.List;
import java.util.UUID;
public interface CompanyService {
List<CompanyEntity> getCompanies();
CompanyEntity createCompany(CreateCompanyRequest companyRequest);
CompanyEntity updateCompany(UUID companyId, CreateCompanyRequest companyRequest);
void deleteCompany(UUID companyId);
CompanyEntity getCompany(UUID companyId);
}

View File

@@ -1,57 +0,0 @@
package ru.somecompany.service;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import ru.somecompany.domain.CompanyEntity;
import ru.somecompany.domain.CreateCompanyRequest;
import ru.somecompany.repository.CompanyRepository;
import java.util.List;
import java.util.UUID;
import static ru.somecompany.exception.ResourceNotFoundException.notFound;
@Service
@RequiredArgsConstructor
public class CompanyServiceImpl implements CompanyService {
private final CompanyRepository companyRepository;
@Override
public List<CompanyEntity> getCompanies() {
return companyRepository.findAll();
}
@Override
public CompanyEntity createCompany(CreateCompanyRequest companyRequest) {
var entity = CompanyEntity.builder()
.name(companyRequest.getName())
.address(companyRequest.getAddress())
.build();
return companyRepository.save(entity);
}
@Override
public CompanyEntity updateCompany(UUID companyId, CreateCompanyRequest companyRequest) {
var company = getById(companyId);
company.setName(companyRequest.getName());
company.setAddress(companyRequest.getAddress());
return companyRepository.save(company);
}
@Override
public void deleteCompany(UUID companyId) {
var company = getById(companyId);
companyRepository.delete(company);
}
@Override
public CompanyEntity getCompany(UUID companyId) {
return getById(companyId);
}
private CompanyEntity getById(UUID companyId) {
return companyRepository.findById(companyId)
.orElseThrow(() -> notFound("Компания не найдена"));
}
}

View File

@@ -1,28 +0,0 @@
server:
port: ${SERVER_PORT:8080}
spring:
application:
name: company-app
jpa:
database: POSTGRESQL
open-in-view: false
show-sql: false
hibernate:
ddl-auto: none
properties:
hibernate:
dialect: org.hibernate.dialect.PostgreSQLDialect
datasource:
url: ${DB_URL:jdbc:postgresql://postgres:5433/company}
username: ${DB_USERNAME:postgres}
password: ${DB_PASSWORD:postgres}
driverClassName: org.postgresql.Driver
type: com.zaxxer.hikari.HikariDataSource
hikari:
maximum-pool-size: 15
minimum-idle: 4
idle-timeout: 180000
max-lifetime: 599000
flyway:
enabled: true
locations: db/migration/

View File

@@ -1,6 +0,0 @@
CREATE TABLE company (
id UUID
CONSTRAINT company_pk PRIMARY KEY,
name VARCHAR(255) UNIQUE NOT NULL,
address VARCHAR(255) NOT NULL
);

View File

@@ -1,43 +0,0 @@
services:
postgres:
image: postgres:latest
container_name: postgres
environment:
POSTGRES_USERNAME: postgres
POSTGRES_PASSWORD: postgres
PGDATA: "/var/lib/postgresql/data/pgdata"
ports:
- "5432:5432"
volumes:
- ./postgres_data:/var/lib/postgresql/data/
- ./init-database.sh:/docker-entrypoint-initdb.d/init-database.sh
company:
build: ./company-service
container_name: company
depends_on:
- postgres
environment:
SERVER_PORT: 8080
DB_URL: jdbc:postgresql://postgres:5432/company
DB_USERNAME: postgres
DB_PASSWORD: postgres
vacancy:
build: ./vacancy-service
container_name: vacancy
depends_on:
- postgres
environment:
SERVER_PORT: 8080
DB_URL: jdbc:postgresql://postgres:5432/vacancy
DB_USERNAME: postgres
DB_PASSWORD: postgres
COMPANY_URL: http://nginx/
nginx:
image: nginx
depends_on:
- vacancy
- company
volumes:
- ./nginx/nginx.conf:/etc/nginx/conf.d/default.conf
ports:
- 80:80

View File

@@ -1,8 +0,0 @@
#!/bin/bash
set -e
# Создаем БД
psql -v ON_ERROR_STOP=1 --username "$POSTGRES_USER" --dbname "$POSTGRES_DB" <<-EOSQL
CREATE DATABASE company;
CREATE DATABASE vacancy;
EOSQL

View File

@@ -1,21 +0,0 @@
server {
listen 80;
listen [::]:80;
server_name localhost;
location /api/v1/company {
proxy_pass http://company:8080;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-Proto $scheme;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
}
location /api/v1/vacancy {
proxy_pass http://vacancy:8080;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
proxy_set_header X-Forwarded-Proto $scheme;
proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
}
}

View File

@@ -1,38 +0,0 @@
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/
### IntelliJ IDEA ###
.idea/modules.xml
.idea/jarRepositories.xml
.idea/compiler.xml
.idea/libraries/
*.iws
*.iml
*.ipr
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store

View File

@@ -1,21 +0,0 @@
# Используем образ Maven для сборки
FROM maven:3.8-eclipse-temurin-21-alpine AS build
# Устанавливаем рабочую директорию
WORKDIR /app
# Копируем остальные исходные файлы
COPY pom.xml .
COPY src src
# Собираем весь проект
RUN mvn clean package -DskipTests
# Используем официальный образ JDK для запуска собранного jar-файла
FROM eclipse-temurin:21-jdk-alpine
# Копируем jar-файл из предыдущего этапа
COPY --from=build /app/target/*.jar /app.jar
# Указываем команду для запуска приложения
CMD ["java", "-jar", "app.jar"]

View File

@@ -1,128 +0,0 @@
<?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">
<modelVersion>4.0.0</modelVersion>
<groupId>ru.somecompany</groupId>
<artifactId>vacancy-service</artifactId>
<version>1.0-SNAPSHOT</version>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.2.3</version>
<relativePath/>
</parent>
<properties>
<maven.compiler.source>21</maven.compiler.source>
<maven.compiler.target>21</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<mapstruct.version>1.5.5.Final</mapstruct.version>
<lombok-mapstruct-binding.version>0.2.0</lombok-mapstruct-binding.version>
<spring-cloud.version>2023.0.3</spring-cloud.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.flywaydb</groupId>
<artifactId>flyway-core</artifactId>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.30</version>
</dependency>
<dependency>
<groupId>org.mapstruct</groupId>
<artifactId>mapstruct</artifactId>
<version>${mapstruct.version}</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok-mapstruct-binding</artifactId>
<version>${lombok-mapstruct-binding.version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
</dependency>
<dependency>
<groupId>io.swagger.core.v3</groupId>
<artifactId>swagger-annotations</artifactId>
<version>2.2.1</version>
</dependency>
<dependency>
<groupId>org.springdoc</groupId>
<artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
<version>2.3.0</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>
<pluginManagement>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<annotationProcessorPaths>
<path>
<groupId>org.mapstruct</groupId>
<artifactId>mapstruct-processor</artifactId>
<version>${mapstruct.version}</version>
</path>
<path>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.30</version>
</path>
<path>
<groupId>org.projectlombok</groupId>
<artifactId>lombok-mapstruct-binding</artifactId>
<version>${lombok-mapstruct-binding.version}</version>
</path>
</annotationProcessorPaths>
<compilerArgs>
<arg>-Amapstruct.defaultComponentModel=spring</arg>
</compilerArgs>
</configuration>
</plugin>
</plugins>
</pluginManagement>
</build>
</project>

View File

@@ -1,14 +0,0 @@
package ru.somecompany;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;
@SpringBootApplication
@EnableFeignClients
public class VacancyApplication {
public static void main(String[] args) {
SpringApplication.run(VacancyApplication.class, args);
}
}

View File

@@ -1,64 +0,0 @@
package ru.somecompany.controller;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.responses.ApiResponse;
import io.swagger.v3.oas.annotations.responses.ApiResponses;
import io.swagger.v3.oas.annotations.tags.Tag;
import jakarta.validation.constraints.NotNull;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.DeleteMapping;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.PutMapping;
import org.springframework.web.bind.annotation.RequestBody;
import ru.somecompany.domain.CreateVacancyRequest;
import ru.somecompany.domain.VacancyEntity;
import ru.somecompany.domain.VacancyResponse;
import java.util.List;
import java.util.UUID;
@Validated
@Tag(name = "vacancy", description = "API для управления вакансиями")
public interface VacancyController {
@Operation(summary = "Получение всех вакансий")
@ApiResponses(value = {
@ApiResponse(responseCode = "200", description = "Данные успешно переданы"),
})
@GetMapping(value = "/api/v1/vacancy")
List<VacancyEntity> getVacancies();
@Operation(summary = "Создание вакансии")
@ApiResponses(value = {
@ApiResponse(responseCode = "200", description = "Вакансия успешно создана"),
})
@PostMapping(value = "/api/v1/vacancy")
VacancyEntity createVacancy(@RequestBody @NotNull CreateVacancyRequest request);
@Operation(summary = "Получение информации о вакансии по id")
@ApiResponses(value = {
@ApiResponse(responseCode = "200", description = "Данные успешно переданы"),
@ApiResponse(responseCode = "404", description = "Вакансия не найдена")
})
@GetMapping(value = "/api/v1/vacancy/{vacancyId}")
VacancyResponse getVacancy(@PathVariable UUID vacancyId);
@Operation(summary = "Редактирование вакансии")
@ApiResponses(value = {
@ApiResponse(responseCode = "200", description = "Данные вакансии успешно изменены"),
@ApiResponse(responseCode = "404", description = "Вакансия не найдена")
})
@PutMapping(value = "/api/v1/vacancy/{vacancyId}")
VacancyEntity updateVacancy(@PathVariable UUID vacancyId,
@RequestBody @NotNull CreateVacancyRequest request);
@Operation(summary = "Удалении вакансии по id")
@ApiResponses(value = {
@ApiResponse(responseCode = "200", description = "Вакансия успешно удалена"),
@ApiResponse(responseCode = "404", description = "Вакансия не найдена")
})
@DeleteMapping(value = "/api/v1/vacancy/{vacancyId}")
void deleteVacancy(@PathVariable UUID vacancyId);
}

View File

@@ -1,45 +0,0 @@
package ru.somecompany.controller;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.RestController;
import ru.somecompany.domain.CreateVacancyRequest;
import ru.somecompany.domain.VacancyEntity;
import ru.somecompany.domain.VacancyResponse;
import ru.somecompany.service.VacancyService;
import java.util.List;
import java.util.UUID;
@Slf4j
@RestController
@RequiredArgsConstructor
public class VacancyControllerImpl implements VacancyController {
private final VacancyService vacancyService;
@Override
public List<VacancyEntity> getVacancies() {
return vacancyService.getVacancies();
}
@Override
public VacancyEntity createVacancy(CreateVacancyRequest request) {
return vacancyService.createVacancy(request);
}
@Override
public VacancyResponse getVacancy(UUID vacancyId) {
return vacancyService.getVacancy(vacancyId);
}
@Override
public VacancyEntity updateVacancy(UUID vacancyId, CreateVacancyRequest request) {
return vacancyService.updateVacancy(vacancyId, request);
}
@Override
public void deleteVacancy(UUID vacancyId) {
vacancyService.deleteVacancy(vacancyId);
}
}

View File

@@ -1,17 +0,0 @@
package ru.somecompany.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
import java.util.UUID;
@Data
@AllArgsConstructor
public class CompanyResponse {
private UUID id;
private String name;
private String address;
}

View File

@@ -1,21 +0,0 @@
package ru.somecompany.domain;
import lombok.AllArgsConstructor;
import lombok.Data;
import java.util.UUID;
@Data
@AllArgsConstructor
public class CreateVacancyRequest {
private String name;
private String description;
private Integer salaryLow;
private Integer salaryHigh;
private UUID companyId;
}

View File

@@ -1,41 +0,0 @@
package ru.somecompany.domain;
import jakarta.persistence.Column;
import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.Id;
import jakarta.persistence.Table;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.UUID;
@Data
@Entity
@Builder
@Table(name = "vacancy")
@AllArgsConstructor
@NoArgsConstructor
public class VacancyEntity {
@Id
@GeneratedValue
private UUID id;
@Column(name = "name", nullable = false)
private String name;
@Column(name = "description", nullable = true, length = 1000)
private String description;
@Column(name = "salary_low", nullable = false)
private Integer salaryLow;
@Column(name = "salary_high", nullable = false)
private Integer salaryHigh;
@Column(name = "company_id", nullable = false)
private UUID companyId;
}

View File

@@ -1,25 +0,0 @@
package ru.somecompany.domain;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Builder;
import lombok.Data;
import java.util.UUID;
@Data
@Builder
@Schema(description = "Данные по вакансии")
public class VacancyResponse {
private UUID id;
private String name;
private String description;
private Integer salaryLow;
private Integer salaryHigh;
private CompanyResponse company;
}

View File

@@ -1,41 +0,0 @@
package ru.somecompany.exception;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import java.time.LocalDateTime;
import static org.springframework.http.HttpStatus.NOT_FOUND;
@Slf4j
public abstract class AbstractWebExceptionHandler {
public static ResponseEntity<ResponseError> buildResponse(ErrorCode errorCode, HttpStatus status, String msg,
boolean details, Throwable ex) {
return buildResponse(errorCode.name(), status, msg, details, ex, LocalDateTime.now());
}
public static ResponseEntity<ResponseError> buildResponse(String errorCode, HttpStatus status, String msg,
boolean details, Throwable ex, LocalDateTime timestamp) {
if (details) {
log.error(msg, ex); // with stack-trace
} else {
var message = StringUtils.equals(msg, ex.getMessage()) ? msg : msg + ": " + ex.getMessage();
if (status == NOT_FOUND) {
log.warn(message);
} else {
log.error(message);
}
}
return ResponseEntity.status(status.value())
.body(ResponseError.builder()
.code(errorCode)
.message(msg)
.timestamp(timestamp)
.status(status.value())
.build());
}
}

View File

@@ -1,5 +0,0 @@
package ru.somecompany.exception;
public enum BasicError implements ErrorCode {
NOT_FOUND
}

View File

@@ -1,26 +0,0 @@
package ru.somecompany.exception;
import lombok.Getter;
import org.springframework.http.HttpStatus;
@Getter
public class CompanyAppRuntimeException extends RuntimeException {
private final ErrorCode errorCode;
private final HttpStatus status;
private final boolean details;
public CompanyAppRuntimeException(ErrorCode errorCode, HttpStatus status, String message) {
this(errorCode, status, message, null);
}
public CompanyAppRuntimeException(ErrorCode errorCode, HttpStatus status, String message, Throwable error) {
this(errorCode, status, message, true, error);
}
public CompanyAppRuntimeException(ErrorCode errorCode, HttpStatus status, String message, boolean details, Throwable error) {
super(message, error);
this.errorCode = errorCode;
this.status = status;
this.details = details;
}
}

View File

@@ -1,9 +0,0 @@
package ru.somecompany.exception;
import java.io.Serializable;
public interface ErrorCode extends Serializable {
String name();
}

View File

@@ -1,28 +0,0 @@
package ru.somecompany.exception;
import org.springframework.http.HttpStatus;
import static ru.somecompany.exception.BasicError.NOT_FOUND;
public class ResourceNotFoundException extends CompanyAppRuntimeException {
public ResourceNotFoundException(ErrorCode errorCode, String message) {
this(errorCode, message, null);
}
public ResourceNotFoundException(ErrorCode errorCode, String message, Throwable error) {
super(errorCode, HttpStatus.NOT_FOUND, message, error);
}
public static ResourceNotFoundException notFound(String message, Object... args) {
return new ResourceNotFoundException(NOT_FOUND, String.format(message, args), null);
}
public static ResourceNotFoundException notFound() {
return new ResourceNotFoundException(NOT_FOUND, "Запрашиваемые данные не найдены", null);
}
public static ResourceNotFoundException notFound(Throwable error) {
return new ResourceNotFoundException(NOT_FOUND, error.getMessage(), error);
}
}

View File

@@ -1,24 +0,0 @@
package ru.somecompany.exception;
import com.fasterxml.jackson.annotation.JsonProperty;
import lombok.AllArgsConstructor;
import lombok.Builder;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.time.LocalDateTime;
@Data
@Builder
@AllArgsConstructor
@NoArgsConstructor
public class ResponseError {
@JsonProperty(required = true)
private LocalDateTime timestamp;
@JsonProperty(required = true)
private Integer status;
@JsonProperty(required = true)
private String message;
@JsonProperty(required = true)
private String code;
}

View File

@@ -1,22 +0,0 @@
package ru.somecompany.exception;
import com.fasterxml.jackson.databind.ObjectMapper;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
@Slf4j
@Getter
@RestControllerAdvice
@RequiredArgsConstructor
public class WebExceptionHandler extends AbstractWebExceptionHandler {
private final ObjectMapper objectMapper;
@ExceptionHandler(CompanyAppRuntimeException.class)
public ResponseEntity<ResponseError> handleException(CompanyAppRuntimeException ex) {
return buildResponse(ex.getErrorCode(), ex.getStatus(), ex.getMessage(), ex.isDetails(), ex);
}
}

View File

@@ -1,15 +0,0 @@
package ru.somecompany.external;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import ru.somecompany.domain.CompanyResponse;
import java.util.UUID;
@FeignClient(name = "company", url = "${app.feign.company-url}")
public interface CompanyClient {
@GetMapping(value = "/api/v1/company/{companyId}")
CompanyResponse getCompany(@PathVariable UUID companyId);
}

View File

@@ -1,24 +0,0 @@
package ru.somecompany.mapper;
import org.mapstruct.Mapper;
import org.mapstruct.Mapping;
import org.mapstruct.MappingTarget;
import ru.somecompany.domain.CompanyResponse;
import ru.somecompany.domain.CreateVacancyRequest;
import ru.somecompany.domain.VacancyEntity;
import ru.somecompany.domain.VacancyResponse;
import java.util.UUID;
@Mapper(imports = UUID.class)
public interface VacancyMapper {
@Mapping(target = "company", source = "company")
@Mapping(target = "name", source = "entity.name")
@Mapping(target = "id", source = "entity.id")
VacancyResponse map(VacancyEntity entity, CompanyResponse company);
VacancyEntity map(CreateVacancyRequest request);
VacancyEntity map(@MappingTarget VacancyEntity entity, CreateVacancyRequest request);
}

View File

@@ -1,11 +0,0 @@
package ru.somecompany.repository;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;
import ru.somecompany.domain.VacancyEntity;
import java.util.UUID;
@Repository
public interface VacancyRepository extends JpaRepository<VacancyEntity, UUID> {
}

View File

@@ -1,21 +0,0 @@
package ru.somecompany.service;
import ru.somecompany.domain.CreateVacancyRequest;
import ru.somecompany.domain.VacancyEntity;
import ru.somecompany.domain.VacancyResponse;
import java.util.List;
import java.util.UUID;
public interface VacancyService {
List<VacancyEntity> getVacancies();
VacancyEntity createVacancy(CreateVacancyRequest request);
VacancyEntity updateVacancy(UUID vacancyId, CreateVacancyRequest request);
void deleteVacancy(UUID vacancyId);
VacancyResponse getVacancy(UUID vacancyId);
}

View File

@@ -1,68 +0,0 @@
package ru.somecompany.service;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import ru.somecompany.domain.CreateVacancyRequest;
import ru.somecompany.domain.VacancyEntity;
import ru.somecompany.domain.VacancyResponse;
import ru.somecompany.mapper.VacancyMapper;
import ru.somecompany.repository.VacancyRepository;
import ru.somecompany.service.adapter.CompanyAdapter;
import java.util.List;
import java.util.UUID;
import static ru.somecompany.exception.ResourceNotFoundException.notFound;
@Slf4j
@Service
@RequiredArgsConstructor
public class VacancyServiceImpl implements VacancyService {
private final VacancyRepository vacancyRepository;
private final CompanyAdapter companyAdapter;
private final VacancyMapper mapper;
@Override
public List<VacancyEntity> getVacancies() {
return vacancyRepository.findAll();
}
@Override
public VacancyEntity createVacancy(CreateVacancyRequest request) {
var entity = mapper.map(request);
return vacancyRepository.save(entity);
}
@Override
public VacancyEntity updateVacancy(UUID vacancyId, CreateVacancyRequest request) {
var entity = getById(vacancyId);
entity = mapper.map(entity, request);
return vacancyRepository.save(entity);
}
@Override
public void deleteVacancy(UUID vacancyId) {
var entity = getById(vacancyId);
vacancyRepository.delete(entity);
}
@Override
public VacancyResponse getVacancy(UUID vacancyId) {
var entity = getById(vacancyId);
var company = companyAdapter.getCompanyById(entity.getCompanyId());
return mapper.map(entity, company);
}
private VacancyEntity getById(UUID vacancyId) {
var entity = vacancyRepository.findById(vacancyId);
if (entity.isEmpty()) {
log.warn("The vacancy with id '{}' was not found", vacancyId);
throw notFound("Вакансия не найдена");
}
return entity.get();
}
}

View File

@@ -1,10 +0,0 @@
package ru.somecompany.service.adapter;
import ru.somecompany.domain.CompanyResponse;
import java.util.UUID;
public interface CompanyAdapter {
CompanyResponse getCompanyById(UUID companyId);
}

View File

@@ -1,20 +0,0 @@
package ru.somecompany.service.adapter;
import lombok.RequiredArgsConstructor;
import org.springframework.stereotype.Service;
import ru.somecompany.domain.CompanyResponse;
import ru.somecompany.external.CompanyClient;
import java.util.UUID;
@Service
@RequiredArgsConstructor
public class CompanyAdapterImpl implements CompanyAdapter {
private final CompanyClient companyClient;
@Override
public CompanyResponse getCompanyById(UUID companyId) {
return companyClient.getCompany(companyId);
}
}

View File

@@ -1,32 +0,0 @@
server:
port: ${SERVER_PORT:8080}
spring:
application:
name: vacancy-app
jpa:
database: POSTGRESQL
open-in-view: false
show-sql: false
hibernate:
ddl-auto: none
properties:
hibernate:
dialect: org.hibernate.dialect.PostgreSQLDialect
datasource:
url: ${DB_URL:jdbc:postgresql://localhost:5433/vacancy}
username: ${DB_USERNAME:postgres}
password: ${DB_PASSWORD:postgres}
driverClassName: org.postgresql.Driver
type: com.zaxxer.hikari.HikariDataSource
hikari:
maximum-pool-size: 15
minimum-idle: 4
idle-timeout: 180000
max-lifetime: 599000
flyway:
enabled: true
locations: db/migration/
app:
feign:
company-url: ${COMPANY_URL:http://localhost:8081}

View File

@@ -1,9 +0,0 @@
CREATE TABLE vacancy (
id UUID
CONSTRAINT company_pk PRIMARY KEY,
name VARCHAR(255) NOT NULL,
description VARCHAR(1000),
salary_low int8 NOT NULL,
salary_high int8 NOT NULL,
company_id UUID NOT NULL
);

View File

@@ -1,33 +0,0 @@
services:
mediawiki:
image: mediawiki
restart: always
ports:
- 8080:80
volumes:
- ./volumes/mediawiki:/var/www/html/images
postgres:
image: postgres:12.20-alpine3.20
restart: always
environment:
POSTGRES_USER: postgres
POSTGRES_PASSWORD: example
ports:
- 5432:5432
volumes:
- ./volumes/database:/var/lib/mysql
git:
image: gitea/gitea:1.22.2
container_name: gitea
environment:
- USER_UID=1000
- USER_GID=1000
restart: always
volumes:
- ./volumes/gitea:/data
- ./volumes/timezone:/etc/timezone:ro
- ./volumes/localtime:/etc/localtime:ro
ports:
- "3000:3000"
- "222:22"

View File

@@ -1,35 +0,0 @@
# Лабораторная работа 1 Дозорова ПИбд-42
В рамках лабораторной работы были развернуты три сервиса с помощью docker-compose:
- Postgres
- MediaWiki
- gitea
## Пример docker-compose для одного из сервисов
```
postgres: - название сервиса
image: postgres:12.20-alpine3.20 - разворачиваемый образ
restart: always - параметр, означающий перезапуск при падении
environment: - переменные среды для сервиса
POSTGRES_USER: postgres
POSTGRES_PASSWORD: example
ports: - проброшенные порты с хоста внутрь контейнера
- 5432:5432
volumes: - проброшенные тома с хоста внутрь контейнера
- ./database:/var/lib/mysql
```
## Запуск
Для запуска лабораторной работы необходимо иметь запущенный Docker\Docker Desktop на устройстве.
Необходимо перейти в папку, где располагается yml файл. Далее открыть терминал и ввести команду:
```
docker compose up
```
Для выполнения в фоновом режиме можно использовать флаг `-d`. Результат выполнения:
```
[+] Running 3/3
✔ Container dozorova_alena_lab_1-mediawiki-1 Started 0.7s
✔ Container gitea Started 1.0s
✔ Container dozorova_alena_lab_1-postgres-1 Started 1.0s
```
## Видео демонстрация
Видеодемонстрация доступна по ссылке: https://drive.google.com/file/d/1cT-p-od2BjCloeTr7kcMGm9hb3htsxcs/view?usp=sharing

View File

@@ -1 +0,0 @@
GITEA_CUSTOM=/data/gitea

View File

@@ -1,98 +0,0 @@
APP_NAME = Gitea: Git with a cup of tea
RUN_MODE = prod
RUN_USER = git
WORK_PATH = /data/gitea
[repository]
ROOT = /data/git/repositories
[repository.local]
LOCAL_COPY_PATH = /data/gitea/tmp/local-repo
[repository.upload]
TEMP_PATH = /data/gitea/uploads
[server]
APP_DATA_PATH = /data/gitea
DOMAIN = localhost
SSH_DOMAIN = localhost
HTTP_PORT = 3000
ROOT_URL = http://localhost:3000/
DISABLE_SSH = false
SSH_PORT = 22
SSH_LISTEN_PORT = 22
LFS_START_SERVER = true
LFS_JWT_SECRET = FrtpRwqeQpRvyJJfayYEK45J0u7LF9mFMnzXzJyxaIM
OFFLINE_MODE = true
[database]
PATH = /data/gitea/gitea.db
DB_TYPE = postgres
HOST = postgres:5432
NAME = postgres
USER = postgres
PASSWD = example
LOG_SQL = false
SCHEMA =
SSL_MODE = disable
[indexer]
ISSUE_INDEXER_PATH = /data/gitea/indexers/issues.bleve
[session]
PROVIDER_CONFIG = /data/gitea/sessions
PROVIDER = file
[picture]
AVATAR_UPLOAD_PATH = /data/gitea/avatars
REPOSITORY_AVATAR_UPLOAD_PATH = /data/gitea/repo-avatars
[attachment]
PATH = /data/gitea/attachments
[log]
MODE = console
LEVEL = info
ROOT_PATH = /data/gitea/log
[security]
INSTALL_LOCK = true
SECRET_KEY =
REVERSE_PROXY_LIMIT = 1
REVERSE_PROXY_TRUSTED_PROXIES = *
INTERNAL_TOKEN = eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJuYmYiOjE3MjYyNTM3NDl9.qF5HZNwWbJzZ1e8Tt-jQZnMgGF1WY-NAruXLpw7kT4o
PASSWORD_HASH_ALGO = pbkdf2
[service]
DISABLE_REGISTRATION = false
REQUIRE_SIGNIN_VIEW = false
REGISTER_EMAIL_CONFIRM = false
ENABLE_NOTIFY_MAIL = false
ALLOW_ONLY_EXTERNAL_REGISTRATION = false
ENABLE_CAPTCHA = false
DEFAULT_KEEP_EMAIL_PRIVATE = false
DEFAULT_ALLOW_CREATE_ORGANIZATION = true
DEFAULT_ENABLE_TIMETRACKING = true
NO_REPLY_ADDRESS = noreply.localhost
[lfs]
PATH = /data/git/lfs
[mailer]
ENABLED = false
[openid]
ENABLE_OPENID_SIGNIN = true
ENABLE_OPENID_SIGNUP = true
[cron.update_checker]
ENABLED = false
[repository.pull-request]
DEFAULT_MERGE_STYLE = merge
[repository.signing]
DEFAULT_TRUST_MODEL = committer
[oauth2]
JWT_SECRET = K4ExL3zYsTAxp7e0CYQu6tbChCprQfp8OrIFeCEUFHQ

View File

@@ -1,22 +0,0 @@
[diff]
algorithm = histogram
[core]
logallrefupdates = true
quotePath = false
commitGraph = true
[gc]
reflogexpire = 90
writeCommitGraph = true
[user]
name = Gitea
email = gitea@fake.local
[receive]
advertisePushOptions = true
procReceiveRefs = refs/for
[fetch]
writeCommitGraph = true
[safe]
directory = *
[uploadpack]
allowfilter = true
allowAnySHA1InWant = true

View File

@@ -1 +0,0 @@
{"storage":"boltdb","index_type":"scorch"}

View File

@@ -1,52 +0,0 @@
-----BEGIN PRIVATE KEY-----
MIIJQwIBADANBgkqhkiG9w0BAQEFAASCCS0wggkpAgEAAoICAQDAlQqewJVPW6kz
aBx7ltjES7KEvanT+0lShf6eUrYm6LsgJC90kHJ5hay3X12iqEVhpRaK91deXFuj
KiySEGUGPt+OeYWJklGb1G6yeYbnZF/Gfq94ElzUCbpOaqGBykFF2Qp0odCGRwiy
Att3c1utK7tofd8S3IGNpXZ4ACODrug0AN5IgotwVbX44j3IXB2nzIC9HGts2hCv
x2ogovghP4gsifJvXsfjbV5MZZtkiVFcvCglcOILzId/A1Qy4/9LVpW5y6+ncN5O
27HI2LDEWpJ6btL3WvGKUkonZKrc34lAz/plJBUuYP/NTFNYNF/b7DWTPHL4qsS/
WusdN+xEK5e+2Co7x1GHS+vImoLbDEADb+ZDINhgaZF3krUytTwGPxeC2Y6ugLQE
zmWI33HgGQFJwBCY+E+mpj9CQRm3Bpd8L9gFfPu/f+9IIvzKkjsZLK0LzQth9jO5
eQXchtK+JJtvv0CKXT2hMz5pecS33jyk2xtC4W3zFjCpOlIutvlwXI5n5F4Re7af
Z6ZxkkdnnzVpgOO9U41d8YhrvwEl+G92FOKOrUxWn/j55OpQlVt0VnlnMldDpvui
zQbuPkrwUnsEFBnzOsT/YDoooSEC99eq8m5UMhuWDEgoB0lG3j5tCuPso2yGv7sB
s//MeLhQ2uKB19ngXQKJ73sGUGNu0wIDAQABAoICAQCp4c/ggtozixQTOQAHNeY6
ItxzpCuvx7fCiFk3qJbuc9a+X61NEi8pa/YUPJgI6I9rt4nPRKlZn/dmU8nFf5je
jY//yss1tFExOY/8+J88d5rVKuP285vXoE0s53tZVuWFjBRhFm0wRnExNrwK/0Qb
2rwTTRX/OW0/WnrLGLQ7cYt8dFehdycyDSndRxZhLIEsiIX4TJ2nBCY8KZlA+QIR
sk2ZnIa0H9QMl2nb0rXlVgzj1UdE3/NHnUDZlkIsMlv+RX8GyttExZgV0E9gcWZd
j9gvEJwhf6Qa9MRdQ7xF4xrchZrIpa/Znc+Jdo7+/BSjmBcarvRsz5eHhdhpie9s
GxTT0qiHZIjjbt+htar7um+5JPdIGDoIegQfwAaBvycf6WxZZkB5E5yJo8/jZMEO
hKhoNyRls5mMNjeyMBDUVIrXFzg1unqjdQWPxEj88vN0SlEEBubrzQPI9o/eOVtU
R/esDnZS2PLwrWJFBofBR3LbTDGeKhNIsvCp71tK5L1byHFVEuQHMnXUmjDonwbz
IShWYAap3oH7tc2Y9QDEPAM30b9pm73ujGKEwkDlG9cTxNksyoidmgWPSIiQ/IgE
KcZBZiIvqoWmdWIku2jaWwSzs0COy19WlqLU9ZZ64Mg2LmS/nyxV46GygIX2ksuE
cPDP9qgi3i+gYDdgAvzgoQKCAQEA6dcmHHP6bOSN5QesjB9RRJolx1YHdVFNaQ/E
ZY9/wcOZloIR4F6srpO3k0/7Q3MXznXplYKUyUIOOHTRnyiQh484VYPcRk1qQtFf
ELNQa5mQZFB2aYTkYLWFUqnla4XQXPWaeq0y19XtR9Z+VlJ2hhAui8R26yUGkrs2
T+cGOdrAAWyxSYhaHJkca78roqs8+yrM4/X+xH1CMBRt2/mRVLWHZ9XeXLuTfFIG
s4yY8/q6DTtyqI7P35TykDS8RYIx7zwnjsPH06Nvwth3Vf9adMOmHkEdKriCUImA
GGs/plFTnH4fcEA2i/tWzqwu/6kalI29S6BkxZ0zCT6XClFg3QKCAQEA0tT9GFRZ
RzlXmTd2YnenTOt6aWqJN8i/11cFwHPte9p8R1Kid/K+BENrkicJ+/pN6EefAzHW
GH2XytFUEDCBrK5pJXyBjVRPHJeOll3ORKt060Ry2X7u2zGfmglVIyhzjGY+qoA9
7f1wFDPiz1x4OLcsygezGE3oE1UDZazPCkCtUbQi86QPBSYEkbWzb3qlEdgY+LFo
K1wDxhaHJdoAK1GNhKaLCJDbv99XfuwTgJdNSH5wgohHajgLoBC7Sum4saqKNW/c
zxkgHkqIZ+zU3WqjmsllPcXehBptO1E6kg1FHdz/kyhk4/2ia1sO9D2/EScDHGeQ
bccnm4H9sK27bwKCAQBTzogaKnbWEBPKwbVVguPdcmGXz31czoav4LbCr2taRoAF
MRi3ETdSWh6w7TlgMx+VHy1YKDSq7MGr+jImmKMz8mB+RYPsrlInIGKx2ZI4/hCB
41SM/NPc1TGzLrDKmGrU5jE3RluyfzlLRdSBm4xe/+2uqfr0y5BPhkkw2duhYITv
/cSMVhH1repBs4IwCq8QVYaZLNDiGwJduPSmogs0ENs2m6/WDGQPalZ8gydOSc3k
cCnnv0dBGmDUzhGr172NwEFtKT203B5x9qLOb3Y74uLmdO+/H+GUe7MtDUMCmKMe
sxURZfImuS2jZJJzjme4VhRBxnpXWL+x0HzRddkBAoIBAQCatIOLyMlCREeNPG94
TcjL3rcSh4RtFLgA8fBcijSnf2lWhMKHNe5M/pP+yPrAlal5WqTKGVW63t31i6kd
wBpHdivdwADojgcHOgb9O5RSO2YuBSopgsUOvtkYlOSOSe6QBa7SOgw3iJMnn/M8
qePl6jPJg+DdYr17AhTeFPJP2anUnFRRZ/9FjeIocaZblSlvcJzSUIvZ1UlHn9xH
4DHjl5I61mKLRJCbuO1hSyX8ZAnnujAg+JM+1CVjrSNiEyLd7ABCufTTWuKAl7yE
VfrVBp1KxaGutHVVhnbE4hQSe/5NrY80kp2F1uXJ1SWh/3UmxvO3ch8/DrZ3m+lm
LfWtAoIBAEz84MbAe69BHCIGljxZOPndj3wWGQWuxgpOIvUIUNc8UVJIxYHMfZFi
vQMmk1emLHkPstnL5KiWUOujybwoZTB2Ac+PQJqXzlbv8h512eINVZTq307LycCi
qrSmXZPsPneavufDI4Bxefqf8ZdW3vEEcwCkzDjRNCFMcrToqps+UceWGxU31IJQ
93VBOWKhNAgEK4vKDy1QJNo+7fyWb64ofXjwWtSAGf4LvwloeeL6IRGDfyFA++Q/
8wPutNuo5qakXUkRCWx7I7lNoobKzoWQLMJGR85kCVkR1mbg5nubLaF+IIPNwTLe
XXGE9FRK35yA3VEgydvvn1EVHrDSqa0=
-----END PRIVATE KEY-----

View File

@@ -1 +0,0 @@
MANIFEST-000000

View File

@@ -1,6 +0,0 @@
=============== Sep 13, 2024 (UTC) ===============
18:55:55.362150 log@legend F·NumFile S·FileSize N·Entry C·BadEntry B·BadBlock Ke·KeyError D·DroppedEntry L·Level Q·SeqNum T·TimeElapsed
18:55:55.371211 db@open opening
18:55:55.373794 version@stat F·[] S·0B[] Sc·[]
18:55:55.381350 db@janitor F·2 G·0
18:55:55.381573 db@open done T·10.223409ms

View File

@@ -1,9 +0,0 @@
-----BEGIN OPENSSH PRIVATE KEY-----
b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAaAAAABNlY2RzYS
1zaGEyLW5pc3RwMjU2AAAACG5pc3RwMjU2AAAAQQRQ+roZZ007kQa7Gww2JTmmVFw127Mu
q28jcvF0dwxqed4YB66jve6n53CCFIiwRUgdL7xTznuc7zK4ubvLzZv8AAAAsI/K32qPyt
9qAAAAE2VjZHNhLXNoYTItbmlzdHAyNTYAAAAIbmlzdHAyNTYAAABBBFD6uhlnTTuRBrsb
DDYlOaZUXDXbsy6rbyNy8XR3DGp53hgHrqO97qfncIIUiLBFSB0vvFPOe5zvMri5u8vNm/
wAAAAhAKA0+nR1F1bBt7+aACPRfCKhwM97EucHO6IwHYNilS57AAAAEXJvb3RAMmRlMzY5
MmIzZTlhAQIDBAUG
-----END OPENSSH PRIVATE KEY-----

View File

@@ -1 +0,0 @@
ecdsa-sha2-nistp256 AAAAE2VjZHNhLXNoYTItbmlzdHAyNTYAAAAIbmlzdHAyNTYAAABBBFD6uhlnTTuRBrsbDDYlOaZUXDXbsy6rbyNy8XR3DGp53hgHrqO97qfncIIUiLBFSB0vvFPOe5zvMri5u8vNm/w= root@2de3692b3e9a

View File

@@ -1,7 +0,0 @@
-----BEGIN OPENSSH PRIVATE KEY-----
b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAAAMwAAAAtzc2gtZW
QyNTUxOQAAACCucAFJv9K4Cdh00YUz8Jqpoi+fvsHi4bIA/RzpKhWTuAAAAJjklphJ5JaY
SQAAAAtzc2gtZWQyNTUxOQAAACCucAFJv9K4Cdh00YUz8Jqpoi+fvsHi4bIA/RzpKhWTuA
AAAEDQcq4vet1WGsAxpKoaeA0RT/1lPObea7lkRE35BWZHn65wAUm/0rgJ2HTRhTPwmqmi
L5++weLhsgD9HOkqFZO4AAAAEXJvb3RAMmRlMzY5MmIzZTlhAQIDBA==
-----END OPENSSH PRIVATE KEY-----

View File

@@ -1 +0,0 @@
ssh-ed25519 AAAAC3NzaC1lZDI1NTE5AAAAIK5wAUm/0rgJ2HTRhTPwmqmiL5++weLhsgD9HOkqFZO4 root@2de3692b3e9a

View File

@@ -1,38 +0,0 @@
-----BEGIN OPENSSH PRIVATE KEY-----
b3BlbnNzaC1rZXktdjEAAAAABG5vbmUAAAAEbm9uZQAAAAAAAAABAAABlwAAAAdzc2gtcn
NhAAAAAwEAAQAAAYEA3mLCgeti3qwGSAQwhMKhI/iUeFKAi0BlwS3oI2oqdM4/xLgT90Yk
GUPij6sF3czftqhwzTIXJDlrEkrB3nOZCIQ/MNIjrlYprN2wXGCtwh8vBsODAR4Fe/UPj0
TT2YdGAkY8hgbS6LPNtQ0rUJBEWCA7LfM+SwFh6ghNB+9LulBLMfZsbd1K3hAxCsjPHOdE
emU2CRdsskQhnf9BRpX5e5LYNhERWfcFolWRkVl8oy2pHIcI7fZ5rnzIu1IGtRf+Lu5j6s
CHByuFhOAtxHLjK3446dlCQuw0vMLLWRZAzfiv5NFqLDjJlCA2XjTHmIDSVC4r5JtMWPE7
7KFgxyOpIJT9ZEQ+D7lToYCgBeyN17IsPk7DiOnDAeo4rHq9x3ywnhBxwVll4Ax2c/LYkZ
y1k5BNKWEykXy8e20+3EPOPzQc2VFwamgc8ynouoUpJ/WMtHTcwkHVwkE2jfoBXeE/iB0t
Jjlrp80njGXaHguNM+nl3A4yo85MpG1/d1oW1+KvAAAFiO8xjnbvMY52AAAAB3NzaC1yc2
EAAAGBAN5iwoHrYt6sBkgEMITCoSP4lHhSgItAZcEt6CNqKnTOP8S4E/dGJBlD4o+rBd3M
37aocM0yFyQ5axJKwd5zmQiEPzDSI65WKazdsFxgrcIfLwbDgwEeBXv1D49E09mHRgJGPI
YG0uizzbUNK1CQRFggOy3zPksBYeoITQfvS7pQSzH2bG3dSt4QMQrIzxznRHplNgkXbLJE
IZ3/QUaV+XuS2DYREVn3BaJVkZFZfKMtqRyHCO32ea58yLtSBrUX/i7uY+rAhwcrhYTgLc
Ry4yt+OOnZQkLsNLzCy1kWQM34r+TRaiw4yZQgNl40x5iA0lQuK+SbTFjxO+yhYMcjqSCU
/WREPg+5U6GAoAXsjdeyLD5Ow4jpwwHqOKx6vcd8sJ4QccFZZeAMdnPy2JGctZOQTSlhMp
F8vHttPtxDzj80HNlRcGpoHPMp6LqFKSf1jLR03MJB1cJBNo36AV3hP4gdLSY5a6fNJ4xl
2h4LjTPp5dwOMqPOTKRtf3daFtfirwAAAAMBAAEAAAGAWchvlPpOeW3kP1EJsZ/OZPJoJs
fQQ+gk7MA2941WRMA8OJTE4tE7o8Onha9bd/fN3jXVDNMLSsGvu7vY15G+GBUkWfaNF0aM
HtGF8VXK8ROb7dQjYOEY/7mppYL5MNqPZj2rE8VPg0mMZGtDsIv+O8IPgnaxEKEnQdBGIU
z4OulN4ocFsbllD5Bj7GG0VIv+NpgEH9mINdSR6fLzDKdiCQT5K6LqaXL0oFyBn7gMPOkj
XHQcI86dw9d3R0FPme9sHBJ0KV/QexJi9zB6Xkqh/A7wyDw0zIDjLvq4wnkWgSGR2reo+i
9RPcbqP71W4AnsEMc/Ax/ulEJh673pfoM5FYJLYCi7vp45hoQc+tmE9l2I4myJ/tBWWiS2
qerfC0xLxi6uTTl/JJO5P/IskNoVmrgLbiSV0zGOmREXCX70L4gP7o2g4WAehX2txwnbXy
rhYr/PEDrVmr56mEbM2icXkxciWV5Ot0YvOotZQyk/hohNJRUIogO2gVigm0cGV8lxAAAA
wBmGyOK2EeBALa0OkcUgmMFPFfs4Z0TuEkYIsI0u5gI8nKBc0Glf3IWekuonyuSCyRwDE2
X1jG/NBH0QY5qFJqPtDcvVdblc86vJsUKIfscKsxnnUt0Zl1KGNmWyWcq1vx9RCaLMQuh1
LqeF5creWKrJjomAbjGzwpv/2/X6fi/iKrLzjHdGMxfdypAHfEnkEij1s2YbwU4lnvACqv
WyOo6kxz/Z7ffSMXWIvigiqdKMfi6JGsY7Y28uOM3oqAfq9wAAAMEA9ZLZT5WQzZTIKWSV
Y9CCn1yQUufgw+MAxRjbqrkzVgPBhqu6XHzBlzPp0uKnu+zk8CUwsiIahx1zOScYov35VP
DFV0g64mfY0F7iZjAVMT7b2gdTsJl1duoo87UqD5+rISTNMeza3iJIHgJMDipXc+Fxfhff
9Hhr9GOL3Ki7V3LsNMd5r5A1ZX2j2Bp6r5YyeJK7AL/nO3cOJ/qgv3iVskCGFFjDgzyDsI
EqjgnmgHwDIs4uzmydb4BRu7XKIpC5AAAAwQDn0+GR3rstayRnZgYC1PAVip5GJOlSUczW
1hZe9ZqhOK2UMFAxBuUZB0YLtPswO5wXexC2J8oC0F3pv5COm5gpRCJarSjFozc3wISd/9
8fdwHxxGjHT5XXmW1dA+poXg+TIXPRF6/IYu5WI4N+7AzS37Uca4tyzy34heaP+MDuWdBq
Wws44lXlE/x3mrwpHA4aKbFKDoQhfO0Iae5Gp2ucic7cE4dqSVjloXuSa5viz6OHvVUz5Y
3pzkkk50kmSqcAAAARcm9vdEAyZGUzNjkyYjNlOWEBAg==
-----END OPENSSH PRIVATE KEY-----

View File

@@ -1 +0,0 @@
ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABgQDeYsKB62LerAZIBDCEwqEj+JR4UoCLQGXBLegjaip0zj/EuBP3RiQZQ+KPqwXdzN+2qHDNMhckOWsSSsHec5kIhD8w0iOuVims3bBcYK3CHy8Gw4MBHgV79Q+PRNPZh0YCRjyGBtLos821DStQkERYIDst8z5LAWHqCE0H70u6UEsx9mxt3UreEDEKyM8c50R6ZTYJF2yyRCGd/0FGlfl7ktg2ERFZ9wWiVZGRWXyjLakchwjt9nmufMi7Uga1F/4u7mPqwIcHK4WE4C3EcuMrfjjp2UJC7DS8wstZFkDN+K/k0WosOMmUIDZeNMeYgNJULivkm0xY8TvsoWDHI6kglP1kRD4PuVOhgKAF7I3Xsiw+TsOI6cMB6jiser3HfLCeEHHBWWXgDHZz8tiRnLWTkE0pYTKRfLx7bT7cQ84/NBzZUXBqaBzzKei6hSkn9Yy0dNzCQdXCQTaN+gFd4T+IHS0mOWunzSeMZdoeC40z6eXcDjKjzkykbX93WhbX4q8= root@2de3692b3e9a

View File

@@ -1,33 +0,0 @@
# Docker Compose: PostgreSQL, RabbitMQ, Nginx
## Описание проекта
Этот проект разворачивает три сервиса с помощью Docker Compose:
1. **PostgreSQL** — реляционная база данных.
2. **RabbitMQ** — брокер сообщений с панелью управления.
3. **Nginx** — веб-сервер и реверс-прокси.
## Команды для запуска
Чтобы развернуть и запустить проект, выполните следующие шаги:
1. Убедитесь, что у вас установлен Docker и Docker Compose.
2. Перейдите в директорию с файлом docker-compose.yml.
3. Запустите сервисы командой: docker-compose up --build
## Сервисы и порты
1. **PostgreSQL:**
**Порт:** 5432
**Доступ:** Локально, через любые приложения, подключающиеся к базе данных PostgreSQL.
2. **RabbitMQ:**
**Порт для приложений:** 5672
**Панель управления RabbitMQ:** Доступна по адресу [http://localhost:15672/](http://localhost:15672/) (логин: `user`, пароль: `password`).
3. **Nginx:**
**Порт:** 80
**Назначение:** Используется как реверс-прокси для распределения трафика.
## Видео https://drive.google.com/file/d/1qzc_IFZBFkUVGJ97bkcsKpbwn8pw3Hay/view

View File

@@ -1,34 +0,0 @@
version: '3.8'
services:
# База данных PostgreSQL
postgres:
image: postgres:15
container_name: postgres-db
environment:
POSTGRES_USER: postgres
POSTGRES_PASSWORD: postgres
POSTGRES_DB: mydb
ports:
- "5432:5432"
# RabbitMQ
rabbitmq:
image: rabbitmq:3-management
container_name: rabbitmq
environment:
RABBITMQ_DEFAULT_USER: user
RABBITMQ_DEFAULT_PASS: password
ports:
- "5672:5672" # для приложений
- "15672:15672" # для панели управления
# Nginx для реверс-прокси (если нужно для других сервисов)
nginx:
image: nginx:latest
container_name: nginx
ports:
- "80:80"
depends_on:
- rabbitmq

View File

@@ -0,0 +1,23 @@
# Распределённое приложение для поиска файлов и обработки чисел
## Описаниe
Данное распределённое приложение состоит из двух консольных Java-приложений, которые работают в контейнерах Docker. Приложения выполняют следующие задачи:
### file-finder:
Ищет самый большой файл в директории /var/data и копирует его в /var/result/data.txt.
### number-processor:
Считывает числа из файла /var/result/data.txt и сохраняет произведение первого и последнего числа в файл /var/result/result.txt.
#### Приложения работают совместно через Docker Compose, используя общий том для передачи файлов между контейнерами.
### Как запустить
1. #### Подготовка данных
Убедитесь, что в директории data находятся файлы, которые вы хотите обработать. Это могут быть текстовые файлы с числами.
2. #### Сборка и запуск контейнеров
Выполните команду для сборки и запуска контейнеров с помощью Docker Compose: docker-compose up --build
3. #### Результаты выполнения
#### Приложение file-finder находит самый большой файл в директории /var/data (локально это монтируемая директория data/) и копирует его в файл /var/result/data.txt.
#### Приложение number-processor читает файл /var/result/data.txt и сохраняет произведение первого и последнего числа в файл /var/result/result.txt.
#### Ссылка на видео https://drive.google.com/file/d/1u7nwZdUI4KHC4NzUAXdOABflYswokGwx/view

31
emelyanov_artem_lab_2/app_1/.gitignore vendored Normal file
View File

@@ -0,0 +1,31 @@
### IntelliJ IDEA ###
out/
!**/src/main/**/out/
!**/src/test/**/out/
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
bin/
!**/src/main/**/bin/
!**/src/test/**/bin/
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store
/.idea/modules.xml
/.idea/vcs.xml

8
emelyanov_artem_lab_2/app_1/.idea/.gitignore generated vendored Normal file
View File

@@ -0,0 +1,8 @@
# Default ignored files
/shelf/
/workspace.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml

View File

@@ -0,0 +1,17 @@
# Используем базовый образ с установленной JDK
FROM openjdk:17-jdk-slim
# Создаем директорию для исходных файлов
RUN mkdir /var/data
# Создаем директорию для приложения
WORKDIR /app
#Копируем исходные файлы приложения внутрь контейнера
COPY src /app/src
#Компилируем код
RUN javac /app/src/Main.java
# Определяем команду для запуска приложения
CMD ["java", "-cp", "/app/src", "Main"]

View File

@@ -0,0 +1,64 @@
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.StandardCopyOption;
public class Main {
public static void main(String[] args) {
/*
Ищет в каталоге /var/data самый большой по объёму файл и перекладывает его в /var/result/data.txt.
*/
File sourceDir = new File("/var/data");
File targetFile = new File("/var/result/data.txt");
// Проверяем, что sourceDir существует и является директорией
if (!sourceDir.exists() || !sourceDir.isDirectory()) {
System.out.println("Каталог " + sourceDir + " не существует или не является директорией.");
return;
}
File[] files = sourceDir.listFiles();
if (files == null || files.length == 0) {
System.out.println("Каталог " + sourceDir + " пуст.");
return;
}
long maxFileSize = -1L;
File maxFile = null;
// Находим файл с максимальным размером
for (File item : files) {
if (item.isFile() && item.length() > maxFileSize) {
maxFileSize = item.length();
maxFile = item;
}
}
if (maxFile != null) {
// Проверяем, существует ли конечная директория, если нет — создаем её
File targetDir = targetFile.getParentFile();
if (!targetDir.exists()) {
boolean dirCreated = targetDir.mkdirs();
if (dirCreated) {
System.out.println("Директория " + targetDir + " была успешно создана.");
} else {
System.out.println("Не удалось создать директорию " + targetDir);
return;
}
}
try {
// Копируем файл
Files.copy(maxFile.toPath(), targetFile.toPath(), StandardCopyOption.REPLACE_EXISTING);
System.out.println("Самый большой файл: " + maxFile.getName() + " был скопирован в /var/result/data.txt");
} catch (IOException e) {
System.out.println("Ошибка копирования файла: " + e.getMessage());
}
} else {
System.out.println("Файлы для копирования не найдены.");
}
}
}

30
emelyanov_artem_lab_2/app_2/.gitignore vendored Normal file
View File

@@ -0,0 +1,30 @@
### IntelliJ IDEA ###
out/
!**/src/main/**/out/
!**/src/test/**/out/
### Eclipse ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache
bin/
!**/src/main/**/bin/
!**/src/test/**/bin/
### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
### VS Code ###
.vscode/
### Mac OS ###
.DS_Store
/.idea/misc.xml

10
emelyanov_artem_lab_2/app_2/.idea/.gitignore generated vendored Normal file
View File

@@ -0,0 +1,10 @@
# Default ignored files
/shelf/
/workspace.xml
# Editor-based HTTP Client requests
/httpRequests/
# Datasource local storage ignored files
/dataSources/
/dataSources.local.xml
/modules.xml
/vcs.xml

View File

@@ -0,0 +1,17 @@
# Используем базовый образ с установленной JDK
FROM openjdk:17-jdk-slim
# Создаем директорию для исходных файлов
RUN mkdir /var/data
# Создаем директорию для приложения
WORKDIR /app
#Копируем исходные файлы приложения внутрь контейнера
COPY src /app/src
#Компилируем код
RUN javac /app/src/Main.java
# Определяем команду для запуска приложения
CMD ["java", "-cp", "/app/src", "Main"]

View File

@@ -0,0 +1,46 @@
import java.io.File;
import java.io.FileNotFoundException;
import java.io.PrintWriter;
import java.util.Scanner;
public class Main {
// Сохраняет произведение первого и последнего числа из файла /var/result/data.txt в /var/result/result.txt.
public static void main(String[] args) {
File sourceFile = new File("/var/result/data.txt");
File targetFile = new File("/var/result/result.txt");
int firstNumber = 0;
int lastNumber = 0;
boolean isFirstNumber = true;
try (Scanner scanner = new Scanner(sourceFile)) {
// Считываем числа
while (scanner.hasNextInt()) {
int currentNumber = scanner.nextInt();
if (isFirstNumber) {
firstNumber = currentNumber; // Сохраняем первое число
isFirstNumber = false;
}
lastNumber = currentNumber; // Последнее число обновляется на каждом шаге
}
} catch (FileNotFoundException ex) {
System.out.println("Файл не найден: " + ex.getMessage());
return; // Выходим, если файл не найден
}
// Рассчитываем произведение первого и последнего числа
int result = firstNumber * lastNumber;
// Сохраняем результат в файл
try (PrintWriter writer = new PrintWriter(targetFile)) {
writer.println(result);
System.out.println("Произведение первого и последнего числа: " + result);
} catch (FileNotFoundException ex) {
System.out.println("Ошибка записи в файл: " + ex.getMessage());
}
}
}

View File

@@ -0,0 +1,10 @@
2
32
1
2
3
54
64
4
3
3

View File

@@ -0,0 +1,12 @@
12
4
12
3
21
3
12
1
3
32
2
5

View File

@@ -0,0 +1,9 @@
12
2
1
2
4
3
1
2
3

View File

@@ -0,0 +1,21 @@
version: '3'
services:
file-finder:
build:
context: ./app_1 # Путь к первому приложению
dockerfile: Dockerfile
volumes:
- C:/Users/Admin/Desktop/УлГТУ/Распределенные вычисления и приложения/DAS_2024_1/emelyanov_artem_lab_2/data:/var/data # Монтируем директорию с файлами
- shared-result:/var/result
number-processor:
build:
context: ./app_2 # Путь ко второму приложению
dockerfile: Dockerfile
depends_on:
- file-finder
volumes:
- shared-result:/var/result
volumes:
shared-result: # Объявляем общий том

View File

@@ -1,14 +0,0 @@
# Переменные для базы данных
POSTGRES_TAG=latest # Берём последнююю версию postgres. Пока это не принципиально
POSTGRES_DATA_DIR=./postgres-data
POSTGRES_PASSWORD=postgres_password
# Переменные для Web gui для БД
DB_GUI_IMAGE=adminer # Самый легковесный Web gui для postgres(и не только)
DB_GUI_CONTEINER_PORT=8080
# Переменные для брокера сообщения RabbitMQ
RABBIT_TAG=3.10.7-management # Тут есть встроенный Web интерфейс
RABBIT_DATA_DIR=./rabbit-data
RABBIT_USERNAME=user
RABBIT_PASSWORD=password

Some files were not shown because too many files have changed in this diff Show More