поправили readme

.gitignore

@@ -7,3 +7,29 @@
 /dozorova_alena_lab_2/ConsoleApp2/.vs
 /dozorova_alena_lab_2/ConsoleApp2/bin
 /dozorova_alena_lab_2/ConsoleApp2/obj
+/dozorova_alena_lab_3/PostService/.vs
+/dozorova_alena_lab_3/WorkerService/.vs
+/dozorova_alena_lab_4/Receive/bin
+/dozorova_alena_lab_4/Receive/obj
+/dozorova_alena_lab_4/Send/bin
+/dozorova_alena_lab_4/Send/obj
+/dozorova_alena_lab_4/EmitLog/.vs
+/dozorova_alena_lab_4/EmitLog/obj
+/dozorova_alena_lab_4/NewTask/.vs
+/dozorova_alena_lab_4/NewTask/bin
+/dozorova_alena_lab_4/NewTask/obj
+/dozorova_alena_lab_4/ReceiveLogs/obj
+/dozorova_alena_lab_4/Worker/.vs
+/dozorova_alena_lab_4/Worker/bin
+/dozorova_alena_lab_4/Worker/obj
+/dozorova_alena_lab_4/EmitLog/bin
+/dozorova_alena_lab_4/ReceiveLogs/.vs
+/dozorova_alena_lab_4/ReceiveLogs/bin
+/dozorova_alena_lab_4/ConsumerDelay/.vs
+/dozorova_alena_lab_4/ConsumerDelay/obj
+/dozorova_alena_lab_4/ConsumerDelay/Properties
+/dozorova_alena_lab_4/ConsumerSimple/.vs
+/dozorova_alena_lab_4/ConsumerSimple/obj
+/dozorova_alena_lab_4/Publisher/.vs
+/dozorova_alena_lab_4/Publisher/bin
+/dozorova_alena_lab_4/Publisher/obj

dozorova_alena_lab_4/ConsumerDelay/.dockerignore

