Compare commits
No commits in common. "f3b2646a1eddd4052ee2bd12f0ac4e6b5aedcb34" and "3b9698ac38a9ac2a5f0e2c1efa0fd543cea6df83" have entirely different histories.
f3b2646a1e
...
3b9698ac38
37
.gitignore
vendored
37
.gitignore
vendored
@ -1,37 +0,0 @@
|
|||||||
################################################################################
|
|
||||||
# Данный GITIGNORE-файл был автоматически создан Microsoft(R) Visual Studio.
|
|
||||||
################################################################################
|
|
||||||
|
|
||||||
/.vs/DAS_2024_1
|
|
||||||
/.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/Container
|
|
||||||
/aleikin_artem_lab_3/TaskProject/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/.vs
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/Consumer1/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/Consumer1/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/Consumer2/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/Consumer2/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/FirstTutorial/Receive/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/FirstTutorial/Receive/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/FirstTutorial/Send/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/FirstTutorial/Send/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/Publisher/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/Publisher/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/SecondTutorial/NewTask/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/SecondTutorial/NewTask/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/SecondTutorial/Worker/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/SecondTutorial/Worker/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/ThirdTutorial/EmitLog/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/ThirdTutorial/EmitLog/obj
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/ThirdTutorial/ReceiveLogs/bin/Debug/net8.0
|
|
||||||
/aleikin_artem_lab_4/RVIPLab4/ThirdTutorial/ReceiveLogs/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_4/RVIPLab4/RVIPLab4.sln
|
|
||||||
@ -1,30 +0,0 @@
|
|||||||
**/.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/**
|
|
||||||
@ -1,17 +0,0 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
|
||||||
|
|
||||||
<PropertyGroup>
|
|
||||||
<OutputType>Exe</OutputType>
|
|
||||||
<TargetFramework>net8.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.21.0" />
|
|
||||||
<PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
<?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>
|
|
||||||
@ -1,28 +0,0 @@
|
|||||||
# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
|
|
||||||
|
|
||||||
# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
|
|
||||||
FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
|
|
||||||
USER app
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
|
|
||||||
# Этот этап используется для сборки проекта службы
|
|
||||||
FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
|
|
||||||
ARG BUILD_CONFIGURATION=Release
|
|
||||||
WORKDIR /src
|
|
||||||
COPY ["Consumer1.csproj", "."]
|
|
||||||
RUN dotnet restore "./Consumer1.csproj"
|
|
||||||
COPY . .
|
|
||||||
WORKDIR "/src/."
|
|
||||||
RUN dotnet build "./Consumer1.csproj" -c $BUILD_CONFIGURATION -o /app/build
|
|
||||||
|
|
||||||
# Этот этап используется для публикации проекта службы, который будет скопирован на последний этап
|
|
||||||
FROM build AS publish
|
|
||||||
ARG BUILD_CONFIGURATION=Release
|
|
||||||
RUN dotnet publish "./Consumer1.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
|
|
||||||
|
|
||||||
# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
|
|
||||||
FROM base AS final
|
|
||||||
WORKDIR /app
|
|
||||||
COPY --from=publish /app/publish .
|
|
||||||
ENTRYPOINT ["dotnet", "Consumer1.dll"]
|
|
||||||
@ -1,39 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using RabbitMQ.Client.Events;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory
|
|
||||||
{
|
|
||||||
HostName = "rabbitmq",
|
|
||||||
UserName = "admin",
|
|
||||||
Password = "admin"
|
|
||||||
};
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
var queueName = "slow_queue";
|
|
||||||
var exchangeName = "logs_exchange";
|
|
||||||
await channel.QueueDeclareAsync(queue: queueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
|
|
||||||
|
|
||||||
await channel.QueueBindAsync(queue: queueName, exchange: exchangeName, routingKey: "");
|
|
||||||
|
|
||||||
Console.WriteLine("[Consumer1] Waiting for messages...");
|
|
||||||
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
var consumer = new AsyncEventingBasicConsumer(channel);
|
|
||||||
consumer.ReceivedAsync += (model, ea) =>
|
|
||||||
{
|
|
||||||
var body = ea.Body.ToArray();
|
|
||||||
var message = Encoding.UTF8.GetString(body);
|
|
||||||
Console.WriteLine($"[Consumer1] Received: {message}");
|
|
||||||
|
|
||||||
Thread.Sleep(new Random().Next(2000, 3000));
|
|
||||||
|
|
||||||
Console.WriteLine("[Consumer1] Done processing");
|
|
||||||
channel.BasicAckAsync(deliveryTag: ea.DeliveryTag, multiple: false);
|
|
||||||
return Task.CompletedTask;
|
|
||||||
};
|
|
||||||
|
|
||||||
await channel.BasicConsumeAsync(queue: queueName, autoAck: false, consumer: consumer);
|
|
||||||
}
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
{
|
|
||||||
"profiles": {
|
|
||||||
"Consumer1": {
|
|
||||||
"commandName": "Project"
|
|
||||||
},
|
|
||||||
"Container (Dockerfile)": {
|
|
||||||
"commandName": "Docker"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,30 +0,0 @@
|
|||||||
**/.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/**
|
|
||||||
@ -1,17 +0,0 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
|
||||||
|
|
||||||
<PropertyGroup>
|
|
||||||
<OutputType>Exe</OutputType>
|
|
||||||
<TargetFramework>net8.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.21.0" />
|
|
||||||
<PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
<?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>
|
|
||||||
@ -1,28 +0,0 @@
|
|||||||
# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
|
|
||||||
|
|
||||||
# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
|
|
||||||
FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
|
|
||||||
USER app
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
|
|
||||||
# Этот этап используется для сборки проекта службы
|
|
||||||
FROM mcr.microsoft.com/dotnet/sdk:8.0 AS build
|
|
||||||
ARG BUILD_CONFIGURATION=Release
|
|
||||||
WORKDIR /src
|
|
||||||
COPY ["Consumer2.csproj", "."]
|
|
||||||
RUN dotnet restore "./Consumer2.csproj"
|
|
||||||
COPY . .
|
|
||||||
WORKDIR "/src/."
|
|
||||||
RUN dotnet build "./Consumer2.csproj" -c $BUILD_CONFIGURATION -o /app/build
|
|
||||||
|
|
||||||
# Этот этап используется для публикации проекта службы, который будет скопирован на последний этап
|
|
||||||
FROM build AS publish
|
|
||||||
ARG BUILD_CONFIGURATION=Release
|
|
||||||
RUN dotnet publish "./Consumer2.csproj" -c $BUILD_CONFIGURATION -o /app/publish /p:UseAppHost=false
|
|
||||||
|
|
||||||
# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
|
|
||||||
FROM base AS final
|
|
||||||
WORKDIR /app
|
|
||||||
COPY --from=publish /app/publish .
|
|
||||||
ENTRYPOINT ["dotnet", "Consumer2.dll"]
|
|
||||||
@ -1,40 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using RabbitMQ.Client.Events;
|
|
||||||
using System.Data.Common;
|
|
||||||
using System.Text;
|
|
||||||
using System.Threading.Channels;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory
|
|
||||||
{
|
|
||||||
HostName = "rabbitmq",
|
|
||||||
UserName = "admin",
|
|
||||||
Password = "admin"
|
|
||||||
};
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
var queueName = "fast_queue";
|
|
||||||
var exchangeName = "logs_exchange";
|
|
||||||
await channel.QueueDeclareAsync(queue: queueName, durable: true, exclusive: false, autoDelete: false, arguments: null);
|
|
||||||
|
|
||||||
await channel.QueueBindAsync(queue: queueName, exchange: exchangeName, routingKey: "");
|
|
||||||
|
|
||||||
Console.WriteLine("[Consumer2] Waiting for messages...");
|
|
||||||
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
var consumer = new AsyncEventingBasicConsumer(channel);
|
|
||||||
consumer.ReceivedAsync += (model, ea) =>
|
|
||||||
{
|
|
||||||
var body = ea.Body.ToArray();
|
|
||||||
var message = Encoding.UTF8.GetString(body);
|
|
||||||
Console.WriteLine($"[Consumer2] Received: {message}");
|
|
||||||
|
|
||||||
Console.WriteLine("[Consumer2] Done processing");
|
|
||||||
channel.BasicAckAsync(deliveryTag: ea.DeliveryTag, multiple: false);
|
|
||||||
return Task.CompletedTask;
|
|
||||||
};
|
|
||||||
|
|
||||||
await channel.BasicConsumeAsync(queue: queueName, autoAck: false, consumer: consumer);
|
|
||||||
}
|
|
||||||
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
{
|
|
||||||
"profiles": {
|
|
||||||
"Consumer2": {
|
|
||||||
"commandName": "Project"
|
|
||||||
},
|
|
||||||
"Container (Dockerfile)": {
|
|
||||||
"commandName": "Docker"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,26 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using RabbitMQ.Client.Events;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
await channel.QueueDeclareAsync(queue: "hello", durable: false,
|
|
||||||
exclusive: false, autoDelete: false,arguments: null);
|
|
||||||
|
|
||||||
Console.WriteLine("[*] Waiting for messages...");
|
|
||||||
|
|
||||||
var consumer = new AsyncEventingBasicConsumer(channel);
|
|
||||||
consumer.ReceivedAsync += (model, ea) =>
|
|
||||||
{
|
|
||||||
var body = ea.Body.ToArray();
|
|
||||||
var message = Encoding.UTF8.GetString(body);
|
|
||||||
Console.WriteLine($" [*] Received {message}");
|
|
||||||
return Task.CompletedTask;
|
|
||||||
};
|
|
||||||
|
|
||||||
await channel.BasicConsumeAsync("hello", autoAck: true, consumer: consumer);
|
|
||||||
|
|
||||||
Console.WriteLine(" Press [enter] to exit.");
|
|
||||||
Console.ReadLine();
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
<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="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,18 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
await channel.QueueDeclareAsync(queue: "hello", durable: false,
|
|
||||||
exclusive: false, autoDelete: false, arguments: null);
|
|
||||||
|
|
||||||
const string message = "Hello, World! ~from Artem";
|
|
||||||
var body = Encoding.UTF8.GetBytes(message);
|
|
||||||
|
|
||||||
await channel.BasicPublishAsync(exchange: string.Empty, routingKey: "hello", body: body);
|
|
||||||
Console.WriteLine($" [x] Sent {message}");
|
|
||||||
|
|
||||||
Console.WriteLine(" Press [enter] to exit.");
|
|
||||||
Console.ReadLine();
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
<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="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
Binary file not shown.
|
Before Width: | Height: | Size: 31 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 32 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 38 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 29 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 60 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 147 KiB |
Binary file not shown.
|
Before Width: | Height: | Size: 69 KiB |
@ -1,30 +0,0 @@
|
|||||||
**/.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/**
|
|
||||||
@ -1,28 +0,0 @@
|
|||||||
# См. статью по ссылке https://aka.ms/customizecontainer, чтобы узнать как настроить контейнер отладки и как Visual Studio использует этот Dockerfile для создания образов для ускорения отладки.
|
|
||||||
|
|
||||||
# Этот этап используется при запуске из VS в быстром режиме (по умолчанию для конфигурации отладки)
|
|
||||||
FROM mcr.microsoft.com/dotnet/runtime:8.0 AS base
|
|
||||||
USER app
|
|
||||||
WORKDIR /app
|
|
||||||
|
|
||||||
|
|
||||||
# Этот этап используется для сборки проекта службы
|
|
||||||
FROM mcr.microsoft.com/dotnet/sdk:8.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
|
|
||||||
|
|
||||||
# Этот этап используется в рабочей среде или при запуске из VS в обычном режиме (по умолчанию, когда конфигурация отладки не используется)
|
|
||||||
FROM base AS final
|
|
||||||
WORKDIR /app
|
|
||||||
COPY --from=publish /app/publish .
|
|
||||||
ENTRYPOINT ["dotnet", "Publisher.dll"]
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
{
|
|
||||||
"profiles": {
|
|
||||||
"Publisher": {
|
|
||||||
"commandName": "Project"
|
|
||||||
},
|
|
||||||
"Container (Dockerfile)": {
|
|
||||||
"commandName": "Docker"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@ -1,31 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory
|
|
||||||
{
|
|
||||||
HostName = "rabbitmq",
|
|
||||||
UserName = "admin",
|
|
||||||
Password = "admin"
|
|
||||||
};
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
Console.WriteLine("Connection established.");
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
Console.WriteLine("Channel created.");
|
|
||||||
|
|
||||||
await channel.ExchangeDeclareAsync(exchange: "logs_exchange", type: ExchangeType.Fanout);
|
|
||||||
|
|
||||||
while (true)
|
|
||||||
{
|
|
||||||
var message = $"Event: {GenerateRandomEvent()}";
|
|
||||||
var body = Encoding.UTF8.GetBytes(message);
|
|
||||||
|
|
||||||
await channel.BasicPublishAsync(exchange: "logs_exchange", routingKey: string.Empty, body: body);
|
|
||||||
Console.WriteLine($"[Publisher] Sent: {message}");
|
|
||||||
await Task.Delay(1000);
|
|
||||||
}
|
|
||||||
|
|
||||||
static string GenerateRandomEvent()
|
|
||||||
{
|
|
||||||
var events = new[] { "Order Received", "User Message", "Create Report" };
|
|
||||||
return events[new Random().Next(events.Length)] + " #" + new Random().Next(0, 99);
|
|
||||||
}
|
|
||||||
@ -1,17 +0,0 @@
|
|||||||
<Project Sdk="Microsoft.NET.Sdk">
|
|
||||||
|
|
||||||
<PropertyGroup>
|
|
||||||
<OutputType>Exe</OutputType>
|
|
||||||
<TargetFramework>net8.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.21.0" />
|
|
||||||
<PackageReference Include="RabbitMQ.Client" Version="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,6 +0,0 @@
|
|||||||
<?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>
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
<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="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,26 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
await channel.QueueDeclareAsync(queue: "task_queue", durable: true, exclusive: false,
|
|
||||||
autoDelete: false, arguments: null);
|
|
||||||
|
|
||||||
var message = GetMessage(args);
|
|
||||||
var body = Encoding.UTF8.GetBytes(message);
|
|
||||||
|
|
||||||
var properties = new BasicProperties
|
|
||||||
{
|
|
||||||
Persistent = true
|
|
||||||
};
|
|
||||||
|
|
||||||
await channel.BasicPublishAsync(exchange: string.Empty, routingKey: "task_queue", mandatory: true,
|
|
||||||
basicProperties: properties, body: body);
|
|
||||||
Console.WriteLine($" [x] Sent {message}");
|
|
||||||
|
|
||||||
static string GetMessage(string[] args)
|
|
||||||
{
|
|
||||||
return ((args.Length > 0) ? string.Join(" ", args) : "Hello World!");
|
|
||||||
}
|
|
||||||
@ -1,35 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using RabbitMQ.Client.Events;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
await channel.QueueDeclareAsync(queue: "task_queue", durable: true, exclusive: false,
|
|
||||||
autoDelete: false, arguments: null);
|
|
||||||
|
|
||||||
await channel.BasicQosAsync(prefetchSize: 0, prefetchCount: 1, global: false);
|
|
||||||
|
|
||||||
Console.WriteLine(" [*] Waiting for messages.");
|
|
||||||
|
|
||||||
var consumer = new AsyncEventingBasicConsumer(channel);
|
|
||||||
consumer.ReceivedAsync += async (model, ea) =>
|
|
||||||
{
|
|
||||||
byte[] body = ea.Body.ToArray();
|
|
||||||
var message = Encoding.UTF8.GetString(body);
|
|
||||||
Console.WriteLine($" [x] Received {message}");
|
|
||||||
|
|
||||||
int dots = message.Split('.').Length - 1;
|
|
||||||
await Task.Delay(dots * 1000);
|
|
||||||
|
|
||||||
Console.WriteLine(" [x] Done");
|
|
||||||
|
|
||||||
// here channel could also be accessed as ((AsyncEventingBasicConsumer)sender).Channel
|
|
||||||
await channel.BasicAckAsync(deliveryTag: ea.DeliveryTag, multiple: false);
|
|
||||||
};
|
|
||||||
|
|
||||||
await channel.BasicConsumeAsync("task_queue", autoAck: false, consumer: consumer);
|
|
||||||
|
|
||||||
Console.WriteLine(" Press [enter] to exit.");
|
|
||||||
Console.ReadLine();
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
<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="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,21 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
await channel.ExchangeDeclareAsync(exchange: "logs", type: ExchangeType.Fanout);
|
|
||||||
|
|
||||||
var message = GetMessage(args);
|
|
||||||
var body = Encoding.UTF8.GetBytes(message);
|
|
||||||
await channel.BasicPublishAsync(exchange: "logs", routingKey: string.Empty, 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!");
|
|
||||||
}
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
<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="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,31 +0,0 @@
|
|||||||
using RabbitMQ.Client;
|
|
||||||
using RabbitMQ.Client.Events;
|
|
||||||
using System.Text;
|
|
||||||
|
|
||||||
var factory = new ConnectionFactory { HostName = "localhost" };
|
|
||||||
using var connection = await factory.CreateConnectionAsync();
|
|
||||||
using var channel = await connection.CreateChannelAsync();
|
|
||||||
|
|
||||||
await channel.ExchangeDeclareAsync(exchange: "logs",
|
|
||||||
type: ExchangeType.Fanout);
|
|
||||||
|
|
||||||
// declare a server-named queue
|
|
||||||
QueueDeclareOk queueDeclareResult = await channel.QueueDeclareAsync();
|
|
||||||
string queueName = queueDeclareResult.QueueName;
|
|
||||||
await channel.QueueBindAsync(queue: queueName, exchange: "logs", routingKey: string.Empty);
|
|
||||||
|
|
||||||
Console.WriteLine(" [*] Waiting for logs.");
|
|
||||||
|
|
||||||
var consumer = new AsyncEventingBasicConsumer(channel);
|
|
||||||
consumer.ReceivedAsync += (model, ea) =>
|
|
||||||
{
|
|
||||||
byte[] body = ea.Body.ToArray();
|
|
||||||
var message = Encoding.UTF8.GetString(body);
|
|
||||||
Console.WriteLine($" [x] {message}");
|
|
||||||
return Task.CompletedTask;
|
|
||||||
};
|
|
||||||
|
|
||||||
await channel.BasicConsumeAsync(queueName, autoAck: true, consumer: consumer);
|
|
||||||
|
|
||||||
Console.WriteLine(" Press [enter] to exit.");
|
|
||||||
Console.ReadLine();
|
|
||||||
@ -1,14 +0,0 @@
|
|||||||
<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="7.0.0" />
|
|
||||||
</ItemGroup>
|
|
||||||
|
|
||||||
</Project>
|
|
||||||
@ -1,61 +0,0 @@
|
|||||||
services:
|
|
||||||
rabbitmq:
|
|
||||||
image: rabbitmq:management
|
|
||||||
container_name: rabbitmq
|
|
||||||
restart: always
|
|
||||||
ports:
|
|
||||||
- "5672:5672"
|
|
||||||
- "15672:15672"
|
|
||||||
environment:
|
|
||||||
RABBITMQ_DEFAULT_USER: admin
|
|
||||||
RABBITMQ_DEFAULT_PASS: admin
|
|
||||||
networks:
|
|
||||||
- my_network
|
|
||||||
|
|
||||||
publisher:
|
|
||||||
build:
|
|
||||||
context: ./Publisher
|
|
||||||
restart: always
|
|
||||||
depends_on:
|
|
||||||
- rabbitmq
|
|
||||||
environment:
|
|
||||||
RABBITMQ_HOST: rabbitmq
|
|
||||||
RABBIT_USERNAME: admin
|
|
||||||
RABBIT_PASSWORD: admin
|
|
||||||
RABBIT_EXCHANGE: 'logs_exchange'
|
|
||||||
networks:
|
|
||||||
- my_network
|
|
||||||
|
|
||||||
consumer1:
|
|
||||||
build:
|
|
||||||
context: ./Consumer1
|
|
||||||
restart: always
|
|
||||||
depends_on:
|
|
||||||
- rabbitmq
|
|
||||||
environment:
|
|
||||||
RABBITMQ_HOST: rabbitmq
|
|
||||||
RABBIT_USERNAME: admin
|
|
||||||
RABBIT_PASSWORD: admin
|
|
||||||
RABBIT_EXCHANGE: 'logs_exchange'
|
|
||||||
RABBIT_QUEUE: 'slow_queue'
|
|
||||||
networks:
|
|
||||||
- my_network
|
|
||||||
|
|
||||||
consumer2:
|
|
||||||
build:
|
|
||||||
context: ./Consumer2
|
|
||||||
restart: always
|
|
||||||
depends_on:
|
|
||||||
- rabbitmq
|
|
||||||
environment:
|
|
||||||
RABBITMQ_HOST: rabbitmq
|
|
||||||
RABBIT_USERNAME: admin
|
|
||||||
RABBIT_PASSWORD: admin
|
|
||||||
RABBIT_EXCHANGE: 'logs_exchange'
|
|
||||||
RABBIT_QUEUE: 'fast_queue'
|
|
||||||
networks:
|
|
||||||
- my_network
|
|
||||||
|
|
||||||
networks:
|
|
||||||
my_network:
|
|
||||||
driver: bridge
|
|
||||||
@ -1,37 +0,0 @@
|
|||||||
# Лабораторная работа 4 - Работа с брокером сообщений
|
|
||||||
## ПИбд-42 || Алейкин Артем
|
|
||||||
|
|
||||||
### Описание
|
|
||||||
В данной лабораторной работе мы познакомились с такой утилитой как RabbitMQ.
|
|
||||||
|
|
||||||
### Туториалы
|
|
||||||
1. HelloWorld - Tutorial
|
|
||||||
|
|
||||||
|
|
||||||
2. Work Queues - Tutorial
|
|
||||||
|
|
||||||
|
|
||||||
3. Publish/Subscribe - Tutorial
|
|
||||||
|
|
||||||
|
|
||||||
### Основное задание
|
|
||||||
Было разработано 3 приложения: Publisher, Consumer1 и Consumer2.
|
|
||||||
Первое отвечало за доставку сообщений в очереди. Оно генерирует одно сообщение раз в секунду.
|
|
||||||
Второе и Третье за обработку этих сообщений из очередей, но Consumer1 имел искусственную задержку в 2-3 секунды, в то время как Consumer2 таких ограничений не имел и работу.
|
|
||||||
|
|
||||||
### Шаги для запуска:
|
|
||||||
1. Запуск контейнеров:
|
|
||||||
```
|
|
||||||
docker-compose up -d
|
|
||||||
```
|
|
||||||
|
|
||||||
В результате мы можем посмотреть графики по этой ссылке http://localhost:15672/
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
После этого было добавлено еще 3 клиента типа Consumer1 и только после этого их суммарной производительности стало хватать для обработки сообщений.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
Видео демонстрации работы: https://vk.com/video248424990_456239611?list=ln-v0VkWDOiRBxdctENzV
|
|
||||||
Loading…
Reference in New Issue
Block a user