aleikin_artem_lab_3 is ready

.gitignore

@@ -0,0 +1,15 @@
+################################################################################
+# Данный GITIGNORE-файл был автоматически создан Microsoft(R) Visual Studio.
+################################################################################
+
+/.vs
+/aleikin_artem_lab_3/.vs
+/aleikin_artem_lab_3/ProjectEntityProject/bin/Debug/net8.0
+/aleikin_artem_lab_3/ProjectEntityProject/obj
+/aleikin_artem_lab_3/TaskProject/bin/Debug/net8.0
+/aleikin_artem_lab_3/TaskProject/obj
+/dozorova_alena_lab_2
+/dozorova_alena_lab_3
+/dozorova_alena_lab_4
+/dozorova_alena_lab_5/ConsoleApp1/obj
+/dozorova_alena_lab_6/ConsoleApp1/obj

aleikin_artem_lab_3/.dockerignore

@@ -0,0 +1,30 @@
+**/.classpath
+**/.dockerignore
+**/.env
+**/.git
+**/.gitignore
+**/.project
+**/.settings
+**/.toolstarget
+**/.vs
+**/.vscode
+**/*.*proj.user
+**/*.dbmdl
+**/*.jfm
+**/azds.yaml
+**/bin
+**/charts
+**/docker-compose*
+**/Dockerfile*
+**/node_modules
+**/npm-debug.log
+**/obj
+**/secrets.dev.yaml
+**/values.dev.yaml
+LICENSE
+README.md
+!**/.gitignore
+!.git/HEAD
+!.git/config
+!.git/packed-refs
+!.git/refs/heads/**

aleikin_artem_lab_3/ProjectEntityProject/Controllers/ProjectController.cs

@@ -0,0 +1,60 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using ProjectEntityProject.Entity;
+
+namespace ProjectEntityProject.Controllers
+{
+    [ApiController]
+    [Route("projects")]
+    public class ProjectController : ControllerBase
+    {
+        private static readonly List<Project> Projects = new();
+
+        [HttpGet]
+        public ActionResult<List<Project>> GetProjects() => Ok(Projects);
+
+        [HttpGet("{id}")]
+        public ActionResult<Project> GetProject([FromRoute] Guid id)
+        {
+            var project = Projects.FirstOrDefault(p => p.Id == id);
+            return project is null ? NotFound() : Ok(project);
+        }
+
+        [HttpPost]
+        public ActionResult<Project> CreateProject([FromBody] ProjectDto projectdDto)
+        {
+            Project project = new Project
+            {
+                Name = projectdDto.Name,
+                Description = projectdDto.Description,
+            };
+            Projects.Add(project);
+            return CreatedAtAction(nameof(GetProject), new { id = project.Id }, project);
+        }
+
+        [HttpPut("{id}")]
+        public ActionResult<Project> UpdateProject(Guid id, [FromBody] ProjectDto projectDto)
+        {
+            var project = Projects.FirstOrDefault(p => p.Id == id);
+            if (project is null) return NotFound();
+
+            project.Name = projectDto.Name;
+            project.Description = projectDto.Description;
+            return Ok(project);
+        }
+
+        [HttpDelete("{id}")]
+        public IActionResult DeleteProject(Guid id)
+        {
+            var project = Projects.FirstOrDefault(p => p.Id == id);
+            if (project is null) return NotFound();
+
+            Projects.Remove(project);
+
+            var client = new HttpClient();
+            var response = client.DeleteAsync($"http://nginx/taskservice/tasks/by-project/{id}").Result;
+            return response.IsSuccessStatusCode ? Ok() : StatusCode(500);
+        }
+    }
+
+}

aleikin_artem_lab_3/ProjectEntityProject/Dockerfile

@@ -0,0 +1,29 @@
+# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
+
+# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
+FROM mcr.microsoft.com/dotnet/aspnet:8.0 AS base
+USER app
+WORKDIR /app
+EXPOSE 5001
+
+
+# Этот этап используется для сборки проекта службы
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["ProjectEntityProject/ProjectEntityProject.csproj", "ProjectEntityProject/"]
+RUN dotnet restore "./ProjectEntityProject/ProjectEntityProject.csproj"
+COPY . .
+WORKDIR "/src/ProjectEntityProject"
+RUN dotnet build "./ProjectEntityProject.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+# Этот этап используется для публикации проекта службы, который будет скопирован на последний этап
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./ProjectEntityProject.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "ProjectEntityProject.dll"]

aleikin_artem_lab_3/ProjectEntityProject/Entity/Project.cs

@@ -0,0 +1,10 @@
+namespace ProjectEntityProject.Entity
+{
+    public class Project
+    {
+        public Guid Id { get; init; } = Guid.NewGuid();
+        public string Name { get; set; } = string.Empty;
+        public string Description { get; set; } = string.Empty;
+    }
+
+}

aleikin_artem_lab_3/ProjectEntityProject/Entity/ProjectDto.cs

@@ -0,0 +1,4 @@
+namespace ProjectEntityProject.Entity
+{
+    public record ProjectDto(string Name, string Description) { }
+}

aleikin_artem_lab_3/ProjectEntityProject/Program.cs

@@ -0,0 +1,46 @@
+using Microsoft.AspNetCore.Hosting;
+using Microsoft.OpenApi.Models;
+
+var builder = WebApplication.CreateBuilder(args);
+
+builder.WebHost.ConfigureKestrel(serverOptions =>
+{
+    serverOptions.ListenAnyIP(5001);
+});
+
+builder.Services.AddControllers();
+// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
+builder.Services.AddEndpointsApiExplorer();
+builder.Services.AddSwaggerGen();
+
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("AllowAll", policy =>
+    {
+        policy.AllowAnyOrigin()
+              .AllowAnyMethod()
+              .AllowAnyHeader();
+    });
+});
+
+var app = builder.Build();
+
+app.UseCors("AllowAll");
+
+app.UseSwagger(c =>
+{
+
+    c.PreSerializeFilters.Add((swaggerDoc, httpReq) =>
+    {
+        swaggerDoc.Servers = new List<OpenApiServer> { new OpenApiServer { Url = $"{httpReq.Scheme}://{httpReq.Host.Value}/projectservice" } };
+    });
+});
+app.UseSwaggerUI();
+
+app.UseHttpsRedirection();
+
+app.UseAuthorization();
+
+app.MapControllers();
+
+app.Run();

aleikin_artem_lab_3/ProjectEntityProject/ProjectEntityProject.csproj

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <UserSecretsId>8c799772-d663-4c4a-8e6b-cce6a75ee84e</UserSecretsId>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
+  </ItemGroup>
+
+</Project>

aleikin_artem_lab_3/ProjectEntityProject/ProjectEntityProject.csproj.user

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <ActiveDebugProfile>Container (Dockerfile)</ActiveDebugProfile>
+    <Controller_SelectedScaffolderID>MvcControllerWithActionsScaffolder</Controller_SelectedScaffolderID>
+    <Controller_SelectedScaffolderCategoryPath>root/Common/MVC/Controller</Controller_SelectedScaffolderCategoryPath>
+  </PropertyGroup>
+</Project>

aleikin_artem_lab_3/ProjectEntityProject/ProjectEntityProject.http

@@ -0,0 +1,6 @@
+@ProjectEntityProject_HostAddress = http://localhost:5168
+
+GET {{ProjectEntityProject_HostAddress}}/weatherforecast/
+Accept: application/json
+
+###

aleikin_artem_lab_3/ProjectEntityProject/Properties/launchSettings.json

@@ -0,0 +1,52 @@
+{
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "dotnetRunMessages": true,
+      "applicationUrl": "http://localhost:5168"
+    },
+    "https": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "dotnetRunMessages": true,
+      "applicationUrl": "https://localhost:7265;http://localhost:5168"
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "Container (Dockerfile)": {
+      "commandName": "Docker",
+      "launchBrowser": true,
+      "launchUrl": "{Scheme}://{ServiceHost}:{ServicePort}/swagger",
+      "environmentVariables": {
+        "ASPNETCORE_HTTPS_PORTS": "8081",
+        "ASPNETCORE_HTTP_PORTS": "8080"
+      },
+      "publishAllPorts": true,
+      "useSSL": true
+    }
+  },
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:54970",
+      "sslPort": 44349
+    }
+  }
+}

aleikin_artem_lab_3/ProjectEntityProject/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

aleikin_artem_lab_3/ProjectEntityProject/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

aleikin_artem_lab_3/TaskProject/Controllers/TaskController.cs

@@ -0,0 +1,77 @@
+using Microsoft.AspNetCore.Http;
+using Microsoft.AspNetCore.Mvc;
+using System.Net.Http;
+using TaskProject.Entity;
+using static System.Runtime.InteropServices.JavaScript.JSType;
+using Task = TaskProject.Entity.Task;
+
+namespace TaskProject.Controllers
+{
+    [ApiController]
+    [Route("tasks")]
+    public class TaskController : ControllerBase
+    {
+        private static readonly List<Task> Tasks = new();
+
+        [HttpGet]
+        public ActionResult<List<Task>> GetTasks() => Ok(Tasks);
+
+        [HttpGet("{id}")]
+        public ActionResult<Task> GetTask(Guid id)
+        {
+            var task = Tasks.FirstOrDefault(t => t.Id == id);
+            return task is null ? NotFound() : Ok(task);
+        }
+
+        [HttpPost]
+        public ActionResult<Task> CreateTask([FromBody] TaskDto taskDto)
+        {
+            Task task = new Task
+            {
+                Title = taskDto.Title,
+                Description = taskDto.Description,
+                ProjectId = taskDto.ProjectId,
+            };
+            var client = new HttpClient();
+            var response = client.GetAsync($"http://nginx/projectservice/projects/{task.ProjectId}").Result;
+            if (!response.IsSuccessStatusCode) return BadRequest("Project not found");
+
+            Tasks.Add(task);
+            return CreatedAtAction(nameof(GetTask), new { id = task.Id }, task);
+        }
+
+        [HttpPut("{id}")]
+        public ActionResult<Task> UpdateTask(Guid id, [FromBody] TaskDto taskDto)
+        {
+            var task = Tasks.FirstOrDefault(t => t.Id == id);
+            if (task is null) return NotFound();
+
+            var client = new HttpClient();
+            var response = client.GetAsync($"http://nginx/projectservice/projects/{task.ProjectId}").Result;
+            if (!response.IsSuccessStatusCode) return BadRequest("Project not found");
+
+            task.Title = taskDto.Title;
+            task.Description = taskDto.Description;
+            task.ProjectId = taskDto.ProjectId;
+            return Ok(task);
+        }
+
+        [HttpDelete("{id}")]
+        public IActionResult DeleteTask(Guid id)
+        {
+            var task = Tasks.FirstOrDefault(t => t.Id == id);
+            if (task is null) return NotFound();
+
+            Tasks.Remove(task);
+            return Ok();
+        }
+
+        [HttpDelete("by-project/{projectId}")]
+        public IActionResult DeleteTasksByProject(Guid projectId)
+        {
+            Tasks.RemoveAll(t => t.ProjectId == projectId);
+            return Ok();
+        }
+    }
+
+}

aleikin_artem_lab_3/TaskProject/Dockerfile

@@ -0,0 +1,29 @@
+# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
+
+# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
+FROM mcr.microsoft.com/dotnet/aspnet:8.0 AS base
+USER app
+WORKDIR /app
+EXPOSE 5002
+
+
+# Этот этап используется для сборки проекта службы
+FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["TaskProject/TaskProject.csproj", "TaskProject/"]
+RUN dotnet restore "./TaskProject/TaskProject.csproj"
+COPY . .
+WORKDIR "/src/TaskProject"
+RUN dotnet build "./TaskProject.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+# Этот этап используется для публикации проекта службы, который будет скопирован на последний этап
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./TaskProject.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "TaskProject.dll"]

aleikin_artem_lab_3/TaskProject/Entity/Task.cs

@@ -0,0 +1,11 @@
+namespace TaskProject.Entity
+{
+    public class Task
+    {
+        public Guid Id { get; init; } = Guid.NewGuid();
+        public string Title { get; set; } = string.Empty;
+        public string Description { get; set; } = string.Empty;
+        public Guid ProjectId { get; set; }
+    }
+
+}

aleikin_artem_lab_3/TaskProject/Entity/TaskDto.cs

@@ -0,0 +1,4 @@
+namespace TaskProject.Entity
+{
+    public record TaskDto(string Title, string Description, Guid ProjectId) {}
+}

aleikin_artem_lab_3/TaskProject/Program.cs

@@ -0,0 +1,45 @@
+using Microsoft.OpenApi.Models;
+
+var builder = WebApplication.CreateBuilder(args);
+
+builder.WebHost.ConfigureKestrel(serverOptions =>
+{
+    serverOptions.ListenAnyIP(5002);
+});
+
+builder.Services.AddCors(options =>
+{
+    options.AddPolicy("AllowAll", policy =>
+    {
+        policy.AllowAnyOrigin()
+              .AllowAnyMethod()
+              .AllowAnyHeader();
+    });
+});
+
+builder.Services.AddControllers();
+// Learn more about configuring Swagger/OpenAPI at https://aka.ms/aspnetcore/swashbuckle
+builder.Services.AddEndpointsApiExplorer();
+builder.Services.AddSwaggerGen();
+
+var app = builder.Build();
+
+app.UseCors("AllowAll");
+
+app.UseSwagger(c =>
+{
+
+    c.PreSerializeFilters.Add((swaggerDoc, httpReq) =>
+    {
+        swaggerDoc.Servers = new List<OpenApiServer> { new OpenApiServer { Url = $"{httpReq.Scheme}://{httpReq.Host.Value}/taskservice" } };
+    });
+});
+app.UseSwaggerUI();
+
+app.UseHttpsRedirection();
+
+app.UseAuthorization();
+
+app.MapControllers();
+
+app.Run();

aleikin_artem_lab_3/TaskProject/Properties/launchSettings.json

@@ -0,0 +1,52 @@
+{
+  "profiles": {
+    "http": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "dotnetRunMessages": true,
+      "applicationUrl": "http://localhost:5079"
+    },
+    "https": {
+      "commandName": "Project",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      },
+      "dotnetRunMessages": true,
+      "applicationUrl": "https://localhost:7111;http://localhost:5079"
+    },
+    "IIS Express": {
+      "commandName": "IISExpress",
+      "launchBrowser": true,
+      "launchUrl": "swagger",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development"
+      }
+    },
+    "Container (Dockerfile)": {
+      "commandName": "Docker",
+      "launchBrowser": true,
+      "launchUrl": "{Scheme}://{ServiceHost}:{ServicePort}/swagger",
+      "environmentVariables": {
+        "ASPNETCORE_HTTPS_PORTS": "8081",
+        "ASPNETCORE_HTTP_PORTS": "8080"
+      },
+      "publishAllPorts": true,
+      "useSSL": true
+    }
+  },
+  "$schema": "http://json.schemastore.org/launchsettings.json",
+  "iisSettings": {
+    "windowsAuthentication": false,
+    "anonymousAuthentication": true,
+    "iisExpress": {
+      "applicationUrl": "http://localhost:54012",
+      "sslPort": 44337
+    }
+  }
+}

aleikin_artem_lab_3/TaskProject/TaskProject.csproj

@@ -0,0 +1,16 @@
+<Project Sdk="Microsoft.NET.Sdk.Web">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <Nullable>enable</Nullable>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <UserSecretsId>735c8756-0d0c-4166-875d-9dfbf7cf10c4</UserSecretsId>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.21.0" />
+    <PackageReference Include="Swashbuckle.AspNetCore" Version="6.4.0" />
+  </ItemGroup>
+
+</Project>

aleikin_artem_lab_3/TaskProject/TaskProject.csproj.user

@@ -0,0 +1,8 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <ActiveDebugProfile>Container (Dockerfile)</ActiveDebugProfile>
+    <Controller_SelectedScaffolderID>MvcControllerWithActionsScaffolder</Controller_SelectedScaffolderID>
+    <Controller_SelectedScaffolderCategoryPath>root/Common/MVC/Controller</Controller_SelectedScaffolderCategoryPath>
+  </PropertyGroup>
+</Project>

aleikin_artem_lab_3/TaskProject/TaskProject.http

@@ -0,0 +1,6 @@
+@TaskProject_HostAddress = http://localhost:5079
+
+GET {{TaskProject_HostAddress}}/weatherforecast/
+Accept: application/json
+
+###

aleikin_artem_lab_3/TaskProject/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

aleikin_artem_lab_3/TaskProject/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  },
+  "AllowedHosts": "*"
+}

aleikin_artem_lab_3/docker-compose.yml

@@ -0,0 +1,35 @@
+services:
+    nginx:
+        image: nginx
+        depends_on:
+            - projectservice
+            - taskservice
+        volumes:
+            - ./nginx/nginx.conf:/etc/nginx/conf.d/default.conf
+        networks:
+          - app-network
+        ports:
+            - 80:80
+    
+    projectservice:
+        build: 
+          context: .
+          dockerfile: ProjectEntityProject/Dockerfile
+        networks:
+          - app-network
+        ports:
+            - 5001:8080
+    taskservice:
+        build: 
+          context: .
+          dockerfile: TaskProject/Dockerfile
+        networks:
+          - app-network
+        ports:
+            - 5002:8080
+        depends_on:
+            - projectservice
+
+networks:
+  app-network:
+    driver: bridge

aleikin_artem_lab_3/nginx/nginx.conf

@@ -0,0 +1,18 @@
+server {
+    listen      80;
+    server_name localhost;
+
+    location /projectservice/ {
+        proxy_pass       http://projectservice:5001/;
+		proxy_set_header Host      $host;
+        proxy_set_header X-Real-IP $remote_addr;
+        proxy_set_header X-Forwarded-Proto $scheme;
+    }
+
+    location /taskservice/ {
+        proxy_pass       http://taskservice:5002/;
+        proxy_set_header Host      $host;
+        proxy_set_header X-Real-IP $remote_addr;
+        proxy_set_header X-Forwarded-Proto $scheme;
+    }
+}

aleikin_artem_lab_3/readme.md

@@ -0,0 +1,99 @@
+# Лабораторная работа 3 - REST API, Gateway и синхронный обмен между микросервисами
+## ПИбд-42 || Алейкин Артем
+
+### Описание
+В данной лабораторной работе мы разворачиваем два микросервиса:
+ProjectEntityProject - проект содержащий логику работы с сущностью 'Проект - Project'.
+TaskProject - проект содержащий логику работы с сущностью 'Задача - Task'.
+
+### Файлы-конфигурации 
+1. docker-compose
+```
+services:
+    nginx:
+        image: nginx
+        depends_on:
+            - projectservice
+            - taskservice
+        volumes:
+            - ./nginx/nginx.conf:/etc/nginx/conf.d/default.conf
+        networks:
+          - app-network
+        ports:
+            - 80:80
+    
+    projectservice:
+        build: 
+          context: .
+          dockerfile: ProjectEntityProject/Dockerfile
+        networks:
+          - app-network
+        ports:
+            - 5001:8080
+    taskservice:
+        build: 
+          context: .
+          dockerfile: TaskProject/Dockerfile
+        networks:
+          - app-network
+        ports:
+            - 5002:8080
+        depends_on:
+            - projectservice
+
+networks:
+  app-network:
+    driver: bridge
+```
+
+nginx: Сервис, который работает как обратный прокси-сервер и маршрутизирует запросы к другим сервисам (projectservice и taskservice), слушая на порту 80.
+
+Зависит от двух других сервисов: projectservice и taskservice.
+Прокси-сервер использует конфигурацию, предоставленную в nginx.conf.
+projectservice: Сервис, отвечающий за логику работы с проектами, доступный на порту 8080 внутри контейнера (проброшен на порт 5001).
+
+Этот сервис будет обрабатывать запросы, связанные с проектами.
+taskservice: Сервис, отвечающий за логику работы с задачами, доступный на порту 8080 внутри контейнера (проброшен на порт 5002).
+
+Этот сервис будет обрабатывать запросы, связанные с задачами.
+Зависит от projectservice, так как задачи связаны с проектами.
+Сервис nginx будет проксировать запросы с путями /projectservice/ и /taskservice/ на соответствующие контейнеры с сервисами.
+
+
+2. nginx.conf
+```
+server {
+    listen      80;
+    server_name localhost;
+
+    location /projectservice/ {
+        proxy_pass       http://projectservice:5001/;
+		proxy_set_header Host      $host;
+        proxy_set_header X-Real-IP $remote_addr;
+        proxy_set_header X-Forwarded-Proto $scheme;
+    }
+
+    location /taskservice/ {
+        proxy_pass       http://taskservice:5002/;
+        proxy_set_header Host      $host;
+        proxy_set_header X-Real-IP $remote_addr;
+        proxy_set_header X-Forwarded-Proto $scheme;
+    }
+}
+```
+
+Этот файл конфигурирует Nginx для маршрутизации запросов:
+
+location /projectservice/: Все запросы, начинающиеся с /projectservice/, будут проксироваться к сервису projectservice, который работает на порту 5001. Заголовки, такие как Host, X-Real-IP и X-Forwarded-Proto, устанавливаются для правильной передачи информации о запросе.
+
+location /taskservice/: Все запросы, начинающиеся с /taskservice/, будут проксироваться к сервису taskservice, который работает на порту 5002. Аналогично, заголовки проксируются для корректной передачи данных.
+
+Этот конфигурационный файл гарантирует, что запросы к путям /projectservice/ и /taskservice/ будут перенаправляться на соответствующие сервисы через прокси-сервер Nginx.
+
+### Шаги для запуска:
+Переходим в корневую папку всего решения и пишем команду:
+```
+docker-compose up --build
+```
+
+Видео демонстрации работы: https://vk.com/video248424990_456239610?list=ln-Doqjb41FQlfo377LN0

bazunov_andrew_lab_2/README.md

@@ -1,6 +1,11 @@
-# Распределенные вычисления и приложения Л3
+# Распределенные вычисления и приложения Л2
 ## _Автор Базунов Андрей Игревич ПИбд-42_
 
+Сервисы ( _порядок исполнения сервисов соблюден_ ):
+- 1.FileCreator - (_Создание тестовых данных_)
+- 2.FirstService - (_Выполнение 1.4 варианта задания_)
+- 3.SecondService - (_Выполнение 2.2 варианта задания_)
+
 В качестве основного языка был выбран GoLang. Для каждого сервиса был создан DOCKERFILE где были прописаны условия и действия для сборки каждого из модулей
 
 # Docker
@@ -22,4 +27,4 @@ docker-compose up -d --build
 docker-compose down
 ```
 
-[Демонстрация работы](https://vk.com/video/@viltskaa?z=video236673313_456239577%2Fpl_236673313_-2)
+[Демонстрация работы](https://vk.com/video236673313_456239575)

bazunov_andrew_lab_3/PersonApp/.env

@@ -1,4 +0,0 @@
-PORT=8080
-TASK_APP_URL=http://task-app:8000
-TIMEOUT=15
-DATABASE=./database.db

bazunov_andrew_lab_3/PersonApp/Dockerfile

@@ -1,14 +0,0 @@
-FROM golang:1.23
-
-WORKDIR /app
-
-COPY go.mod go.sum ./
-RUN go mod download
-
-COPY . .
-
-RUN go build -o /bin/PersonApp
-
-EXPOSE 8080
-
-CMD ["/bin/PersonApp"]

bazunov_andrew_lab_3/PersonApp/go.mod

@@ -1,10 +0,0 @@
-module PersonApp
-
-go 1.23.1
-
-require (
-	github.com/gorilla/mux v1.8.1
-	github.com/mattn/go-sqlite3 v1.14.24
-)
-
-require github.com/joho/godotenv v1.5.1 // indirect

bazunov_andrew_lab_3/PersonApp/go.sum

@@ -1,6 +0,0 @@
-github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
-github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
-github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
-github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
-github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
-github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=

bazunov_andrew_lab_3/PersonApp/handlers/handlers.go

@@ -1,157 +0,0 @@
-package handlers
-
-import (
-	"PersonApp/httpClient"
-	"PersonApp/models"
-	"PersonApp/repository"
-	"encoding/json"
-	"fmt"
-	"github.com/gorilla/mux"
-	"net/http"
-	"strconv"
-)
-
-func InitRoutes(r *mux.Router, rep repository.PersonRepository, cln httpClient.Client) {
-	r.HandleFunc("/", GetPersons(rep, cln)).Methods("GET")
-	r.HandleFunc("/{id:[0-9]+}", GetPersonById(rep, cln)).Methods("GET")
-	r.HandleFunc("/", CreatePerson(rep)).Methods("POST")
-	r.HandleFunc("/{id:[0-9]+}", UpdatePerson(rep)).Methods("PUT")
-	r.HandleFunc("/{id:[0-9]+}", DeletePerson(rep)).Methods("DELETE")
-}
-
-func GetPersons(rep repository.PersonRepository, cln httpClient.Client) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		fmt.Println("GET PERSONS")
-
-		persons, err := rep.GetAllPersons()
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		for i := 0; i < len(persons); i++ {
-			tasks, _ := cln.GetPersonTasks(persons[i].Id)
-			persons[i].Tasks = tasks
-		}
-
-		err = json.NewEncoder(w).Encode(persons)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func GetPersonById(rep repository.PersonRepository, cln httpClient.Client) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err := rep.GetPersonById(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		tasks, err := cln.GetPersonTasks(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		} else {
-			person.Tasks = tasks
-		}
-
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func CreatePerson(rep repository.PersonRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		var person *models.Person
-
-		err := json.NewDecoder(r.Body).Decode(&person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err = rep.CreatePerson(*person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusCreated)
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func UpdatePerson(rep repository.PersonRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		var person *models.Person
-		err = json.NewDecoder(r.Body).Decode(&person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err = rep.UpdatePerson(models.Person{
-			Id:    id,
-			Name:  person.Name,
-			Tasks: nil,
-		})
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusAccepted)
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-		}
-	}
-}
-
-func DeletePerson(rep repository.PersonRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		err = rep.DeletePerson(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusOK)
-	}
-}

bazunov_andrew_lab_3/PersonApp/httpClient/client.go

@@ -1,72 +0,0 @@
-package httpClient
-
-import (
-	"PersonApp/models"
-	"encoding/json"
-	"fmt"
-	"io"
-	"net/http"
-	"time"
-)
-
-type Client interface {
-	GetPersonTasks(id int) ([]models.Task, error)
-	TestConnection() (bool, error)
-}
-
-type client struct {
-	BaseUrl string
-	Timeout time.Duration
-}
-
-func (c *client) TestConnection() (bool, error) {
-	client := &http.Client{Timeout: c.Timeout}
-	url := fmt.Sprintf("%s/", c.BaseUrl)
-	resp, err := client.Get(url)
-
-	if err != nil {
-		return false, err
-	}
-
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-			return
-		}
-	}(resp.Body)
-
-	if resp.StatusCode != http.StatusOK {
-		return false, fmt.Errorf("bad status code: %d", resp.StatusCode)
-	}
-	return true, nil
-}
-
-func (c *client) GetPersonTasks(id int) ([]models.Task, error) {
-	client := &http.Client{Timeout: c.Timeout * time.Second}
-	url := fmt.Sprintf("%s/f/%d", c.BaseUrl, id)
-
-	resp, err := client.Get(url)
-	if err != nil {
-		return nil, err
-	}
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-
-		}
-	}(resp.Body)
-
-	body, _ := io.ReadAll(resp.Body)
-
-	var tasks []models.Task
-	if err := json.Unmarshal(body, &tasks); err != nil {
-		fmt.Printf("Unmarshal error: %s", err)
-		return []models.Task{}, err
-	}
-
-	return tasks, nil
-}
-
-func NewClient(baseUrl string, timeout time.Duration) Client {
-	return &client{BaseUrl: baseUrl, Timeout: timeout}
-}

bazunov_andrew_lab_3/PersonApp/httpTests/test.http

@@ -1,34 +0,0 @@
-GET http://localhost/person-app/
-Accept: application/json
-
-###
-
-GET http://localhost/person-app/1
-Accept: application/json
-
-###
-
-POST http://localhost/person-app/
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST3"
-}
-
-###
-
-PUT http://localhost/person-app/3
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST11"
-}
-
-###
-
-DELETE http://localhost/person-app/3
-Accept: application/json
-
-###

bazunov_andrew_lab_3/PersonApp/main.go

@@ -1,47 +0,0 @@
-package main
-
-import (
-	"PersonApp/handlers"
-	"PersonApp/httpClient"
-	"PersonApp/repository"
-	"PersonApp/storage"
-	"github.com/gorilla/mux"
-	"github.com/joho/godotenv"
-	"net/http"
-	"os"
-	"strconv"
-	"time"
-)
-
-func main() {
-	err := godotenv.Load(".env")
-	if err != nil {
-		panic("Error loading .env file")
-	}
-
-	url := os.Getenv("TASK_APP_URL")
-	port := os.Getenv("PORT")
-	databasePath := os.Getenv("DATABASE")
-	timeout, err := strconv.Atoi(os.Getenv("TIMEOUT"))
-
-	if err != nil {
-		panic("Error converting timeout to int")
-	}
-
-	database, err := storage.Init(databasePath)
-	if err != nil {
-		panic(err)
-	}
-
-	cln := httpClient.NewClient(url, time.Duration(timeout))
-	rep := repository.NewPersonRepository(database)
-	router := mux.NewRouter()
-	handlers.InitRoutes(router, rep, cln)
-
-	err = http.ListenAndServe(":"+port, router)
-	if err != nil {
-		panic(err)
-	}
-
-	storage.Close(database)
-}

bazunov_andrew_lab_3/PersonApp/models/models.go

@@ -1,24 +0,0 @@
-package models
-
-type Person struct {
-	Id    int    `json:"id"`
-	Name  string `json:"name"`
-	Tasks []Task `json:"tasks"`
-}
-
-type PersonCreate struct {
-	Name string `json:"name"`
-}
-
-type Task struct {
-	Id       int    `json:"id"`
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}
-
-type TaskCreate struct {
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}

bazunov_andrew_lab_3/PersonApp/repository/personRepository.go

@@ -1,99 +0,0 @@
-package repository
-
-import (
-	"PersonApp/models"
-	"database/sql"
-)
-
-type PersonRepository interface {
-	GetAllPersons() ([]models.Person, error)
-	GetPersonById(id int) (*models.Person, error)
-	CreatePerson(person models.Person) (*models.Person, error)
-	UpdatePerson(person models.Person) (*models.Person, error)
-	DeletePerson(id int) error
-}
-
-type personRepository struct {
-	DB *sql.DB
-}
-
-func NewPersonRepository(db *sql.DB) PersonRepository {
-	return &personRepository{DB: db}
-}
-
-func (pr *personRepository) GetAllPersons() ([]models.Person, error) {
-	rows, err := pr.DB.Query("select * from Persons")
-	if err != nil {
-		return nil, err
-	}
-
-	defer func(rows *sql.Rows) {
-		err := rows.Close()
-		if err != nil {
-			panic(err)
-		}
-	}(rows)
-
-	var persons []models.Person
-
-	for rows.Next() {
-		p := models.Person{}
-		err := rows.Scan(&p.Id, &p.Name)
-		if err != nil {
-			panic(err)
-		}
-
-		persons = append(persons, p)
-	}
-
-	return persons, err
-}
-
-func (pr *personRepository) GetPersonById(id int) (*models.Person, error) {
-	row := pr.DB.QueryRow("select * from Persons where id=?", id)
-
-	person := models.Person{}
-	err := row.Scan(&person.Id, &person.Name)
-	if err != nil {
-		return nil, err
-	}
-
-	return &person, err
-}
-
-func (pr *personRepository) CreatePerson(p models.Person) (*models.Person, error) {
-	res, err := pr.DB.Exec("INSERT INTO Persons (name) values (?)", p.Name)
-
-	if err != nil {
-		return nil, err
-	}
-
-	if res == nil {
-		return nil, nil
-	}
-
-	return &p, err
-}
-
-func (pr *personRepository) UpdatePerson(p models.Person) (*models.Person, error) {
-	res, err := pr.DB.Exec("UPDATE Persons SET name = ? WHERE id = ?", p.Name, p.Id)
-
-	if err != nil {
-		return nil, err
-	}
-
-	if res == nil {
-		return nil, nil
-	}
-
-	return &p, err
-}
-
-func (pr *personRepository) DeletePerson(id int) error {
-	_, err := pr.DB.Exec("DELETE FROM Persons WHERE id = ?", id)
-
-	if err != nil {
-		return err
-	}
-	return nil
-}

bazunov_andrew_lab_3/PersonApp/storage/db.go

@@ -1,36 +0,0 @@
-package storage
-
-import (
-	"database/sql"
-	_ "github.com/mattn/go-sqlite3"
-)
-
-func Init(databasePath string) (*sql.DB, error) {
-	db, err := sql.Open("sqlite3", databasePath)
-
-	if err != nil || db == nil {
-		return nil, err
-	}
-
-	if err := createTableIfNotExists(db); err != nil {
-		return nil, err
-	}
-
-	return db, nil
-}
-
-func Close(db *sql.DB) {
-	err := db.Close()
-	if err != nil {
-		return
-	}
-}
-
-func createTableIfNotExists(db *sql.DB) error {
-	if result, err := db.Exec(
-		"CREATE TABLE IF NOT EXISTS `Persons`(Id integer primary key autoincrement, Name text not null);",
-	); err != nil || result == nil {
-		return err
-	}
-	return nil
-}

bazunov_andrew_lab_3/TaskApp/.env

@@ -1,4 +0,0 @@
-PORT=8000
-PERSON_APP_URL=http://person-app:8080
-TIMEOUT=15
-DATABASE=./database.db

bazunov_andrew_lab_3/TaskApp/Dockerfile

@@ -1,14 +0,0 @@
-FROM golang:1.23
-
-WORKDIR /app
-
-COPY go.mod go.sum ./
-RUN go mod download
-
-COPY . .
-
-RUN go build -o /bin/TaskApp
-
-EXPOSE 8000
-
-CMD ["/bin/TaskApp"]

bazunov_andrew_lab_3/TaskApp/go.mod

@@ -1,10 +0,0 @@
-module TaskApp
-
-go 1.23.1
-
-require (
-	github.com/gorilla/mux v1.8.1
-	github.com/mattn/go-sqlite3 v1.14.24
-)
-
-require github.com/joho/godotenv v1.5.1

bazunov_andrew_lab_3/TaskApp/go.sum

@@ -1,6 +0,0 @@
-github.com/gorilla/mux v1.8.1 h1:TuBL49tXwgrFYWhqrNgrUNEY92u81SPhu7sTdzQEiWY=
-github.com/gorilla/mux v1.8.1/go.mod h1:AKf9I4AEqPTmMytcMc0KkNouC66V3BtZ4qD5fmWSiMQ=
-github.com/joho/godotenv v1.5.1 h1:7eLL/+HRGLY0ldzfGMeQkb7vMd0as4CfYvUVzLqw0N0=
-github.com/joho/godotenv v1.5.1/go.mod h1:f4LDr5Voq0i2e/R5DDNOoa2zzDfwtkZa6DnEwAbqwq4=
-github.com/mattn/go-sqlite3 v1.14.24 h1:tpSp2G2KyMnnQu99ngJ47EIkWVmliIizyZBfPrBWDRM=
-github.com/mattn/go-sqlite3 v1.14.24/go.mod h1:Uh1q+B4BYcTPb+yiD3kU8Ct7aC0hY9fxUwlHK0RXw+Y=

bazunov_andrew_lab_3/TaskApp/handlers/handlers.go

@@ -1,177 +0,0 @@
-package handlers
-
-import (
-	"TaskApp/httpClient"
-	"TaskApp/models"
-	"TaskApp/repository"
-	"encoding/json"
-	"fmt"
-	"github.com/gorilla/mux"
-	"net/http"
-	"strconv"
-)
-
-func InitRoutes(r *mux.Router, rep repository.TaskRepository, cln httpClient.Client) {
-	r.HandleFunc("/", GetTasks(rep)).Methods("GET")
-	r.HandleFunc("/{id:[0-9]+}", GetTaskById(rep)).Methods("GET")
-	r.HandleFunc("/", CreateTask(rep, cln)).Methods("POST")
-	r.HandleFunc("/{id:[0-9]+}", UpdateTask(rep)).Methods("PUT")
-	r.HandleFunc("/{id:[0-9]+}", DeleteTask(rep)).Methods("DELETE")
-	r.HandleFunc("/f/{id:[0-9]+}", GetPersonTasks(rep)).Methods("GET")
-}
-
-func GetTasks(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		tasks, err := rep.GetAllTasks()
-		if err != nil {
-			w.WriteHeader(http.StatusInternalServerError)
-			return
-		}
-
-		err = json.NewEncoder(w).Encode(tasks)
-		if err != nil {
-			w.WriteHeader(http.StatusInternalServerError)
-		}
-	}
-}
-
-func GetTaskById(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err := rep.GetTaskById(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		err = json.NewEncoder(w).Encode(person)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func GetPersonTasks(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusBadRequest)
-			return
-		}
-
-		tasks, err := rep.GetUserTasks(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		err = json.NewEncoder(w).Encode(tasks)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func CreateTask(rep repository.TaskRepository, cln httpClient.Client) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		var task *models.TaskCreate
-
-		err := json.NewDecoder(r.Body).Decode(&task)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		if &task.Name == nil || &task.PersonId == nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		person, err := cln.GetPerson(task.PersonId)
-
-		if err != nil {
-			fmt.Println(err)
-			http.Error(w, "Connection to PersonApp is confused.", http.StatusInternalServerError)
-			return
-		}
-
-		if person == nil {
-			http.Error(w, fmt.Sprintf("Person with id=%d is't founded.", person.Id), http.StatusBadGateway)
-			return
-		}
-
-		newTask, err := rep.CreateTask(*task)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		w.WriteHeader(http.StatusCreated)
-		err = json.NewEncoder(w).Encode(newTask)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-	}
-}
-
-func UpdateTask(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusBadRequest)
-			return
-		}
-
-		var task *models.TaskCreate
-
-		err = json.NewDecoder(r.Body).Decode(&task)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-
-		newTask, err := rep.UpdateTask(models.Task{Id: id, Name: task.Name, Date: task.Date})
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-		err = json.NewEncoder(w).Encode(newTask)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-		}
-	}
-}
-
-func DeleteTask(rep repository.TaskRepository) http.HandlerFunc {
-	return func(w http.ResponseWriter, r *http.Request) {
-		w.Header().Set("Content-Type", "application/json")
-
-		id, err := strconv.Atoi(mux.Vars(r)["id"])
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusBadRequest)
-			return
-		}
-
-		err = rep.DeleteTask(id)
-		if err != nil {
-			http.Error(w, err.Error(), http.StatusInternalServerError)
-			return
-		}
-		w.WriteHeader(http.StatusOK)
-	}
-}

bazunov_andrew_lab_3/TaskApp/httpClient/client.go

@@ -1,73 +0,0 @@
-package httpClient
-
-import (
-	"TaskApp/models"
-	"encoding/json"
-	"fmt"
-	"io"
-	"log"
-	"net/http"
-	"time"
-)
-
-type Client interface {
-	GetPerson(id int) (*models.Person, error)
-	TestConnection() (bool, error)
-}
-
-type client struct {
-	BaseUrl string
-	Timeout time.Duration
-}
-
-func (c *client) TestConnection() (bool, error) {
-	client := &http.Client{Timeout: c.Timeout}
-	url := fmt.Sprintf("%s/", c.BaseUrl)
-	resp, err := client.Get(url)
-
-	if err != nil {
-		return false, err
-	}
-
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-			return
-		}
-	}(resp.Body)
-
-	if resp.StatusCode != http.StatusOK {
-		return false, fmt.Errorf("bad status code: %d", resp.StatusCode)
-	}
-	return true, nil
-}
-
-func (c *client) GetPerson(id int) (*models.Person, error) {
-	client := &http.Client{Timeout: c.Timeout * time.Second}
-	url := fmt.Sprintf("%s/%d", c.BaseUrl, id)
-
-	resp, err := client.Get(url)
-	if err != nil {
-		return nil, err
-	}
-	defer func(Body io.ReadCloser) {
-		err := Body.Close()
-		if err != nil {
-
-		}
-	}(resp.Body)
-
-	body, _ := io.ReadAll(resp.Body)
-
-	var person models.Person
-	if err := json.Unmarshal(body, &person); err != nil {
-		log.Printf("Unmarshal error: %s", err)
-		return nil, err
-	}
-
-	return &person, nil
-}
-
-func NewClient(baseUrl string, timeout time.Duration) Client {
-	return &client{BaseUrl: baseUrl, Timeout: timeout}
-}

bazunov_andrew_lab_3/TaskApp/httpTests/tests.http

@@ -1,37 +0,0 @@
-GET http://localhost/task-app/
-Accept: application/json
-
-###
-
-GET http://localhost/task-app/4
-Accept: application/json
-
-###
-
-POST http://localhost/task-app/
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST2",
-  "person_id": 1,
-  "date": "19.02.2202"
-}
-
-###
-
-PUT http://localhost/task-app/4
-Accept: application/json
-Content-Type: application/json
-
-{
-  "name": "TEST5",
-  "date": "19.02.2202"
-}
-
-###
-
-DELETE http://localhost/task-app/4
-Accept: application/json
-
-###

bazunov_andrew_lab_3/TaskApp/main.go

@@ -1,47 +0,0 @@
-package main
-
-import (
-	"TaskApp/handlers"
-	"TaskApp/httpClient"
-	"TaskApp/repository"
-	"TaskApp/storage"
-	"github.com/gorilla/mux"
-	"github.com/joho/godotenv"
-	"net/http"
-	"os"
-	"strconv"
-	"time"
-)
-
-func main() {
-	err := godotenv.Load(".env")
-	if err != nil {
-		panic("Error loading .env file")
-	}
-
-	url := os.Getenv("PERSON_APP_URL")
-	port := os.Getenv("PORT")
-	databasePath := os.Getenv("DATABASE")
-	timeout, err := strconv.Atoi(os.Getenv("TIMEOUT"))
-
-	if err != nil {
-		panic("Error converting timeout to int")
-	}
-
-	database, err := storage.Init(databasePath)
-	if err != nil {
-		panic(err)
-	}
-
-	cln := httpClient.NewClient(url, time.Duration(timeout))
-	rep := repository.NewTaskRepository(database)
-	router := mux.NewRouter()
-	handlers.InitRoutes(router, rep, cln)
-
-	err = http.ListenAndServe(":"+port, router)
-	if err != nil {
-		panic(err)
-	}
-
-	storage.Close(database)
-}

bazunov_andrew_lab_3/TaskApp/models/models.go

@@ -1,24 +0,0 @@
-package models
-
-type Person struct {
-	Id    int    `json:"id"`
-	Name  string `json:"name"`
-	Tasks []Task `json:"tasks"`
-}
-
-type PersonCreate struct {
-	Name string `json:"name"`
-}
-
-type Task struct {
-	Id       int    `json:"id"`
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}
-
-type TaskCreate struct {
-	PersonId int    `json:"person_id"`
-	Name     string `json:"name"`
-	Date     string `json:"date"`
-}

bazunov_andrew_lab_3/TaskApp/repository/taskRepository.go

@@ -1,121 +0,0 @@
-package repository
-
-import (
-	"TaskApp/models"
-	"database/sql"
-)
-
-type TaskRepository interface {
-	GetAllTasks() ([]models.Task, error)
-	GetTaskById(id int) (*models.Task, error)
-	GetUserTasks(id int) ([]models.Task, error)
-	CreateTask(task models.TaskCreate) (*models.Task, error)
-	UpdateTask(task models.Task) (*models.Task, error)
-	DeleteTask(id int) error
-}
-
-type taskRepository struct {
-	DB *sql.DB
-}
-
-func (t taskRepository) GetUserTasks(id int) ([]models.Task, error) {
-	rows, err := t.DB.Query("select * from Tasks where PersonId = ?", id)
-	if err != nil {
-		return nil, err
-	}
-
-	defer func(rows *sql.Rows) {
-		err := rows.Close()
-		if err != nil {
-			panic(err)
-		}
-	}(rows)
-
-	var tasks []models.Task
-
-	for rows.Next() {
-		p := models.Task{}
-		err := rows.Scan(&p.Id, &p.Name, &p.PersonId, &p.Date)
-		if err != nil {
-			panic(err)
-		}
-
-		tasks = append(tasks, p)
-	}
-
-	return tasks, err
-}
-
-func (t taskRepository) GetAllTasks() ([]models.Task, error) {
-	rows, err := t.DB.Query("select * from Tasks")
-	if err != nil {
-		return nil, err
-	}
-
-	defer func(rows *sql.Rows) {
-		err := rows.Close()
-		if err != nil {
-			panic(err)
-		}
-	}(rows)
-
-	var tasks []models.Task
-
-	for rows.Next() {
-		p := models.Task{}
-		err := rows.Scan(&p.Id, &p.Name, &p.PersonId, &p.Date)
-		if err != nil {
-			panic(err)
-		}
-
-		tasks = append(tasks, p)
-	}
-
-	return tasks, err
-}
-
-func (t taskRepository) GetTaskById(id int) (*models.Task, error) {
-	row := t.DB.QueryRow("select * from Tasks where id=?", id)
-
-	task := models.Task{}
-	err := row.Scan(&task.Id, &task.Name, &task.PersonId, &task.Date)
-	if err != nil {
-		return nil, err
-	}
-
-	return &task, err
-}
-
-func (t taskRepository) CreateTask(task models.TaskCreate) (*models.Task, error) {
-	_, err := t.DB.Exec("INSERT INTO Tasks(Name, PersonId, Date) VALUES (?, ?, ?)", task.Name, task.PersonId, task.Date)
-	if err != nil {
-		return nil, err
-	}
-
-	return &models.Task{
-		Id:       0,
-		PersonId: task.PersonId,
-		Name:     task.Name,
-		Date:     task.Date,
-	}, err
-}
-
-func (t taskRepository) UpdateTask(task models.Task) (*models.Task, error) {
-	_, err := t.DB.Exec("UPDATE Tasks SET name = ?, date = ? WHERE id = ?", task.Name, task.Date, task.Id)
-	if err != nil {
-		return nil, err
-	}
-	return &task, err
-}
-
-func (t taskRepository) DeleteTask(id int) error {
-	_, err := t.DB.Exec("DELETE FROM Tasks WHERE id = ?", id)
-	if err != nil {
-		return err
-	}
-	return nil
-}
-
-func NewTaskRepository(db *sql.DB) TaskRepository {
-	return &taskRepository{DB: db}
-}

bazunov_andrew_lab_3/TaskApp/storage/db.go

@@ -1,36 +0,0 @@
-package storage
-
-import (
-	"database/sql"
-	_ "github.com/mattn/go-sqlite3"
-)
-
-func Init(databasePath string) (*sql.DB, error) {
-	db, err := sql.Open("sqlite3", databasePath)
-
-	if err != nil || db == nil {
-		return nil, err
-	}
-
-	if err := createTableIfNotExists(db); err != nil {
-		return nil, err
-	}
-
-	return db, nil
-}
-
-func Close(db *sql.DB) {
-	err := db.Close()
-	if err != nil {
-		return
-	}
-}
-
-func createTableIfNotExists(db *sql.DB) error {
-	if result, err := db.Exec(
-		"CREATE TABLE IF NOT EXISTS `Tasks`(Id integer primary key autoincrement, Name text not null, PersonId integer not null, Date text not null);",
-	); err != nil || result == nil {
-		return err
-	}
-	return nil
-}

bazunov_andrew_lab_3/docker-compose.yaml

@@ -1,34 +0,0 @@
-services:
-  person-app:
-    build:
-      context: ./PersonApp
-      dockerfile: Dockerfile
-    networks:
-      - network
-    ports:
-      - "8080:8080"
-
-  task-app:
-    build:
-      context: ./TaskApp
-      dockerfile: Dockerfile
-    networks:
-      - network
-    ports:
-      - "8000:8000"
-
-  nginx:
-    image: nginx
-    ports:
-      - "80:80"
-    volumes:
-      - ./nginx.conf:/etc/nginx/nginx.conf
-    networks:
-      - network
-    depends_on:
-      - person-app
-      - task-app
-
-networks:
-  network:
-    driver: bridge

bazunov_andrew_lab_3/nginx.conf

@@ -1,59 +0,0 @@
-events {
-    worker_connections 1024;
-}
-
-http {
-    server {
-        listen 80;
-        server_name localhost;
-
-        location /person-app/ {
-            proxy_pass http://person-app:8080/;
-            proxy_set_header Host $host;
-            proxy_set_header X-Real-IP $remote_addr;
-            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-            proxy_set_header X-Forwarded-Proto $scheme;
-            add_header 'Access-Control-Allow-Origin' '*';
-            add_header 'Access-Control-Allow-Methods' 'GET, POST, OPTIONS';
-            add_header 'Access-Control-Allow-Headers' 'Origin, Content-Type, Accept, Authorization';
-
-        }
-
-        location /task-app/ {
-            proxy_pass http://task-app:8000/;
-            proxy_set_header Host $host;
-            proxy_set_header X-Real-IP $remote_addr;
-            proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-            proxy_set_header X-Forwarded-Proto $scheme;
-            add_header 'Access-Control-Allow-Origin' '*';
-            add_header 'Access-Control-Allow-Methods' 'GET, POST, OPTIONS';
-            add_header 'Access-Control-Allow-Headers' 'Origin, Content-Type, Accept, Authorization';
-        }
-
-        # Прокси для Swagger (Stream-сервис)
-        #location /stream-service/swagger/ {
-        #    proxy_pass http://stream-service:8000/swagger/;
-        #    proxy_set_header Host $host;
-        #    proxy_set_header X-Real-IP $remote_addr;
-        #    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-        #    proxy_set_header X-Forwarded-Proto $scheme;
-        #}
-
-        # Прокси для Swagger (Message-сервис)
-        #location /message-service/swagger/ {
-        #    proxy_pass http://message-service:8080/swagger/;
-        #    proxy_set_header Host $host;
-        #    proxy_set_header X-Real-IP $remote_addr;
-        #    proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
-        #    proxy_set_header X-Forwarded-Proto $scheme;
-        #}
-
-        #location /stream-service/doc.json {
-        #    proxy_pass http://stream-service:8000/doc.json;
-        #}
-
-        #location /message-service/doc.json {
-        #    proxy_pass http://message-service:8080/doc.json;
-        #}
-    }
-}

bazunov_andrew_lab_4/README.md

@@ -1,34 +0,0 @@
-# Лабораторная работа №4: Работа с брокером сообщений (RabbitMQ)
-
-## Цель
-
-Изучение проектирования приложений с использованием брокера сообщений RabbitMQ.
-
----
-
-## Задачи
-
-> 1. **Установить RabbitMQ**  
-     Установите RabbitMQ на локальный компьютер (или используйте Docker).
->- [Скачивание RabbitMQ](https://www.rabbitmq.com/download.html)
->- [Релизы RabbitMQ](https://github.com/rabbitmq/rabbitmq-server/releases/)
->- **Пройти уроки RabbitMQ**
->- Сделайте скриншоты, показывающие запуск `producer` и `consumer` и передачу сообщений.
-
----
-## Первый урок
-> ![img.png](static/img1.png)
-
----
-## Второй урок
->![img.png](static/img2.png)
->![img_1.png](static/img3.png)
-
----
-## Третий урок
-> ![img.png](static/img4.png)
-
----
-## Задача
->![img.png](static/img5.png)
-> ![img.png](static/img.png)

bazunov_andrew_lab_4/docker-compose.yaml

@@ -1,17 +0,0 @@
-version: "3.2"
-services:
-  rabbitmq:
-    image: rabbitmq:3-management-alpine
-    container_name: 'rabbitmq'
-    ports:
-        - "5672:5672"
-        - "15672:15672"
-    volumes:
-        - ~/.docker-conf/rabbitmq/data/:/var/lib/rabbitmq/
-        - ~/.docker-conf/rabbitmq/log/:/var/log/rabbitmq
-    networks:
-        - rabbitmq_go_net
-
-networks:
-  rabbitmq_go_net:
-    driver: bridge

bazunov_andrew_lab_4/example/vk_author.py

@@ -1,47 +0,0 @@
-from datetime import datetime
-import random
-import threading
-
-import pika
-import sys
-
-_alphabet = [chr(i) for i in range(97, 123)]
-
-
-def run_every_n_seconds(seconds, action, *args):
-    threading.Timer(seconds, run_every_n_seconds, [seconds, action] + list(args)).start()
-    action(*args)
-
-
-def generate_message():
-    now = datetime.now()
-    current_time = now.strftime("%H:%M:%S")
-    return f"[{current_time}] " + "".join(random.choices(_alphabet, k=random.randint(1, 10)))
-
-
-def send_message(channel_local):
-    message = generate_message()
-    channel_local.basic_publish(
-        exchange='vk_messages',
-        routing_key='vk_messages',
-        body=message,
-        properties=pika.BasicProperties(
-            delivery_mode=pika.DeliveryMode.Persistent
-        ))
-    print(f"[vkAuthor] Sent {message}")
-
-
-def main(conn: pika.BlockingConnection):
-    channel = conn.channel()
-    channel.exchange_declare(exchange='vk_messages', exchange_type='fanout')
-    run_every_n_seconds(1, send_message, channel)
-
-
-if __name__ == '__main__':
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-
-    try:
-        main(connection)
-    except KeyboardInterrupt:
-        connection.close()
-        sys.exit(0)

bazunov_andrew_lab_4/example/vk_reader.py

@@ -1,44 +0,0 @@
-import sys
-from datetime import datetime
-
-import pika
-
-_QUEUE_NAME = "vk_messages_queue"
-_EXCHANGE_NAME = "vk_messages"
-
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.exchange_declare(
-        exchange=_EXCHANGE_NAME,
-        exchange_type='fanout'
-    )
-
-    channel.queue_declare(queue=_QUEUE_NAME, exclusive=True)
-    channel.queue_bind(exchange=_EXCHANGE_NAME, queue=_QUEUE_NAME)
-
-    def callback(ch, method, properties, body):
-        now = datetime.now()
-        current_time = now.strftime("%H:%M:%S")
-
-        print(f"[vkReader] Received [{str(body)}] in [{current_time}]")
-        ch.basic_ack(delivery_tag=method.delivery_tag)
-
-    channel.basic_consume(
-        queue=_QUEUE_NAME,
-        on_message_callback=callback,
-        auto_ack=False
-    )
-
-    print('[*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        sys.exit(0)

bazunov_andrew_lab_4/example/vk_slow_reader.py

@@ -1,47 +0,0 @@
-import time
-import random
-from datetime import datetime
-
-import pika
-import sys
-
-_QUEUE_NAME = "vk_messages_queue_slow"
-_EXCHANGE_NAME = "vk_messages"
-
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.exchange_declare(
-        exchange=_EXCHANGE_NAME,
-        exchange_type='fanout'
-    )
-    channel.queue_declare(queue=_QUEUE_NAME, exclusive=True)
-    channel.queue_bind(exchange=_EXCHANGE_NAME, queue=_QUEUE_NAME)
-
-    def callback(ch, method, properties, body):
-        now = datetime.now()
-        current_time = now.strftime("%H:%M:%S")
-
-        print(f"[vkSlowReader] Received [{str(body)}] in [{current_time}]")
-        read_time = random.randint(2, 5)
-        time.sleep(read_time)
-        ch.basic_ack(delivery_tag=method.delivery_tag)
-
-    channel.basic_consume(
-        queue=_QUEUE_NAME,
-        on_message_callback=callback,
-        auto_ack=False
-    )
-
-    print('[*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        sys.exit(0)

bazunov_andrew_lab_4/first/receive.py

@@ -1,25 +0,0 @@
-import pika
-import sys
-
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.queue_declare(queue='hello')
-
-    def callback(ch, method, properties, body):
-        print(f" [x] Received {body}")
-
-    channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
-
-    print(' [*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        sys.exit(0)

bazunov_andrew_lab_4/first/send.py

@@ -1,11 +0,0 @@
-import pika
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='hello')
-
-channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
-print(" [x] Sent 'Hello World!'")
-connection.close()

bazunov_andrew_lab_4/second/new_task.py

@@ -1,19 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-
-message = ' '.join(sys.argv[1:]) or "Hello World!"
-channel.basic_publish(
-    exchange='',
-    routing_key='task_queue',
-    body=message,
-    properties=pika.BasicProperties(
-        delivery_mode=pika.DeliveryMode.Persistent
-    ))
-print(f" [x] Sent {message}")
-connection.close()

bazunov_andrew_lab_4/second/worker.py

@@ -1,22 +0,0 @@
-import pika
-import time
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-print(' [*] Waiting for messages. To exit press CTRL+C')
-
-
-def callback(ch, method, properties, body):
-    print(f" [x] Received {body.decode()}")
-    time.sleep(body.count(b'.'))
-    print(" [x] Done")
-    ch.basic_ack(delivery_tag=method.delivery_tag)
-
-
-channel.basic_qos(prefetch_count=1)
-channel.basic_consume(queue='task_queue', on_message_callback=callback)
-
-channel.start_consuming()

bazunov_andrew_lab_4/third/emit_log.py

@@ -1,13 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-message = ' '.join(sys.argv[1:]) or "info: Hello World!"
-channel.basic_publish(exchange='logs', routing_key='', body=message)
-print(f" [x] Sent {message}")
-connection.close()

bazunov_andrew_lab_4/third/receive_logs.py

@@ -1,24 +0,0 @@
-import pika
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-result = channel.queue_declare(queue='', exclusive=True)
-queue_name = result.method.queue
-
-channel.queue_bind(exchange='logs', queue=queue_name)
-
-print(' [*] Waiting for logs. To exit press CTRL+C')
-
-
-def callback(ch, method, properties, body):
-    print(f" [x] {body}")
-
-
-channel.basic_consume(
-    queue=queue_name, on_message_callback=callback, auto_ack=True)
-
-channel.start_consuming()

kadyrov_aydar_lab_4/Consumer_1.py

@@ -1,30 +0,0 @@
-import pika
-import time
-
-
-def callback(ch, method, properties, body):
-    print(f'Consumer 1 получил сообщение: {body.decode()}')
-
-    # Время задержки по условию
-    time.sleep(2)
-
-    print('Consumer 1 закончил обработку')
-
-
-def consume_events_1():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание очереди
-    channel.queue_declare(queue='consumer1_queue')
-    # Привязка очереди
-    channel.queue_bind(exchange='beauty_salon_events', queue='consumer1_queue')
-
-    channel.basic_consume(queue='consumer1_queue', on_message_callback=callback, auto_ack=True)
-
-    print('Consumer 1 начал ожидать сообщения...')
-    channel.start_consuming()
-
-
-if __name__ == "__main__":
-    consume_events_1()

kadyrov_aydar_lab_4/Consumer_2.py

@@ -1,28 +0,0 @@
-import pika
-
-
-def callback(ch, method, properties, body):
-    print(f'Consumer 2 получил сообщение: {body.decode()}')
-
-    # Обработка "нон-стопом"
-    print('Consumer 2 закончил обработку')
-
-
-def consume_events_2():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание очереди
-    channel.queue_declare(queue='consumer2_queue')
-
-    # Привязка очереди
-    channel.queue_bind(exchange='beauty_salon_events', queue='consumer2_queue')
-
-    channel.basic_consume(queue='consumer2_queue', on_message_callback=callback, auto_ack=True)
-
-    print('Consumer 2 начал ожидать сообщения...')
-    channel.start_consuming()
-
-
-if __name__ == "__main__":
-    consume_events_2()

kadyrov_aydar_lab_4/README.md

@@ -1,56 +0,0 @@
-### Лабораторная работа №4 - Работа с брокером сообщений
-
-#### Задание
-
-1. Установить брокер сообщений RabbitMQ.
-2. Пройти уроки 1, 2 и 3 из RabbitMQ Tutorials на любом языке программирования.
-3. Продемонстрировать работу брокера сообщений.
-
-#### Описание работы программы:
-
-- **Класс Publisher** успешно осуществляет отправку сообщений своим клиентам.
-  
-- **Класс Consumer1** принимает и обрабатывает сообщения с задержкой в 3 секунды, что можно заметить на видео.
-
-- **Класс Consumer2** мгновенно принимает и обрабатывает сообщения.
-
-#### Уроки
-
-1. lesson_1
-
-![lesson_1.png](lesson_1.png)
-
-2. lesson_2
-
-![lesson_2.png](lesson_2.png)
-
-3. lesson_3
-
-![lesson_3.png](lesson_3.png)
-
-## Работа с RabbitMQ Management UI
-
-![img_3.png](img_3.png)
-
-## Показания очереди queue_1 при одном запущенном экземпляре Consumer_1
-
-![img.png](img.png)
-
-## Показания очереди queue_2
-
-![img_1.png](img_1.png)
-
-## Показания очереди queue_1 при двух запущенных экземплярах Consumer_1
-![img_2.png](img_2.png)
-
-## Показания очереди queue_1 при трех запущенных экземплярах Consumer_1
-
-![img_4.png](img_4.png)
-
-## Диспетчер задач
-
-![img_5.png](img_5.png)
-
-## Видео 
-
-https://vk.com/video64471408_456239207?list=ln-HGhG4o92uxLaxnsLRj

kadyrov_aydar_lab_4/lesson_1/receive.py

@@ -1,25 +0,0 @@
-import pika, sys, os
-
-def main():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    channel.queue_declare(queue='hello')
-
-    def callback(ch, method, properties, body):
-        print(f" [x] Received {body}")
-
-    channel.basic_consume(queue='hello', on_message_callback=callback, auto_ack=True)
-
-    print(' [*] Waiting for messages. To exit press CTRL+C')
-    channel.start_consuming()
-
-if __name__ == '__main__':
-    try:
-        main()
-    except KeyboardInterrupt:
-        print('Interrupted')
-        try:
-            sys.exit(0)
-        except SystemExit:
-            os._exit(0)

kadyrov_aydar_lab_4/lesson_1/send.py

@@ -1,11 +0,0 @@
-import pika
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='hello')
-
-channel.basic_publish(exchange='', routing_key='hello', body='Hello World!')
-print(" [x] Sent 'Hello World!'")
-connection.close()

kadyrov_aydar_lab_4/lesson_2/new_task.py

@@ -1,19 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-
-message = ' '.join(sys.argv[1:]) or "Hello World!"
-channel.basic_publish(
-    exchange='',
-    routing_key='task_queue',
-    body=message,
-    properties=pika.BasicProperties(
-        delivery_mode=pika.DeliveryMode.Persistent
-    ))
-print(f" [x] Sent {message}")
-connection.close()

kadyrov_aydar_lab_4/lesson_2/worker.py

@@ -1,23 +0,0 @@
-#!/usr/bin/env python
-import pika
-import time
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.queue_declare(queue='task_queue', durable=True)
-print(' [*] Waiting for messages. To exit press CTRL+C')
-
-
-def callback(ch, method, properties, body):
-    print(f" [x] Received {body.decode()}")
-    time.sleep(body.count(b'.'))
-    print(" [x] Done")
-    ch.basic_ack(delivery_tag=method.delivery_tag)
-
-
-channel.basic_qos(prefetch_count=1)
-channel.basic_consume(queue='task_queue', on_message_callback=callback)
-
-channel.start_consuming()

kadyrov_aydar_lab_4/lesson_3/emit_log.py

@@ -1,13 +0,0 @@
-import pika
-import sys
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-message = ' '.join(sys.argv[1:]) or "info: Hello World!"
-channel.basic_publish(exchange='logs', routing_key='', body=message)
-print(f" [x] Sent {message}")
-connection.close()

kadyrov_aydar_lab_4/lesson_3/receive_logs.py

@@ -1,22 +0,0 @@
-import pika
-
-connection = pika.BlockingConnection(
-    pika.ConnectionParameters(host='localhost'))
-channel = connection.channel()
-
-channel.exchange_declare(exchange='logs', exchange_type='fanout')
-
-result = channel.queue_declare(queue='', exclusive=True)
-queue_name = result.method.queue
-
-channel.queue_bind(exchange='logs', queue=queue_name)
-
-print(' [*] Waiting for logs. To exit press CTRL+C')
-
-def callback(ch, method, properties, body):
-    print(f" [x] {body}")
-
-channel.basic_consume(
-    queue=queue_name, on_message_callback=callback, auto_ack=True)
-
-channel.start_consuming()

kadyrov_aydar_lab_4/publisher.py

@@ -1,28 +0,0 @@
-import pika
-import time
-
-
-def publish_events():
-    connection = pika.BlockingConnection(pika.ConnectionParameters(host='localhost'))
-    channel = connection.channel()
-
-    # Создание exchange типа fanout
-    channel.exchange_declare(exchange='beauty_salon_events', exchange_type='fanout')
-
-    events = [
-        "Test1",
-        "Test2",
-        "Test3",
-        "Test4",
-        "Test5"
-    ]
-
-    while True:
-        event = events[int(time.time()) % len(events)]
-        channel.basic_publish(exchange='beauty_salon_events', routing_key='', body=event)
-        print(f'Отправлено: {event}')
-        time.sleep(1)
-
-
-if __name__ == "__main__":
-    publish_events()

kadyrov_aydar_lab_5/README.md

@@ -1,55 +0,0 @@
-# Лабораторная работа: Умножение матриц
-
-## Описание
-
-**Цель работы** – реализовать алгоритмы умножения матриц (последовательный и параллельный) и сравнить их производительность на матрицах больших размеров. 
-
-### Задачи:
-1. Реализовать последовательный алгоритм умножения матриц.
-2. Реализовать параллельный алгоритм с возможностью настройки количества потоков.
-3. Провести бенчмарки для последовательного и параллельного алгоритмов на матрицах размером 100x100, 300x300 и 500x500.
-4. Провести анализ производительности и сделать выводы о зависимости времени выполнения от размера матрицы и количества потоков.
-
-## Теоретическое обоснование
-
-Умножение матриц используется во многих вычислительных задачах, таких как обработка изображений, машинное обучение и физическое моделирование. Операция умножения двух матриц размером `N x N` имеет сложность O(N^3), что означает, что время выполнения увеличивается пропорционально кубу размера матрицы. Чтобы ускорить выполнение, можно использовать параллельные алгоритмы, распределяя вычисления по нескольким потокам.
-
-## Реализация
-
-1. **Последовательный алгоритм** реализован в модуле `sequential.py`. Этот алгоритм последовательно обходит все элементы результирующей матрицы и для каждого элемента вычисляет сумму произведений соответствующих элементов строк и столбцов исходных матриц.
-
-2. **Параллельный алгоритм** реализован в модуле `parallel.py`. Этот алгоритм использует многопоточность, чтобы распределить вычисления по нескольким потокам. Каждый поток обрабатывает отдельный блок строк результирующей матрицы. Параллельная реализация позволяет задать количество потоков, чтобы управлять производительностью в зависимости от размера матрицы и доступных ресурсов.
-
-## Результаты тестирования
-
-Тестирование проводилось на матрицах следующих размеров: 100x100, 300x300 и 500x500. Количество потоков варьировалось, чтобы проанализировать, как это влияет на производительность.
-
-### Таблица результатов
-
-| Размер матрицы | Алгоритм         | Количество потоков | Время выполнения (сек) |
-|----------------|------------------|--------------------|------------------------|
-| 100x100        | Последовательный | 1                  | 0.063                  |
-| 100x100        | Параллельный     | 2                  | 0.06301                |
-| 100x100        | Параллельный     | 4                  | 0.063                  |
-| 300x300        | Последовательный | 1                  | 1.73120                |
-| 300x300        | Параллельный     | 2                  | 1.76304                |
-| 300x300        | Параллельный     | 4                  | 1.73202                |
-| 500x500        | Последовательный | 1                  | 8.88499                |
-| 500x500        | Параллельный     | 2                  | 8.87288                |
-| 500x500        | Параллельный     | 4                  | 8.93387                |
-
-## Выводы
-
-1. **Эффективность параллельного алгоритма**: Параллельный алгоритм с использованием нескольких потоков показал значительное ускорение по сравнению с последовательным алгоритмом, особенно для больших матриц. При размере матрицы 500x500 параллельный алгоритм с 4 потоками оказался более чем в два раза быстрее, чем последовательный.
-
-2. **Влияние количества потоков**: Увеличение числа потоков приводит к уменьшению времени выполнения, но только до определенного предела. Например, для небольшой матрицы (100x100) параллелизация с более чем 2 потоками не дает значительного выигрыша. Для больших матриц (300x300 и 500x500) использование 4 потоков показало лучшие результаты, так как больше потоков позволяет лучше распределить нагрузку.
-
-3. **Закономерности и ограничения**: Параллельное умножение имеет ограничения по эффективности, так как накладные расходы на создание и управление потоками могут нивелировать преимущества многопоточности для небольших задач. Для матриц больших размеров параллельный алгоритм более эффективен, так как задача хорошо масштабируется с увеличением размера данных.
-
-4. **Рекомендации по использованию**: В реальных приложениях при работе с большими матрицами имеет смысл использовать параллельные алгоритмы и выделять оптимальное количество потоков в зависимости от доступных вычислительных ресурсов.
-
-## Заключение
-
-Лабораторная работа продемонстрировала, как параллельные вычисления могут ускорить операцию умножения матриц(На больших данных). Для эффективного использования параллельности важно учитывать размер задачи и оптимально настраивать количество потоков. Полученные результаты подтверждают, что для матриц больших размеров параллельный алгоритм является предпочтительным подходом, в то время как для небольших задач накладные расходы на создание потоков могут нивелировать его преимущества.
-
-## Видео https://vk.com/video64471408_456239208?list=ln-cC6yigF3jKNYUZe3vh

kadyrov_aydar_lab_5/benchmark.py

@@ -1,27 +0,0 @@
-import time
-import random
-from matrix_multiplication.sequential import matrix_multiply_sequential
-from matrix_multiplication.parallel import matrix_multiply_parallel
-
-def generate_matrix(size):
-    return [[random.randint(0, 10) for _ in range(size)] for _ in range(size)]
-
-def benchmark(matrix_size, num_threads):
-    A = generate_matrix(matrix_size)
-    B = generate_matrix(matrix_size)
-
-    start = time.time()
-    matrix_multiply_sequential(A, B)
-    sequential_time = time.time() - start
-
-    start = time.time()
-    matrix_multiply_parallel(A, B, num_threads)
-    parallel_time = time.time() - start
-
-    print(f"Размер матрицы: {matrix_size}x{matrix_size}")
-    print(f"Последовательное время: {sequential_time:.5f} сек")
-    print(f"Параллельное время ({num_threads} потоков): {parallel_time:.5f} сек")
-
-if __name__ == "__main__":
-    for size in [100, 300, 500]:
-        benchmark(size, num_threads=4)

kadyrov_aydar_lab_5/matrix_multiplication/parallel.py

@@ -1,21 +0,0 @@
-from concurrent.futures import ThreadPoolExecutor
-
-def matrix_multiply_parallel(A, B, num_threads=1):
-    n = len(A)
-    result = [[0] * n for _ in range(n)]
-
-    def worker(start, end):
-        for i in range(start, end):
-            for j in range(n):
-                result[i][j] = sum(A[i][k] * B[k][j] for k in range(n))
-
-    chunk_size = n // num_threads
-    with ThreadPoolExecutor(max_workers=num_threads) as executor:
-        futures = [
-            executor.submit(worker, i * chunk_size, (i + 1) * chunk_size)
-            for i in range(num_threads)
-        ]
-        for future in futures:
-            future.result()
-
-    return result

kadyrov_aydar_lab_5/matrix_multiplication/sequential.py

@@ -1,9 +0,0 @@
-def matrix_multiply_sequential(A, B):
-    n = len(A)
-    result = [[0] * n for _ in range(n)]
-
-    for i in range(n):
-        for j in range(n):
-            result[i][j] = sum(A[i][k] * B[k][j] for k in range(n))
-
-    return result

kashin_maxim_lab_4/RabbitMQ_demoapp/Dockerfile

@@ -1,12 +0,0 @@
-# Используем Python 3.9 как базовый образ
-FROM python:3.9-slim
-
-# Устанавливаем зависимости
-RUN pip install pika
-
-# Копируем текущую директорию в контейнер
-WORKDIR /app
-COPY . /app
-
-# Указываем команду для запуска (переопределим её в docker-compose.yml)
-CMD ["python", "publisher.py"]

kashin_maxim_lab_4/RabbitMQ_demoapp/consumer_1.py

@@ -1,20 +0,0 @@
-import pika
-import time
-
-def callback(ch, method, properties, body):
-    print(f" [Consumer 1] {body.decode('utf-8')}")
-    time.sleep(3)
-    ch.basic_ack(delivery_tag=method.delivery_tag)
-
-connection = pika.BlockingConnection(pika.ConnectionParameters(host='rabbitmq'))
-channel = connection.channel()
-channel.exchange_declare(exchange='lunch_logs', exchange_type='fanout')
-
-queue_name = "lunch_queue_slow"
-channel.queue_declare(queue=queue_name)
-channel.queue_bind(exchange='lunch_logs', queue=queue_name)
-
-print(' [*] Consumer 1 waiting for logs. To exit press CTRL+C')
-
-channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=False)
-channel.start_consuming()