forked from v.moiseev/distributed-computing
Compare commits
1 Commits
melnikov-k
...
melnikov-k
| Author | SHA1 | Date | |
|---|---|---|---|
| e6e89afa88 |
@@ -1,85 +0,0 @@
|
||||
# Отчёт по лабораторной работе №2
|
||||
|
||||
Выполнил: студент гр. ИСЭбд-41, Мельников Кирилл.
|
||||
|
||||
Вариант программы 1: 6. Берёт из каталога `/var/data `случайный файл и перекладывает его в `/var/result/data.txt`.
|
||||
|
||||
Вариант программы 2: 4. Ищет наименьшее число из файла `/var/data/data.txt` и сохраняет количество таких чисел из последовательности в `/var/result/result.txt`.
|
||||
|
||||
## Создание приложений
|
||||
|
||||
Создадим 2 приложения.
|
||||
Был выбран язык C# и технология .NET 5.
|
||||
|
||||
Для создания обычных консольных приложений воспользуемся командами:
|
||||
|
||||
```sh
|
||||
dotnet new console -o worker-1
|
||||
dotnet new console -o worker-2
|
||||
```
|
||||
|
||||
Согласно варианту, программа 1 должна брать из каталога `/var/data `случайный файл и перекладывать его в `/var/result/data.txt`.
|
||||
|
||||
[Исходный код программы worker-1](worker-1/Program.cs)
|
||||
|
||||
Согласно варианту программа 2 должна искать наименьшее число из файла `/var/data/data.txt` и сохранять количество таких чисел из последовательности в `/var/result/result.txt`.
|
||||
|
||||
[Исходный код программы worker-2](worker-2/Program.cs)
|
||||
|
||||
Дополнительно создан файл [.gitignore](.gitignore) для того, чтобы не закоммитить в git ничего лишнего.
|
||||
|
||||
## Настройка окружения
|
||||
|
||||
Для связи двух приложений воспользуемся следующей схемой:
|
||||
|
||||
1. Каталог `./data` должен быть примонтирован в каталог `/var/data` для программы 1.
|
||||
Оттуда будут браться исходные данные.
|
||||
2. Каталог `./result-1` должен быть примонтирован в каталог `/var/result` для программы 2.
|
||||
Туда будут складываться промежуточные данные.
|
||||
3. Каталог `./result-1` также должен быть примонтирован в каталог `/var/data` для программы 2.
|
||||
Оттуда будут браться промежуточные результаты.
|
||||
4. Каталог `./result` должен быть примонтирован в каталог `/var/result` для программы 2.
|
||||
Туда будут складывать результаты финальной обработки.
|
||||
|
||||
Для каждой программы были созданы файлы Dockerfile ([программа 1](worker-1/Dockerfile), [программа 2](worker-2/Dockerfile)) с подробным описанием процесса сборки.
|
||||
|
||||
Был создан файл [docker-compose.yml](docker-compose.yml), в котором указан манифест для запуска распределённого приложения.
|
||||
|
||||
|
||||
## Сборка и запуск
|
||||
|
||||
1. В каталог `./data` помещены 3 файла с различными названиями и содержимым.
|
||||
|
||||
|
||||
|
||||
На выходе программа должна записать данные из рандомного файла директории `/var/data`.
|
||||
|
||||
|
||||
|
||||
|
||||
|
||||
2. Теперь, обрабатывая эти файлы:
|
||||
|
||||
|
||||
|
||||
На выходе программа должна записать число 5 в `./result` так как в файле c названием data.txt минимальное число = 11, которое встречается 5 раз.
|
||||
|
||||
|
||||
|
||||
Для запуска приложения необходимо ввести команду `docker compose up --build`.
|
||||
Результат запуска после сборки:
|
||||
|
||||
```
|
||||
[+] Running 2/1
|
||||
✔ Container lab_2-worker-1-1 Created 0.0s
|
||||
✔ Container lab_2-worker-2-1 Created 0.0s
|
||||
Attaching to lab_2-worker-1-1, lab_2-worker-2-1
|
||||
lab_2-worker-1-1 | Файл /var/data/data.txt успешно скопирован в /var/result/data.txt.
|
||||
lab_2-worker-1-1 exited with code 0
|
||||
lab_2-worker-2-1 | Количество наименьших чисел сохранено в файле: /var/result/result.txt
|
||||
lab_2-worker-2-1 exited with code 0
|
||||
```
|
||||
|
||||
В результате в каталоге `./result` создался файл `result.txt` с содержимым `5`, что соответствует входным данным.
|
||||
|
||||
Изменение значений в файлах из каталога `./data` также изменяет содержимое в файлах из каталогов `./result-1` и `./result`.
|
||||
@@ -1,19 +0,0 @@
|
||||
100
|
||||
22
|
||||
11
|
||||
15
|
||||
46
|
||||
23
|
||||
11
|
||||
55
|
||||
449
|
||||
78
|
||||
65
|
||||
15
|
||||
35
|
||||
11
|
||||
59
|
||||
11
|
||||
87
|
||||
465
|
||||
11
|
||||
@@ -1,24 +0,0 @@
|
||||
156
|
||||
46
|
||||
23
|
||||
485
|
||||
12
|
||||
45
|
||||
98
|
||||
12
|
||||
45
|
||||
65
|
||||
12
|
||||
45
|
||||
748
|
||||
652
|
||||
32
|
||||
12
|
||||
4698
|
||||
789
|
||||
65
|
||||
16
|
||||
654
|
||||
9874
|
||||
654
|
||||
12
|
||||
@@ -1,53 +0,0 @@
|
||||
54
|
||||
465
|
||||
654
|
||||
74894
|
||||
654
|
||||
16847
|
||||
9874
|
||||
654
|
||||
9847
|
||||
96841
|
||||
9874
|
||||
654
|
||||
498654
|
||||
14654
|
||||
6541
|
||||
64
|
||||
6541
|
||||
496
|
||||
54
|
||||
6
|
||||
21
|
||||
54
|
||||
65
|
||||
21
|
||||
654
|
||||
21
|
||||
54
|
||||
68
|
||||
2
|
||||
486
|
||||
2
|
||||
485
|
||||
2
|
||||
68
|
||||
2
|
||||
196
|
||||
2
|
||||
4196
|
||||
2
|
||||
469
|
||||
2
|
||||
5
|
||||
3
|
||||
4
|
||||
6
|
||||
8
|
||||
7
|
||||
9
|
||||
4
|
||||
2
|
||||
2
|
||||
2
|
||||
|
||||
@@ -1,18 +0,0 @@
|
||||
version: "3.1"
|
||||
services:
|
||||
worker-1:
|
||||
build: ./worker-1
|
||||
volumes:
|
||||
# Монтирует локальную папку data к папке data в контейнере.
|
||||
- ./data:/var/data
|
||||
# Монтирует локальную папку result-1 к папке result в контейнере.
|
||||
- ./result-1:/var/result
|
||||
worker-2:
|
||||
build: ./worker-2
|
||||
volumes:
|
||||
# Монтирует локальную папку result-1 к папке data в контейнере.
|
||||
- ./result-1:/var/data
|
||||
- ./result:/var/result
|
||||
# Зависимость от первого приложения.
|
||||
depends_on:
|
||||
- worker-1
|
||||
@@ -1,28 +0,0 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.0.31903.59
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-1", "worker-1\worker-1.csproj", "{1C85F952-D0EA-4B7A-BADF-D95E24589A96}"
|
||||
EndProject
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-2", "worker-2\worker-2.csproj", "{7E758C59-DA3A-4A38-8DAC-37239F6602E9}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{1C85F952-D0EA-4B7A-BADF-D95E24589A96}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{1C85F952-D0EA-4B7A-BADF-D95E24589A96}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{1C85F952-D0EA-4B7A-BADF-D95E24589A96}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{1C85F952-D0EA-4B7A-BADF-D95E24589A96}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
{7E758C59-DA3A-4A38-8DAC-37239F6602E9}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{7E758C59-DA3A-4A38-8DAC-37239F6602E9}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{7E758C59-DA3A-4A38-8DAC-37239F6602E9}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{7E758C59-DA3A-4A38-8DAC-37239F6602E9}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
@@ -1,19 +0,0 @@
|
||||
100
|
||||
22
|
||||
11
|
||||
15
|
||||
46
|
||||
23
|
||||
11
|
||||
55
|
||||
449
|
||||
78
|
||||
65
|
||||
15
|
||||
35
|
||||
11
|
||||
59
|
||||
11
|
||||
87
|
||||
465
|
||||
11
|
||||
@@ -1 +0,0 @@
|
||||
5
|
||||
Binary file not shown.
|
Before Width: | Height: | Size: 3.9 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 53 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 49 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 59 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 48 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 43 KiB |
@@ -1,18 +0,0 @@
|
||||
# Задаем базовый образ на .net
|
||||
FROM mcr.microsoft.com/dotnet/sdk:5.0 AS build-env
|
||||
# Задаем рабочую директорию
|
||||
WORKDIR /src
|
||||
|
||||
|
||||
# Копируем файлы и папки в каталог в контейнер
|
||||
COPY . ./
|
||||
# Создаем образы и устанавливаем данные пакеты в контейнер
|
||||
RUN dotnet restore
|
||||
COPY . .
|
||||
RUN dotnet publish -c Release -o /publish
|
||||
|
||||
FROM mcr.microsoft.com/dotnet/aspnet:5.0
|
||||
WORKDIR /publish
|
||||
COPY --from=build-env /publish .
|
||||
# Вызываем приложение во время выполнения контейнера
|
||||
ENTRYPOINT ["dotnet", "worker-1.dll"]
|
||||
@@ -1,48 +0,0 @@
|
||||
using System;
|
||||
using System.IO;
|
||||
|
||||
class Program
|
||||
{
|
||||
static void Main()
|
||||
{
|
||||
string sourceDirectoryPath = "/var/data";
|
||||
string destinationFilePath = "/var/result/data.txt";
|
||||
|
||||
try
|
||||
{
|
||||
DirectoryInfo sourceDirectory = new DirectoryInfo(sourceDirectoryPath);
|
||||
FileInfo[] files = sourceDirectory.GetFiles();
|
||||
|
||||
if (files.Length == 0)
|
||||
{
|
||||
Console.WriteLine("Каталог {0} не содержит файлов.", sourceDirectoryPath);
|
||||
return;
|
||||
}
|
||||
|
||||
// Выбираем случайный файл из каталога
|
||||
Random random = new Random();
|
||||
FileInfo randomFile = files[random.Next(files.Length)];
|
||||
|
||||
// Перекладываем содержимое файла в указанный путь
|
||||
File.Copy(randomFile.FullName, destinationFilePath, true);
|
||||
|
||||
Console.WriteLine("Файл {0} успешно скопирован в {1}.", randomFile.FullName, destinationFilePath);
|
||||
}
|
||||
catch (DirectoryNotFoundException)
|
||||
{
|
||||
Console.WriteLine("Каталог {0} не найден.", sourceDirectoryPath);
|
||||
}
|
||||
catch (IOException e)
|
||||
{
|
||||
Console.WriteLine("Произошла ошибка при копировании файла: {0}", e.Message);
|
||||
}
|
||||
catch (UnauthorizedAccessException e)
|
||||
{
|
||||
Console.WriteLine("Отсутствует доступ к файлу: {0}", e.Message);
|
||||
}
|
||||
catch (ArgumentException)
|
||||
{
|
||||
Console.WriteLine("Путь {0} содержит недопустимые символы.", destinationFilePath);
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,11 +0,0 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net5.0</TargetFramework>
|
||||
<RootNamespace>worker_1</RootNamespace>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
</Project>
|
||||
@@ -1,18 +0,0 @@
|
||||
# Задаем базовый образ на .net
|
||||
FROM mcr.microsoft.com/dotnet/sdk:5.0 AS build-env
|
||||
# Задаем рабочую директорию
|
||||
WORKDIR /src
|
||||
|
||||
|
||||
# Копируем файлы и папки в каталог в контейнер
|
||||
COPY . ./
|
||||
# Создаем образы и устанавливаем данные пакеты в контейнер
|
||||
RUN dotnet restore
|
||||
COPY . .
|
||||
RUN dotnet publish -c Release -o /publish
|
||||
|
||||
FROM mcr.microsoft.com/dotnet/aspnet:5.0
|
||||
WORKDIR /publish
|
||||
COPY --from=build-env /publish .
|
||||
# Вызываем приложение во время выполнения контейнера
|
||||
ENTRYPOINT ["dotnet", "worker-2.dll"]
|
||||
@@ -1,22 +0,0 @@
|
||||
using System;
|
||||
using System.IO;
|
||||
using System.Linq;
|
||||
|
||||
class Program
|
||||
{
|
||||
static void Main()
|
||||
{
|
||||
string inputFile = "/var/data/data.txt";
|
||||
string outputFile = "/var/result/result.txt";
|
||||
|
||||
string[] lines = File.ReadAllLines(inputFile);
|
||||
int[] numbers = lines.Select(int.Parse).ToArray();
|
||||
|
||||
int minNumber = numbers.Min();
|
||||
int countOfMinNumbers = numbers.Count(n => n == minNumber);
|
||||
|
||||
File.WriteAllText(outputFile, countOfMinNumbers.ToString());
|
||||
|
||||
Console.WriteLine("Количество наименьших чисел сохранено в файле: " + outputFile);
|
||||
}
|
||||
}
|
||||
@@ -1,11 +0,0 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<OutputType>Exe</OutputType>
|
||||
<TargetFramework>net5.0</TargetFramework>
|
||||
<RootNamespace>worker_2</RootNamespace>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<Nullable>enable</Nullable>
|
||||
</PropertyGroup>
|
||||
|
||||
</Project>
|
||||
@@ -1,7 +1,10 @@
|
||||
## Ignore Visual Studio temporary files, build results, and
|
||||
## files generated by popular Visual Studio add-ons.
|
||||
##
|
||||
## Get latest from https://github.com/github/gitignore/blob/main/VisualStudio.gitignore
|
||||
## Get latest from `dotnet new gitignore`
|
||||
|
||||
# dotenv files
|
||||
.env
|
||||
|
||||
# User-specific files
|
||||
*.rsuser
|
||||
@@ -399,6 +402,7 @@ FodyWeavers.xsd
|
||||
|
||||
# JetBrains Rider
|
||||
*.sln.iml
|
||||
.idea
|
||||
|
||||
##
|
||||
## Visual studio for Mac
|
||||
@@ -475,3 +479,6 @@ $RECYCLE.BIN/
|
||||
|
||||
# Windows shortcuts
|
||||
*.lnk
|
||||
|
||||
# Vim temporary swap files
|
||||
*.swp
|
||||
86
tasks/melnikov-ky/lab_3/README.md
Normal file
86
tasks/melnikov-ky/lab_3/README.md
Normal file
@@ -0,0 +1,86 @@
|
||||
# Отчет по лабораторной работе №3
|
||||
|
||||
Выполнил студент гр. ИСЭбд-41 Мельников К.Ю.
|
||||
|
||||
## REST API, Gateway и синхронный обмен между микросервисами
|
||||
|
||||
## Создание микросервисов
|
||||
|
||||
1. С помощью команды `dotnet new web -n worker-1` в терминале создал первый микросервис
|
||||
2. Добавил решение командой `dotnet new sln`
|
||||
3. Связал решение и проект командой `dotnet sln worker-1.sln add worker-1.csproj`
|
||||
4. Повторил действие для второго микросервиса
|
||||
5. Добавил библиотеку Swagger и OpenAi в проекты и запустил с помощью команды `dotnet run`
|
||||
|
||||
Скриншоты протестированных микросервисов:
|
||||
|
||||
|
||||
|
||||
## Реализация синхронного обмена
|
||||
|
||||
Реализовал код, который вызывает сихронно данные из соседнего микросервиса.
|
||||
|
||||
```cs
|
||||
//worker-2
|
||||
app.MapGet("/Parts/", async () =>
|
||||
{
|
||||
var httpClient = new HttpClient();
|
||||
var secondWorkerResponse = await httpClient.GetStringAsync("http://worker-1:8080/");
|
||||
|
||||
return secondWorkerResponse.ToArray();
|
||||
})
|
||||
.WithName("GetCars")
|
||||
.WithOpenApi();
|
||||
```
|
||||
|
||||
## Реализация gateway при помощи nginx
|
||||
|
||||
Добавил nginx.conf:
|
||||
|
||||
```conf
|
||||
server {
|
||||
listen 8080;
|
||||
listen [::]:8080;
|
||||
server_name localhost;
|
||||
|
||||
location / {
|
||||
root /usr/share/nginx/html;
|
||||
index index.html index.htm;
|
||||
}
|
||||
|
||||
location /worker-1/ {
|
||||
proxy_pass http://worker-1: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-Prefix /worker-1;
|
||||
}
|
||||
|
||||
location /worker-2/ {
|
||||
proxy_pass http://worker-2: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-Prefix /worker-2;
|
||||
}
|
||||
}
|
||||
|
||||
```
|
||||
|
||||
Результат, после выполнения команды `docker-compose up`:
|
||||
|
||||
Docker:
|
||||
|
||||
|
||||
|
||||
index.html на gateway-1:
|
||||
|
||||
|
||||
|
||||
worker-1:
|
||||
|
||||
|
||||
|
||||
worker-2:
|
||||
|
||||
|
||||
15
tasks/melnikov-ky/lab_3/docker-compose.yml
Normal file
15
tasks/melnikov-ky/lab_3/docker-compose.yml
Normal file
@@ -0,0 +1,15 @@
|
||||
version: "3.1"
|
||||
services:
|
||||
worker-1:
|
||||
build: ./worker-1
|
||||
worker-2:
|
||||
build: ./worker-2
|
||||
depends_on:
|
||||
- worker-1
|
||||
gateway:
|
||||
image: nginx:latest
|
||||
ports:
|
||||
- 8080:8080
|
||||
volumes:
|
||||
- ./static:/usr/share/nginx/html:ro
|
||||
- ./nginx.conf:/etc/nginx/conf.d/default.conf:ro
|
||||
26
tasks/melnikov-ky/lab_3/nginx.conf
Normal file
26
tasks/melnikov-ky/lab_3/nginx.conf
Normal file
@@ -0,0 +1,26 @@
|
||||
server {
|
||||
listen 8080;
|
||||
listen [::]:8080;
|
||||
server_name localhost;
|
||||
|
||||
location / {
|
||||
root /usr/share/nginx/html;
|
||||
index index.html index.htm;
|
||||
}
|
||||
|
||||
location /worker-1/ {
|
||||
proxy_pass http://worker-1: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-Prefix /worker-1;
|
||||
}
|
||||
|
||||
location /worker-2/ {
|
||||
proxy_pass http://worker-2: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-Prefix /worker-2;
|
||||
}
|
||||
}
|
||||
BIN
tasks/melnikov-ky/lab_3/scrins/1.png
Normal file
BIN
tasks/melnikov-ky/lab_3/scrins/1.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 67 KiB |
BIN
tasks/melnikov-ky/lab_3/scrins/2.png
Normal file
BIN
tasks/melnikov-ky/lab_3/scrins/2.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 41 KiB |
BIN
tasks/melnikov-ky/lab_3/scrins/3.png
Normal file
BIN
tasks/melnikov-ky/lab_3/scrins/3.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 25 KiB |
BIN
tasks/melnikov-ky/lab_3/scrins/4.png
Normal file
BIN
tasks/melnikov-ky/lab_3/scrins/4.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 33 KiB |
BIN
tasks/melnikov-ky/lab_3/scrins/5.png
Normal file
BIN
tasks/melnikov-ky/lab_3/scrins/5.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 29 KiB |
13
tasks/melnikov-ky/lab_3/static/index.html
Normal file
13
tasks/melnikov-ky/lab_3/static/index.html
Normal file
@@ -0,0 +1,13 @@
|
||||
<!DOCTYPE html>
|
||||
<html lang="ru">
|
||||
<head>
|
||||
<meta charset="UTF-8">
|
||||
<meta name="viewport" content="width=device-width, initial-scale=1.0">
|
||||
<title>Тестовое приложение для л/р 3</title>
|
||||
</head>
|
||||
<body>
|
||||
<p>Мельников К.Ю. ИСЭбд-41.</p>
|
||||
<p><a href="/worker-1/">Отправить запрос к worker-1</a></p>
|
||||
<p><a href="/worker-2/">Отправить запрос к worker-2</a></p>
|
||||
</body>
|
||||
</html>
|
||||
11
tasks/melnikov-ky/lab_3/worker-1/Dockerfile
Normal file
11
tasks/melnikov-ky/lab_3/worker-1/Dockerfile
Normal file
@@ -0,0 +1,11 @@
|
||||
FROM mcr.microsoft.com/dotnet/sdk:7.0 AS build-env
|
||||
WORKDIR /app
|
||||
|
||||
COPY . ./
|
||||
RUN dotnet restore
|
||||
RUN dotnet publish -c Release -o out
|
||||
|
||||
FROM mcr.microsoft.com/dotnet/aspnet:7.0
|
||||
WORKDIR /app
|
||||
COPY --from=build-env /app/out .
|
||||
ENTRYPOINT ["dotnet", "worker-1.dll"]
|
||||
111
tasks/melnikov-ky/lab_3/worker-1/Program.cs
Normal file
111
tasks/melnikov-ky/lab_3/worker-1/Program.cs
Normal file
@@ -0,0 +1,111 @@
|
||||
List<Cars> cars = new()
|
||||
{
|
||||
new Cars() { Uuid= Guid.Parse("6a1b4a72-5669-41fe-8d5b-106dc86f58bd"), Model = "Priora", Brand = "Lada"},
|
||||
new Cars() { Uuid= Guid.Parse("464bbdb8-39c0-4644-b9c0-3df1c484ea7e"), Model = "CRV", Brand = "Honda"},
|
||||
new Cars() { Uuid= Guid.Parse("f8692bea-b7e6-4164-b564-a921f16c35c9"), Model = "Jumper", Brand = "Citroen"},
|
||||
};
|
||||
|
||||
var builder = WebApplication.CreateBuilder(args);
|
||||
|
||||
builder.Services.AddEndpointsApiExplorer();
|
||||
builder.Services.AddSwaggerGen();
|
||||
|
||||
var app = builder.Build();
|
||||
|
||||
if (app.Environment.IsDevelopment())
|
||||
{
|
||||
app.UseSwagger();
|
||||
app.UseSwaggerUI();
|
||||
}
|
||||
|
||||
app.UseHttpsRedirection();
|
||||
|
||||
app.MapGet("/", () =>
|
||||
{
|
||||
return cars.Select(r => new CarEntityDto()
|
||||
{
|
||||
Uuid = r.Uuid,
|
||||
Model = r.Model,
|
||||
Brand = r.Brand,
|
||||
});
|
||||
})
|
||||
.WithName("GetCars")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapGet("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var car = cars.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (car == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new CarEntityDto()
|
||||
{
|
||||
Uuid = car.Uuid,
|
||||
Model = car.Model,
|
||||
Brand = car.Brand,
|
||||
});
|
||||
})
|
||||
.WithName("GetCarByGUID")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPost("/{model}/{brand}", (string Model, string Brand) =>
|
||||
{
|
||||
Guid NewGuid = Guid.NewGuid();
|
||||
cars.Add(new Cars() { Uuid = NewGuid, Model = (string)Model, Brand = (string)Brand});
|
||||
|
||||
var car = cars.FirstOrDefault(r => r.Uuid == NewGuid);
|
||||
if (car == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new CarEntityDto()
|
||||
{
|
||||
Uuid = car.Uuid,
|
||||
Model = car.Model,
|
||||
Brand = car.Brand,
|
||||
});
|
||||
})
|
||||
.WithName("PostCar")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPatch("/{uuid}/{model}/{brand}", (Guid uuid, string ?model, string ?brand) =>
|
||||
{
|
||||
var car = cars.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (car == null)
|
||||
return Results.NotFound();
|
||||
if (model != null) car.Model = model;
|
||||
if (brand != null) car.Brand = brand;
|
||||
|
||||
return Results.Json(new CarEntityDto()
|
||||
{
|
||||
Uuid = car.Uuid,
|
||||
Model = car.Model,
|
||||
Brand = car.Brand,
|
||||
});
|
||||
})
|
||||
.WithName("UpdateCar")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapDelete("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var car = cars.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (car == null)
|
||||
return Results.NotFound();
|
||||
cars.Remove(car);
|
||||
return Results.Json(new CarEntityDto()
|
||||
{
|
||||
Uuid = car.Uuid,
|
||||
Model = car.Model,
|
||||
Brand = car.Brand,
|
||||
});
|
||||
})
|
||||
.WithName("DeleteCarByGUID")
|
||||
.WithOpenApi();
|
||||
|
||||
app.Run();
|
||||
|
||||
public class Cars
|
||||
{
|
||||
public Guid Uuid { get; set; }
|
||||
public string Model { get; set; } = string.Empty;
|
||||
public string Brand { get; set; } = string.Empty;
|
||||
}
|
||||
|
||||
public class CarEntityDto : Cars { }
|
||||
@@ -0,0 +1,38 @@
|
||||
{
|
||||
"$schema": "http://json.schemastore.org/launchsettings.json",
|
||||
"iisSettings": {
|
||||
"windowsAuthentication": false,
|
||||
"anonymousAuthentication": true,
|
||||
"iisExpress": {
|
||||
"applicationUrl": "http://localhost:51956",
|
||||
"sslPort": 44303
|
||||
}
|
||||
},
|
||||
"profiles": {
|
||||
"http": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "http://localhost:5197",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"https": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "https://localhost:7027;http://localhost:5197",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"IIS Express": {
|
||||
"commandName": "IISExpress",
|
||||
"launchBrowser": true,
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,8 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
}
|
||||
}
|
||||
9
tasks/melnikov-ky/lab_3/worker-1/appsettings.json
Normal file
9
tasks/melnikov-ky/lab_3/worker-1/appsettings.json
Normal file
@@ -0,0 +1,9 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*"
|
||||
}
|
||||
15
tasks/melnikov-ky/lab_3/worker-1/worker-1.csproj
Normal file
15
tasks/melnikov-ky/lab_3/worker-1/worker-1.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net7.0</TargetFramework>
|
||||
<Nullable>enable</Nullable>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<RootNamespace>worker_1</RootNamespace>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.0" />
|
||||
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
22
tasks/melnikov-ky/lab_3/worker-1/worker-1.sln
Normal file
22
tasks/melnikov-ky/lab_3/worker-1/worker-1.sln
Normal file
@@ -0,0 +1,22 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.0.31903.59
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-1", "worker-1.csproj", "{90F6C7BD-78E2-47C8-A702-DD47E74D3865}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{90F6C7BD-78E2-47C8-A702-DD47E74D3865}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
11
tasks/melnikov-ky/lab_3/worker-2/Dockerfile
Normal file
11
tasks/melnikov-ky/lab_3/worker-2/Dockerfile
Normal file
@@ -0,0 +1,11 @@
|
||||
FROM mcr.microsoft.com/dotnet/sdk:7.0 AS build-env
|
||||
WORKDIR /app
|
||||
|
||||
COPY . ./
|
||||
RUN dotnet restore
|
||||
RUN dotnet publish -c Release -o out
|
||||
|
||||
FROM mcr.microsoft.com/dotnet/aspnet:7.0
|
||||
WORKDIR /app
|
||||
COPY --from=build-env /app/out .
|
||||
ENTRYPOINT ["dotnet", "worker-2.dll"]
|
||||
139
tasks/melnikov-ky/lab_3/worker-2/Program.cs
Normal file
139
tasks/melnikov-ky/lab_3/worker-2/Program.cs
Normal file
@@ -0,0 +1,139 @@
|
||||
|
||||
List<Parts> parts = new()
|
||||
{
|
||||
new Parts() { Uuid= Guid.NewGuid(), Name = "Engine", IsNew = true, IdCar = Guid.Parse("6a1b4a72-5669-41fe-8d5b-106dc86f58bd") },
|
||||
new Parts() { Uuid= Guid.NewGuid(), Name = "Wheels", IsNew = false, IdCar = Guid.Parse("f8692bea-b7e6-4164-b564-a921f16c35c9") },
|
||||
new Parts() { Uuid= Guid.NewGuid(), Name = "Transmission", IsNew = false, IdCar = Guid.Parse("464bbdb8-39c0-4644-b9c0-3df1c484ea7e") },
|
||||
new Parts() { Uuid= Guid.NewGuid(), Name = "Radiator ", IsNew = true, IdCar = Guid.Parse("464bbdb8-39c0-4644-b9c0-3df1c484ea7e") },
|
||||
};
|
||||
|
||||
var builder = WebApplication.CreateBuilder(args);
|
||||
|
||||
builder.Services.AddEndpointsApiExplorer();
|
||||
builder.Services.AddSwaggerGen();
|
||||
|
||||
var app = builder.Build();
|
||||
|
||||
if (app.Environment.IsDevelopment())
|
||||
{
|
||||
app.UseSwagger();
|
||||
app.UseSwaggerUI();
|
||||
}
|
||||
|
||||
app.UseHttpsRedirection();
|
||||
|
||||
app.MapGet("/", () =>
|
||||
{
|
||||
return parts.Select(r => new PartEntityDto()
|
||||
{
|
||||
Uuid = r.Uuid,
|
||||
Name = r.Name,
|
||||
IsNew = r.IsNew,
|
||||
IdCar = r.IdCar,
|
||||
});
|
||||
})
|
||||
.WithName("GetParts")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapGet("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var part = parts.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (part == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new PartEntityDto()
|
||||
{
|
||||
Uuid = part.Uuid,
|
||||
Name = part.Name,
|
||||
IsNew = part.IsNew,
|
||||
IdCar = part.IdCar,
|
||||
});
|
||||
})
|
||||
.WithName("GetPartByGUID")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPost("/{name}/{isNew}/{idCar}", (string? Name, bool IsNew, Guid IdCar) =>
|
||||
{
|
||||
Guid NewGuid = Guid.NewGuid();
|
||||
parts.Add(new Parts() { Uuid = NewGuid, Name = (string)Name, IsNew = (bool)IsNew, IdCar = (Guid)IdCar });
|
||||
|
||||
var part = parts.FirstOrDefault(r => r.Uuid == NewGuid);
|
||||
if (part == null)
|
||||
return Results.NotFound();
|
||||
return Results.Json(new PartEntityDto()
|
||||
{
|
||||
Uuid = part.Uuid,
|
||||
Name = part.Name,
|
||||
IsNew = part.IsNew,
|
||||
IdCar = part.IdCar,
|
||||
});
|
||||
})
|
||||
.WithName("PostPart")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapPatch("/{uuid}/{name}/{isNew}/{idCar}", (Guid uuid, string ?name, bool isNew, Guid idCar) =>
|
||||
{
|
||||
var part = parts.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (part == null)
|
||||
return Results.NotFound();
|
||||
if (name != ",") part.Name = name;
|
||||
if (isNew != part.IsNew) part.IsNew = isNew;
|
||||
if (idCar != part.IdCar) part.IdCar = idCar;
|
||||
|
||||
return Results.Json(new PartEntityDto()
|
||||
{
|
||||
Uuid = part.Uuid,
|
||||
Name = part.Name,
|
||||
IsNew = part.IsNew,
|
||||
IdCar = part.IdCar,
|
||||
});
|
||||
})
|
||||
.WithName("UpdatePart")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapDelete("/{uuid}", (Guid uuid) =>
|
||||
{
|
||||
var part = parts.FirstOrDefault(r => r.Uuid == uuid);
|
||||
if (part == null)
|
||||
return Results.NotFound();
|
||||
parts.Remove(part);
|
||||
return Results.Json(new PartEntityDto()
|
||||
{
|
||||
Uuid = part.Uuid,
|
||||
Name = part.Name,
|
||||
IsNew = part.IsNew,
|
||||
IdCar = part.IdCar,
|
||||
});
|
||||
})
|
||||
.WithName("DeletePart")
|
||||
.WithOpenApi();
|
||||
|
||||
app.MapGet("/Parts/", async () =>
|
||||
{
|
||||
var httpClient = new HttpClient();
|
||||
var secondWorkerResponse = await httpClient.GetStringAsync("http://worker-1:8080/");
|
||||
|
||||
return secondWorkerResponse.ToArray();
|
||||
})
|
||||
.WithName("GetCars")
|
||||
.WithOpenApi();
|
||||
|
||||
app.Run();
|
||||
|
||||
public class Parts
|
||||
{
|
||||
public Guid Uuid { get; set; }
|
||||
public string Name { get; set; } = string.Empty;
|
||||
public bool IsNew { get; set; }
|
||||
public Guid IdCar { get; set; }
|
||||
}
|
||||
|
||||
public class PartEntityDto : Parts { }
|
||||
|
||||
public class Cars
|
||||
{
|
||||
public Guid Uuid { get; set; }
|
||||
public string Model { get; set; } = string.Empty;
|
||||
public string Brand { get; set; } = string.Empty;
|
||||
}
|
||||
|
||||
public class CarEntityDto : Cars { }
|
||||
@@ -0,0 +1,38 @@
|
||||
{
|
||||
"$schema": "http://json.schemastore.org/launchsettings.json",
|
||||
"iisSettings": {
|
||||
"windowsAuthentication": false,
|
||||
"anonymousAuthentication": true,
|
||||
"iisExpress": {
|
||||
"applicationUrl": "http://localhost:36404",
|
||||
"sslPort": 44384
|
||||
}
|
||||
},
|
||||
"profiles": {
|
||||
"http": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "http://localhost:5101",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"https": {
|
||||
"commandName": "Project",
|
||||
"dotnetRunMessages": true,
|
||||
"launchBrowser": true,
|
||||
"applicationUrl": "https://localhost:7125;http://localhost:5101",
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
},
|
||||
"IIS Express": {
|
||||
"commandName": "IISExpress",
|
||||
"launchBrowser": true,
|
||||
"environmentVariables": {
|
||||
"ASPNETCORE_ENVIRONMENT": "Development"
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,8 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
}
|
||||
}
|
||||
9
tasks/melnikov-ky/lab_3/worker-2/appsettings.json
Normal file
9
tasks/melnikov-ky/lab_3/worker-2/appsettings.json
Normal file
@@ -0,0 +1,9 @@
|
||||
{
|
||||
"Logging": {
|
||||
"LogLevel": {
|
||||
"Default": "Information",
|
||||
"Microsoft.AspNetCore": "Warning"
|
||||
}
|
||||
},
|
||||
"AllowedHosts": "*"
|
||||
}
|
||||
15
tasks/melnikov-ky/lab_3/worker-2/worker-2.csproj
Normal file
15
tasks/melnikov-ky/lab_3/worker-2/worker-2.csproj
Normal file
@@ -0,0 +1,15 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net7.0</TargetFramework>
|
||||
<Nullable>enable</Nullable>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
<RootNamespace>worker_2</RootNamespace>
|
||||
</PropertyGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="7.0.0" />
|
||||
<PackageReference Include="Swashbuckle.AspNetCore" Version="6.5.0" />
|
||||
</ItemGroup>
|
||||
|
||||
</Project>
|
||||
22
tasks/melnikov-ky/lab_3/worker-2/worker-2.sln
Normal file
22
tasks/melnikov-ky/lab_3/worker-2/worker-2.sln
Normal file
@@ -0,0 +1,22 @@
|
||||
|
||||
Microsoft Visual Studio Solution File, Format Version 12.00
|
||||
# Visual Studio Version 17
|
||||
VisualStudioVersion = 17.0.31903.59
|
||||
MinimumVisualStudioVersion = 10.0.40219.1
|
||||
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "worker-2", "worker-2.csproj", "{C9D63524-2C63-4E86-91B6-D86955CFA5F8}"
|
||||
EndProject
|
||||
Global
|
||||
GlobalSection(SolutionConfigurationPlatforms) = preSolution
|
||||
Debug|Any CPU = Debug|Any CPU
|
||||
Release|Any CPU = Release|Any CPU
|
||||
EndGlobalSection
|
||||
GlobalSection(SolutionProperties) = preSolution
|
||||
HideSolutionNode = FALSE
|
||||
EndGlobalSection
|
||||
GlobalSection(ProjectConfigurationPlatforms) = postSolution
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Debug|Any CPU.Build.0 = Debug|Any CPU
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Release|Any CPU.ActiveCfg = Release|Any CPU
|
||||
{C9D63524-2C63-4E86-91B6-D86955CFA5F8}.Release|Any CPU.Build.0 = Release|Any CPU
|
||||
EndGlobalSection
|
||||
EndGlobal
|
||||
Reference in New Issue
Block a user