@@ -1,30 +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
+**/.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/**

dozorova_alena_lab_4/ConsumerDelay/ConsumerDelay.csproj

@@ -1,19 +1,17 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.6" />
-  </ItemGroup>
-
-  <!-- <ItemGroup>
-    <ProjectReference Include="..\FileGeneration\FileGeneration.csproj" />
-  </ItemGroup> -->
-
-</Project>
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+    <DockerfileContext>.</DockerfileContext>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.20.1" />
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/ConsumerDelay/ConsumerDelay.csproj.user

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

dozorova_alena_lab_4/ConsumerDelay/ConsumerDelay.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.10.35004.147
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsumerDelay", "ConsumerDelay.csproj", "{4DD86D5F-D90D-4BBB-AAA4-F16DA855B51E}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{4DD86D5F-D90D-4BBB-AAA4-F16DA855B51E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{4DD86D5F-D90D-4BBB-AAA4-F16DA855B51E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{4DD86D5F-D90D-4BBB-AAA4-F16DA855B51E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{4DD86D5F-D90D-4BBB-AAA4-F16DA855B51E}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {3E7AED20-0868-42FE-9C39-581BC9D2BB22}
+	EndGlobalSection
+EndGlobal

dozorova_alena_lab_4/ConsumerDelay/Dockerfile

@@ -0,0 +1,22 @@
+#See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
+
+FROM mcr.microsoft.com/dotnet/runtime:6.0 AS base
+WORKDIR /app
+
+FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["ConsumerDelay.csproj", "."]
+RUN dotnet restore "./ConsumerDelay.csproj"
+COPY . .
+WORKDIR "/src/."
+RUN dotnet build "./ConsumerDelay.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./ConsumerDelay.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "ConsumerDelay.dll"]

dozorova_alena_lab_4/ConsumerDelay/Program.cs

@@ -0,0 +1,24 @@
+using ConsumerDelay;
+
+var rabbitHost = Environment.GetEnvironmentVariable("RABBIT_HOST") ?? "localhost";
+var rabbitUsername = Environment.GetEnvironmentVariable("RABBIT_USERNAME") ?? "user";
+var rabbitPassword = Environment.GetEnvironmentVariable("RABBIT_PASSWORD") ?? "password";
+var rabbitExchange = Environment.GetEnvironmentVariable("RABBIT_EXCHANGE") ?? "ReportIn";
+var rabbitQueue = Environment.GetEnvironmentVariable("RABBIT_QUEUE") ?? "Second";
+
+Thread.Sleep(2000);
+
+var receiver = new Receiver(rabbitHost, rabbitUsername, rabbitPassword);
+
+receiver.SubscribeTo(rabbitExchange, (message) =>
+{
+    var rnd = new Random();
+
+    Console.WriteLine($"Пришло сообщение: {message}");
+
+    Thread.Sleep(rnd.Next(2000, 3000));
+    Console.WriteLine($"Обработка сообщения завершена");
+},
+rabbitQueue);
+
+while (true) ;

dozorova_alena_lab_4/ConsumerDelay/Receiver.cs

@@ -0,0 +1,82 @@
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+using System.Text;
+
+namespace ConsumerDelay
+{
+    public class Receiver : IDisposable
+    {
+        private readonly ConnectionFactory _connectionFactory;
+        private readonly IConnection _connection;
+        private readonly IModel _channel;
+
+        public Dictionary<string, HashSet<string>> Queues { get; private set; } = new();
+
+        public Receiver(string brockerHost, string brockerUsername, string brockerPassword)
+        {
+            _connectionFactory = new ConnectionFactory() { HostName = brockerHost, UserName = brockerUsername, Password = brockerPassword };
+            _connection = _connectionFactory.CreateConnection();
+            _channel = _connection.CreateModel();
+        }
+
+        public bool SubscribeTo(string exchange, Action<string> handler, string? queueName = null)
+        {
+            try
+            {
+                if (!Queues.ContainsKey(exchange))
+                {
+                    _channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
+                    Queues.Add(exchange, new HashSet<string>());
+                }
+                if (queueName != null)
+                    _channel.QueueDeclare(queue: queueName,
+                        durable: true,
+                        exclusive: false,
+                        autoDelete: false,
+                        arguments: null);
+
+                queueName = queueName ?? _channel.QueueDeclare().QueueName;
+
+
+                _channel.QueueBind(queue: queueName,
+                    exchange: exchange,
+                    routingKey: string.Empty);
+
+                var consumer = new EventingBasicConsumer(_channel);
+                consumer.Received += (model, ea) =>
+                {
+                    try
+                    {
+                        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
+                        handler(message);
+                        _channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine(ex.Message);
+                    }
+
+                };
+                _channel.BasicConsume(queue: queueName,
+                                     autoAck: false,
+                                     consumer: consumer);
+
+                Queues[exchange].Add(queueName);
+                return true;
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+            }
+            return false;
+        }
+
+        ~Receiver() => Dispose();
+
+        public void Dispose()
+        {
+            _connection.Dispose();
+            _channel.Dispose();
+        }
+    }
+}

dozorova_alena_lab_4/ConsumerSimple/.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/**

dozorova_alena_lab_4/ConsumerSimple/ConsumerSimple.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+    <DockerfileContext>.</DockerfileContext>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.20.1" />
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/ConsumerSimple/ConsumerSimple.csproj.user

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

dozorova_alena_lab_4/ConsumerSimple/ConsumerSimple.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.10.35004.147
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "ConsumerSimple", "ConsumerSimple.csproj", "{ACA8DE52-E29E-41BA-B3DA-213AF316685E}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{ACA8DE52-E29E-41BA-B3DA-213AF316685E}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{ACA8DE52-E29E-41BA-B3DA-213AF316685E}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{ACA8DE52-E29E-41BA-B3DA-213AF316685E}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{ACA8DE52-E29E-41BA-B3DA-213AF316685E}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {73265D6C-436C-470E-AE8A-17047E6C2ECC}
+	EndGlobalSection
+EndGlobal

dozorova_alena_lab_4/ConsumerSimple/Dockerfile

@@ -0,0 +1,22 @@
+#See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
+
+FROM mcr.microsoft.com/dotnet/runtime:6.0 AS base
+WORKDIR /app
+
+FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["ConsumerSimple.csproj", "."]
+RUN dotnet restore "./ConsumerSimple.csproj"
+COPY . .
+WORKDIR "/src/."
+RUN dotnet build "./ConsumerSimple.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./ConsumerSimple.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "ConsumerSimple.dll"]

dozorova_alena_lab_4/ConsumerSimple/Program.cs

@@ -0,0 +1,23 @@
+using ConsumerSimple;
+
+var rabbitHost = Environment.GetEnvironmentVariable("RABBIT_HOST") ?? "localhost";
+var rabbitUsername = Environment.GetEnvironmentVariable("RABBIT_USERNAME") ?? "user";
+var rabbitPassword = Environment.GetEnvironmentVariable("RABBIT_PASSWORD") ?? "password";
+var rabbitExchange = Environment.GetEnvironmentVariable("RABBIT_EXCHANGE") ?? "ReportIn";
+var rabbitQueue = Environment.GetEnvironmentVariable("RABBIT_QUEUE") ?? "First";
+
+Thread.Sleep(2000);
+
+var receiver = new Receiver(rabbitHost, rabbitUsername, rabbitPassword);
+
+receiver.SubscribeTo(rabbitExchange, (message) =>
+{
+    var rnd = new Random();
+
+    Console.WriteLine($"Пришло сообщение: {message}");
+
+    Console.WriteLine($"Сообщение обрабатывается мгновенно");
+},
+rabbitQueue);
+
+while (true) ;

dozorova_alena_lab_4/ConsumerSimple/Properties/launchSettings.json

@@ -1,10 +1,10 @@
-{
-  "profiles": {
-    "App2": {
-      "commandName": "Project"
-    },
-    "Container (Dockerfile)": {
-      "commandName": "Docker"
-    }
-  }
+{
+  "profiles": {
+    "ConsumerSimple": {
+      "commandName": "Project"
+    },
+    "Container (Dockerfile)": {
+      "commandName": "Docker"
+    }
+  }
 }

dozorova_alena_lab_4/ConsumerSimple/Receiver.cs

@@ -0,0 +1,82 @@
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+using System.Text;
+
+namespace ConsumerSimple
+{
+    public class Receiver : IDisposable
+    {
+        private readonly ConnectionFactory _connectionFactory;
+        private readonly IConnection _connection;
+        private readonly IModel _channel;
+
+        public Dictionary<string, HashSet<string>> Queues { get; private set; } = new();
+
+        public Receiver(string brockerHost, string brockerUsername, string brockerPassword)
+        {
+            _connectionFactory = new ConnectionFactory() { HostName = brockerHost, UserName = brockerUsername, Password = brockerPassword };
+            _connection = _connectionFactory.CreateConnection();
+            _channel = _connection.CreateModel();
+        }
+
+        public bool SubscribeTo(string exchange, Action<string> handler, string? queueName = null)
+        {
+            try
+            {
+                if (!Queues.ContainsKey(exchange))
+                {
+                    _channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
+                    Queues.Add(exchange, new HashSet<string>());
+                }
+                if (queueName != null)
+                    _channel.QueueDeclare(queue: queueName,
+                        durable: true,
+                        exclusive: false,
+                        autoDelete: false,
+                        arguments: null);
+
+                queueName = queueName ?? _channel.QueueDeclare().QueueName;
+
+
+                _channel.QueueBind(queue: queueName,
+                    exchange: exchange,
+                    routingKey: string.Empty);
+
+                var consumer = new EventingBasicConsumer(_channel);
+                consumer.Received += (model, ea) =>
+                {
+                    try
+                    {
+                        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
+                        handler(message);
+                        _channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
+                    }
+                    catch (Exception ex)
+                    {
+                        Console.WriteLine(ex.Message);
+                    }
+
+                };
+                _channel.BasicConsume(queue: queueName,
+                                     autoAck: false,
+                                     consumer: consumer);
+
+                Queues[exchange].Add(queueName);
+                return true;
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+            }
+            return false;
+        }
+
+        ~Receiver() => Dispose();
+
+        public void Dispose()
+        {
+            _connection.Dispose();
+            _channel.Dispose();
+        }
+    }
+}

dozorova_alena_lab_4/EmitLog/EmitLog..csproj

@@ -1,15 +1,15 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.6" />
-  </ItemGroup>
-
-</Project>
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <RootNamespace>EmitLog_</RootNamespace>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/EmitLog/Program.cs

@@ -0,0 +1,24 @@
+using System.Text;
+using RabbitMQ.Client;
+
+var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = factory.CreateConnection();
+using var channel = connection.CreateModel();
+
+channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
+
+var message = GetMessage(args);
+var body = Encoding.UTF8.GetBytes(message);
+channel.BasicPublish(exchange: "logs",
+                     routingKey: string.Empty,
+                     basicProperties: null,
+                     body: body);
+Console.WriteLine($" [x] Sent {message}");
+
+Console.WriteLine(" Press [enter] to exit.");
+Console.ReadLine();
+
+static string GetMessage(string[] args)
+{
+    return ((args.Length > 0) ? string.Join(" ", args) : "info: Hello World!");
+}

dozorova_alena_lab_4/NewTask/NewTask.csproj

@@ -1,15 +1,14 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <PropertyGroup>
-    <OutputType>Exe</OutputType>
-    <TargetFramework>net8.0</TargetFramework>
-    <ImplicitUsings>enable</ImplicitUsings>
-    <Nullable>enable</Nullable>
-    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
-  </PropertyGroup>
-
-  <ItemGroup>
-    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.19.6" />
-  </ItemGroup>
-
-</Project>
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/NewTask/Program.cs

@@ -0,0 +1,32 @@
+using System.Text;
+using RabbitMQ.Client;
+
+var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = factory.CreateConnection();
+using var channel = connection.CreateModel();
+
+channel.QueueDeclare(queue: "task_queue",
+                     durable: true,
+                     exclusive: false,
+                     autoDelete: false,
+                     arguments: null);
+
+var message = GetMessage(args);
+var body = Encoding.UTF8.GetBytes(message);
+
+var properties = channel.CreateBasicProperties();
+properties.Persistent = true;
+
+channel.BasicPublish(exchange: string.Empty,
+                     routingKey: "task_queue",
+                     basicProperties: properties,
+                     body: body);
+Console.WriteLine($" [x] Sent {message}");
+
+Console.WriteLine(" Press [enter] to exit.");
+Console.ReadLine();
+
+static string GetMessage(string[] args)
+{
+    return ((args.Length > 0) ? string.Join(" ", args) : "Hello World!");
+}

dozorova_alena_lab_4/Publisher/.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/**

dozorova_alena_lab_4/Publisher/Dockerfile

@@ -0,0 +1,20 @@
+FROM mcr.microsoft.com/dotnet/runtime:6.0 AS base
+WORKDIR /app
+
+FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build
+ARG BUILD_CONFIGURATION=Release
+WORKDIR /src
+COPY ["Publisher.csproj", "."]
+RUN dotnet restore "./Publisher.csproj"
+COPY . .
+WORKDIR "/src/."
+RUN dotnet build "./Publisher.csproj" -c $BUILD_CONFIGURATION -o /app/build
+
+FROM build AS publish
+ARG BUILD_CONFIGURATION=Release
+RUN dotnet publish "./Publisher.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
+
+FROM base AS final
+WORKDIR /app
+COPY --from=publish /app/publish .
+ENTRYPOINT ["dotnet", "Publisher.dll"]

dozorova_alena_lab_4/Publisher/Program.cs

@@ -0,0 +1,40 @@
+using Publisher;
+using System.Text;
+
+var rabbitHost = Environment.GetEnvironmentVariable("RABBIT_HOST") ?? "localhost";
+var rabbitUsername = Environment.GetEnvironmentVariable("RABBIT_USERNAME") ?? "user";
+var rabbitPassword = Environment.GetEnvironmentVariable("RABBIT_PASSWORD") ?? "password";
+var rabbitExchange = Environment.GetEnvironmentVariable("RABBIT_EXCHANGE") ?? "ReportIn";
+
+var sender = new Sender(rabbitHost, rabbitUsername, rabbitPassword);
+
+sender.AddExcange(rabbitExchange);
+
+var rnd = new Random();
+
+while (true)
+{
+    StringBuilder sb = new();
+
+    var type = rnd.Next();
+    switch (type%2)
+    {
+        case 0:
+            {
+                sb.Append($"Был запрошен отчет о данных под номером {rnd.Next(1000)}");
+                break;
+            }
+        case 1:
+            {
+                sb.Append($"Был запрошен отчет об ошибках под номером {rnd.Next(1000)}");
+                break;
+            }
+    }
+
+    var text = sb.ToString();
+    Console.WriteLine($"Было опубликовано сообщение: {text}");
+    sender.PublishToExchange(rabbitExchange, text);
+
+    await Task.Delay(1000);
+}
+

dozorova_alena_lab_4/Publisher/Properties/launchSettings.json

@@ -1,10 +1,10 @@
-{
-  "profiles": {
-    "App1": {
-      "commandName": "Project"
-    },
-    "Container (Dockerfile)": {
-      "commandName": "Docker"
-    }
-  }
+{
+  "profiles": {
+    "Publisher": {
+      "commandName": "Project"
+    },
+    "Container (Dockerfile)": {
+      "commandName": "Docker"
+    }
+  }
 }

dozorova_alena_lab_4/Publisher/Publisher.csproj

@@ -0,0 +1,17 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
+    <DockerfileContext>.</DockerfileContext>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.VisualStudio.Azure.Containers.Tools.Targets" Version="1.20.1" />
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/Publisher/Publisher.csproj.user

@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="utf-8"?>
+<Project ToolsVersion="Current" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <PropertyGroup>
+    <ActiveDebugProfile>Container (Dockerfile)</ActiveDebugProfile>
+  </PropertyGroup>
+  <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
+    <DebuggerFlavor>ProjectDebugger</DebuggerFlavor>
+  </PropertyGroup>
+</Project>

dozorova_alena_lab_4/Publisher/Publisher.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.10.35004.147
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Publisher", "Publisher.csproj", "{C23890FA-A4DD-4E5B-897F-37210C2F60CE}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{C23890FA-A4DD-4E5B-897F-37210C2F60CE}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{C23890FA-A4DD-4E5B-897F-37210C2F60CE}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{C23890FA-A4DD-4E5B-897F-37210C2F60CE}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{C23890FA-A4DD-4E5B-897F-37210C2F60CE}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {3BB20EB3-DE49-46CE-8C7A-D956E3DE90BC}
+	EndGlobalSection
+EndGlobal

dozorova_alena_lab_4/Publisher/Sender.cs

@@ -0,0 +1,69 @@
+using RabbitMQ.Client;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Publisher
+{
+    public class Sender : IDisposable
+    {
+        private readonly ConnectionFactory _connectionFactory;
+        private readonly IConnection _connection;
+        private readonly IModel _channel;
+
+        public HashSet<string> Exchanges { get; private set; } = new HashSet<string>();
+
+        public Sender(string brockerHost, string brockerUsername, string brockerPassword)
+        {
+            _connectionFactory = new ConnectionFactory() { HostName = brockerHost, UserName = brockerUsername, Password = brockerPassword };
+            _connection = _connectionFactory.CreateConnection();
+            _channel = _connection.CreateModel();
+        }
+
+        public bool AddExcange(string exchange, string exchangeType = ExchangeType.Fanout)
+        {
+            try
+            {
+                _channel.ExchangeDeclare(exchange, exchangeType);
+                Exchanges.Add(exchange);
+                return true;
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+            }
+            return false;
+        }
+
+        public bool PublishToExchange(string exchange, string message)
+        {
+            try
+            {
+                if (!Exchanges.Contains(exchange))
+                    return false;
+
+                var messageBody = Encoding.UTF8.GetBytes(message);
+                _channel.BasicPublish(exchange: exchange,
+                                     routingKey: string.Empty,
+                                     basicProperties: null,
+                                     body: messageBody);
+                return true;
+            }
+            catch (Exception ex)
+            {
+                Console.WriteLine(ex.Message);
+            }
+            return false;
+        }
+
+        ~Sender() => Dispose();
+
+        public void Dispose()
+        {
+            _connection.Dispose();
+            _channel.Dispose();
+        }
+    }
+}

dozorova_alena_lab_4/README.md

@@ -0,0 +1,39 @@
+# Лабораторная работа 4
+В рамках данной работы были реализованы несколько проектов, работающих с RabbitMQ.
+## tutorial
+Для каждого урока были созданы консольные проекты 
+### "Hello World!"
+![Task 1](image-4.png)
+### Work Queues
+![Task 2](image-5.png)
+### Publish/Subscribe
+![Task 3](image-6.png)
+## Описание
+В качестве предметной области была выбрана система запросов отчета двух видов: отчета и ошибок.  
+## Запуск
+Для запуска лабораторной работы необходимо иметь запущенный Docker на устройстве.
+Необходимо перейти в папку, где располагается данный файл. Далее открыть терминал и ввести команду:
+```
+docker compose up -d --build
+```
+Порты для RabbitMQ были 8081 (для UI) и 5672.
+## Анализ
+Первоначальный вариант запуска предполагает, что имеется всего 2 потребителя:
+ 1. Тратит на обработку сообщения 2-3 секунды
+ 2. Тратит на обработку сообщения крайне малое время
+Задержка при обработке понижает пропускную способность обработчика, что вызывает переполнение очереди. Это подтверждается скринами.
+<br/>
+![alt text](image.png)
+<br/>
+![alt text](image-1.png)
+<br/>
+Теперь запустим несколько обычных обработчиков. Очередь не переполнена постоянно, а периодически, соответственно обработчики вполне справляются с потоком сообщений и увеличение их количества позволит в принципе избавиться от переполнения 
+<br/>
+![alt text](image-2.png)
+<br/>
+![alt text](image-3.png)
+
+## Видеодемонстрация
+Демонстрация: (https://drive.google.com/file/d/16gJMGbMKSFZ_I5gCzuDekpAqUrhbpFRA/view?usp=sharing) Стоит обратить внимание на то, что настройки docker compose файла не гарантируют верный порядок подъема контейнеров, из-за чего некоторые контейнеры пришлось перезапустить.
+
+

dozorova_alena_lab_4/Receive/Program.cs

@@ -0,0 +1,29 @@
+using System.Text;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+
+var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = factory.CreateConnection();
+using var channel = connection.CreateModel();
+
+channel.QueueDeclare(queue: "hello",
+                     durable: false,
+                     exclusive: false,
+                     autoDelete: false,
+                     arguments: null);
+
+Console.WriteLine(" [*] Waiting for messages.");
+
+var consumer = new EventingBasicConsumer(channel);
+consumer.Received += (model, ea) =>
+{
+    var body = ea.Body.ToArray();
+    var message = Encoding.UTF8.GetString(body);
+    Console.WriteLine($" [x] Received {message}");
+};
+channel.BasicConsume(queue: "hello",
+                     autoAck: true,
+                     consumer: consumer);
+
+Console.WriteLine(" Press [enter] to exit.");
+Console.ReadLine();

dozorova_alena_lab_4/Receive/Receive.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/ReceiveLogs/Program.cs

@@ -0,0 +1,31 @@
+using System.Text;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+
+var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = factory.CreateConnection();
+using var channel = connection.CreateModel();
+
+channel.ExchangeDeclare(exchange: "logs", type: ExchangeType.Fanout);
+
+// declare a server-named queue
+var queueName = channel.QueueDeclare().QueueName;
+channel.QueueBind(queue: queueName,
+                  exchange: "logs",
+                  routingKey: string.Empty);
+
+Console.WriteLine(" [*] Waiting for logs.");
+
+var consumer = new EventingBasicConsumer(channel);
+consumer.Received += (model, ea) =>
+{
+    byte[] body = ea.Body.ToArray();
+    var message = Encoding.UTF8.GetString(body);
+    Console.WriteLine($" [x] {message}");
+};
+channel.BasicConsume(queue: queueName,
+                     autoAck: true,
+                     consumer: consumer);
+
+Console.WriteLine(" Press [enter] to exit.");
+Console.ReadLine();

dozorova_alena_lab_4/ReceiveLogs/ReceiveLogs.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/Send/Program.cs

@@ -0,0 +1,24 @@
+using System.Text;
+using RabbitMQ.Client;
+
+var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = factory.CreateConnection();
+using var channel = connection.CreateModel();
+
+channel.QueueDeclare(queue: "hello",
+                     durable: false,
+                     exclusive: false,
+                     autoDelete: false,
+                     arguments: null);
+
+const string message = "Hello World!";
+var body = Encoding.UTF8.GetBytes(message);
+
+channel.BasicPublish(exchange: string.Empty,
+                     routingKey: "hello",
+                     basicProperties: null,
+                     body: body);
+Console.WriteLine($" [x] Sent {message}");
+
+Console.WriteLine(" Press [enter] to exit.");
+Console.ReadLine();

dozorova_alena_lab_4/Send/Send.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/Worker/Program.cs

@@ -0,0 +1,39 @@
+using System.Text;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+
+var factory = new ConnectionFactory { HostName = "localhost" };
+using var connection = factory.CreateConnection();
+using var channel = connection.CreateModel();
+
+channel.QueueDeclare(queue: "task_queue",
+                     durable: true,
+                     exclusive: false,
+                     autoDelete: false,
+                     arguments: null);
+
+channel.BasicQos(prefetchSize: 0, prefetchCount: 1, global: false);
+
+Console.WriteLine(" [*] Waiting for messages.");
+
+var consumer = new EventingBasicConsumer(channel);
+consumer.Received += (model, ea) =>
+{
+    byte[] body = ea.Body.ToArray();
+    var message = Encoding.UTF8.GetString(body);
+    Console.WriteLine($" [x] Received {message}");
+
+    int dots = message.Split('.').Length - 1;
+    Thread.Sleep(dots * 1000);
+
+    Console.WriteLine(" [x] Done");
+
+    // here channel could also be accessed as ((EventingBasicConsumer)sender).Model
+    channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
+};
+channel.BasicConsume(queue: "task_queue",
+                     autoAck: false,
+                     consumer: consumer);
+
+Console.WriteLine(" Press [enter] to exit.");
+Console.ReadLine();

dozorova_alena_lab_4/Worker/Worker.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
+  </ItemGroup>
+
+</Project>

dozorova_alena_lab_4/docker-compose.yaml

@@ -0,0 +1,59 @@
+services:
+  rabbit:                                       
+    image: rabbitmq:3.10.7-management             
+    restart: always     
+    ports:  
+      - 5672:5672                               
+      - 8081:15672                              
+    environment:
+      RABBITMQ_DEFAULT_USER: admin 
+      RABBITMQ_DEFAULT_PASS: admin
+  
+  publisher:
+    build: ./Publisher/
+    restart: always
+    depends_on:
+      - rabbit
+    environment:
+      RABBIT_HOST: rabbit
+      RABBIT_USERNAME: admin
+      RABBIT_PASSWORD: admin
+      RABBIT_EXCHANGE: 'ReportIn'
+
+  concumer1:
+    build: ./ConsumerSimple/
+    restart: always
+    depends_on:
+      - rabbit
+      - publisher
+    environment:
+      RABBIT_HOST: rabbit
+      RABBIT_USERNAME: admin
+      RABBIT_PASSWORD: admin
+      RABBIT_EXCHANGE: 'ReportIn'
+      RABBIT_QUEUE: 'First'
+
+  concumer2:
+    build: ./ConsumerSimple/
+    restart: always
+    depends_on:
+      - rabbit
+      - publisher
+    environment:
+      RABBIT_HOST: rabbit
+      RABBIT_USERNAME: admin
+      RABBIT_PASSWORD: admin
+      RABBIT_EXCHANGE: 'ReportIn'
+      RABBIT_QUEUE: 'Second'
+  # concumer2:
+  #   build: ./ConsumerDelay/
+  #   restart: always
+  #   depends_on:
+  #     - rabbit
+  #     - publisher
+  #   environment:
+  #     RABBIT_HOST: rabbit
+  #     RABBIT_USERNAME: admin
+  #     RABBIT_PASSWORD: admin
+  #     RABBIT_EXCHANGE: 'ReportIn'
+  #     RABBIT_QUEUE: 'Second'

yakovleva_yulia_lab_2/.gitignore

@@ -1,484 +0,0 @@
-## Ignore Visual Studio temporary files, build results, and
-## files generated by popular Visual Studio add-ons.
-##
-## Get latest from `dotnet new gitignore`
-
-# dotenv files
-.env
-
-# User-specific files
-*.rsuser
-*.suo
-*.user
-*.userosscache
-*.sln.docstates
-
-# User-specific files (MonoDevelop/Xamarin Studio)
-*.userprefs
-
-# Mono auto generated files
-mono_crash.*
-
-# Build results
-[Dd]ebug/
-[Dd]ebugPublic/
-[Rr]elease/
-[Rr]eleases/
-x64/
-x86/
-[Ww][Ii][Nn]32/
-[Aa][Rr][Mm]/
-[Aa][Rr][Mm]64/
-bld/
-[Bb]in/
-[Oo]bj/
-[Ll]og/
-[Ll]ogs/
-
-# Visual Studio 2015/2017 cache/options directory
-.vs/
-# Uncomment if you have tasks that create the project's static files in wwwroot
-#wwwroot/
-
-# Visual Studio 2017 auto generated files
-Generated\ Files/
-
-# MSTest test Results
-[Tt]est[Rr]esult*/
-[Bb]uild[Ll]og.*
-
-# NUnit
-*.VisualState.xml
-TestResult.xml
-nunit-*.xml
-
-# Build Results of an ATL Project
-[Dd]ebugPS/
-[Rr]eleasePS/
-dlldata.c
-
-# Benchmark Results
-BenchmarkDotNet.Artifacts/
-
-# .NET
-project.lock.json
-project.fragment.lock.json
-artifacts/
-
-# Tye
-.tye/
-
-# ASP.NET Scaffolding
-ScaffoldingReadMe.txt
-
-# StyleCop
-StyleCopReport.xml
-
-# Files built by Visual Studio
-*_i.c
-*_p.c
-*_h.h
-*.ilk
-*.meta
-*.obj
-*.iobj
-*.pch
-*.pdb
-*.ipdb
-*.pgc
-*.pgd
-*.rsp
-*.sbr
-*.tlb
-*.tli
-*.tlh
-*.tmp
-*.tmp_proj
-*_wpftmp.csproj
-*.log
-*.tlog
-*.vspscc
-*.vssscc
-.builds
-*.pidb
-*.svclog
-*.scc
-
-# Chutzpah Test files
-_Chutzpah*
-
-# Visual C++ cache files
-ipch/
-*.aps
-*.ncb
-*.opendb
-*.opensdf
-*.sdf
-*.cachefile
-*.VC.db
-*.VC.VC.opendb
-
-# Visual Studio profiler
-*.psess
-*.vsp
-*.vspx
-*.sap
-
-# Visual Studio Trace Files
-*.e2e
-
-# TFS 2012 Local Workspace
-$tf/
-
-# Guidance Automation Toolkit
-*.gpState
-
-# ReSharper is a .NET coding add-in
-_ReSharper*/
-*.[Rr]e[Ss]harper
-*.DotSettings.user
-
-# TeamCity is a build add-in
-_TeamCity*
-
-# DotCover is a Code Coverage Tool
-*.dotCover
-
-# AxoCover is a Code Coverage Tool
-.axoCover/*
-!.axoCover/settings.json
-
-# Coverlet is a free, cross platform Code Coverage Tool
-coverage*.json
-coverage*.xml
-coverage*.info
-
-# Visual Studio code coverage results
-*.coverage
-*.coveragexml
-
-# NCrunch
-_NCrunch_*
-.*crunch*.local.xml
-nCrunchTemp_*
-
-# MightyMoose
-*.mm.*
-AutoTest.Net/
-
-# Web workbench (sass)
-.sass-cache/
-
-# Installshield output folder
-[Ee]xpress/
-
-# DocProject is a documentation generator add-in
-DocProject/buildhelp/
-DocProject/Help/*.HxT
-DocProject/Help/*.HxC
-DocProject/Help/*.hhc
-DocProject/Help/*.hhk
-DocProject/Help/*.hhp
-DocProject/Help/Html2
-DocProject/Help/html
-
-# Click-Once directory
-publish/
-
-# Publish Web Output
-*.[Pp]ublish.xml
-*.azurePubxml
-# Note: Comment the next line if you want to checkin your web deploy settings,
-# but database connection strings (with potential passwords) will be unencrypted
-*.pubxml
-*.publishproj
-
-# Microsoft Azure Web App publish settings. Comment the next line if you want to
-# checkin your Azure Web App publish settings, but sensitive information contained
-# in these scripts will be unencrypted
-PublishScripts/
-
-# NuGet Packages
-*.nupkg
-# NuGet Symbol Packages
-*.snupkg
-# The packages folder can be ignored because of Package Restore
-**/[Pp]ackages/*
-# except build/, which is used as an MSBuild target.
-!**/[Pp]ackages/build/
-# Uncomment if necessary however generally it will be regenerated when needed
-#!**/[Pp]ackages/repositories.config
-# NuGet v3's project.json files produces more ignorable files
-*.nuget.props
-*.nuget.targets
-
-# Microsoft Azure Build Output
-csx/
-*.build.csdef
-
-# Microsoft Azure Emulator
-ecf/
-rcf/
-
-# Windows Store app package directories and files
-AppPackages/
-BundleArtifacts/
-Package.StoreAssociation.xml
-_pkginfo.txt
-*.appx
-*.appxbundle
-*.appxupload
-
-# Visual Studio cache files
-# files ending in .cache can be ignored
-*.[Cc]ache
-# but keep track of directories ending in .cache
-!?*.[Cc]ache/
-
-# Others
-ClientBin/
-~$*
-*~
-*.dbmdl
-*.dbproj.schemaview
-*.jfm
-*.pfx
-*.publishsettings
-orleans.codegen.cs
-
-# Including strong name files can present a security risk
-# (https://github.com/github/gitignore/pull/2483#issue-259490424)
-#*.snk
-
-# Since there are multiple workflows, uncomment next line to ignore bower_components
-# (https://github.com/github/gitignore/pull/1529#issuecomment-104372622)
-#bower_components/
-
-# RIA/Silverlight projects
-Generated_Code/
-
-# Backup & report files from converting an old project file
-# to a newer Visual Studio version. Backup files are not needed,
-# because we have git ;-)
-_UpgradeReport_Files/
-Backup*/
-UpgradeLog*.XML
-UpgradeLog*.htm
-ServiceFabricBackup/
-*.rptproj.bak
-
-# SQL Server files
-*.mdf
-*.ldf
-*.ndf
-
-# Business Intelligence projects
-*.rdl.data
-*.bim.layout
-*.bim_*.settings
-*.rptproj.rsuser
-*- [Bb]ackup.rdl
-*- [Bb]ackup ([0-9]).rdl
-*- [Bb]ackup ([0-9][0-9]).rdl
-
-# Microsoft Fakes
-FakesAssemblies/
-
-# GhostDoc plugin setting file
-*.GhostDoc.xml
-
-# Node.js Tools for Visual Studio
-.ntvs_analysis.dat
-node_modules/
-
-# Visual Studio 6 build log
-*.plg
-
-# Visual Studio 6 workspace options file
-*.opt
-
-# Visual Studio 6 auto-generated workspace file (contains which files were open etc.)
-*.vbw
-
-# Visual Studio 6 auto-generated project file (contains which files were open etc.)
-*.vbp
-
-# Visual Studio 6 workspace and project file (working project files containing files to include in project)
-*.dsw
-*.dsp
-
-# Visual Studio 6 technical files
-*.ncb
-*.aps
-
-# Visual Studio LightSwitch build output
-**/*.HTMLClient/GeneratedArtifacts
-**/*.DesktopClient/GeneratedArtifacts
-**/*.DesktopClient/ModelManifest.xml
-**/*.Server/GeneratedArtifacts
-**/*.Server/ModelManifest.xml
-_Pvt_Extensions
-
-# Paket dependency manager
-.paket/paket.exe
-paket-files/
-
-# FAKE - F# Make
-.fake/
-
-# CodeRush personal settings
-.cr/personal
-
-# Python Tools for Visual Studio (PTVS)
-__pycache__/
-*.pyc
-
-# Cake - Uncomment if you are using it
-# tools/**
-# !tools/packages.config
-
-# Tabs Studio
-*.tss
-
-# Telerik's JustMock configuration file
-*.jmconfig
-
-# BizTalk build output
-*.btp.cs
-*.btm.cs
-*.odx.cs
-*.xsd.cs
-
-# OpenCover UI analysis results
-OpenCover/
-
-# Azure Stream Analytics local run output
-ASALocalRun/
-
-# MSBuild Binary and Structured Log
-*.binlog
-
-# NVidia Nsight GPU debugger configuration file
-*.nvuser
-
-# MFractors (Xamarin productivity tool) working folder
-.mfractor/
-
-# Local History for Visual Studio
-.localhistory/
-
-# Visual Studio History (VSHistory) files
-.vshistory/
-
-# BeatPulse healthcheck temp database
-healthchecksdb
-
-# Backup folder for Package Reference Convert tool in Visual Studio 2017
-MigrationBackup/
-
-# Ionide (cross platform F# VS Code tools) working folder
-.ionide/
-
-# Fody - auto-generated XML schema
-FodyWeavers.xsd
-
-# VS Code files for those working on multiple tools
-.vscode/*
-!.vscode/settings.json
-!.vscode/tasks.json
-!.vscode/launch.json
-!.vscode/extensions.json
-*.code-workspace
-
-# Local History for Visual Studio Code
-.history/
-
-# Windows Installer files from build outputs
-*.cab
-*.msi
-*.msix
-*.msm
-*.msp
-
-# JetBrains Rider
-*.sln.iml
-.idea
-
-##
-## Visual studio for Mac
-##
-
-
-# globs
-Makefile.in
-*.userprefs
-*.usertasks
-config.make
-config.status
-aclocal.m4
-install-sh
-autom4te.cache/
-*.tar.gz
-tarballs/
-test-results/
-
-# Mac bundle stuff
-*.dmg
-*.app
-
-# content below from: https://github.com/github/gitignore/blob/master/Global/macOS.gitignore
-# General
-.DS_Store
-.AppleDouble
-.LSOverride
-
-# Icon must end with two \r
-Icon
-
-
-# Thumbnails
-._*
-
-# Files that might appear in the root of a volume
-.DocumentRevisions-V100
-.fseventsd
-.Spotlight-V100
-.TemporaryItems
-.Trashes
-.VolumeIcon.icns
-.com.apple.timemachine.donotpresent
-
-# Directories potentially created on remote AFP share
-.AppleDB
-.AppleDesktop
-Network Trash Folder
-Temporary Items
-.apdisk
-
-# content below from: https://github.com/github/gitignore/blob/master/Global/Windows.gitignore
-# Windows thumbnail cache files
-Thumbs.db
-ehthumbs.db
-ehthumbs_vista.db
-
-# Dump file
-*.stackdump
-
-# Folder config file
-[Dd]esktop.ini
-
-# Recycle Bin used on file shares
-$RECYCLE.BIN/
-
-# Windows Installer files
-*.cab
-*.msi
-*.msix
-*.msm
-*.msp
-
-# Windows shortcuts
-*.lnk
-
-# Vim temporary swap files
-*.swp

yakovleva_yulia_lab_2/App1/Dockerfile

@@ -1,20 +0,0 @@
-FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
-WORKDIR /app	
-
-FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build 
-ARG BUILD_CONFIGURATION=Release														
-WORKDIR /src
-COPY ["App1.csproj", "App1/"]
-RUN dotnet restore "App1/App1.csproj"
-WORKDIR "/src/App1"
-COPY . .		
-RUN dotnet build "App1.csproj" -c $BUILD_CONFIGURATION -o /app/build
-
-FROM build AS publish																										
-ARG BUILD_CONFIGURATION=Release	
-RUN dotnet publish "App1.csproj" -c $BUILD_CONFIGURATION -o /app/publish --self-contained false --no-restore	
-
-FROM base AS final
-WORKDIR /app
-COPY --from=publish /app/publish .
-ENTRYPOINT ["dotnet", "App1.dll"]	

yakovleva_yulia_lab_2/App1/Program.cs

@@ -1,31 +0,0 @@
-using System;
-using System.IO;
-
-class Program
-{
-    static void Main()
-    {
-        string inputPath = Environment.GetEnvironmentVariable("DATA_PATH") ?? ".\\data";
-        string outputPath = Environment.GetEnvironmentVariable("RESULT_PATH") ?? ".\\result";
-
-        try
-        {
-            string[] files = Directory.GetFiles(inputPath);
-
-            using (StreamWriter writer = new StreamWriter(Path.Combine(outputPath, "data.txt")))
-            {
-                foreach (string file in files)
-                {
-                    int lineCount = File.ReadAllLines(file).Length;
-                    writer.WriteLine(lineCount);
-                }
-            }
-
-            Console.WriteLine("Файл data.txt успешно создан");
-        }
-        catch (Exception ex)
-        {
-            Console.WriteLine("Произошла ошибка: " + ex.Message);
-        }
-    }
-}

yakovleva_yulia_lab_2/App2/Dockerfile

@@ -1,20 +0,0 @@
-FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
-WORKDIR /app	
-
-FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build 
-ARG BUILD_CONFIGURATION=Release														
-WORKDIR /src
-COPY ["App2.csproj", "App2/"]
-RUN dotnet restore "App2/App2.csproj"
-WORKDIR "/src/App2"
-COPY . .		
-RUN dotnet build "App2.csproj" -c $BUILD_CONFIGURATION -o /app/build
-
-FROM build AS publish																										
-ARG BUILD_CONFIGURATION=Release	
-RUN dotnet publish "App2.csproj" -c $BUILD_CONFIGURATION -o /app/publish --self-contained false --no-restore	
-
-FROM base AS final
-WORKDIR /app
-COPY --from=publish /app/publish .
-ENTRYPOINT ["dotnet", "App2.dll"]	

yakovleva_yulia_lab_2/App2/Program.cs

@@ -1,35 +0,0 @@
-using System;
-using System.IO;
-using System.Linq;
-
-class Program
-{
-    static void Main()
-    {
-        string inputPath = Environment.GetEnvironmentVariable("DATA_PATH") ?? ".\\data";
-        string outputPath = Environment.GetEnvironmentVariable("RESULT_PATH") ?? ".\\result";
-
-        try
-        {
-            string dataFilePath = Path.Combine(inputPath, "data.txt");
-
-            // Чтение всех строк из файла
-            string[] lines = File.ReadAllLines(dataFilePath);
-            int[] numbers = lines.Select(int.Parse).ToArray();
-
-            // Поиск наибольшего числа
-            int maxNumber = numbers.Max();
-
-            // Подсчет количества таких чисел
-            int maxCount = numbers.Count(n => n == maxNumber);
-
-            File.WriteAllText(Path.Combine(outputPath, "result.txt"), maxCount.ToString());
-
-            Console.WriteLine($"Количество наибольших чисел: {maxCount}");
-        }
-        catch (Exception ex)
-        {
-            Console.WriteLine("Произошла ошибка: " + ex.Message);
-        }
-    }
-}

yakovleva_yulia_lab_2/Distributed computing and applications.sln

@@ -1,37 +0,0 @@
-
-Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio Version 17
-VisualStudioVersion = 17.9.34728.123
-MinimumVisualStudioVersion = 10.0.40219.1
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "App2", "App2\App2.csproj", "{D03073B1-0CB3-4CA9-A9D8-F1FB804F92D1}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "App1", "App1\App1.csproj", "{729837A1-27A7-4D48-BBB2-21F68E5F7766}"
-EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "FileGeneration", "FileGeneration\FileGeneration.csproj", "{E7AD8A8C-C957-41FF-B92A-924465D73DDB}"
-EndProject
-Global
-	GlobalSection(SolutionConfigurationPlatforms) = preSolution
-		Debug|Any CPU = Debug|Any CPU
-		Release|Any CPU = Release|Any CPU
-	EndGlobalSection
-	GlobalSection(ProjectConfigurationPlatforms) = postSolution
-		{D03073B1-0CB3-4CA9-A9D8-F1FB804F92D1}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{D03073B1-0CB3-4CA9-A9D8-F1FB804F92D1}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{D03073B1-0CB3-4CA9-A9D8-F1FB804F92D1}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{D03073B1-0CB3-4CA9-A9D8-F1FB804F92D1}.Release|Any CPU.Build.0 = Release|Any CPU
-		{729837A1-27A7-4D48-BBB2-21F68E5F7766}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{729837A1-27A7-4D48-BBB2-21F68E5F7766}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{729837A1-27A7-4D48-BBB2-21F68E5F7766}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{729837A1-27A7-4D48-BBB2-21F68E5F7766}.Release|Any CPU.Build.0 = Release|Any CPU
-		{E7AD8A8C-C957-41FF-B92A-924465D73DDB}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
-		{E7AD8A8C-C957-41FF-B92A-924465D73DDB}.Debug|Any CPU.Build.0 = Debug|Any CPU
-		{E7AD8A8C-C957-41FF-B92A-924465D73DDB}.Release|Any CPU.ActiveCfg = Release|Any CPU
-		{E7AD8A8C-C957-41FF-B92A-924465D73DDB}.Release|Any CPU.Build.0 = Release|Any CPU
-	EndGlobalSection
-	GlobalSection(SolutionProperties) = preSolution
-		HideSolutionNode = FALSE
-	EndGlobalSection
-	GlobalSection(ExtensibilityGlobals) = postSolution
-		SolutionGuid = {36392E9A-B3A7-4CFF-B577-B2A3146B3007}
-	EndGlobalSection
-EndGlobal

yakovleva_yulia_lab_2/FileGeneration/Dockerfile

@@ -1,22 +0,0 @@
-#See https://aka.ms/customizecontainer to learn how to customize your debug container and how Visual Studio uses this Dockerfile to build your images for faster debugging.
-
-FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
-WORKDIR /app	
-
-FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build 
-ARG BUILD_CONFIGURATION=Release														
-WORKDIR /src
-COPY ["FileGeneration.csproj", "FileGeneration/"]
-RUN dotnet restore "FileGeneration/FileGeneration.csproj"
-WORKDIR "/src/FileGeneration"
-COPY . .		
-RUN dotnet build "FileGeneration.csproj" -c $BUILD_CONFIGURATION -o /app/build
-
-FROM build AS publish																										
-ARG BUILD_CONFIGURATION=Release	
-RUN dotnet publish "FileGeneration.csproj" -c $BUILD_CONFIGURATION -o /app/publish --self-contained false --no-restore	
-
-FROM base AS final
-WORKDIR /app
-COPY --from=publish /app/publish .
-ENTRYPOINT ["dotnet", "FileGeneration.dll"]	

yakovleva_yulia_lab_2/FileGeneration/Program.cs

@@ -1,41 +0,0 @@
-using System;
-using System.IO;
-
-class Program
-{
-    static void Main()
-    {
-        string directoryPath = Environment.GetEnvironmentVariable("DATA_PATH") ?? ".\\data";
-
-        Random random = new Random();
-
-        try
-        {
-            if (!Directory.Exists(directoryPath))
-            {
-                Directory.CreateDirectory(directoryPath);
-            }
-
-            for (int i = 1; i <= 100; i++)
-            {
-                int lineCount = random.Next(1, 101);
-
-                string filePath = Path.Combine(directoryPath, $"file_{i}.txt");
-
-                using (StreamWriter writer = new StreamWriter(filePath))
-                {
-                    for (int j = 0; j < lineCount; j++)
-                    {
-                        writer.WriteLine($"{j + 1}");
-                    }
-                }
-
-                Console.WriteLine($"Файл {filePath} успешно создан с {lineCount} строками.");
-            }
-        }
-        catch (Exception ex)
-        {
-            Console.WriteLine("Произошла ошибка: " + ex.Message);
-        }
-    }
-}

yakovleva_yulia_lab_2/FileGeneration/Properties/launchSettings.json

@@ -1,10 +0,0 @@
-{
-  "profiles": {
-    "FileGeneration": {
-      "commandName": "Project"
-    },
-    "Container (Dockerfile)": {
-      "commandName": "Docker"
-    }
-  }
-}

yakovleva_yulia_lab_2/README.md

@@ -1,34 +0,0 @@
-# Лабораторная работа 2
-
-## Описание
-В данной лабораторной работе были изучены файлы сборки образов и создание их для приложений. Сборки образов необходимы для контейниризации созданных приложений. В файле сборки мы указываем папку из которой копируем в контейнер и собираем проект.
-
-## Описание работы
-Были выбраны варианты для первого приложения - 3 вариант и для второго 3 вариант.
-
-В первом приложении мы ищем все файлы из папки output и записываем количество строк каждого файла в файл data.txt. Затем второе приложение ищет в data.txt наибольшее значения и записывает количество наибольших значений в файл result.txt.
-
-## Запуск
-1. Для начала необходимо запустить Docker
-2. Открыть консоль, перейти в папку с docker-compose.yml
-3. Ввести команду:
-```
-docker compose up --build
-```
-`--build` необходим для принудительной сборки контейнеров, даже если они уже запущены.
-
-## Результат
-В результате в логах видим, что приложения успешно отработали:
-```
-app2-1           | Количество наибольших чисел: 1
-app1-1 exited with code 0
-app2-1 exited with code 0
-```
-И также видим в папке Files две созданные папки: data и result. В data находятся сгенерированные файлы, а в result - файл с результатом.
-
-## Описание docker-compose.yml
-В docker-compose.yml запускаются 3 сервиса: первый генерирует файлы с рандомным набором строк, второй сервис записывает количество строк каждого файла в data.txt, а третий сервис определяет количество наибольших чисел из файла data.txt и записывает результат в файл result.txt. Также используются зависимости `depends_on`, второй сервис зависит от запуска первого, и третий севрис зависит от запуска второго.
-С помощью `volumes` создаем буферную область, которая позволяет использовать двум севрисам одну папку. `build` позволяет использовать только что собранный образ в момент запуска.
-
-## Видеоотчёт
-[Видеоотчёт](https://disk.yandex.ru/i/Ds2f4xO8vQ8XPA)

yakovleva_yulia_lab_2/docker-compose.yml

@@ -1,33 +0,0 @@
-services:
-  generatefiles:
-    build: ./FileGeneration/
-    volumes:
-      - ./Files/data:/var/data
-      - buffer:/var/result
-    environment:
-      DATA_PATH: "/var/data"
-      RESULT_PATH: "/var/result"
-
-  app1:
-    build: ./App1/
-    depends_on:
-      - generatefiles
-    volumes:
-      - ./Files/data:/var/data
-      - buffer:/var/result
-    environment:
-      DATA_PATH: "/var/data"
-      RESULT_PATH: "/var/result"
-  
-  app2:
-    build: ./App2/
-    depends_on:
-      - app1
-    volumes:
-      - buffer:/var/data
-      - ./Files/result:/var/result
-    environment:
-      DATA_PATH: "/var/data"
-      RESULT_PATH: "/var/result"
-volumes:
-  buffer: